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 a7436e6152eac85150058e84de11a38b415953ee Author: zhaohaidao <[email protected]> AuthorDate: Mon Nov 14 09:27:55 2022 +0800 Apply recycle logic during add entry creation but ledger close to LedgerHandleAdv (#3621) Descriptions of the changes in this PR: Apply recycle logic during add entry creation but ledger close to LedgerHandleAdv ### Motivation This pr is a supplement to #3321 If I understand correctly. these recycled logic should be applied to LedgerHandleAdv (cherry picked from commit 0d2fbe434ec2412a166103ebf7fe9c28ecfc48f6) --- .../src/main/java/org/apache/bookkeeper/client/LedgerHandleAdv.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/LedgerHandleAdv.java b/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/LedgerHandleAdv.java index 1320fc0fd2..a30824b044 100644 --- a/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/LedgerHandleAdv.java +++ b/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/LedgerHandleAdv.java @@ -249,6 +249,7 @@ public class LedgerHandleAdv extends LedgerHandle implements WriteAdvHandle { LOG.warn("Attempt to add to closed ledger: {}", ledgerId); op.cb.addCompleteWithLatency(BKException.Code.LedgerClosedException, LedgerHandleAdv.this, op.getEntryId(), 0, op.ctx); + op.recyclePendAddOpObject(); } @Override public String toString() { @@ -259,6 +260,7 @@ public class LedgerHandleAdv extends LedgerHandle implements WriteAdvHandle { op.cb.addCompleteWithLatency(BookKeeper.getReturnRc(clientCtx.getBookieClient(), BKException.Code.InterruptedException), LedgerHandleAdv.this, op.getEntryId(), 0, op.ctx); + op.recyclePendAddOpObject(); } return; }
