diff options
Diffstat (limited to 'ext/node/polyfills/child_process.ts')
-rw-r--r-- | ext/node/polyfills/child_process.ts | 25 |
1 files changed, 23 insertions, 2 deletions
diff --git a/ext/node/polyfills/child_process.ts b/ext/node/polyfills/child_process.ts index 2aba88d63..bb38b746c 100644 --- a/ext/node/polyfills/child_process.ts +++ b/ext/node/polyfills/child_process.ts @@ -115,7 +115,8 @@ export function fork( // more const v8Flags: string[] = []; if (Array.isArray(execArgv)) { - for (let index = 0; index < execArgv.length; index++) { + let index = 0; + while (index < execArgv.length) { const flag = execArgv[index]; if (flag.startsWith("--max-old-space-size")) { execArgv.splice(index, 1); @@ -123,6 +124,16 @@ export function fork( } else if (flag.startsWith("--enable-source-maps")) { // https://github.com/denoland/deno/issues/21750 execArgv.splice(index, 1); + } else if (flag.startsWith("-C") || flag.startsWith("--conditions")) { + let rm = 1; + if (flag.indexOf("=") === -1) { + // --conditions foo + // so remove the next argument as well. + rm = 2; + } + execArgv.splice(index, rm); + } else { + index++; } } } @@ -825,7 +836,17 @@ export function execFileSync( function setupChildProcessIpcChannel() { const fd = op_node_child_ipc_pipe(); if (typeof fd != "number" || fd < 0) return; - setupChannel(process, fd); + const control = setupChannel(process, fd); + process.on("newListener", (name: string) => { + if (name === "message" || name === "disconnect") { + control.refCounted(); + } + }); + process.on("removeListener", (name: string) => { + if (name === "message" || name === "disconnect") { + control.unrefCounted(); + } + }); } internals.__setupChildProcessIpcChannel = setupChildProcessIpcChannel; |