final long electionTimeout = raftActor.getRaftActorContext().getConfigParams()
.getElectionTimeOutInterval().toMillis();
final int variance = raftActor.getRaftActorContext().getConfigParams().getElectionTimeVariance();
- newLeaderTimeoutInMillis = electionTimeout + variance * 2;
+ newLeaderTimeoutInMillis = 2 * (electionTimeout + variance);
}
void init() {
raftActor.pauseLeader(new TimedRunnable(context.getConfigParams().getElectionTimeOutInterval(), raftActor) {
@Override
protected void doRun() {
+ LOG.debug("{}: pauseLeader successfully completed - doing transfer", raftActor.persistenceId());
doTransfer();
}
@Override
protected void doCancel() {
- LOG.debug("{}: pauseLeader timed out - aborting transfer", raftActor.persistenceId());
- abortTransfer();
+ LOG.debug("{}: pauseLeader timed out - continuing with transfer", raftActor.persistenceId());
+ doTransfer();
}
});
}