Fixes bufferlease reuse (#13)

teragrep · Oct 16, 2024 · 5f0e4aa · 5f0e4aa
1 parent ba8d298
commit 5f0e4aa
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/main/java/com/teragrep/net_01/channel/context/IngressImpl.java b/src/main/java/com/teragrep/net_01/channel/context/IngressImpl.java
@@ -109,6 +109,7 @@ public void run() {
                 boolean continueReading = true;
                 while (!activeBuffers.isEmpty()) {
                     BufferLease bufferLease = activeBuffers.removeFirst();
+                    bufferLease.addRef();
                     LOGGER
                             .debug(
                                     "submitting buffer <{}> from activeBuffers <{}> to relpFrame", bufferLease,
@@ -126,7 +127,7 @@ public void run() {
                     }
 
                     LOGGER.debug("clock returned continueReading <{}>", continueReading);
-                    if (!bufferLease.isTerminated() && bufferLease.buffer().hasRemaining()) {
+                    if (bufferLease.buffer().hasRemaining()) {
                         // return back as it has some remaining
                         LOGGER.debug("pushBack bufferLease id <{}>", bufferLease.id());
                         activeBuffers.push(bufferLease);
@@ -138,6 +139,7 @@ public void run() {
                                     );
                         }
                     }
+                    bufferLease.removeRef();
                     if (!continueReading) {
                         break;
                     }