Skip to content

Commit

Permalink
test: fix test-cluster-send-handle-large-payload
Browse files Browse the repository at this point in the history
On macOS, the parent process might not receive a message if it
is sent to soon, and then subsequent messages are also sometimes not
received.

(Is this a bug or expected operating system behavior like the
way a file watcher is returned before it's actually watching the file
system on/ macOS?)

Send a second message after a delay on macOS.

While at it, minor refactoring to the test:

* Blank line after loading `common` module per test-writing guide
* Wrap arrow function in braces where implicit return is not needed
* Remove unnecessary unref in subprocess

Fixes: nodejs#14747
  • Loading branch information
Trott committed Aug 12, 2017
1 parent ab2b331 commit b248049
Showing 1 changed file with 17 additions and 3 deletions.
20 changes: 17 additions & 3 deletions test/parallel/test-cluster-send-handle-large-payload.js
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
'use strict';
const common = require('../common');

const assert = require('assert');
const cluster = require('cluster');
const net = require('net');
Expand All @@ -9,7 +10,7 @@ const payload = 'a'.repeat(800004);
if (cluster.isMaster) {
const server = net.createServer();

server.on('connection', common.mustCall((socket) => socket.unref()));
server.on('connection', common.mustCall((socket) => { socket.unref(); }));

const worker = cluster.fork();
worker.on('message', common.mustCall(({ payload: received }, handle) => {
Expand All @@ -31,10 +32,23 @@ if (cluster.isMaster) {
process.on('message', common.mustCall(({ payload: received }, handle) => {
assert.strictEqual(payload, received);
assert(handle instanceof net.Socket);
process.send({ payload }, handle);

// On macOS, the parent process might not receive a message if it is sent
// to soon, and then subsequent messages are also sometimes not received.
//
// (Is this a bug or expected operating system behavior like the way a file
// watcher is returned before it's actually watching the file system on
// macOS?)
//
// Send a second message after a delay on macOS.
//
// Refs: https://github.com/nodejs/node/issues/14747
if (common.isOSX)
setTimeout(() => { process.send({ payload }, handle); }, 1000);
else
process.send({ payload }, handle);

// Prepare for a clean exit.
process.channel.unref();
handle.unref();
}));
}

0 comments on commit b248049

Please sign in to comment.