Skip to content

Commit

Permalink
test: dynamic port in parallel cluster tests
Browse files Browse the repository at this point in the history
Removed common.PORT from test-cluster-message,
test-cluster-server-restart-none, test-cluster-server-restart-rr
and test-cluster-shared-handle-bind-error to eliminate the
possibility that a dynamic port used in another test will collide
with common.PORT.

PR-URL: #12584
Ref: #12376
Reviewed-By: Colin Ihrig <[email protected]>
Reviewed-By: Santiago Gimeno <[email protected]>
Reviewed-By: James M Snell <[email protected]>
Reviewed-By: Gibson Fahnestock <[email protected]>
  • Loading branch information
Sebastian Plesciuc authored and MylesBorins committed May 18, 2017
1 parent fd126b5 commit 51794dd
Show file tree
Hide file tree
Showing 4 changed files with 12 additions and 11 deletions.
8 changes: 4 additions & 4 deletions test/parallel/test-cluster-message.js
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
'use strict';
const common = require('../common');
require('../common');
const assert = require('assert');
const cluster = require('cluster');
const net = require('net');
Expand Down Expand Up @@ -39,7 +39,7 @@ if (cluster.isWorker) {
maybeReply();
});

server.listen(common.PORT, '127.0.0.1');
server.listen(0, '127.0.0.1');
} else if (cluster.isMaster) {

const checks = {
Expand Down Expand Up @@ -88,9 +88,9 @@ if (cluster.isWorker) {
});

// When a TCP server is listening in the worker connect to it
worker.on('listening', function() {
worker.on('listening', function(address) {

client = net.connect(common.PORT, function() {
client = net.connect(address.port, function() {
// Send message to worker.
worker.send('message from master');
});
Expand Down
4 changes: 2 additions & 2 deletions test/parallel/test-cluster-server-restart-none.js
Original file line number Diff line number Diff line change
Expand Up @@ -23,10 +23,10 @@ if (cluster.isMaster) {
} else {
const net = require('net');
const server = net.createServer();
server.listen(common.PORT, common.mustCall(() => {
server.listen(0, common.mustCall(() => {
if (cluster.worker.id === 2) {
server.close(() => {
server.listen(common.PORT, common.mustCall(() => {
server.listen(0, common.mustCall(() => {
server.close(() => {
process.disconnect();
});
Expand Down
4 changes: 2 additions & 2 deletions test/parallel/test-cluster-server-restart-rr.js
Original file line number Diff line number Diff line change
Expand Up @@ -23,10 +23,10 @@ if (cluster.isMaster) {
} else {
const net = require('net');
const server = net.createServer();
server.listen(common.PORT, common.mustCall(() => {
server.listen(0, common.mustCall(() => {
if (cluster.worker.id === 2) {
server.close(() => {
server.listen(common.PORT, common.mustCall(() => {
server.listen(0, common.mustCall(() => {
server.close(() => {
process.disconnect();
});
Expand Down
7 changes: 4 additions & 3 deletions test/parallel/test-cluster-shared-handle-bind-error.js
Original file line number Diff line number Diff line change
Expand Up @@ -10,16 +10,17 @@ if (cluster.isMaster) {
// Hog the TCP port so that when the worker tries to bind, it'll fail.
const server = net.createServer(common.mustNotCall());

server.listen(common.PORT, common.mustCall(() => {
const worker = cluster.fork();
server.listen(0, common.mustCall(() => {
const worker = cluster.fork({PORT: server.address().port});
worker.on('exit', common.mustCall((exitCode) => {
assert.strictEqual(exitCode, 0);
server.close();
}));
}));
} else {
assert(process.env.PORT);
const s = net.createServer(common.mustNotCall());
s.listen(common.PORT, common.mustNotCall('listen should have failed'));
s.listen(process.env.PORT, common.mustNotCall('listen should have failed'));
s.on('error', common.mustCall((err) => {
assert.strictEqual(err.code, 'EADDRINUSE');
process.disconnect();
Expand Down

0 comments on commit 51794dd

Please sign in to comment.