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%2Fbehaviors%2FPartitionedCandidateOnStartupElectionScenarioTest.java;h=9d58d03237c6f7b63bb1d32dc6e3008b84f8ecb7;hp=7ab76d271a31d7b7cd82aa1559c4507800088819;hb=e1eca73a5ae2ffae8dd78c6fe5281cd2f45d5ef3;hpb=608760751ce7fcf4e84e86a8b33d43bc1d9984d6 diff --git a/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/behaviors/PartitionedCandidateOnStartupElectionScenarioTest.java b/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/behaviors/PartitionedCandidateOnStartupElectionScenarioTest.java index 7ab76d271a..9d58d03237 100644 --- a/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/behaviors/PartitionedCandidateOnStartupElectionScenarioTest.java +++ b/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/behaviors/PartitionedCandidateOnStartupElectionScenarioTest.java @@ -8,6 +8,7 @@ package org.opendaylight.controller.cluster.raft.behaviors; import static org.junit.Assert.assertEquals; + import akka.actor.ActorRef; import com.google.common.collect.ImmutableMap; import org.junit.Test; @@ -17,6 +18,7 @@ import org.opendaylight.controller.cluster.raft.MockRaftActorContext.MockReplica import org.opendaylight.controller.cluster.raft.MockRaftActorContext.SimpleReplicatedLog; import org.opendaylight.controller.cluster.raft.RaftState; import org.opendaylight.controller.cluster.raft.base.messages.ElectionTimeout; +import org.opendaylight.controller.cluster.raft.base.messages.TimeoutNow; import org.opendaylight.controller.cluster.raft.messages.RequestVote; import org.opendaylight.controller.cluster.raft.messages.RequestVoteReply; @@ -61,7 +63,7 @@ public class PartitionedCandidateOnStartupElectionScenarioTest extends AbstractL member3Actor.expectMessageClass(RequestVote.class, 1); member3Actor.expectBehaviorStateChange(); - member1ActorRef.tell(new ElectionTimeout(), ActorRef.noSender()); + member1ActorRef.tell(TimeoutNow.INSTANCE, ActorRef.noSender()); member2Actor.waitForExpectedMessages(RequestVote.class); member3Actor.waitForExpectedMessages(RequestVote.class); @@ -110,7 +112,7 @@ public class PartitionedCandidateOnStartupElectionScenarioTest extends AbstractL // term and return a RequestVoteReply but should not grant the vote. candidateElectionTerm += 2; - for(int i = 0; i < 2; i++) { + for (int i = 0; i < 2; i++) { member1Actor.clear(); member1Actor.expectMessageClass(RequestVote.class, 1); member2Actor.clear(); @@ -118,7 +120,7 @@ public class PartitionedCandidateOnStartupElectionScenarioTest extends AbstractL member3Actor.clear(); member3Actor.expectMessageClass(RequestVoteReply.class, 1); - member3ActorRef.tell(new ElectionTimeout(), ActorRef.noSender()); + member3ActorRef.tell(ElectionTimeout.INSTANCE, ActorRef.noSender()); member1Actor.waitForExpectedMessages(RequestVote.class); member2Actor.waitForExpectedMessages(RequestVote.class); @@ -153,9 +155,9 @@ public class PartitionedCandidateOnStartupElectionScenarioTest extends AbstractL // Create member 3's behavior initially as a Candidate. member3Context = newRaftActorContext("member3", member3ActorRef, - ImmutableMap.builder(). - put("member1", member1ActorRef.path().toString()). - put("member2", member2ActorRef.path().toString()).build()); + ImmutableMap.builder() + .put("member1", member1ActorRef.path().toString()) + .put("member2", member2ActorRef.path().toString()).build()); DefaultConfigParamsImpl member3ConfigParams = newConfigParams(); member3Context.setConfigParams(member3ConfigParams); @@ -164,10 +166,11 @@ public class PartitionedCandidateOnStartupElectionScenarioTest extends AbstractL // will be 2 and the last term will be 1 so it is behind the leader's log. SimpleReplicatedLog candidateReplicatedLog = new SimpleReplicatedLog(); - candidateReplicatedLog.append(new MockReplicatedLogEntry(1, 1, new MockPayload(""))); - candidateReplicatedLog.append(new MockReplicatedLogEntry(2, 1, new MockPayload(""))); + candidateReplicatedLog.append(new MockReplicatedLogEntry(2, 0, new MockPayload(""))); member3Context.setReplicatedLog(candidateReplicatedLog); + member3Context.setCommitIndex(candidateReplicatedLog.lastIndex()); + member3Context.setLastApplied(candidateReplicatedLog.lastIndex()); member3Context.getTermInformation().update(2, member1Context.getId()); // The member 3 Candidate will start a new term and send RequestVotes. However it will be @@ -181,13 +184,14 @@ public class PartitionedCandidateOnStartupElectionScenarioTest extends AbstractL Candidate member3Behavior = new Candidate(member3Context); member3Actor.behavior = member3Behavior; + member3Context.setCurrentBehavior(member3Behavior); // Send several additional ElectionTimeouts to Candidate member 3. Each ElectionTimeout will // start a new term so Candidate member 3's current term will be greater than the leader's // current term. - for(int i = 0; i < numCandidateElections - 1; i++) { - member3ActorRef.tell(new ElectionTimeout(), ActorRef.noSender()); + for (int i = 0; i < numCandidateElections - 1; i++) { + member3ActorRef.tell(ElectionTimeout.INSTANCE, ActorRef.noSender()); } member1Actor.waitForExpectedMessages(RequestVote.class); @@ -208,47 +212,52 @@ public class PartitionedCandidateOnStartupElectionScenarioTest extends AbstractL private void setupInitialMember1AndMember2Behaviors() throws Exception { testLog.info("setupInitialMember1AndMember2Behaviors starting"); + // Initialize the ReplicatedLog and election term info for member 1 and 2. The current term + // will be 3 and the last term will be 2. + + SimpleReplicatedLog replicatedLog = new SimpleReplicatedLog(); + replicatedLog.append(new MockReplicatedLogEntry(2, 0, new MockPayload(""))); + replicatedLog.append(new MockReplicatedLogEntry(3, 1, new MockPayload(""))); + // Create member 2's behavior as Follower. member2Context = newRaftActorContext("member2", member2ActorRef, - ImmutableMap.builder(). - put("member1", member1ActorRef.path().toString()). - put("member3", member3ActorRef.path().toString()).build()); + ImmutableMap.builder() + .put("member1", member1ActorRef.path().toString()) + .put("member3", member3ActorRef.path().toString()).build()); DefaultConfigParamsImpl member2ConfigParams = newConfigParams(); member2Context.setConfigParams(member2ConfigParams); - Follower member2Behavior = new Follower(member2Context); - member2Actor.behavior = member2Behavior; + member2Context.setReplicatedLog(replicatedLog); + member2Context.setCommitIndex(replicatedLog.lastIndex()); + member2Context.setLastApplied(replicatedLog.lastIndex()); + member2Context.getTermInformation().update(3, "member1"); + + member2Actor.behavior = new Follower(member2Context); + member2Context.setCurrentBehavior(member2Actor.behavior); // Create member 1's behavior as Leader. member1Context = newRaftActorContext("member1", member1ActorRef, - ImmutableMap.builder(). - put("member2", member2ActorRef.path().toString()). - put("member3", member3ActorRef.path().toString()).build()); + ImmutableMap.builder() + .put("member2", member2ActorRef.path().toString()) + .put("member3", member3ActorRef.path().toString()).build()); DefaultConfigParamsImpl member1ConfigParams = newConfigParams(); member1Context.setConfigParams(member1ConfigParams); + member1Context.setReplicatedLog(replicatedLog); + member1Context.setCommitIndex(replicatedLog.lastIndex()); + member1Context.setLastApplied(replicatedLog.lastIndex()); + member1Context.getTermInformation().update(3, "member1"); + initializeLeaderBehavior(member1Actor, member1Context, 1); member2Actor.clear(); member3Actor.clear(); - // Initialize the ReplicatedLog and election term info for member 1 and 2. The current term - // will be 3 and the last term will be 2. - - SimpleReplicatedLog replicatedLog = new SimpleReplicatedLog(); - replicatedLog.append(new MockReplicatedLogEntry(2, 1, new MockPayload(""))); - replicatedLog.append(new MockReplicatedLogEntry(3, 1, new MockPayload(""))); - - member1Context.setReplicatedLog(replicatedLog); - member1Context.getTermInformation().update(3, ""); - - member2Context.setReplicatedLog(replicatedLog); - member2Context.getTermInformation().update(3, member1Context.getId()); - testLog.info("setupInitialMember1AndMember2Behaviors ending"); + } }