diff options
author | cjihrig <cjihrig@gmail.com> | 2016-05-26 13:00:51 -0400 |
---|---|---|
committer | cjihrig <cjihrig@gmail.com> | 2016-05-31 09:45:14 -0400 |
commit | 67368d8553977a281f778a144de9b0a75bc17f90 (patch) | |
tree | 380e5386f175e68c1397a83f7119af05994ccb9d /lib/cluster.js | |
parent | c4f80c1f3466eb56f33136ee6e2332335db0ec67 (diff) | |
download | node-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.js | 8 |
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); } |