From 09402ffd90f43cf936a2438e6f2dee4dec76c12c Mon Sep 17 00:00:00 2001 From: Mikko Kortelainen Date: Thu, 17 Oct 2024 11:39:25 +0300 Subject: [PATCH] move partial buffer tracking to net_01 (#225) * move partial buffer tracking to net_01 * Update net_01 to 2.0.0 --------- Co-authored-by: StrongestNumber9 <16169054+StrongestNumber9@users.noreply.github.com> --- pom.xml | 2 +- .../rlp_03/frame/FrameDelegationClock.java | 15 --------------- 2 files changed, 1 insertion(+), 16 deletions(-) diff --git a/pom.xml b/pom.xml index f343fc9..95e2cc0 100644 --- a/pom.xml +++ b/pom.xml @@ -41,7 +41,7 @@ com.teragrep net_01 - 1.0.1 + 2.0.0 diff --git a/src/main/java/com/teragrep/rlp_03/frame/FrameDelegationClock.java b/src/main/java/com/teragrep/rlp_03/frame/FrameDelegationClock.java index 3b9289a..fbf79e3 100644 --- a/src/main/java/com/teragrep/rlp_03/frame/FrameDelegationClock.java +++ b/src/main/java/com/teragrep/rlp_03/frame/FrameDelegationClock.java @@ -75,27 +75,12 @@ public void advance(BufferLease bufferLease) { LOGGER.debug("submitting bufferLease id <{}>", bufferLease.id()); RelpFrame relpFrame = frameClockLeaseful.submit(bufferLease); - if (bufferLease.buffer().hasRemaining()) { // TODO should this even be responsibility of a Clock, probably not? - bufferLease.addRef(); // a shared buffer - } - LOGGER.debug("bufferLease id <{}> hasRemaining <{}>", bufferLease.id(), bufferLease.buffer().remaining()); - boolean interested; if (relpFrame.isStub()) { interested = true; } else { - LOGGER - .debug( - "bufferLease id <{}> before delegate hasRemaining <{}>", bufferLease.id(), - bufferLease.buffer().hasRemaining() - ); interested = delegateFrame(relpFrame); - LOGGER - .debug( - "bufferLease id <{}> after delegate isTerminated <{}>", bufferLease.id(), - bufferLease.isTerminated() - ); } LOGGER.debug("bufferLease id <{}> isTerminated <{}>", bufferLease.id(), bufferLease.isTerminated());