+ @Test
+ public void translateAndWriteReplyTypeGroupFeatures() {
+ DeviceContext mockedDeviceContext = mock(DeviceContext.class);
+
+ MultipartReplyGroupFeaturesBuilder multipartReplyGroupFeaturesBuilder = new MultipartReplyGroupFeaturesBuilder();
+ multipartReplyGroupFeaturesBuilder.setTypes(new GroupTypes(true, true, true, true));
+ multipartReplyGroupFeaturesBuilder.setCapabilities(new GroupCapabilities(true, true, true, true));
+ ActionType actionType = new ActionType(true, true, true, true, true, true, true, true, true, true, true, true, true, true, true, true, true);
+ multipartReplyGroupFeaturesBuilder.setActionsBitmap(Lists.newArrayList(actionType));
+
+ MultipartReplyGroupFeatures multipartReplyGroupFeatures = multipartReplyGroupFeaturesBuilder.build();
+
+ MultipartReplyGroupFeaturesCaseBuilder multipartReplyGroupFeaturesCaseBuilder = new MultipartReplyGroupFeaturesCaseBuilder();
+ multipartReplyGroupFeaturesCaseBuilder.setMultipartReplyGroupFeatures(multipartReplyGroupFeatures);
+
+ MultipartReplyMessage multipartReplyMessage = new MultipartReplyMessageBuilder().setMultipartReplyBody(multipartReplyGroupFeaturesCaseBuilder.build()).build();
+ Set<MultipartReply> multipartReplyMessages = Collections.<MultipartReply>singleton(multipartReplyMessage);
+
+ DeviceManagerImpl.translateAndWriteReply(MultipartType.OFPMPGROUPFEATURES, mockedDeviceContext, DUMMY_NODE_II, multipartReplyMessages);
+ verify(mockedDeviceContext)
+ .writeToTransaction(eq(LogicalDatastoreType.OPERATIONAL), eq(DUMMY_NODE_II.augmentation(NodeGroupFeatures.class)), any(NodeGroupFeatures.class));
+ }
+
+
+ @Test
+ public void translateAndWriteReplyTypePortDesc() {
+ DeviceContext mockedDeviceContext = mock(DeviceContext.class);
+
+ ConnectionContext mockedPrimaryConnectionContext = mock(ConnectionContext.class);
+ FeaturesReply mockedFeatures = mock(FeaturesReply.class);
+ when(mockedFeatures.getDatapathId()).thenReturn(new BigInteger(DUMMY_DATAPATH_ID));
+ when(mockedPrimaryConnectionContext.getFeatures()).thenReturn(mockedFeatures);
+ when(mockedDeviceContext.getPrimaryConnectionContext()).thenReturn(mockedPrimaryConnectionContext);
+ DeviceState mockedDeviceState = mock(DeviceState.class);
+ when(mockedDeviceState.getVersion()).thenReturn(OFConstants.OFP_VERSION_1_0);
+ when(mockedDeviceContext.getDeviceState()).thenReturn(mockedDeviceState);
+ TranslatorLibrary translatorLibrary = mock(TranslatorLibrary.class);
+ MessageTranslator mockedTranslator = mock(MessageTranslator.class);
+ when(translatorLibrary.lookupTranslator(any(TranslatorKey.class))).thenReturn(mockedTranslator);
+ when(mockedDeviceContext.oook()).thenReturn(translatorLibrary);
+
+ MultipartReplyPortDescBuilder multipartReplyPortDescBuilder = new MultipartReplyPortDescBuilder();
+
+ PortsBuilder portsBuilder = new PortsBuilder();
+ portsBuilder.setPortNo(DUMMY_PORT_NUMBER);
+
+ multipartReplyPortDescBuilder.setPorts(Lists.newArrayList(portsBuilder.build()));
+
+ MultipartReplyPortDescCaseBuilder multipartReplyPortDescCaseBuilder = new MultipartReplyPortDescCaseBuilder();
+ multipartReplyPortDescCaseBuilder.setMultipartReplyPortDesc(multipartReplyPortDescBuilder.build());
+
+ MultipartReplyMessage multipartReplyMessage = new MultipartReplyMessageBuilder().setMultipartReplyBody(multipartReplyPortDescCaseBuilder.build()).build();
+ Set<MultipartReply> multipartReplyMessages = Collections.<MultipartReply>singleton(multipartReplyMessage);
+
+ OpenflowPortsUtil.init();
+ DeviceManagerImpl.translateAndWriteReply(MultipartType.OFPMPPORTDESC, mockedDeviceContext, DUMMY_NODE_II, multipartReplyMessages);
+ verify(mockedDeviceContext)
+ .writeToTransaction(eq(LogicalDatastoreType.OPERATIONAL), any(InstanceIdentifier.class), any(NodeConnector.class));
+ }