X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2FDistributedDataStoreRemotingIntegrationTest.java;h=50085c29c07859865af4ac26ee49118aca3ef2c5;hb=refs%2Fchanges%2F20%2F98320%2F1;hp=fbc7fa2ae8ab6b60575f7512db44ccbc2153b119;hpb=760350a21a49693c649205b6db88f2fe8c50e288;p=controller.git

diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/DistributedDataStoreRemotingIntegrationTest.java b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/DistributedDataStoreRemotingIntegrationTest.java
index fbc7fa2ae8..50085c29c0 100644
--- a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/DistributedDataStoreRemotingIntegrationTest.java
+++ b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/DistributedDataStoreRemotingIntegrationTest.java
@@ -32,7 +32,6 @@ import akka.testkit.javadsl.TestKit;
 import com.google.common.base.Stopwatch;
 import com.google.common.base.Throwables;
 import com.google.common.collect.ImmutableMap;
-import com.google.common.collect.Range;
 import com.google.common.primitives.UnsignedLong;
 import com.google.common.util.concurrent.ListenableFuture;
 import com.google.common.util.concurrent.MoreExecutors;
@@ -45,7 +44,6 @@ import java.util.Iterator;
 import java.util.LinkedList;
 import java.util.List;
 import java.util.Optional;
-import java.util.Set;
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
@@ -402,8 +400,12 @@ public class DistributedDataStoreRemotingIntegrationTest extends AbstractTest {
                         }
 
                         assertEquals(0, metadata.getClosedTransactions().size());
-                        assertEquals(Range.closedOpen(UnsignedLong.valueOf(0), UnsignedLong.valueOf(11)),
-                                metadata.getPurgedTransactions().asRanges().iterator().next());
+
+                        final var purgedRanges = metadata.getPurgedTransactions().ranges();
+                        assertEquals(1, purgedRanges.size());
+                        final var purgedRange = purgedRanges.first();
+                        assertEquals(UnsignedLong.ZERO, purgedRange.lower());
+                        assertEquals(UnsignedLong.valueOf(10), purgedRange.upper());
                     } else {
                         // ask based should track no metadata
                         assertTrue(frontendMetadata.getClients().get(0).getCurrentHistories().isEmpty());
@@ -466,10 +468,8 @@ public class DistributedDataStoreRemotingIntegrationTest extends AbstractTest {
                             metadata = iterator.next();
                         }
 
-                        Set<Range<UnsignedLong>> ranges = metadata.getPurgedTransactions().asRanges();
-
                         assertEquals(0, metadata.getClosedTransactions().size());
-                        assertEquals(1, ranges.size());
+                        assertEquals(1, metadata.getPurgedTransactions().size());
                     } else {
                         // ask based should track no metadata
                         assertTrue(frontendMetadata.getClients().get(0).getCurrentHistories().isEmpty());