test: fix flaky test-child-process-pass-fd

test-child-process-pass-fd needs to launch many processes simultaneously. On Fedora 24, this can result in EAGAIN "Resource temporarily unavailable" errors. When this occurs, simply try to launch a worker again. PR-URL: #17598 Fixes: #17589 Reviewed-By: Santiago Gimeno <santiago.gimeno@gmail.com> Reviewed-By: Gibson Fahnestock <gibfahn@gmail.com> Reviewed-By: Ruben Bridgewater <ruben@bridgewater.de> Reviewed-By: James M Snell <jasnell@gmail.com> Reviewed-By: Gireesh Punathil <gpunathi@in.ibm.com>
nodejs · MylesBorins · Feb 13, 2018 · Nov 22, 2017 · Nov 18, 2017 · Nov 18, 2017
commit fb0bd8a5843f4700a03a566a90ddee3e4254f807
diff --git a/test/sequential/test-child-process-pass-fd.js b/test/sequential/test-child-process-pass-fd.js
@@ -18,26 +18,42 @@ const { fork } = require('child_process');
 const net = require('net');
 
 const N = 80;
+let messageCallbackCount = 0;
 
-if (process.argv[2] !== 'child') {
-  for (let i = 0; i < N; ++i) {
-    const worker = fork(__filename, ['child']);
-    worker.once('message', common.mustCall((msg, handle) => {
-      assert.strictEqual(msg, 'handle');
-      assert.ok(handle);
-      worker.send('got');
-
-      let recvData = '';
-      handle.on('data', common.mustCall((data) => {
-        recvData += data;
-      }));
+function forkWorker() {
+  const messageCallback = (msg, handle) => {
+    messageCallbackCount++;
+    assert.strictEqual(msg, 'handle');
+    assert.ok(handle);
+    worker.send('got');
 
-      handle.on('end', () => {
-        assert.strictEqual(recvData, 'hello');
-        worker.kill();
-      });
+    let recvData = '';
+    handle.on('data', common.mustCall((data) => {
+      recvData += data;
     }));
+
+    handle.on('end', () => {
+      assert.strictEqual(recvData, 'hello');
+      worker.kill();
+    });
+  };
+
+  const worker = fork(__filename, ['child']);
+  worker.on('error', (err) => {
+    if (/\bEAGAIN\b/.test(err.message)) {
+      forkWorker();
+      return;
+    }
+    throw err;
+  });
+  worker.once('message', messageCallback);
+}
+
+if (process.argv[2] !== 'child') {
+  for (let i = 0; i < N; ++i) {
+    forkWorker();
   }
+  process.on('exit', () => { assert.strictEqual(messageCallbackCount, N); });
 } else {
   let socket;
   let cbcalls = 0;