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=3f5ca17d7abc17b27bd3288d0cf6d5c9b1819b1f;hp=7ab76d271a31d7b7cd82aa1559c4507800088819;hb=e83057f284dc3c9bf84063a47a18bb41a26aebf3;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..3f5ca17d7a 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,17 +8,19 @@ 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; import org.opendaylight.controller.cluster.raft.DefaultConfigParamsImpl; import org.opendaylight.controller.cluster.raft.MockRaftActorContext.MockPayload; -import org.opendaylight.controller.cluster.raft.MockRaftActorContext.MockReplicatedLogEntry; 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; +import org.opendaylight.controller.cluster.raft.persisted.SimpleReplicatedLogEntry; /** * A leader election scenario test that partitions a candidate when trying to join a cluster on startup. @@ -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 SimpleReplicatedLogEntry(0, 2, 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 @@ -179,15 +182,15 @@ public class PartitionedCandidateOnStartupElectionScenarioTest extends AbstractL member2Actor.dropMessagesToBehavior(RequestVote.class, numCandidateElections); - Candidate member3Behavior = new Candidate(member3Context); - member3Actor.behavior = member3Behavior; + member3Actor.self().tell(new SetBehavior(new Candidate(member3Context), member3Context), + ActorRef.noSender()); // 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 +211,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 SimpleReplicatedLogEntry(0, 2, new MockPayload(""))); + replicatedLog.append(new SimpleReplicatedLogEntry(1, 3, 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.self().tell(new SetBehavior(new Follower(member2Context), member2Context), + ActorRef.noSender()); // 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"); + } }