From 44ebb34d8f82d89db21280221178c7389669ac15 Mon Sep 17 00:00:00 2001
From: yewenhai-github <59827688+yewenhai-github@users.noreply.github.com>
Date: Mon, 15 Aug 2022 11:13:18 +0800
Subject: [PATCH] issues #199 DLedger pagecachert overtime (#200)
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Co-authored-by: 叶文海 <yewenhai@ienglish.cn>
---
 .../io/openmessaging/storage/dledger/DLedgerEntryPusher.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/java/io/openmessaging/storage/dledger/DLedgerEntryPusher.java b/src/main/java/io/openmessaging/storage/dledger/DLedgerEntryPusher.java
index 16826e29..02bb7c8c 100644
--- a/src/main/java/io/openmessaging/storage/dledger/DLedgerEntryPusher.java
+++ b/src/main/java/io/openmessaging/storage/dledger/DLedgerEntryPusher.java
@@ -244,7 +244,7 @@ private void checkResponseFuturesElapsed(final long endIndex) {
         final long currTerm = this.memberState.currTerm();
         final Map<Long, TimeoutFuture<AppendEntryResponse>> responses = this.pendingAppendResponsesByTerm.get(currTerm);
         for (Map.Entry<Long, TimeoutFuture<AppendEntryResponse>> futureEntry : responses.entrySet()) {
-            if (futureEntry.getKey() < endIndex) {
+            if (futureEntry.getKey() <= endIndex) {
                 AppendEntryResponse response = new AppendEntryResponse();
                 response.setGroup(memberState.getGroup());
                 response.setTerm(currTerm);