You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@zookeeper.apache.org by rg...@apache.org on 2015/12/05 22:32:41 UTC
svn commit: r1718121 - in /zookeeper/trunk: CHANGES.txt
src/java/main/org/apache/zookeeper/ClientCnxn.java
src/java/main/org/apache/zookeeper/client/ZooKeeperSaslClient.java
Author: rgs
Date: Sat Dec 5 21:32:41 2015
New Revision: 1718121
URL: http://svn.apache.org/viewvc?rev=1718121&view=rev
Log:
ZOOKEEPER-2330: ZooKeeper close API does not close Login thread
(Arshad Mohammad via rgs)
Modified:
zookeeper/trunk/CHANGES.txt
zookeeper/trunk/src/java/main/org/apache/zookeeper/ClientCnxn.java
zookeeper/trunk/src/java/main/org/apache/zookeeper/client/ZooKeeperSaslClient.java
Modified: zookeeper/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/zookeeper/trunk/CHANGES.txt?rev=1718121&r1=1718120&r2=1718121&view=diff
==============================================================================
--- zookeeper/trunk/CHANGES.txt (original)
+++ zookeeper/trunk/CHANGES.txt Sat Dec 5 21:32:41 2015
@@ -220,6 +220,9 @@ BUGFIXES:
ZOOKEEPER-2329: Clear javac and javadoc warning from zookeeper
(Arshad Mohammad via rgs)
+ ZOOKEEPER-2330: ZooKeeper close API does not close Login thread
+ (Arshad Mohammad via rgs)
+
IMPROVEMENTS:
ZOOKEEPER-1660 Documentation for Dynamic Reconfiguration (Reed Wanderman-Milne via shralex)
Modified: zookeeper/trunk/src/java/main/org/apache/zookeeper/ClientCnxn.java
URL: http://svn.apache.org/viewvc/zookeeper/trunk/src/java/main/org/apache/zookeeper/ClientCnxn.java?rev=1718121&r1=1718120&r2=1718121&view=diff
==============================================================================
--- zookeeper/trunk/src/java/main/org/apache/zookeeper/ClientCnxn.java (original)
+++ zookeeper/trunk/src/java/main/org/apache/zookeeper/ClientCnxn.java Sat Dec 5 21:32:41 2015
@@ -1464,6 +1464,9 @@ public class ClientCnxn {
sendThread.close();
eventThread.queueEventOfDeath();
+ if (null != zooKeeperSaslClient) {
+ zooKeeperSaslClient.shutdown();
+ }
}
/**
Modified: zookeeper/trunk/src/java/main/org/apache/zookeeper/client/ZooKeeperSaslClient.java
URL: http://svn.apache.org/viewvc/zookeeper/trunk/src/java/main/org/apache/zookeeper/client/ZooKeeperSaslClient.java?rev=1718121&r1=1718120&r2=1718121&view=diff
==============================================================================
--- zookeeper/trunk/src/java/main/org/apache/zookeeper/client/ZooKeeperSaslClient.java (original)
+++ zookeeper/trunk/src/java/main/org/apache/zookeeper/client/ZooKeeperSaslClient.java Sat Dec 5 21:32:41 2015
@@ -580,5 +580,12 @@ public class ZooKeeperSaslClient {
}
}
-
+ /**
+ * close login thread if running
+ */
+ public void shutdown() {
+ if (null != login) {
+ login.shutdown();
+ }
+ }
}