[ratis] branch master updated: RATIS-1773. Fix readIndexHeartbeat using incorrct index handle onAppendEntriesReply method (#810)

[szetszwo]

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 <lylpy...@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;
         }