This is an automated email from the ASF dual-hosted git repository.
yong 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 221cba4ed3 Check client if closed when complete callback. (#3661)
221cba4ed3 is described below
commit 221cba4ed32980e6e3109e9b9cca7e380b64ee65
Author: Qiang Zhao <[email protected]>
AuthorDate: Thu Nov 24 10:53:12 2022 +0800
Check client if closed when complete callback. (#3661)
### Motivation
Follow the same rules to complete the callback to avoid Bookkeeper client
operations being allowed even after its closure.
### Changes
- Use `bk.getReturnRc(rc)` check the client state.
---
.../src/main/java/org/apache/bookkeeper/client/LedgerOpenOp.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/LedgerOpenOp.java
b/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/LedgerOpenOp.java
index 027a3da286..7278af7d42 100644
---
a/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/LedgerOpenOp.java
+++
b/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/LedgerOpenOp.java
@@ -206,7 +206,7 @@ class LedgerOpenOp {
}
if (rc ==
BKException.Code.UnauthorizedAccessException
|| rc ==
BKException.Code.TimeoutException) {
- openComplete(rc, null);
+ openComplete(bk.getReturnRc(rc), null);
} else {
openComplete(bk.getReturnRc(BKException.Code.LedgerRecoveryException), null);
}