zookeeper-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From f..@apache.org
Subject svn commit: r1430091 - in /zookeeper/bookkeeper/trunk: CHANGES.txt hedwig-server/src/main/java/org/apache/hedwig/server/subscriptions/AbstractSubscriptionManager.java
Date Mon, 07 Jan 2013 23:44:34 GMT
Author: fpj
Date: Mon Jan  7 23:44:33 2013
New Revision: 1430091

URL: http://svn.apache.org/viewvc?rev=1430091&view=rev
Log:
BOOKKEEPER-532: AbstractSubscriptionManager#AcquireOp read subscriptions every time even it
already owned the topic. (sijie via fpj)


Modified:
    zookeeper/bookkeeper/trunk/CHANGES.txt
    zookeeper/bookkeeper/trunk/hedwig-server/src/main/java/org/apache/hedwig/server/subscriptions/AbstractSubscriptionManager.java

Modified: zookeeper/bookkeeper/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/zookeeper/bookkeeper/trunk/CHANGES.txt?rev=1430091&r1=1430090&r2=1430091&view=diff
==============================================================================
--- zookeeper/bookkeeper/trunk/CHANGES.txt (original)
+++ zookeeper/bookkeeper/trunk/CHANGES.txt Mon Jan  7 23:44:33 2013
@@ -218,6 +218,8 @@ Trunk (unreleased changes)
 
         BOOKKEEPER-507: Race condition happens if closeSubscription and subscribe happened
at the same time (in multiplexed client). (sijie via ivank)
 
+	BOOKKEEPER-532: AbstractSubscriptionManager#AcquireOp read subscriptions every time even
it already owned the topic. (sijie via fpj)
+
     IMPROVEMENTS:
 
       BOOKKEEPER-467: Allocate ports for testing dynamically (ivank)

Modified: zookeeper/bookkeeper/trunk/hedwig-server/src/main/java/org/apache/hedwig/server/subscriptions/AbstractSubscriptionManager.java
URL: http://svn.apache.org/viewvc/zookeeper/bookkeeper/trunk/hedwig-server/src/main/java/org/apache/hedwig/server/subscriptions/AbstractSubscriptionManager.java?rev=1430091&r1=1430090&r2=1430091&view=diff
==============================================================================
--- zookeeper/bookkeeper/trunk/hedwig-server/src/main/java/org/apache/hedwig/server/subscriptions/AbstractSubscriptionManager.java
(original)
+++ zookeeper/bookkeeper/trunk/hedwig-server/src/main/java/org/apache/hedwig/server/subscriptions/AbstractSubscriptionManager.java
Mon Jan  7 23:44:33 2013
@@ -165,6 +165,7 @@ public abstract class AbstractSubscripti
         public void run() {
             if (top2sub2seq.containsKey(topic)) {
                 cb.operationFinished(ctx, null);
+                return;
             }
 
             readSubscriptions(topic, new Callback<Map<ByteString, InMemorySubscriptionState>>()
{



Mime
View raw message