Browse Source

test: dynamic port in cluster worker send

Remove common.PORT from test-cluster-send-deadlock and
test-cluster-send-handle-twice to reduce possibility that
a dynamic port used in another test will collide with common.PORT.

PR-URL: https://github.com/nodejs/node/pull/12472
Ref: https://github.com/nodejs/node/issues/12376
Reviewed-By: James M Snell <jasnell@gmail.com>
Reviewed-By: Colin Ihrig <cjihrig@gmail.com>
Reviewed-By: Santiago Gimeno <santiago.gimeno@gmail.com>
v6
Sebastian Plesciuc 8 years ago
committed by James M Snell
parent
commit
9c5c4697b5
  1. 13
      test/parallel/test-cluster-send-deadlock.js
  2. 7
      test/parallel/test-cluster-send-handle-twice.js

13
test/parallel/test-cluster-send-deadlock.js

@ -23,7 +23,7 @@
// Testing mutual send of handles: from master to worker, and from worker to
// master.
const common = require('../common');
require('../common');
const assert = require('assert');
const cluster = require('cluster');
const net = require('net');
@ -40,14 +40,15 @@ if (cluster.isMaster) {
worker.send('handle', socket);
});
server.listen(common.PORT, function() {
worker.send('listen');
server.listen(0, function() {
worker.send({message: 'listen', port: server.address().port});
});
} else {
process.on('message', function(msg, handle) {
if (msg === 'listen') {
const client1 = net.connect({ host: 'localhost', port: common.PORT });
const client2 = net.connect({ host: 'localhost', port: common.PORT });
if (msg.message && msg.message === 'listen') {
assert(msg.port);
const client1 = net.connect({ host: 'localhost', port: msg.port });
const client2 = net.connect({ host: 'localhost', port: msg.port });
let waiting = 2;
client1.on('close', onclose);
client2.on('close', onclose);

7
test/parallel/test-cluster-send-handle-twice.js

@ -45,8 +45,11 @@ if (cluster.isMaster) {
process.send('send-handle-2', socket);
});
server.listen(common.PORT, function() {
const client = net.connect({ host: 'localhost', port: common.PORT });
server.listen(0, function() {
const client = net.connect({
host: 'localhost',
port: server.address().port
});
client.on('close', common.mustCall(() => { cluster.worker.disconnect(); }));
setTimeout(function() { client.end(); }, 50);
}).on('error', function(e) {

Loading…
Cancel
Save