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());