Repository: bookkeeper Updated Branches: refs/heads/master 2f71beb5e -> 1f7e47005
BOOKKEEPER-927: LedgerHandleAdv to handle disabled ledgers operation ⦠â¦throttling BOOKKEEPER-886 missed taking care of LedgerHandleAdv. This takes care of that issue. Signed-off-by: Venkateswararao Jujjuri (JV) <vjujjurisalesforce.com> Author: JV <[email protected]> Reviewers: Sijie Guo <[email protected]> Closes #45 from jvrao/bookkeeper-927 Project: http://git-wip-us.apache.org/repos/asf/bookkeeper/repo Commit: http://git-wip-us.apache.org/repos/asf/bookkeeper/commit/1f7e4700 Tree: http://git-wip-us.apache.org/repos/asf/bookkeeper/tree/1f7e4700 Diff: http://git-wip-us.apache.org/repos/asf/bookkeeper/diff/1f7e4700 Branch: refs/heads/master Commit: 1f7e47005588eedd879d0b9d163b4f125c6a0d59 Parents: 2f71beb Author: JV <[email protected]> Authored: Mon Jul 25 15:22:34 2016 -0700 Committer: JV <[email protected]> Committed: Mon Jul 25 15:22:34 2016 -0700 ---------------------------------------------------------------------- .../main/java/org/apache/bookkeeper/client/LedgerHandleAdv.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/bookkeeper/blob/1f7e4700/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/LedgerHandleAdv.java ---------------------------------------------------------------------- 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 00fcfa7..c69a0e5 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 @@ -170,7 +170,9 @@ public class LedgerHandleAdv extends LedgerHandle { "Invalid values for offset("+offset +") or length("+length+")"); } - throttler.acquire(); + if (throttler != null) { + throttler.acquire(); + } if (metadata.isClosed()) { // make sure the callback is triggered in main worker pool
