Skip to content

Commit

Permalink
child_process: guard against race condition
Browse files Browse the repository at this point in the history
It is possible that the internal hnadleMessage() might try to send to
a channel that has been closed. The result can be an AssertionError.
Guard against this.

Fixes: #4205
PR-URL: #4418
Reviewed-By: Brian White <mscdex@mscdex.net>
Reviewed-By: Johan Bergström <bugs@bergstroem.nu>
  • Loading branch information
Trott authored and Fishrock123 committed Jan 6, 2016
1 parent cd79ec2 commit 2526282
Show file tree
Hide file tree
Showing 2 changed files with 36 additions and 0 deletions.
3 changes: 3 additions & 0 deletions lib/internal/child_process.js
Original file line number Diff line number Diff line change
Expand Up @@ -675,6 +675,9 @@ function setupChannel(target, channel) {

const INTERNAL_PREFIX = 'NODE_';
function handleMessage(target, message, handle) {
if (!target._channel)
return;

var eventName = 'message';
if (message !== null &&
typeof message === 'object' &&
Expand Down
33 changes: 33 additions & 0 deletions test/parallel/test-cluster-disconnect-race.js
Original file line number Diff line number Diff line change
@@ -0,0 +1,33 @@
'use strict';

// This code triggers an AssertionError on Linux in Node.js 5.3.0 and earlier.
// Ref: https://github.com/nodejs/node/issues/4205

const common = require('../common');
const assert = require('assert');
const net = require('net');
const cluster = require('cluster');
cluster.schedulingPolicy = cluster.SCHED_NONE;

if (cluster.isMaster) {
var worker1, worker2;

worker1 = cluster.fork();
worker1.on('message', common.mustCall(function() {
worker2 = cluster.fork();
worker1.disconnect();
worker2.on('online', common.mustCall(worker2.disconnect));
}));

cluster.on('exit', function(worker, code) {
assert.strictEqual(code, 0, 'worker exited with error');
});

return;
}

var server = net.createServer();

server.listen(common.PORT, function() {
process.send('listening');
});

0 comments on commit 2526282

Please sign in to comment.