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/01/19 14:37:45 UTC
[ratis] branch master updated: RATIS-1773. Fix readIndexHeartbeat using incorrct index handle onAppendEntriesReply method (#810)
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 9f3134af3 RATIS-1773. Fix readIndexHeartbeat using incorrct index handle onAppendEntriesReply method (#810)
9f3134af3 is described below
commit 9f3134af3c8211e96800ded7c046f4b34dddf168
Author: Yaolong Liu <ly...@163.com>
AuthorDate: Thu Jan 19 22:37:40 2023 +0800
RATIS-1773. Fix readIndexHeartbeat using incorrct index handle onAppendEntriesReply method (#810)
---
.../main/java/org/apache/ratis/server/impl/ReadIndexHeartbeats.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/ratis-server/src/main/java/org/apache/ratis/server/impl/ReadIndexHeartbeats.java b/ratis-server/src/main/java/org/apache/ratis/server/impl/ReadIndexHeartbeats.java
index 40c559b2f..f7671e2f6 100644
--- a/ratis-server/src/main/java/org/apache/ratis/server/impl/ReadIndexHeartbeats.java
+++ b/ratis-server/src/main/java/org/apache/ratis/server/impl/ReadIndexHeartbeats.java
@@ -124,12 +124,12 @@ class ReadIndexHeartbeats {
synchronized void onAppendEntriesReply(LogAppender appender, AppendEntriesReplyProto reply,
Predicate<Predicate<RaftPeerId>> hasMajority) {
- final long callId = reply.getServerReply().getCallId();
+ final long followerCommit = reply.getFollowerCommit();
Iterator<Map.Entry<Long, AppendEntriesListener>> iterator = sorted.entrySet().iterator();
while (iterator.hasNext()) {
Map.Entry<Long, AppendEntriesListener> entry = iterator.next();
- if (entry.getKey() > callId) {
+ if (entry.getKey() > followerCommit) {
return;
}