zookeeper-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tha...@apache.org
Subject svn commit: r1541810 - /zookeeper/trunk/src/java/main/org/apache/zookeeper/server/quorum/ObserverZooKeeperServer.java
Date Thu, 14 Nov 2013 04:34:42 GMT
Author: thawan
Date: Thu Nov 14 04:34:42 2013
New Revision: 1541810

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

Modified:
    zookeeper/trunk/src/java/main/org/apache/zookeeper/server/quorum/ObserverZooKeeperServer.java

Modified: zookeeper/trunk/src/java/main/org/apache/zookeeper/server/quorum/ObserverZooKeeperServer.java
URL: http://svn.apache.org/viewvc/zookeeper/trunk/src/java/main/org/apache/zookeeper/server/quorum/ObserverZooKeeperServer.java?rev=1541810&r1=1541809&r2=1541810&view=diff
==============================================================================
--- zookeeper/trunk/src/java/main/org/apache/zookeeper/server/quorum/ObserverZooKeeperServer.java
(original)
+++ zookeeper/trunk/src/java/main/org/apache/zookeeper/server/quorum/ObserverZooKeeperServer.java
Thu Nov 14 04:34:42 2013
@@ -134,4 +134,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