This is an automated email from the ASF dual-hosted git repository. yong pushed a commit to branch branch-4.15 in repository https://gitbox.apache.org/repos/asf/bookkeeper.git
commit 7b8096430a77ec96306c7ee27fa0dd6e12a3e348 Author: wenbingshen <[email protected]> AuthorDate: Wed Apr 26 13:54:24 2023 +0800 recycle dropping read-write requests when various exceptions happened (#3912) (cherry picked from commit 3a9fe1b2874dd238766569895175ce2e9cabcabf) --- .../src/main/java/org/apache/bookkeeper/proto/ReadEntryProcessor.java | 1 + .../src/main/java/org/apache/bookkeeper/proto/WriteEntryProcessor.java | 2 ++ 2 files changed, 3 insertions(+) diff --git a/bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/ReadEntryProcessor.java b/bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/ReadEntryProcessor.java index 3373bf8ffd..03ff80cfe7 100644 --- a/bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/ReadEntryProcessor.java +++ b/bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/ReadEntryProcessor.java @@ -66,6 +66,7 @@ class ReadEntryProcessor extends PacketProcessorBase<ReadRequest> { LOG.debug("Dropping read request for closed channel: {}", channel); } requestProcessor.onReadRequestFinish(); + recycle(); return; } int errorCode = BookieProtocol.EOK; diff --git a/bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/WriteEntryProcessor.java b/bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/WriteEntryProcessor.java index 163b8be0f2..013da53755 100644 --- a/bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/WriteEntryProcessor.java +++ b/bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/WriteEntryProcessor.java @@ -68,6 +68,7 @@ class WriteEntryProcessor extends PacketProcessorBase<ParsedAddRequest> implemen requestProcessor.getRequestStats().getAddRequestStats()); request.release(); request.recycle(); + recycle(); return; } @@ -111,6 +112,7 @@ class WriteEntryProcessor extends PacketProcessorBase<ParsedAddRequest> implemen ResponseBuilder.buildErrorResponse(rc, request), requestProcessor.getRequestStats().getAddRequestStats()); request.recycle(); + recycle(); } }
