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%2Fentityownership%2FEntityOwnershipShardTest.java;h=276f11f93605e636d692ef88382b2e139af2331d;hp=cfef02c509a106cc1e4ea6f25d4c058440f8f80b;hb=1b0f84c4957e464bad6f7cb7350a8171c3d1621b;hpb=0792888092341cbb7db5f851a5e3bcbca9609e73 diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/entityownership/EntityOwnershipShardTest.java b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/entityownership/EntityOwnershipShardTest.java index cfef02c509..276f11f936 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/entityownership/EntityOwnershipShardTest.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/entityownership/EntityOwnershipShardTest.java @@ -36,6 +36,7 @@ import java.util.List; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.TimeUnit; +import java.util.concurrent.atomic.AtomicLong; import java.util.function.Predicate; import org.junit.After; import org.junit.Test; @@ -630,6 +631,16 @@ public class EntityOwnershipShardTest extends AbstractEntityOwnershipTest { verifyOwner(peer1, ENTITY_TYPE, ENTITY_ID3, LOCAL_MEMBER_NAME); verifyOwner(peer1, ENTITY_TYPE, ENTITY_ID4, ""); + AtomicLong leaderLastApplied = new AtomicLong(); + verifyRaftState(leader, rs -> { + assertEquals("LastApplied up-to-date", rs.getLastApplied(), rs.getLastIndex()); + leaderLastApplied.set(rs.getLastApplied()); + }); + + verifyRaftState(peer2, rs -> { + assertEquals("LastApplied", leaderLastApplied.get(), rs.getLastIndex()); + }); + // Kill the local leader and elect peer2 the leader. This should cause a new owner to be selected for // the entities (1 and 3) previously owned by the local leader member.