[bookkeeper] branch master updated: Apply recycle logic during add entry creation but ledger close to LedgerHandleAdv (#3621)

[chenhang]

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

chenhang 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 0d2fbe434e Apply recycle logic during add entry creation but ledger 
close to LedgerHandleAdv (#3621)
0d2fbe434e is described below

commit 0d2fbe434ec2412a166103ebf7fe9c28ecfc48f6
Author: zhaohaidao <zhaohaidao2...@hotmail.com>
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
---
 .../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 8440faf37b..92bddc9cc4 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
@@ -248,6 +248,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() {
@@ -258,6 +259,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;
         }