Function sampleMcpPeerProcesses

src/server/mcp-lifecycle.ts:204–261

(
  commandExecutor: CommandExecutor,
  currentPid: number,
)

}

async function sampleMcpPeerProcesses(
  commandExecutor: CommandExecutor,
  currentPid: number,
): Promise<PeerProcessSample> {
  try {
    const result = await commandExecutor(
      ['ps', '-axo', 'pid=,etime=,rss=,command='],
      'Sample MCP lifecycle peer processes',
      false,
    );
    if (!result.success) {
      return { count: null, peers: [] };
    }

    const matched = result.output
      .split('\n')
      .map((line) => line.trim())
      .filter(Boolean)
      .map((line) => {
        const match = line.match(/^(\d+)\s+(\S+)\s+(\d+)\s+(.+)$/);
        if (!match) {
          return null;
        }
        const [, pidRaw, elapsedRaw, rssRaw, command] = match;
        const ageSeconds = parseElapsedSeconds(elapsedRaw);
        return {
          pid: Number(pidRaw),
          ageSeconds,
          rssKb: Number(rssRaw),
          command,
        };
      })
      .filter(
        (entry): entry is { pid: number; ageSeconds: number; rssKb: number; command: string } => {
          return (
            entry !== null &&
            Number.isFinite(entry.pid) &&
            Number.isFinite(entry.ageSeconds) &&
            Number.isFinite(entry.rssKb) &&
            isLikelyMcpProcessCommand(entry.command)
          );
        },
      );

    const peers = matched
      .filter((entry) => entry.pid !== currentPid)
      .map(({ pid, ageSeconds, rssKb }) => ({ pid, ageSeconds, rssKb }))
      .sort((left, right) => right.ageSeconds - left.ageSeconds || right.rssKb - left.rssKb)
      .slice(0, 5);

    return {
      count: matched.length,
      peers,
    };
  } catch {
    return { count: null, peers: [] };
  }
}