- 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));
- }
-
- @Test
- public void onDeviceContextLevelUpSuccessTest() throws Exception {
- onDeviceContextLevelUp(false);
- }
-
- private DeviceManagerImpl prepareDeviceManager() {
- final DataBroker mockedDataBroker = mock(DataBroker.class);
- final WriteTransaction mockedWriteTransaction = mock(WriteTransaction.class);
-
- final BindingTransactionChain mockedTxChain = mock(BindingTransactionChain.class);
- final WriteTransaction mockedWTx = mock(WriteTransaction.class);
- when(mockedTxChain.newWriteOnlyTransaction()).thenReturn(mockedWTx);
- when(mockedDataBroker.createTransactionChain(any(TransactionChainListener.class))).thenReturn
- (mockedTxChain);
- when(mockedDataBroker.newWriteOnlyTransaction()).thenReturn(mockedWriteTransaction);
-
- when(mockedWriteTransaction.submit()).thenReturn(mockedFuture);
-
- final DeviceManagerImpl deviceManager = new DeviceManagerImpl(
- mockedDataBroker,
- TEST_VALUE_GLOBAL_NOTIFICATION_QUOTA,
- false,
- barrierIntervalNanos,
- barrierCountLimit,
+ 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)
+ .build(),
+ dataBroker,