[jira] [Updated] (BOOKKEEPER-532) AbstractSubscriptionManager#AcquireOp read subscriptions every time even it already owned the topic

["Sijie Guo (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/BOOKKEEPER-532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Sijie Guo updated BOOKKEEPER-532:
---------------------------------

    Attachment: BOOKKEEPER-532.diff

attach a simple fix.
                
> AbstractSubscriptionManager#AcquireOp read subscriptions every time even it already owned the topic
> ---------------------------------------------------------------------------------------------------
>
>                 Key: BOOKKEEPER-532
>                 URL: https://issues.apache.org/jira/browse/BOOKKEEPER-532
>             Project: Bookkeeper
>          Issue Type: Bug
>          Components: hedwig-server
>            Reporter: Sijie Guo
>            Assignee: Sijie Guo
>            Priority: Blocker
>             Fix For: 4.2.0
>
>         Attachments: BOOKKEEPER-532.diff
>
>
> {code}
>     private class AcquireOp extends TopicOpQueuer.AsynchronousOp<Void> {
>         public AcquireOp(ByteString topic, Callback<Void> callback, Object ctx) {
>             queuer.super(topic, callback, ctx);
>         }   
>         @Override
>         public void run() {
>             if (top2sub2seq.containsKey(topic)) {
>                 cb.operationFinished(ctx, null);
>             }   
>             readSubscriptions(topic, new Callback<Map<ByteString, InMemorySubscriptionState>>() {
> {code}
> it doesn't return after it found subscriptions and callback.

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira