test: make common.PIPE process unique

* includes a tiny bit of refactoring in adjacent lines.
* fixes 1 test and 1 benchmark that depended on PIPE being constant.

PR-URL: #14168
Fixes: #14128
Reviewed-By: James M Snell <[email protected]>

Author: refack

benchmark/http/_chunky_http_client.js

@@ -3,7 +3,6 @@
 // test HTTP throughput in fragmented header case
 var common = require('../common.js');
 var net = require('net');
-var test = require('../../test/common');
 
 var bench = common.createBenchmark(main, {
   len:  [1, 4, 8, 16, 32, 64, 128],
@@ -56,7 +55,7 @@ function main(conf) {
   var mult = 17;
   var add = 11;
   var count = 0;
-  var PIPE = test.PIPE;
+  var PIPE = process.env.PIPE_NAME;
   var socket = net.connect(PIPE, function() {
     bench.start();
     WriteHTTPHeaders(socket, 1, len);

benchmark/http/http_server_for_chunky_client.js

@@ -1,24 +1,22 @@
 'use strict';
 
 var assert = require('assert');
-var path = require('path');
 var http = require('http');
 var fs = require('fs');
-var fork = require('child_process').fork;
+var { fork } = require('child_process');
 var common = require('../common.js');
-var test = require('../../test/common');
-var pep = `${path.dirname(process.argv[1])}/_chunky_http_client.js`;
-var PIPE = test.PIPE;
+const { PIPE, tmpDir } = require('../../test/common');
+process.env.PIPE_NAME = PIPE;
 
 try {
-  fs.accessSync(test.tmpDir, fs.F_OK);
+  fs.accessSync(tmpDir, fs.F_OK);
 } catch (e) {
-  fs.mkdirSync(test.tmpDir);
+  fs.mkdirSync(tmpDir);
 }
 
 var server;
 try {
-  fs.unlinkSync(PIPE);
+  fs.unlinkSync(process.env.PIPE_NAME);
 } catch (e) { /* ignore */ }
 
 server = http.createServer(function(req, res) {
@@ -33,10 +31,12 @@ server = http.createServer(function(req, res) {
 server.on('error', function(err) {
   throw new Error(`server error: ${err}`);
 });
-
 server.listen(PIPE);
 
-var child = fork(pep, process.argv.slice(2));
+const child = fork(
+  `${__dirname}/_chunky_http_client.js`,
+  process.argv.slice(2)
+);
 child.on('message', common.sendResult);
 child.on('close', function(code) {
   server.close();

test/common/index.js

@@ -246,7 +246,7 @@ Object.defineProperty(exports, 'opensslCli', {get: function() {
 
 Object.defineProperty(exports, 'hasCrypto', {
   get: function() {
-    return process.versions.openssl ? true : false;
+    return Boolean(process.versions.openssl);
   }
 });
 
@@ -256,22 +256,21 @@ Object.defineProperty(exports, 'hasFipsCrypto', {
   }
 });
 
-if (exports.isWindows) {
-  exports.PIPE = '\\\\.\\pipe\\libuv-test';
-  if (process.env.TEST_THREAD_ID) {
-    exports.PIPE += `.${process.env.TEST_THREAD_ID}`;
-  }
-} else {
-  exports.PIPE = `${exports.tmpDir}/test.sock`;
+{
+  const pipePrefix = exports.isWindows ? '\\\\.\\pipe\\' : `${exports.tmpDir}/`;
+  const pipeName = `node-test.${process.pid}.sock`;
+  exports.PIPE = pipePrefix + pipeName;
 }
 
-const ifaces = os.networkInterfaces();
-const re = /lo/;
-exports.hasIPv6 = Object.keys(ifaces).some(function(name) {
-  return re.test(name) && ifaces[name].some(function(info) {
-    return info.family === 'IPv6';
+{
+  const iFaces = os.networkInterfaces();
+  const re = /lo/;
+  exports.hasIPv6 = Object.keys(iFaces).some(function(name) {
+    return re.test(name) && iFaces[name].some(function(info) {
+      return info.family === 'IPv6';
+    });
   });
-});
+}
 
 /*
  * Check that when running a test with

test/fixtures/listen-on-socket-and-exit.js

@@ -20,19 +20,22 @@
 // USE OR OTHER DEALINGS IN THE SOFTWARE.
 
 'use strict';
+const common = require('../common');
+
 // Test that errors propagated from cluster workers are properly
 // received in their master. Creates an EADDRINUSE condition by forking
 // a process in child cluster and propagates the error to the master.
 
-const common = require('../common');
 const assert = require('assert');
 const cluster = require('cluster');
 const fork = require('child_process').fork;
-const fs = require('fs');
 const net = require('net');
 
-if (cluster.isMaster) {
-  const worker = cluster.fork();
+if (cluster.isMaster && process.argv.length !== 3) {
+  // cluster.isMaster
+  common.refreshTmpDir();
+  const PIPE_NAME = common.PIPE;
+  const worker = cluster.fork({PIPE_NAME});
 
   // makes sure master is able to fork the worker
   cluster.on('fork', common.mustCall());
@@ -43,40 +46,37 @@ if (cluster.isMaster) {
   worker.on('message', common.mustCall(function(err) {
     // disconnect first, so that we will not leave zombies
     worker.disconnect();
-
-    console.log(err);
     assert.strictEqual('EADDRINUSE', err.code);
   }));
-
-  process.on('exit', function() {
-    console.log('master exited');
-    try {
-      fs.unlinkSync(common.PIPE);
-    } catch (e) {
-    }
-  });
-
-} else {
-  common.refreshTmpDir();
-  const cp = fork(`${common.fixturesDir}/listen-on-socket-and-exit.js`,
-                { stdio: 'inherit' });
+} else if (process.argv.length !== 3) {
+  // cluster.worker
+  const PIPE_NAME = process.env.PIPE_NAME;
+  const cp = fork(__filename, [PIPE_NAME], { stdio: 'inherit' });
 
   // message from the child indicates it's ready and listening
   cp.on('message', common.mustCall(function() {
-    const server = net.createServer().listen(common.PIPE, function() {
+    const server = net.createServer().listen(PIPE_NAME, function() {
       // message child process so that it can exit
       cp.send('end');
       // inform master about the unexpected situation
       process.send('PIPE should have been in use.');
     });
 
     server.on('error', function(err) {
-      console.log('parent error, ending');
       // message to child process tells it to exit
       cp.send('end');
       // propagate error to parent
       process.send(err);
     });
+  }));
+} else if (process.argv.length === 3) {
+  // child process (of cluster.worker)
+  const PIPE_NAME = process.argv[2];
 
+  const server = net.createServer().listen(PIPE_NAME, common.mustCall(() => {
+    process.send('listening');
   }));
+  process.once('message', common.mustCall(() => server.close()));
+} else {
+  assert.fail('Impossible state');
 }