fix bug in redis client disconnect

NetEase · Jun 14, 2017 · 1b60e66 · 1b60e66
1 parent 1eb91c8
commit 1b60e66
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/lib/monitors/redismonitor.js b/lib/monitors/redismonitor.js
@@ -76,7 +76,7 @@ Monitor.prototype.start = function(cb) {
 Monitor.prototype.stop = function() {
   this.client.disconnect();
   if (!!this.pingRedis) {
-    this.pingRedis.disconnect();
+    this.pingRedis.end();
   }
   clearInterval(this.timer);
 };
@@ -183,14 +183,14 @@ var getMaster = function(self, redisNodes) {
               ping(self, client, redis);
             }, constants.TIME.DEFAULT_REDIS_PING);
           } else {
-            client.disconnect();
+            client.end();
             client = null;
           }
         });
       });
       client.on('error', function() {
         logger.error('[redisMonitor] monitor redis connect error');
-        client.disconnect();
+        client.end();
         client = null;
       });
     })(i);
@@ -203,7 +203,7 @@ var ping = function(self, client, rds) {
     clearInterval(self.pingtimer);
     if(self.pingtimer) {
       logger.info('[redisMonitor] clear pingtimer timeout');
-      client.disconnect();
+      client.end();
       client = null;
       self.pingtimer = null;
       rds.disconnect();
@@ -225,7 +225,7 @@ var clearPingTimer = function(self, cb) {
   clearInterval(self.pingtimer);
   var client = self.pingRedis;
   if(!!client) {
-    client.disconnect();
+    client.end();
     client = null;
     self.pingtimer = null;
   }