X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-akka-raft%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fraft%2FRaftActorTest.java;h=d999bb2ba1de79e59d65b5cd78614bc8b3fc2c7c;hp=c833a86e9b825c926002ce5fc5b163438a6a4ce0;hb=d840c921a370f0704ba2d68faf4cfffda08c4440;hpb=d564bfe7b9b24474cc0426a859cfae8dbad8b571 diff --git a/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/RaftActorTest.java b/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/RaftActorTest.java index c833a86e9b..d999bb2ba1 100644 --- a/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/RaftActorTest.java +++ b/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/RaftActorTest.java @@ -883,24 +883,27 @@ public class RaftActorTest extends AbstractActorTest { TestActorRef mockActorRef = TestActorRef.create(getSystem(), MockRaftActor.props(id, Collections.emptyMap(), Optional.of(config), notifierActor), id); - MockRaftActor mockRaftActor = mockActorRef.underlyingActor(); - mockRaftActor.setCurrentBehavior(new Follower(mockRaftActor.getRaftActorContext())); - // sleeping for a minimum of 2 seconds, if it spans more its fine. Uninterruptibles.sleepUninterruptibly(2, TimeUnit.SECONDS); List matches = MessageCollectorActor.getAllMatching(notifierActor, RoleChanged.class); assertNotNull(matches); - assertEquals(2, matches.size()); + assertEquals(3, matches.size()); - // check if the notifier got a role change from Follower to Candidate + // check if the notifier got a role change from null to Follower RoleChanged raftRoleChanged = (RoleChanged) matches.get(0); assertEquals(id, raftRoleChanged.getMemberId()); + assertNull(raftRoleChanged.getOldRole()); + assertEquals(RaftState.Follower.name(), raftRoleChanged.getNewRole()); + + // check if the notifier got a role change from Follower to Candidate + raftRoleChanged = (RoleChanged) matches.get(1); + assertEquals(id, raftRoleChanged.getMemberId()); assertEquals(RaftState.Follower.name(), raftRoleChanged.getOldRole()); assertEquals(RaftState.Candidate.name(), raftRoleChanged.getNewRole()); // check if the notifier got a role change from Candidate to Leader - raftRoleChanged = (RoleChanged) matches.get(1); + raftRoleChanged = (RoleChanged) matches.get(2); assertEquals(id, raftRoleChanged.getMemberId()); assertEquals(RaftState.Candidate.name(), raftRoleChanged.getOldRole()); assertEquals(RaftState.Leader.name(), raftRoleChanged.getNewRole());