import java.lang.reflect.Field;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ExecutionException;
+import java.util.concurrent.ExecutorService;
import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;
import org.opendaylight.mdsal.binding.api.WriteTransaction;
import org.opendaylight.mdsal.common.api.CommitInfo;
import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
-import org.opendaylight.mdsal.common.api.TransactionCommitFailedException;
import org.opendaylight.openflowjava.protocol.api.connection.ConnectionAdapter;
import org.opendaylight.openflowplugin.api.openflow.connection.ConnectionContext;
import org.opendaylight.openflowplugin.api.openflow.device.DeviceContext;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.openflow.provider.config.rev160510.OpenflowProviderConfigBuilder;
import org.opendaylight.yangtools.util.concurrent.FluentFutures;
import org.opendaylight.yangtools.yang.binding.KeyedInstanceIdentifier;
+import org.opendaylight.yangtools.yang.common.Uint16;
+import org.opendaylight.yangtools.yang.common.Uint32;
@RunWith(MockitoJUnitRunner.class)
public class DeviceManagerImplTest {
- private static final long TEST_VALUE_GLOBAL_NOTIFICATION_QUOTA = 2000L;
- private static final int BARRIER_COUNT_LIMIT = 25600;
- private static final long BARRIER_INTERVAL_NANOS = 500;
+ private static final Uint32 TEST_VALUE_GLOBAL_NOTIFICATION_QUOTA = Uint32.valueOf(2000);
+ private static final Uint16 BARRIER_COUNT_LIMIT = Uint16.valueOf(25600);
+ private static final Uint32 BARRIER_INTERVAL_NANOS = Uint32.valueOf(500);
private static final NodeId DUMMY_NODE_ID = new NodeId("dummyNodeId");
private static final KeyedInstanceIdentifier<Node, NodeKey> DUMMY_IDENTIFIER = DeviceStateUtil
.createNodeInstanceIdentifier(DUMMY_NODE_ID);
private NotificationPublishService notificationPublishService;
@Mock
private TranslatorLibrary translatorLibrary;
+ @Mock
+ private ExecutorService executorService;
private DeviceManagerImpl deviceManager;
.setEnableFlowRemovedNotification(true)
.setSkipTableFeatures(false)
.setUseSingleLayerSerialization(true)
+ .setIsStatisticsPollingOn(false)
.build(),
dataBroker,
messageIntelligenceAgency,
notificationPublishService,
new HashedWheelTimer(),
convertorExecutor,
- DeviceInitializerProviderFactory.createDefaultProvider());
+ DeviceInitializerProviderFactory.createDefaultProvider(),
+ executorService);
deviceManager.setTranslatorLibrary(translatorLibrary);
verify(dataBroker).newWriteOnlyTransaction();
@Test(expected = ExecutionException.class)
public void removeDeviceFromOperationalDSException() throws Exception {
- final FluentFuture<CommitInfo> failedFuture = FluentFutures.immediateFailedFluentFuture(
- new TransactionCommitFailedException("Test failed transaction"));
+ final FluentFuture<?> failedFuture = FluentFutures.immediateFailedFluentFuture(
+ new ExecutionException(new Throwable("Test failed transaction")));
Mockito.doReturn(failedFuture).when(writeTransaction).commit();
final ListenableFuture<?> future = deviceManager.removeDeviceFromOperationalDS(DUMMY_IDENTIFIER);
future.get();