summaryrefslogtreecommitdiff
path: root/ext/node/polyfills/child_process.ts
diff options
context:
space:
mode:
Diffstat (limited to 'ext/node/polyfills/child_process.ts')
-rw-r--r--ext/node/polyfills/child_process.ts25
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;