Function drainEvents

scripts/thread-stalker.js:302–324

(tid, state, events)

}

function drainEvents(tid, state, events) {
  let parsed;
  try {
    parsed = Stalker.parse(events, { annotate: true, stringify: false });
  } catch (e) { return; }

  const lines = [];
  for (const ev of parsed) {
    if (state.count >= CONFIG.maxEventsPerThread) {
      stopStalk(tid, `event cap ${CONFIG.maxEventsPerThread} reached`);
      break;
    }
    const line = formatEvent(state, ev);
    if (line == null) continue; // filtered out by scope
    state.count++;
    if (lines.length < CONFIG.flushBatch) lines.push(line);
    else state.dropped++;
  }
  if (lines.length) {
    const tag = `${C.dim}#${tid}${C.reset}`;
    console.log(lines.map((l) => `${tag} ${l}`).join("\n"));
  }
}

function sym(addr) {
  if (!CONFIG.symbolicate) return addr.toString();