You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ratis.apache.org by sz...@apache.org on 2023/03/14 02:18:27 UTC
[ratis] branch master updated: RATIS-1796. Fix TransferLeadership stopped by heartbeat from old leader (#844)
This is an automated email from the ASF dual-hosted git repository.
szetszwo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ratis.git
The following commit(s) were added to refs/heads/master by this push:
new 05c0db044 RATIS-1796. Fix TransferLeadership stopped by heartbeat from old leader (#844)
05c0db044 is described below
commit 05c0db0444eaade1b18e49465c3cde2ea5336485
Author: Kaijie Chen <ck...@apache.org>
AuthorDate: Tue Mar 14 10:18:23 2023 +0800
RATIS-1796. Fix TransferLeadership stopped by heartbeat from old leader (#844)
---
.../org/apache/ratis/server/impl/LeaderElection.java | 16 +++++++++++++---
1 file changed, 13 insertions(+), 3 deletions(-)
diff --git a/ratis-server/src/main/java/org/apache/ratis/server/impl/LeaderElection.java b/ratis-server/src/main/java/org/apache/ratis/server/impl/LeaderElection.java
index 7239ceb41..dedc56cfc 100644
--- a/ratis-server/src/main/java/org/apache/ratis/server/impl/LeaderElection.java
+++ b/ratis-server/src/main/java/org/apache/ratis/server/impl/LeaderElection.java
@@ -186,16 +186,23 @@ class LeaderElection implements Runnable {
private final RaftServerImpl server;
private final boolean skipPreVote;
+ private final ConfAndTerm round0;
- LeaderElection(RaftServerImpl server, boolean skipPreVote) {
+ LeaderElection(RaftServerImpl server, boolean force) {
this.name = server.getMemberId() + "-" + JavaUtils.getClassSimpleName(getClass()) + COUNT.incrementAndGet();
this.lifeCycle = new LifeCycle(this);
this.daemon = Daemon.newBuilder().setName(name).setRunnable(this)
.setThreadGroup(server.getThreadGroup()).build();
this.server = server;
- this.skipPreVote = skipPreVote ||
+ this.skipPreVote = force ||
!RaftServerConfigKeys.LeaderElection.preVote(
server.getRaftServer().getProperties());
+ try {
+ // increase term of the candidate in advance if it's forced to election
+ this.round0 = force ? server.getState().initElection(Phase.ELECTION) : null;
+ } catch (IOException e) {
+ throw new IllegalStateException(name + ": Failed to initialize election", e);
+ }
}
void start() {
@@ -302,7 +309,10 @@ class LeaderElection implements Runnable {
if (!shouldRun()) {
return false;
}
- final ConfAndTerm confAndTerm = server.getState().initElection(phase);
+ // If round0 is non-null, we have already called initElection in the constructor,
+ // reuse round0 to avoid initElection again for the first round
+ final ConfAndTerm confAndTerm = (round == 0 && round0 != null) ?
+ round0 : server.getState().initElection(phase);
electionTerm = confAndTerm.getTerm();
conf = confAndTerm.getConf();
}