import org.opendaylight.controller.cluster.raft.messages.InstallSnapshot;
import org.opendaylight.controller.cluster.raft.messages.InstallSnapshotReply;
import org.opendaylight.controller.cluster.raft.messages.RaftRPC;
+import org.opendaylight.controller.cluster.raft.messages.RequestVote;
import org.opendaylight.controller.cluster.raft.messages.RequestVoteReply;
/**
*/
public class Follower extends AbstractRaftActorBehavior {
-
-
private SnapshotTracker snapshotTracker = null;
private final InitialSyncStatusTracker initialSyncStatusTracker;
handleInstallSnapshot(sender, installSnapshot);
}
- scheduleElection(electionDuration());
+ if(message instanceof RaftRPC && (!(message instanceof RequestVote) || (canGrantVote((RequestVote) message)))){
+ scheduleElection(electionDuration());
+ }
return super.handleMessage(sender, message);
}