issues #199 DLedger pagecachert overtime (#200)

Co-authored-by: 叶文海 <[email protected]>
openmessaging · Aug 15, 2022 · 44ebb34 · 44ebb34
1 parent b42dda8
commit 44ebb34
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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);