feat: add debug details for connection pool

redis · Jun 22, 2018 · 9ec16b6 · 9ec16b6
1 parent 1fdd46c
commit 9ec16b6
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/lib/cluster/connection_pool.js b/lib/cluster/connection_pool.js
@@ -5,6 +5,7 @@ var utils = require('../utils');
 var EventEmitter = require('events').EventEmitter;
 var _ = require('../utils/lodash');
 var Redis = require('../redis');
+var debug = require('../utils/debug')('ioredis:cluster:connectionPool');
 
 function ConnectionPool(redisOptions) {
   EventEmitter.call(this);
@@ -115,11 +116,14 @@ ConnectionPool.prototype.reset = function (nodes) {
   var _this = this;
   Object.keys(this.nodes.all).forEach(function (key) {
     if (!newNodes[key]) {
+      debug('Disconnect %s because the node does not hold any slot', key);
       _this.nodes.all[key].disconnect();
     }
   });
   Object.keys(newNodes).forEach(function (key) {
-    _this.findOrCreate(newNodes[key], newNodes[key].readOnly);
+    var node = newNodes[key];
+    debug('Connecting to %s as %s', key, node.readOnly ? 'slave' : 'master');
+    _this.findOrCreate(node, node.readOnly);
   });
 };