zookeeper-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tha...@apache.org
Subject svn commit: r1541814 - /zookeeper/branches/branch-3.4/src/java/main/org/apache/zookeeper/server/quorum/ObserverZooKeeperServer.java
Date Thu, 14 Nov 2013 04:43:46 GMT
Author: thawan
Date: Thu Nov 14 04:43:46 2013
New Revision: 1541814

URL: http://svn.apache.org/r1541814
Log:
ZOOKEEPER-1798. Fix race condition in testNormalObserverRun (Part 2) (thawan, fpj via thawan)

Modified:
    zookeeper/branches/branch-3.4/src/java/main/org/apache/zookeeper/server/quorum/ObserverZooKeeperServer.java

Modified: zookeeper/branches/branch-3.4/src/java/main/org/apache/zookeeper/server/quorum/ObserverZooKeeperServer.java
URL: http://svn.apache.org/viewvc/zookeeper/branches/branch-3.4/src/java/main/org/apache/zookeeper/server/quorum/ObserverZooKeeperServer.java?rev=1541814&r1=1541813&r2=1541814&view=diff
==============================================================================
--- zookeeper/branches/branch-3.4/src/java/main/org/apache/zookeeper/server/quorum/ObserverZooKeeperServer.java
(original)
+++ zookeeper/branches/branch-3.4/src/java/main/org/apache/zookeeper/server/quorum/ObserverZooKeeperServer.java
Thu Nov 14 04:43:46 2013
@@ -136,4 +136,12 @@ public class ObserverZooKeeperServer ext
     public String getState() {
         return "observer";
     };    
+
+    @Override
+    public void shutdown() {
+        super.shutdown();
+        if (syncRequestProcessorEnabled && syncProcessor != null) {
+            syncProcessor.shutdown();
+        }
+    }
 }



Mime
View raw message