Skip to content

Commit d0a0017

Browse files
committed
fix(cluster): avoid command.reject being overwritten twice
1 parent b52c1bf commit d0a0017

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

lib/cluster/index.js

+2-1
Original file line numberDiff line numberDiff line change
@@ -409,7 +409,8 @@ Cluster.prototype.sendCommand = function (command, stream, node) {
409409
var targetSlot = node ? node.slot : command.getSlot();
410410
var ttl = {};
411411
var _this = this;
412-
if (!node) {
412+
if (!node && !command.__is_reject_overwritten) {
413+
command.__is_reject_overwritten = true;
413414
var reject = command.reject;
414415
var partialTry = _.partial(tryConnection, true);
415416
command.reject = function (err) {

0 commit comments

Comments
 (0)