diff --git a/lib/internal/bootstrap/node.js b/lib/internal/bootstrap/node.js index dcb0be8f7eb6ba..0f207ab6602fdc 100644 --- a/lib/internal/bootstrap/node.js +++ b/lib/internal/bootstrap/node.js @@ -155,7 +155,12 @@ function startup() { return; } - if (isMainThread) { + // If the process is spawned with env NODE_CHANNEL_FD, it's probably + // spawned by our child_process module, then initialize IPC. + // This attaches some internal event listeners and creates: + // process.send(), process.channel, process.connected, + // process.disconnect() + if (isMainThread && process.env.NODE_CHANNEL_FD) { mainThreadSetup.setupChildProcessIpcChannel(); } diff --git a/lib/internal/process/main_thread_only.js b/lib/internal/process/main_thread_only.js index 1db693f1ec716d..862194ae46e27e 100644 --- a/lib/internal/process/main_thread_only.js +++ b/lib/internal/process/main_thread_only.js @@ -21,8 +21,6 @@ const { getMainThreadStdio } = require('internal/process/stdio'); -const assert = require('assert').strict; - function setupStdio() { setupProcessStdio(getMainThreadStdio()); } @@ -163,18 +161,16 @@ function setupSignalHandlers(internalBinding) { } function setupChildProcessIpcChannel() { - // If we were spawned with env NODE_CHANNEL_FD then load that up and - // start parsing data from that stream. - if (process.env.NODE_CHANNEL_FD) { - const fd = parseInt(process.env.NODE_CHANNEL_FD, 10); - assert(fd >= 0); + const assert = require('assert').strict; - // Make sure it's not accidentally inherited by child processes. - delete process.env.NODE_CHANNEL_FD; + const fd = parseInt(process.env.NODE_CHANNEL_FD, 10); + assert(fd >= 0); - require('child_process')._forkChild(fd); - assert(process.send); - } + // Make sure it's not accidentally inherited by child processes. + delete process.env.NODE_CHANNEL_FD; + + require('child_process')._forkChild(fd); + assert(process.send); } module.exports = {