Merge pull request #271 from DavidVujic/init-and-reset-noresponsecounter

Init and reset the noResponseCounter state variable

Author: DavidVujic

examples/socketserver.js

@@ -9,8 +9,9 @@ net.createServer((sock) => {
 
     sock.on('data', (data) => {
         console.log(`DATA ${sock.remoteAddress}: ${data}`);
-
-        sock.write(`You said "${data}"`);
+        setInterval(() => {
+            sock.write(`You said "${data}"`);
+        }, 3000);
     });
 
     sock.on('close', (data) => {

examples/wrapper.js

@@ -18,7 +18,7 @@ function createClient(timeoutMs = 5000) {
         const config = {
             connect: host,
             timeout: timeoutMs,
-            debug_level: constants.ZOO_LOG_LEVEL_WARN,
+            debug_level: constants.ZOO_LOG_LEVEL_INFO,
             host_order_deterministic: false,
         };
 

prebuilds/darwin-x64/node.abi72.node

@@ -419,6 +419,8 @@ class ZooKeeper: public Nan::ObjectWrap {
         uv_timer_init(uv_default_loop(), &zk_timer);
         zk_timer.data = this;
 
+        noResponseCounter = 0;
+
         yield();
         return true;
     }
@@ -1040,6 +1042,8 @@ class ZooKeeper: public Nan::ObjectWrap {
             // Unrefing after is important to avoid memory being freed too early.
             uv_close((uv_handle_t*) &zk_timer, timer_closed);
 
+            noResponseCounter = 0;
+
             Nan::HandleScope scope;
             DoEmitClose (Nan::New(on_closed), code);
         }