[bookkeeper] branch master updated: recycle dropping read-write requests when various exceptions happened (#3912)

[lushiji]

This is an automated email from the ASF dual-hosted git repository.

lushiji pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/bookkeeper.git


The following commit(s) were added to refs/heads/master by this push:
     new 3a9fe1b287 recycle dropping read-write requests when various 
exceptions happened (#3912)
3a9fe1b287 is described below

commit 3a9fe1b2874dd238766569895175ce2e9cabcabf
Author: wenbingshen <oliver.shen...@gmail.com>
AuthorDate: Wed Apr 26 13:54:24 2023 +0800

    recycle dropping read-write requests when various exceptions happened 
(#3912)
---
 .../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 c44216a028..4c9c1c9440 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
@@ -65,6 +65,7 @@ class ReadEntryProcessor extends 
PacketProcessorBase<ReadRequest> {
                 LOG.debug("Dropping read request for closed channel: {}", 
requestHandler.ctx().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 29b3a5abb7..0cd01c7970 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
@@ -65,6 +65,7 @@ class WriteEntryProcessor extends 
PacketProcessorBase<ParsedAddRequest> implemen
                          
requestProcessor.getRequestStats().getAddRequestStats());
             request.release();
             request.recycle();
+            recycle();
             return;
         }
 
@@ -109,6 +110,7 @@ class WriteEntryProcessor extends 
PacketProcessorBase<ParsedAddRequest> implemen
                          ResponseBuilder.buildErrorResponse(rc, request),
                          
requestProcessor.getRequestStats().getAddRequestStats());
             request.recycle();
+            recycle();
         }
     }