From 9ec16b6e5bf3bbffe15b5e525b6a29f15ee71d61 Mon Sep 17 00:00:00 2001 From: luin Date: Sat, 23 Jun 2018 02:37:09 +0800 Subject: [PATCH] feat: add debug details for connection pool --- lib/cluster/connection_pool.js | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/lib/cluster/connection_pool.js b/lib/cluster/connection_pool.js index cf4d8d1b..ce8ebc82 100644 --- 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); }); };