Function killProcessGroup

packages/core/src/utils/process-utils.ts:38–148

(options: KillOptions)

 * to ensure all descendants are killed.
 */
export async function killProcessGroup(options: KillOptions): Promise<void> {
  const { pid, escalate = false, isExited = () => false, pty } = options;
  const isWindows = os.platform() === 'win32';

  if (isWindows) {
    if (pty) {
      try {
        pty.kill();
      } catch {
        // Ignore errors for dead processes
      }
    }
    // Invoke taskkill to ensure the entire tree is terminated and any orphaned descendant processes are reaped.
    try {
      await spawnAsync('taskkill', ['/pid', pid.toString(), '/f', '/t']);
    } catch {
      // Ignore errors if the process tree is already dead
    }
    return;
  }

  // Unix logic: Walk process tree to find all descendants
  const getAllDescendants = async (parentPid: number): Promise<number[]> => {
    let children: number[] = [];
    try {
      const { stdout } = await spawnAsync('pgrep', [
        '-P',
        parentPid.toString(),
      ]);
      const pids = stdout
        .trim()
        .split('\n')
        .map((p: string) => parseInt(p, 10))
        .filter((p: number) => !isNaN(p));
      for (const p of pids) {
        children.push(p);
        const grandchildren = await getAllDescendants(p);
        children = children.concat(grandchildren);
      }
    } catch {
      // pgrep exits with 1 if no children are found
    }
    return children;
  };

  const descendants = await getAllDescendants(pid);
  const allPidsToKill = [...descendants.reverse(), pid];

  try {
    const initialSignal = options.signal || (escalate ? 'SIGTERM' : 'SIGKILL');

    // Try killing the process group first (-pid)
    try {
      process.kill(-pid, initialSignal);
    } catch {
      // Ignore
    }