You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@zookeeper.apache.org by ca...@apache.org on 2011/09/28 16:46:15 UTC
svn commit: r1176903 -
/zookeeper/trunk/src/java/main/org/apache/zookeeper/ClientCnxnSocketNIO.java
Author: camille
Date: Wed Sep 28 14:46:15 2011
New Revision: 1176903
URL: http://svn.apache.org/viewvc?rev=1176903&view=rev
Log:
ZOOKEEPER-786. Reverting a bad line of this checkin
Modified:
zookeeper/trunk/src/java/main/org/apache/zookeeper/ClientCnxnSocketNIO.java
Modified: zookeeper/trunk/src/java/main/org/apache/zookeeper/ClientCnxnSocketNIO.java
URL: http://svn.apache.org/viewvc/zookeeper/trunk/src/java/main/org/apache/zookeeper/ClientCnxnSocketNIO.java?rev=1176903&r1=1176902&r2=1176903&view=diff
==============================================================================
--- zookeeper/trunk/src/java/main/org/apache/zookeeper/ClientCnxnSocketNIO.java (original)
+++ zookeeper/trunk/src/java/main/org/apache/zookeeper/ClientCnxnSocketNIO.java Wed Sep 28 14:46:15 2011
@@ -190,7 +190,9 @@ public class ClientCnxnSocketNIO extends
sock.socket().setSoLinger(false, -1);
sock.socket().setTcpNoDelay(true);
sockKey = sock.register(selector, SelectionKey.OP_CONNECT);
- sock.connect(addr);
+ if (sock.connect(addr)) {
+ sendThread.primeConnection();
+ }
initialized = false;
/*