Function startStalk

scripts/thread-stalker.js:266–300

(thread, scopeModule)

}

function startStalk(thread, scopeModule) {
  const tid = thread.id;
  if (stalked.has(tid)) return;
  if (stalkedCount >= CONFIG.maxThreads) {
    console.log(`${C.yellow}[stalk] skip ${tid} (maxThreads ${CONFIG.maxThreads} reached)${C.reset}`);
    return;
  }

  const state = {
    name: thread.name || `(tid ${tid})`,
    scope: scopeSetFor(scopeModule),
    count: 0, dropped: 0, startedAt: tms(),
  };
  stalked.set(tid, state);
  stalkedCount++;
  const scopeDesc = state.scope ? [...state.scope].join(",") : "ALL";
  console.log(`${C.green}[stalk+]${C.reset} ${PID}:${state.name}#${tid} ${C.dim}scope=${scopeDesc} @+${state.startedAt}ms${C.reset}`);

  // Exclude all non-target modules now — the target lib is guaranteed loaded
  // here (this thread's entry lives in it), unlike at script load time.
  excludeAllButTargetsOnce();

  try {
    Stalker.follow(tid, {
      events: eventsConfig(),
      onReceive(events) {
        drainEvents(tid, state, events);
      },
    });
  } catch (e) {
    console.log(`${C.red}[stalk] follow ${tid} failed: ${e}${C.reset}`);
    stalked.delete(tid);
    stalkedCount--;
  }
}

function drainEvents(tid, state, events) {
  let parsed;