X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatabroker%2FConcurrentDOMDataBrokerTest.java;h=7f0e0f5577621ca26cff4ab371c964108f727c60;hp=acf08eb1d9e50fffea8dcf7470464cf6fe05a301;hb=466078ab1dc8a8cc2981b161051f6edecd6af85a;hpb=84d6864d26fddddd92da32fd00d57c7224d4213d diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/databroker/ConcurrentDOMDataBrokerTest.java b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/databroker/ConcurrentDOMDataBrokerTest.java index acf08eb1d9..7f0e0f5577 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/databroker/ConcurrentDOMDataBrokerTest.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/databroker/ConcurrentDOMDataBrokerTest.java @@ -19,10 +19,13 @@ import static org.mockito.Mockito.mock; import static org.mockito.Mockito.never; import static org.mockito.Mockito.times; import static org.mockito.Mockito.verify; +import static org.opendaylight.yangtools.util.concurrent.FluentFutures.immediateFalseFluentFuture; +import static org.opendaylight.yangtools.util.concurrent.FluentFutures.immediateNullFluentFuture; +import static org.opendaylight.yangtools.util.concurrent.FluentFutures.immediateTrueFluentFuture; import com.google.common.base.Throwables; +import com.google.common.collect.ClassToInstanceMap; import com.google.common.collect.ImmutableMap; -import com.google.common.util.concurrent.CheckedFuture; import com.google.common.util.concurrent.FluentFuture; import com.google.common.util.concurrent.FutureCallback; import com.google.common.util.concurrent.Futures; @@ -34,7 +37,6 @@ import java.util.ArrayList; import java.util.Arrays; import java.util.Collection; import java.util.List; -import java.util.Map; import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutionException; import java.util.concurrent.SynchronousQueue; @@ -52,7 +54,6 @@ import org.opendaylight.controller.cluster.datastore.exceptions.NoShardLeaderExc import org.opendaylight.mdsal.common.api.CommitInfo; import org.opendaylight.mdsal.common.api.DataStoreUnavailableException; import org.opendaylight.mdsal.common.api.LogicalDatastoreType; -import org.opendaylight.mdsal.common.api.TransactionChainListener; import org.opendaylight.mdsal.common.api.TransactionCommitFailedException; import org.opendaylight.mdsal.dom.api.DOMDataBrokerExtension; import org.opendaylight.mdsal.dom.api.DOMDataTreeChangeService; @@ -63,6 +64,7 @@ import org.opendaylight.mdsal.dom.api.DOMDataTreeReadTransaction; import org.opendaylight.mdsal.dom.api.DOMDataTreeReadWriteTransaction; import org.opendaylight.mdsal.dom.api.DOMDataTreeWriteTransaction; import org.opendaylight.mdsal.dom.api.DOMTransactionChain; +import org.opendaylight.mdsal.dom.api.DOMTransactionChainListener; import org.opendaylight.mdsal.dom.broker.TransactionCommitFailedExceptionMapper; import org.opendaylight.mdsal.dom.spi.store.DOMStore; import org.opendaylight.mdsal.dom.spi.store.DOMStoreReadTransaction; @@ -121,22 +123,22 @@ public class ConcurrentDOMDataBrokerTest { new Thread(() -> { Uninterruptibles.awaitUninterruptibly(asyncCanCommitContinue, 10, TimeUnit.SECONDS); - future.set(true); + future.set(Boolean.TRUE); }).start(); } else { - future.set(true); + future.set(Boolean.TRUE); } return future; }; doAnswer(asyncCanCommit).when(mockCohort1).canCommit(); - doReturn(Futures.immediateFuture(null)).when(mockCohort1).preCommit(); - doReturn(Futures.immediateFuture(null)).when(mockCohort1).commit(); + doReturn(immediateNullFluentFuture()).when(mockCohort1).preCommit(); + doReturn(immediateNullFluentFuture()).when(mockCohort1).commit(); - doReturn(Futures.immediateFuture(true)).when(mockCohort2).canCommit(); - doReturn(Futures.immediateFuture(null)).when(mockCohort2).preCommit(); - doReturn(Futures.immediateFuture(null)).when(mockCohort2).commit(); + doReturn(immediateTrueFluentFuture()).when(mockCohort2).canCommit(); + doReturn(immediateNullFluentFuture()).when(mockCohort2).preCommit(); + doReturn(immediateNullFluentFuture()).when(mockCohort2).commit(); ListenableFuture future = coordinator.commit(transaction, Arrays.asList(mockCohort1, mockCohort2)); @@ -158,7 +160,7 @@ public class ConcurrentDOMDataBrokerTest { asyncCanCommitContinue.countDown(); - assertEquals("Submit complete", true, doneLatch.await(5, TimeUnit.SECONDS)); + assertTrue("Submit complete", doneLatch.await(5, TimeUnit.SECONDS)); if (caughtEx.get() != null) { Throwables.throwIfUnchecked(caughtEx.get()); @@ -178,15 +180,15 @@ public class ConcurrentDOMDataBrokerTest { @Test public void testSubmitWithNegativeCanCommitResponse() throws Exception { - doReturn(Futures.immediateFuture(true)).when(mockCohort1).canCommit(); - doReturn(Futures.immediateFuture(null)).when(mockCohort1).abort(); + doReturn(immediateTrueFluentFuture()).when(mockCohort1).canCommit(); + doReturn(immediateNullFluentFuture()).when(mockCohort1).abort(); - doReturn(Futures.immediateFuture(false)).when(mockCohort2).canCommit(); - doReturn(Futures.immediateFuture(null)).when(mockCohort2).abort(); + doReturn(Futures.immediateFuture(Boolean.FALSE)).when(mockCohort2).canCommit(); + doReturn(immediateNullFluentFuture()).when(mockCohort2).abort(); DOMStoreThreePhaseCommitCohort mockCohort3 = mock(DOMStoreThreePhaseCommitCohort.class); - doReturn(Futures.immediateFuture(false)).when(mockCohort3).canCommit(); - doReturn(Futures.immediateFuture(null)).when(mockCohort3).abort(); + doReturn(Futures.immediateFuture(Boolean.FALSE)).when(mockCohort3).canCommit(); + doReturn(immediateNullFluentFuture()).when(mockCohort3).abort(); ListenableFuture future = coordinator.commit( transaction, Arrays.asList(mockCohort1, mockCohort2, mockCohort3)); @@ -194,9 +196,8 @@ public class ConcurrentDOMDataBrokerTest { assertFailure(future, null, mockCohort1, mockCohort2, mockCohort3); } - private static void assertFailure(final ListenableFuture future, - final Exception expCause, final DOMStoreThreePhaseCommitCohort... mockCohorts) - throws Exception { + private static void assertFailure(final ListenableFuture future, final Exception expCause, + final DOMStoreThreePhaseCommitCohort... mockCohorts) throws Exception { try { future.get(5, TimeUnit.SECONDS); fail("Expected TransactionCommitFailedException"); @@ -217,12 +218,12 @@ public class ConcurrentDOMDataBrokerTest { @Test public void testSubmitWithCanCommitException() throws Exception { - doReturn(Futures.immediateFuture(true)).when(mockCohort1).canCommit(); - doReturn(Futures.immediateFuture(null)).when(mockCohort1).abort(); + doReturn(immediateTrueFluentFuture()).when(mockCohort1).canCommit(); + doReturn(immediateNullFluentFuture()).when(mockCohort1).abort(); IllegalStateException cause = new IllegalStateException("mock"); doReturn(Futures.immediateFailedFuture(cause)).when(mockCohort2).canCommit(); - doReturn(Futures.immediateFuture(null)).when(mockCohort2).abort(); + doReturn(immediateNullFluentFuture()).when(mockCohort2).abort(); FluentFuture future = coordinator.commit( transaction, Arrays.asList(mockCohort1, mockCohort2)); @@ -232,12 +233,12 @@ public class ConcurrentDOMDataBrokerTest { @Test public void testSubmitWithCanCommitDataStoreUnavailableException() throws Exception { - doReturn(Futures.immediateFuture(true)).when(mockCohort1).canCommit(); - doReturn(Futures.immediateFuture(null)).when(mockCohort1).abort(); + doReturn(immediateTrueFluentFuture()).when(mockCohort1).canCommit(); + doReturn(immediateNullFluentFuture()).when(mockCohort1).abort(); NoShardLeaderException rootCause = new NoShardLeaderException("mock"); DataStoreUnavailableException cause = new DataStoreUnavailableException(rootCause.getMessage(), rootCause); doReturn(Futures.immediateFailedFuture(rootCause)).when(mockCohort2).canCommit(); - doReturn(Futures.immediateFuture(null)).when(mockCohort2).abort(); + doReturn(immediateNullFluentFuture()).when(mockCohort2).abort(); FluentFuture future = coordinator.commit( transaction, Arrays.asList(mockCohort1, mockCohort2)); @@ -247,20 +248,20 @@ public class ConcurrentDOMDataBrokerTest { @Test public void testSubmitWithPreCommitException() throws Exception { - doReturn(Futures.immediateFuture(true)).when(mockCohort1).canCommit(); - doReturn(Futures.immediateFuture(null)).when(mockCohort1).preCommit(); - doReturn(Futures.immediateFuture(null)).when(mockCohort1).abort(); + doReturn(immediateTrueFluentFuture()).when(mockCohort1).canCommit(); + doReturn(immediateNullFluentFuture()).when(mockCohort1).preCommit(); + doReturn(immediateNullFluentFuture()).when(mockCohort1).abort(); - doReturn(Futures.immediateFuture(true)).when(mockCohort2).canCommit(); + doReturn(immediateTrueFluentFuture()).when(mockCohort2).canCommit(); IllegalStateException cause = new IllegalStateException("mock"); doReturn(Futures.immediateFailedFuture(cause)).when(mockCohort2).preCommit(); - doReturn(Futures.immediateFuture(null)).when(mockCohort2).abort(); + doReturn(immediateNullFluentFuture()).when(mockCohort2).abort(); DOMStoreThreePhaseCommitCohort mockCohort3 = mock(DOMStoreThreePhaseCommitCohort.class); - doReturn(Futures.immediateFuture(true)).when(mockCohort3).canCommit(); + doReturn(immediateTrueFluentFuture()).when(mockCohort3).canCommit(); doReturn(Futures.immediateFailedFuture(new IllegalStateException("mock2"))) .when(mockCohort3).preCommit(); - doReturn(Futures.immediateFuture(null)).when(mockCohort3).abort(); + doReturn(immediateNullFluentFuture()).when(mockCohort3).abort(); FluentFuture future = coordinator.commit( transaction, Arrays.asList(mockCohort1, mockCohort2, mockCohort3)); @@ -270,23 +271,23 @@ public class ConcurrentDOMDataBrokerTest { @Test public void testSubmitWithCommitException() throws Exception { - doReturn(Futures.immediateFuture(true)).when(mockCohort1).canCommit(); - doReturn(Futures.immediateFuture(null)).when(mockCohort1).preCommit(); - doReturn(Futures.immediateFuture(null)).when(mockCohort1).commit(); - doReturn(Futures.immediateFuture(null)).when(mockCohort1).abort(); + doReturn(immediateTrueFluentFuture()).when(mockCohort1).canCommit(); + doReturn(immediateNullFluentFuture()).when(mockCohort1).preCommit(); + doReturn(immediateNullFluentFuture()).when(mockCohort1).commit(); + doReturn(immediateNullFluentFuture()).when(mockCohort1).abort(); - doReturn(Futures.immediateFuture(true)).when(mockCohort2).canCommit(); - doReturn(Futures.immediateFuture(null)).when(mockCohort2).preCommit(); + doReturn(immediateTrueFluentFuture()).when(mockCohort2).canCommit(); + doReturn(immediateNullFluentFuture()).when(mockCohort2).preCommit(); IllegalStateException cause = new IllegalStateException("mock"); doReturn(Futures.immediateFailedFuture(cause)).when(mockCohort2).commit(); - doReturn(Futures.immediateFuture(null)).when(mockCohort2).abort(); + doReturn(immediateNullFluentFuture()).when(mockCohort2).abort(); DOMStoreThreePhaseCommitCohort mockCohort3 = mock(DOMStoreThreePhaseCommitCohort.class); - doReturn(Futures.immediateFuture(true)).when(mockCohort3).canCommit(); - doReturn(Futures.immediateFuture(null)).when(mockCohort3).preCommit(); + doReturn(immediateTrueFluentFuture()).when(mockCohort3).canCommit(); + doReturn(immediateNullFluentFuture()).when(mockCohort3).preCommit(); doReturn(Futures.immediateFailedFuture(new IllegalStateException("mock2"))) .when(mockCohort3).commit(); - doReturn(Futures.immediateFuture(null)).when(mockCohort3).abort(); + doReturn(immediateNullFluentFuture()).when(mockCohort3).abort(); FluentFuture future = coordinator.commit( transaction, Arrays.asList(mockCohort1, mockCohort2, mockCohort3)); @@ -296,13 +297,13 @@ public class ConcurrentDOMDataBrokerTest { @Test public void testSubmitWithAbortException() throws Exception { - doReturn(Futures.immediateFuture(true)).when(mockCohort1).canCommit(); + doReturn(immediateTrueFluentFuture()).when(mockCohort1).canCommit(); doReturn(Futures.immediateFailedFuture(new IllegalStateException("mock abort error"))) .when(mockCohort1).abort(); IllegalStateException cause = new IllegalStateException("mock canCommit error"); doReturn(Futures.immediateFailedFuture(cause)).when(mockCohort2).canCommit(); - doReturn(Futures.immediateFuture(null)).when(mockCohort2).abort(); + doReturn(immediateNullFluentFuture()).when(mockCohort2).abort(); FluentFuture future = coordinator.commit( transaction, Arrays.asList(mockCohort1, mockCohort2)); @@ -438,8 +439,8 @@ public class ConcurrentDOMDataBrokerTest { doReturn(mockStoreReadWriteTransaction).when(operationalDomStore).newReadWriteTransaction(); doReturn(mockCohort).when(mockStoreReadWriteTransaction).ready(); - doReturn(Futures.immediateFuture(false)).when(mockCohort).canCommit(); - doReturn(Futures.immediateFuture(null)).when(mockCohort).abort(); + doReturn(immediateFalseFluentFuture()).when(mockCohort).canCommit(); + doReturn(immediateNullFluentFuture()).when(mockCohort).abort(); final CountDownLatch latch = new CountDownLatch(1); final List commitCohorts = new ArrayList<>(); @@ -459,7 +460,7 @@ public class ConcurrentDOMDataBrokerTest { domDataReadWriteTransaction.delete(LogicalDatastoreType.OPERATIONAL, YangInstanceIdentifier.EMPTY); - domDataReadWriteTransaction.submit(); + domDataReadWriteTransaction.commit(); assertTrue(latch.await(10, TimeUnit.SECONDS)); @@ -480,12 +481,12 @@ public class ConcurrentDOMDataBrokerTest { doReturn(configTransaction).when(configDomStore).newReadWriteTransaction(); doReturn(mockCohortOperational).when(operationalTransaction).ready(); - doReturn(Futures.immediateFuture(false)).when(mockCohortOperational).canCommit(); - doReturn(Futures.immediateFuture(null)).when(mockCohortOperational).abort(); + doReturn(immediateFalseFluentFuture()).when(mockCohortOperational).canCommit(); + doReturn(immediateNullFluentFuture()).when(mockCohortOperational).abort(); doReturn(mockCohortConfig).when(configTransaction).ready(); - doReturn(Futures.immediateFuture(false)).when(mockCohortConfig).canCommit(); - doReturn(Futures.immediateFuture(null)).when(mockCohortConfig).abort(); + doReturn(immediateFalseFluentFuture()).when(mockCohortConfig).canCommit(); + doReturn(immediateNullFluentFuture()).when(mockCohortConfig).abort(); final CountDownLatch latch = new CountDownLatch(1); final List commitCohorts = new ArrayList<>(); @@ -509,7 +510,7 @@ public class ConcurrentDOMDataBrokerTest { domDataReadWriteTransaction.merge(LogicalDatastoreType.CONFIGURATION, YangInstanceIdentifier.EMPTY, mock(NormalizedNode.class)); - domDataReadWriteTransaction.submit(); + domDataReadWriteTransaction.commit(); assertTrue(latch.await(10, TimeUnit.SECONDS)); @@ -524,7 +525,7 @@ public class ConcurrentDOMDataBrokerTest { LogicalDatastoreType.OPERATIONAL, domStore, LogicalDatastoreType.CONFIGURATION, domStore), futureExecutor)) { - dataBroker.createTransactionChain(mock(TransactionChainListener.class)); + dataBroker.createTransactionChain(mock(DOMTransactionChainListener.class)); verify(domStore, times(2)).createTransactionChain(); } @@ -545,7 +546,7 @@ public class ConcurrentDOMDataBrokerTest { doReturn(operationalTransaction).when(mockChain).newWriteOnlyTransaction(); DOMTransactionChain transactionChain = dataBroker.createTransactionChain( - mock(TransactionChainListener.class)); + mock(DOMTransactionChainListener.class)); DOMDataTreeWriteTransaction domDataWriteTransaction = transactionChain.newWriteOnlyTransaction(); @@ -563,15 +564,13 @@ public class ConcurrentDOMDataBrokerTest { LogicalDatastoreType.OPERATIONAL, domStore, LogicalDatastoreType.CONFIGURATION, domStore), futureExecutor)) { - CheckedFuture submit1 = - dataBroker.newWriteOnlyTransaction().submit(); + FluentFuture submit1 = dataBroker.newWriteOnlyTransaction().commit(); assertNotNull(submit1); submit1.get(); - CheckedFuture submit2 = - dataBroker.newReadWriteTransaction().submit(); + FluentFuture submit2 = dataBroker.newReadWriteTransaction().commit(); assertNotNull(submit2); @@ -587,12 +586,11 @@ public class ConcurrentDOMDataBrokerTest { LogicalDatastoreType.OPERATIONAL, mockOperStore, LogicalDatastoreType.CONFIGURATION, mockConfigStore), futureExecutor)) { - Map, DOMDataBrokerExtension> supportedExtensions = - dataBroker.getSupportedExtensions(); - assertNotNull(supportedExtensions.get(DOMDataTreeChangeService.class)); + ClassToInstanceMap supportedExtensions = dataBroker.getExtensions(); + assertNotNull(supportedExtensions.getInstance(DOMDataTreeChangeService.class)); - DOMDataTreeCommitCohortRegistry cohortRegistry = - (DOMDataTreeCommitCohortRegistry) supportedExtensions.get(DOMDataTreeCommitCohortRegistry.class); + DOMDataTreeCommitCohortRegistry cohortRegistry = supportedExtensions.getInstance( + DOMDataTreeCommitCohortRegistry.class); assertNotNull(cohortRegistry); DOMDataTreeCommitCohort mockCohort = mock(DOMDataTreeCommitCohort.class);