Function processWorkspaces

src/core/parser.ts:350–467

(
  entries: { logsDir: string; dirEntries: fs.Dirent[] }[],
  totalDirs: number,
  ctx: ParseContext,
  onProgress?: ProgressCallback,
  isColdParse = true,
)

}

async function processWorkspaces(
  entries: { logsDir: string; dirEntries: fs.Dirent[] }[],
  totalDirs: number,
  ctx: ParseContext,
  onProgress?: ProgressCallback,
  isColdParse = true,
): Promise<void> {
  const effectiveMaxPrefetch = isColdParse
    ? Math.min(COLD_PARSE_MAX_PREFETCH_FILES, MAX_PREFETCH_FILES)
    : MAX_PREFETCH_FILES;
  const effectiveMaxPrefetchBytes = isColdParse ? COLD_PARSE_MAX_PREFETCH_BYTES : MAX_PREFETCH_BYTES;
  const tWorkList = Date.now();
  const work = await buildWorkspaceWorkList(entries);
  const workListMs = Date.now() - tWorkList;
  const planItems = buildWorkspacePlan(work);

  // Phase-2 gap attribution (issue #106 follow-up). The cold-parse-breakdown showed the actual
  // file parsing is a small fraction of phase 2; these accumulators reveal where the rest of the
  // wall-clock goes (workspace listing vs prefetch I/O wait vs per-workspace processing).
  let prefetchWaitMs = 0;
  let entryWallMs = 0;

  // Build the workspace-level loading plan in processing order.
  if (onProgress && planItems.length > 0) {
    onProgress({
      phase: 2,
      detail: `Scanning ${totalDirs} workspace folders for sessions`,
      pct: pct(2, 0),
      sessions: ctx.sessions.length,
      workspacePlan: planItems,
    });
    await yieldToLoop();
  }

  let processed = 0;
  let lastLocIndex = 0;
  let strippedUpTo = 0;
  const running = createRunningTotals();

  function foldNewSessions(): void {
    for (; lastLocIndex < ctx.sessions.length; lastLocIndex++) running.add(ctx.sessions[lastLocIndex]);
  }

  try {
    for (let i = 0; i < work.length; i += BATCH_SIZE) {
      const batch = work.slice(i, i + BATCH_SIZE);
      const nextBatch = work.slice(i + BATCH_SIZE, i + BATCH_SIZE * 2);

      if (i === 0) {
        const tPre = Date.now();
        await prefetchBatch(batch, effectiveMaxPrefetch, effectiveMaxPrefetchBytes);
        prefetchWaitMs += Date.now() - tPre;
      }

      const nextPrefetch = nextBatch.length > 0 ? prefetchBatch(nextBatch, effectiveMaxPrefetch, effectiveMaxPrefetchBytes) : Promise.resolve();

      let lastWsName = '';
      for (const { logsDir, wsId, harness, workspaceKey } of batch) {