|
@@ -18,6 +18,7 @@
|
|
|
|
|
|
package org.apache.zookeeper;
|
|
package org.apache.zookeeper;
|
|
|
|
|
|
|
|
+import java.io.IOException;
|
|
import org.slf4j.Logger;
|
|
import org.slf4j.Logger;
|
|
import org.slf4j.LoggerFactory;
|
|
import org.slf4j.LoggerFactory;
|
|
|
|
|
|
@@ -47,4 +48,10 @@ class ZooKeeperTestable implements Testable {
|
|
clientCnxn.eventThread.queueEvent(event);
|
|
clientCnxn.eventThread.queueEvent(event);
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+ @Override
|
|
|
|
+ public void closeSocket() throws IOException {
|
|
|
|
+ LOG.info("closeSocket() called");
|
|
|
|
+ clientCnxn.sendThread.testableCloseSocket();
|
|
|
|
+ }
|
|
|
|
+
|
|
}
|
|
}
|