X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-akka-raft%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fraft%2Fbehaviors%2FCandidate.java;h=ecd49012461a7b1ee76f4678c7451a4fa1edbfb1;hb=fe4049d34de103016d11f3a9050853c6380646d3;hp=0c23db4c8a0184af45461ddfd3ec214ce117c460;hpb=3019650e87a3fc05f80e8f6359e01ca5f1c5f197;p=controller.git diff --git a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/behaviors/Candidate.java b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/behaviors/Candidate.java index 0c23db4c8a..ecd4901246 100644 --- a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/behaviors/Candidate.java +++ b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/behaviors/Candidate.java @@ -158,6 +158,8 @@ public class Candidate extends AbstractRaftActorBehavior { context.getLogger().debug("Starting new term " + (currentTerm+1)); // Request for a vote + // TODO: Retry request for vote if replies do not arrive in a reasonable + // amount of time TBD for (ActorSelection peerActor : peerToActor.values()) { peerActor.tell(new RequestVote( context.getTermInformation().getCurrentTerm(),