test: use random ports where possible

This helps to prevent issues where a failed test can keep a bound
socket open long enough to cause other tests to fail with EADDRINUSE
because the same port number is used.

PR-URL: #7045
Reviewed-By: Ben Noordhuis <[email protected]>
Reviewed-By: Matteo Collina <[email protected]>
Reviewed-By: Rod Vagg <[email protected]>

Author: mscdex

test/parallel/test-async-wrap-check-providers.js

@@ -76,12 +76,12 @@ net.createServer(function(c) {
 net.createServer(function(c) {
   c.end();
   this.close(checkTLS);
-}).listen(common.PORT, function() {
-  net.connect(common.PORT, noop);
+}).listen(0, function() {
+  net.connect(this.address().port, noop);
 });
 
-dgram.createSocket('udp4').bind(common.PORT, function() {
-  this.send(new Buffer(2), 0, 2, common.PORT, '::', () => {
+dgram.createSocket('udp4').bind(0, function() {
+  this.send(new Buffer(2), 0, 2, this.address().port, '::', () => {
     this.close();
   });
 });
@@ -95,8 +95,9 @@ function checkTLS() {
     cert: fs.readFileSync(common.fixturesDir + '/keys/ec-cert.pem')
   };
   const server = tls.createServer(options, noop)
-    .listen(common.PORT, function() {
-      tls.connect(common.PORT, { rejectUnauthorized: false }, function() {
+    .listen(0, function() {
+      const connectOpts = { rejectUnauthorized: false };
+      tls.connect(this.address().port, connectOpts, function() {
         this.destroy();
         server.close();
       });

test/parallel/test-async-wrap-disabled-propagate-parent.js

@@ -1,6 +1,6 @@
 'use strict';
 
-const common = require('../common');
+require('../common');
 const assert = require('assert');
 const net = require('net');
 const async_wrap = process.binding('async_wrap');
@@ -40,8 +40,8 @@ const server = net.createServer(function(c) {
     c.end();
     this.close();
   });
-}).listen(common.PORT, function() {
-  net.connect(common.PORT, noop);
+}).listen(0, function() {
+  net.connect(this.address().port, noop);
 });
 
 async_wrap.disable();

test/parallel/test-async-wrap-propagate-parent.js

@@ -1,6 +1,6 @@
 'use strict';
 
-const common = require('../common');
+require('../common');
 const assert = require('assert');
 const net = require('net');
 const async_wrap = process.binding('async_wrap');
@@ -40,8 +40,8 @@ const server = net.createServer(function(c) {
     c.end();
     this.close();
   });
-}).listen(common.PORT, function() {
-  net.connect(common.PORT, noop);
+}).listen(0, function() {
+  net.connect(this.address().port, noop);
 });
 
 

test/parallel/test-beforeexit-event.js

@@ -1,7 +1,7 @@
 'use strict';
+require('../common');
 var assert = require('assert');
 var net = require('net');
-var common = require('../common');
 var revivals = 0;
 var deaths = 0;
 
@@ -29,7 +29,7 @@ function tryTimer() {
 function tryListen() {
   console.log('create a server');
   net.createServer()
-    .listen(common.PORT)
+    .listen(0)
     .on('listening', function() {
       revivals++;
       this.close();

test/parallel/test-child-process-disconnect.js

@@ -38,10 +38,10 @@ if (process.argv[2] === 'child') {
 
   // when the server is ready tell parent
   server.on('listening', function() {
-    process.send('ready');
+    process.send({ msg: 'ready', port: server.address().port });
   });
 
-  server.listen(common.PORT);
+  server.listen(0);
 
 } else {
   // testcase
@@ -65,11 +65,11 @@ if (process.argv[2] === 'child') {
   });
 
   // when child is listening
-  child.on('message', function(msg) {
-    if (msg === 'ready') {
+  child.on('message', function(obj) {
+    if (obj && obj.msg === 'ready') {
 
       // connect to child using TCP to know if disconnect was emitted
-      var socket = net.connect(common.PORT);
+      var socket = net.connect(obj.port);
 
       socket.on('data', function(data) {
         data = data.toString();

test/parallel/test-child-process-fork-dgram.js

@@ -72,7 +72,7 @@ if (process.argv[2] === 'child') {
         msg,
         0,
         msg.length,
-        common.PORT,
+        server.address().port,
         '127.0.0.1',
         function(err) {
           if (err) throw err;
@@ -98,7 +98,7 @@ if (process.argv[2] === 'child') {
     client.close();
   };
 
-  server.bind(common.PORT, '127.0.0.1');
+  server.bind(0, '127.0.0.1');
 
   process.once('exit', function() {
     assert(parentGotMessage);

test/parallel/test-child-process-fork-net.js

@@ -1,6 +1,6 @@
 'use strict';
-const assert = require('assert');
 require('../common');
+const assert = require('assert');
 const fork = require('child_process').fork;
 const net = require('net');
 

test/parallel/test-child-process-fork-net2.js

@@ -99,7 +99,7 @@ if (process.argv[2] === 'child') {
 
     var j = count, client;
     while (j--) {
-      client = net.connect(common.PORT, '127.0.0.1');
+      client = net.connect(this.address().port, '127.0.0.1');
       client.on('error', function() {
         // This can happen if we kill the child too early.
         // The client should still get a close event afterwards.
@@ -125,7 +125,7 @@ if (process.argv[2] === 'child') {
     child3.kill();
   }));
 
-  server.listen(common.PORT, '127.0.0.1');
+  server.listen(0, '127.0.0.1');
 
   var closeServer = function() {
     server.close();

test/parallel/test-child-process-fork-regr-gh-2847.js

@@ -25,11 +25,11 @@ var server = net.createServer(function(s) {
   setTimeout(function() {
     s.destroy();
   }, 100);
-}).listen(common.PORT, function() {
+}).listen(0, function() {
   var worker = cluster.fork();
 
   function send(callback) {
-    var s = net.connect(common.PORT, function() {
+    var s = net.connect(server.address().port, function() {
       worker.send({}, s, callback);
     });
 

test/parallel/test-child-process-recv-handle.js

@@ -24,7 +24,7 @@ function master() {
   });
   proc.stdout.on('data', function(data) {
     assert.equal(data, 'ok\r\n');
-    net.createServer(common.fail).listen(common.PORT, function() {
+    net.createServer(common.fail).listen(0, function() {
       handle = this._handle;
       proc.send('one');
       proc.send('two', handle);

test/parallel/test-crypto-verify-failure.js

@@ -36,9 +36,9 @@ function verify() {
     .verify(certPem, 'asdfasdfas', 'base64');
 }
 
-server.listen(common.PORT, function() {
+server.listen(0, function() {
   tls.connect({
-    port: common.PORT,
+    port: this.address().port,
     rejectUnauthorized: false
   }, function() {
     verify();

test/parallel/test-dgram-address.js

@@ -10,7 +10,9 @@ var family_ipv4 = 'IPv4';
 socket_ipv4.on('listening', function() {
   var address_ipv4 = socket_ipv4.address();
   assert.strictEqual(address_ipv4.address, common.localhostIPv4);
-  assert.strictEqual(address_ipv4.port, common.PORT);
+  assert.strictEqual(typeof address_ipv4.port, 'number');
+  assert.ok(isFinite(address_ipv4.port));
+  assert.ok(address_ipv4.port > 0);
   assert.strictEqual(address_ipv4.family, family_ipv4);
   socket_ipv4.close();
 });
@@ -20,7 +22,7 @@ socket_ipv4.on('error', function(e) {
   socket_ipv4.close();
 });
 
-socket_ipv4.bind(common.PORT, common.localhostIPv4);
+socket_ipv4.bind(0, common.localhostIPv4);
 
 // IPv6 Test
 var localhost_ipv6 = '::1';
@@ -30,7 +32,9 @@ var family_ipv6 = 'IPv6';
 socket_ipv6.on('listening', function() {
   var address_ipv6 = socket_ipv6.address();
   assert.strictEqual(address_ipv6.address, localhost_ipv6);
-  assert.strictEqual(address_ipv6.port, common.PORT);
+  assert.strictEqual(typeof address_ipv6.port, 'number');
+  assert.ok(isFinite(address_ipv6.port));
+  assert.ok(address_ipv6.port > 0);
   assert.strictEqual(address_ipv6.family, family_ipv6);
   socket_ipv6.close();
 });
@@ -40,4 +44,4 @@ socket_ipv6.on('error', function(e) {
   socket_ipv6.close();
 });
 
-socket_ipv6.bind(common.PORT, localhost_ipv6);
+socket_ipv6.bind(0, localhost_ipv6);

test/parallel/test-dgram-bind-default-address.js

@@ -9,8 +9,10 @@ if (common.inFreeBSDJail) {
   return;
 }
 
-dgram.createSocket('udp4').bind(common.PORT + 0, common.mustCall(function() {
-  assert.equal(this.address().port, common.PORT + 0);
+dgram.createSocket('udp4').bind(0, common.mustCall(function() {
+  assert.strictEqual(typeof this.address().port, 'number');
+  assert.ok(isFinite(this.address().port));
+  assert.ok(this.address().port > 0);
   assert.equal(this.address().address, '0.0.0.0');
   this.close();
 }));
@@ -20,8 +22,10 @@ if (!common.hasIPv6) {
   return;
 }
 
-dgram.createSocket('udp6').bind(common.PORT + 1, common.mustCall(function() {
-  assert.equal(this.address().port, common.PORT + 1);
+dgram.createSocket('udp6').bind(0, common.mustCall(function() {
+  assert.strictEqual(typeof this.address().port, 'number');
+  assert.ok(isFinite(this.address().port));
+  assert.ok(this.address().port > 0);
   var address = this.address().address;
   if (address === '::ffff:0.0.0.0')
     address = '::';

test/parallel/test-dgram-empty-packet.js

@@ -13,26 +13,27 @@ if (process.platform === 'darwin') {
 
 client = dgram.createSocket('udp4');
 
-client.bind(common.PORT);
-
-function callback() {
-  callbacks++;
-  if (callbacks == 2) {
-    clearTimeout(timer);
-    client.close();
-  } else if (callbacks > 2) {
-    throw new Error('the callbacks should be called only two times');
+client.bind(0, function() {
+  function callback() {
+    callbacks++;
+    if (callbacks == 2) {
+      clearTimeout(timer);
+      client.close();
+    } else if (callbacks > 2) {
+      throw new Error('the callbacks should be called only two times');
+    }
   }
-}
 
-client.on('message', function(buffer, bytes) {
-  callback();
-});
+  client.on('message', function(buffer, bytes) {
+    callback();
+  });
 
-client.send(new Buffer(1), 0, 0, common.PORT, '127.0.0.1', function(err, len) {
-  callback();
-});
+  const port = this.address().port;
+  client.send(new Buffer(1), 0, 0, port, '127.0.0.1', function(err, len) {
+    callback();
+  });
 
-timer = setTimeout(function() {
-  throw new Error('Timeout');
-}, 200);
+  timer = setTimeout(function() {
+    throw new Error('Timeout');
+  }, 200);
+});

test/parallel/test-dgram-error-message-address.js

@@ -9,14 +9,14 @@ var socket_ipv4 = dgram.createSocket('udp4');
 socket_ipv4.on('listening', common.fail);
 
 socket_ipv4.on('error', common.mustCall(function(e) {
-  assert.equal(e.message, 'bind EADDRNOTAVAIL 1.1.1.1:' + common.PORT);
+  assert.strictEqual(e.port, undefined);
+  assert.equal(e.message, 'bind EADDRNOTAVAIL 1.1.1.1');
   assert.equal(e.address, '1.1.1.1');
-  assert.equal(e.port, common.PORT);
   assert.equal(e.code, 'EADDRNOTAVAIL');
   socket_ipv4.close();
 }));
 
-socket_ipv4.bind(common.PORT, '1.1.1.1');
+socket_ipv4.bind(0, '1.1.1.1');
 
 // IPv6 Test
 var socket_ipv6 = dgram.createSocket('udp6');
@@ -27,10 +27,10 @@ socket_ipv6.on('error', common.mustCall(function(e) {
   // EAFNOSUPPORT or EPROTONOSUPPORT means IPv6 is disabled on this system.
   var allowed = ['EADDRNOTAVAIL', 'EAFNOSUPPORT', 'EPROTONOSUPPORT'];
   assert.notEqual(allowed.indexOf(e.code), -1);
-  assert.equal(e.message, 'bind ' + e.code + ' 111::1:' + common.PORT);
+  assert.strictEqual(e.port, undefined);
+  assert.equal(e.message, 'bind ' + e.code + ' 111::1');
   assert.equal(e.address, '111::1');
-  assert.equal(e.port, common.PORT);
   socket_ipv6.close();
 }));
 
-socket_ipv6.bind(common.PORT, '111::1');
+socket_ipv6.bind(0, '111::1');

test/parallel/test-dgram-implicit-bind.js

@@ -1,5 +1,5 @@
 'use strict';
-var common = require('../common');
+require('../common');
 var assert = require('assert');
 var dgram = require('dgram');
 
@@ -22,8 +22,9 @@ target.on('message', function(buf) {
 
 target.on('listening', function() {
   // Second .send() call should not throw a bind error.
-  source.send(Buffer('abc'), 0, 3, common.PORT, '127.0.0.1');
-  source.send(Buffer('def'), 0, 3, common.PORT, '127.0.0.1');
+  const port = this.address().port;
+  source.send(Buffer('abc'), 0, 3, port, '127.0.0.1');
+  source.send(Buffer('def'), 0, 3, port, '127.0.0.1');
 });
 
-target.bind(common.PORT);
+target.bind(0);

test/parallel/test-dgram-multicast-setTTL.js

@@ -1,11 +1,11 @@
 'use strict';
-const common = require('../common');
+require('../common');
 const assert = require('assert');
 const dgram = require('dgram');
 const socket = dgram.createSocket('udp4');
 let thrown = false;
 
-socket.bind(common.PORT);
+socket.bind(0);
 socket.on('listening', function() {
   socket.setMulticastTTL(16);
 

test/parallel/test-dgram-send-callback-recursive.js

@@ -9,17 +9,19 @@ let received = 0;
 let sent = 0;
 const limit = 10;
 let async = false;
+let port;
 
 function onsend() {
   if (sent++ < limit) {
-    client.send(
-      chunk, 0, chunk.length, common.PORT, common.localhostIPv4, onsend);
+    client.send(chunk, 0, chunk.length, port, common.localhostIPv4, onsend);
   } else {
     assert.strictEqual(async, true, 'Send should be asynchronous.');
   }
 }
 
 client.on('listening', function() {
+  port = this.address().port;
+
   setImmediate(function() {
     async = true;
   });
@@ -38,4 +40,4 @@ client.on('close', common.mustCall(function() {
   assert.equal(received, limit);
 }));
 
-client.bind(common.PORT);
+client.bind(0);