Github user arshadmohammad commented on a diff in the pull request:
https://github.com/apache/zookeeper/pull/119#discussion_r203928468
--- Diff: src/java/main/org/apache/zookeeper/ClientCnxn.java ---
@@ -1495,10 +1504,21 @@ public ReplyHeader submitRequest(RequestHeader h,
Record request,
Packet packet = queuePacket(h, r, request, response, null, null,
null,
null, watchRegistration, watchDeregistration);
synchronized (packet) {
+ long waitStartTime = System.currentTimeMillis();
while (!packet.finished) {
- packet.wait();
+ packet.wait(requestTimeout);
+ if (!packet.finished && ((System.currentTimeMillis()
--- End diff --
Corrected
---
