Fix a bug.

apache · Dec 27, 2024 · 8d1f887 · 8d1f887
1 parent 54dc115
commit 8d1f887
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/ratis-server/src/main/java/org/apache/ratis/server/leader/LogAppenderBase.java b/ratis-server/src/main/java/org/apache/ratis/server/leader/LogAppenderBase.java
@@ -339,7 +339,11 @@ protected ReferenceCountedObject<AppendEntriesRequestProto> nextAppendEntriesReq
     assertProtos(protos, followerNext, previous, snapshotIndex);
     AppendEntriesRequestProto appendEntriesProto =
         leaderState.newAppendEntriesRequestProto(follower, protos, previous, callId);
-    return ReferenceCountedObject.wrap(appendEntriesProto, entryList::retain, entryList::release);
+    final ReferenceCountedObject<AppendEntriesRequestProto> ref = ReferenceCountedObject.wrap(
+        appendEntriesProto, entryList::retain, entryList::release);
+    ref.retain();
+    entryList.release();
+    return ref;
   }
 
   private void assertProtos(List<LogEntryProto> protos, long nextIndex, TermIndex previous, long snapshotIndex) {