- final Capabilities capabilitiesV13 = mock(Capabilities.class);
- final CapabilitiesV10 capabilitiesV10 = mock(CapabilitiesV10.class);
- when(mockFeatures.getCapabilities()).thenReturn(capabilitiesV13);
- when(mockFeatures.getCapabilitiesV10()).thenReturn(capabilitiesV10);
- when(mockFeatures.getDatapathId()).thenReturn(BigInteger.valueOf(21L));
+ when(mockedFuture.isDone()).thenReturn(true);
+ doReturn(mockedFuture).when(writeTransaction).commit();
+ when(dataBroker.newWriteOnlyTransaction()).thenReturn(writeTransaction);
+
+ deviceManager = new DeviceManagerImpl(
+ new OpenflowProviderConfigBuilder()
+ .setBarrierCountLimit(new NonZeroUint16Type(BARRIER_COUNT_LIMIT))
+ .setBarrierIntervalTimeoutLimit(new NonZeroUint32Type(BARRIER_INTERVAL_NANOS))
+ .setGlobalNotificationQuota(TEST_VALUE_GLOBAL_NOTIFICATION_QUOTA)
+ .setSwitchFeaturesMandatory(false)
+ .setEnableFlowRemovedNotification(true)
+ .setSkipTableFeatures(false)
+ .setUseSingleLayerSerialization(true)
+ .setIsStatisticsPollingOn(false)
+ .build(),
+ dataBroker,
+ messageIntelligenceAgency,
+ notificationPublishService,
+ new HashedWheelTimer(),
+ convertorExecutor,
+ DeviceInitializerProviderFactory.createDefaultProvider(),
+ executorService);
+
+ deviceManager.setTranslatorLibrary(translatorLibrary);
+ verify(dataBroker).newWriteOnlyTransaction();
+ verify(writeTransaction).merge(eq(LogicalDatastoreType.OPERATIONAL), any(), any());
+ verify(writeTransaction).commit();