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%2Fdatastore%2FDistributedDataStoreTest.java;h=923ec5a01c56de5f589ee0a656d4c575e7bcd475;hp=c8c254879cf64ed73e6278fc37ab8aa137ba9583;hb=5464f50be733df1bbbe31cf05665d542d3b7c5e7;hpb=aa77e20225cc04235315892cf148393149cbf8fc diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/DistributedDataStoreTest.java b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/DistributedDataStoreTest.java index c8c254879c..923ec5a01c 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/DistributedDataStoreTest.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/DistributedDataStoreTest.java @@ -12,6 +12,7 @@ import static org.junit.Assert.assertTrue; import static org.mockito.Mockito.doReturn; import static org.mockito.Mockito.times; import static org.mockito.Mockito.verify; + import akka.util.Timeout; import com.google.common.util.concurrent.Uninterruptibles; import java.util.concurrent.Executors; @@ -55,7 +56,7 @@ public class DistributedDataStoreTest extends AbstractActorTest { } @Test - public void testRateLimitingUsedInReadWriteTxCreation(){ + public void testRateLimitingUsedInReadWriteTxCreation() { try (DistributedDataStore distributedDataStore = new DistributedDataStore(actorContext, UNKNOWN_ID)) { distributedDataStore.newReadWriteTransaction(); @@ -65,7 +66,7 @@ public class DistributedDataStoreTest extends AbstractActorTest { } @Test - public void testRateLimitingUsedInWriteOnlyTxCreation(){ + public void testRateLimitingUsedInWriteOnlyTxCreation() { try (DistributedDataStore distributedDataStore = new DistributedDataStore(actorContext, UNKNOWN_ID)) { distributedDataStore.newWriteOnlyTransaction(); @@ -75,7 +76,7 @@ public class DistributedDataStoreTest extends AbstractActorTest { } @Test - public void testRateLimitingNotUsedInReadOnlyTxCreation(){ + public void testRateLimitingNotUsedInReadOnlyTxCreation() { try (DistributedDataStore distributedDataStore = new DistributedDataStore(actorContext, UNKNOWN_ID)) { distributedDataStore.newReadOnlyTransaction(); @@ -87,7 +88,7 @@ public class DistributedDataStoreTest extends AbstractActorTest { } @Test - public void testWaitTillReadyBlocking(){ + public void testWaitTillReadyBlocking() { doReturn(datastoreContext).when(actorContext).getDatastoreContext(); doReturn(shardElectionTimeout).when(datastoreContext).getShardLeaderElectionTimeout(); doReturn(FiniteDuration.apply(50, TimeUnit.MILLISECONDS)).when(shardElectionTimeout).duration(); @@ -99,12 +100,12 @@ public class DistributedDataStoreTest extends AbstractActorTest { long end = System.currentTimeMillis(); - assertTrue("Expected to be blocked for 50 millis", (end - start) >= 50); + assertTrue("Expected to be blocked for 50 millis", end - start >= 50); } } @Test - public void testWaitTillReadyCountDown(){ + public void testWaitTillReadyCountDown() { try (final DistributedDataStore distributedDataStore = new DistributedDataStore(actorContext, UNKNOWN_ID)) { doReturn(datastoreContext).when(actorContext).getDatastoreContext(); doReturn(shardElectionTimeout).when(datastoreContext).getShardLeaderElectionTimeout(); @@ -121,8 +122,7 @@ public class DistributedDataStoreTest extends AbstractActorTest { long end = System.currentTimeMillis(); - assertTrue("Expected to be released in 500 millis", (end - start) < 5000); + assertTrue("Expected to be released in 500 millis", end - start < 5000); } } - }