You've already forked node-redis
mirror of
https://github.com/redis/node-redis.git
synced 2025-08-06 02:15:48 +03:00
fix unescaped exception in Multi.exec
This commit is contained in:
9
index.js
9
index.js
@@ -713,7 +713,7 @@ RedisClient.prototype.send_command = function (command, args, callback) {
|
|||||||
return callback(err);
|
return callback(err);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
buffer_args = false;
|
buffer_args = false;
|
||||||
for (i = 0, il = args.length, arg; i < il; i += 1) {
|
for (i = 0, il = args.length, arg; i < il; i += 1) {
|
||||||
if (Buffer.isBuffer(args[i])) {
|
if (Buffer.isBuffer(args[i])) {
|
||||||
@@ -1037,7 +1037,12 @@ Multi.prototype.exec = function (callback) {
|
|||||||
if (typeof cur[cur.length - 1] === "function") {
|
if (typeof cur[cur.length - 1] === "function") {
|
||||||
cur[cur.length - 1](err);
|
cur[cur.length - 1](err);
|
||||||
} else {
|
} else {
|
||||||
throw new Error(err);
|
if (callback) {
|
||||||
|
callback(new Error(err));
|
||||||
|
return;
|
||||||
|
} else {
|
||||||
|
throw new Error(err);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
self.queue.splice(index, 1);
|
self.queue.splice(index, 1);
|
||||||
}
|
}
|
||||||
|
Reference in New Issue
Block a user