summaryrefslogtreecommitdiff
path: root/lib/cluster.js
diff options
context:
space:
mode:
authorcjihrig <cjihrig@gmail.com>2016-05-26 13:00:51 -0400
committercjihrig <cjihrig@gmail.com>2016-05-31 09:45:14 -0400
commit67368d8553977a281f778a144de9b0a75bc17f90 (patch)
tree380e5386f175e68c1397a83f7119af05994ccb9d /lib/cluster.js
parentc4f80c1f3466eb56f33136ee6e2332335db0ec67 (diff)
downloadnode-new-67368d8553977a281f778a144de9b0a75bc17f90.tar.gz
cluster: expose result of send()
There are several places in the cluster module where a version of process.send() is called, but the result is swallowed. Most of these cases are internal, but Worker.prototype.send(), which is publicly documented, also suffers from this problem. This commit exposes the return value to facilitate better error handling, and bring Worker.prototype.send() into compliance with the documentation. PR-URL: https://github.com/nodejs/node/pull/6998 Reviewed-By: James M Snell <jasnell@gmail.com> Reviewed-By: Ron Korving <ron@ronkorving.nl> Reviewed-By: Ben Noordhuis <info@bnoordhuis.nl>
Diffstat (limited to 'lib/cluster.js')
-rw-r--r--lib/cluster.js8
1 files changed, 4 insertions, 4 deletions
diff --git a/lib/cluster.js b/lib/cluster.js
index 45cbf5f772..34f27d0c12 100644
--- a/lib/cluster.js
+++ b/lib/cluster.js
@@ -61,7 +61,7 @@ Worker.prototype.kill = function() {
};
Worker.prototype.send = function() {
- this.process.send.apply(this.process, arguments);
+ return this.process.send.apply(this.process, arguments);
};
Worker.prototype.isDead = function isDead() {
@@ -533,7 +533,7 @@ function masterInit() {
}
function send(worker, message, handle, cb) {
- sendHelper(worker.process, message, handle, cb);
+ return sendHelper(worker.process, message, handle, cb);
}
}
@@ -701,7 +701,7 @@ function workerInit() {
};
function send(message, cb) {
- sendHelper(process, message, null, cb);
+ return sendHelper(process, message, null, cb);
}
function _disconnect(masterInitiated) {
@@ -747,7 +747,7 @@ function sendHelper(proc, message, handle, cb) {
if (cb) callbacks[seq] = cb;
message.seq = seq;
seq += 1;
- proc.send(message, handle);
+ return proc.send(message, handle);
}