feat(flexible):modify code

sofastack · Jul 26, 2023 · faeac76 · faeac76
1 parent 20345bf
commit faeac76
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/jraft-core/src/main/java/com/alipay/sofa/jraft/core/NodeImpl.java b/jraft-core/src/main/java/com/alipay/sofa/jraft/core/NodeImpl.java
@@ -1589,7 +1589,8 @@ public ReadIndexHeartbeatResponseClosure(final RpcResponseClosure<ReadIndexRespo
  this.closure = closure;
  this.respBuilder = rb;
  this.quorum = quorum;
- this.failPeersThreshold = quorum.getW();
+ this.failPeersThreshold = !options.isEnableFlexibleRaft() && peersCount % 2 == 0 ?
+ quorum.getW() - 1 : quorum.getW();
  this.ackSuccess = 0;
  this.ackFailures = 0;
  this.isDone = false;