|
@@ -102,7 +102,9 @@ public class NIOServerCnxn extends ServerCnxn {
|
|
|
outstandingLimit = zk.getGlobalOutstandingLimit();
|
|
|
}
|
|
|
sock.socket().setTcpNoDelay(true);
|
|
|
- sock.socket().setSoLinger(true, 2);
|
|
|
+ /* set socket linger to false, so that socket close does not
|
|
|
+ * block */
|
|
|
+ sock.socket().setSoLinger(false, -1);
|
|
|
InetAddress addr = ((InetSocketAddress) sock.socket()
|
|
|
.getRemoteSocketAddress()).getAddress();
|
|
|
authInfo.add(new Id("ip", addr.getHostAddress()));
|