MCPcopy Create free account
hub / github.com/colbymchenry/codegraph / onWorkerGone

Method onWorkerGone

src/extraction/parse-pool.ts:313–323  ·  view source on GitHub ↗

A worker died (crash hook / OOM exit / spawn error). Reject its in-flight * parse so the caller's retry pass can re-attempt it, then respawn.

(w: ParsePoolWorker, message: string)

Source from the content-addressed store, hash-verified

311 /** A worker died (crash hook / OOM exit / spawn error). Reject its in-flight
312 * parse so the caller's retry pass can re-attempt it, then respawn. */
313 private onWorkerGone(w: ParsePoolWorker, message: string): void {
314 if (!this.workers.has(w)) return; // already handled (error+exit both fire), or recycled
315 this.removeWorker(w);
316 this.totalCrashes++;
317 const job = this.inflight.get(w);
318 this.inflight.delete(w);
319 try { void w.terminate(); } catch { /* already gone */ }
320 if (job) this.settle(job, undefined, new Error(message));
321 if (this.healthy) this.spawnOne(); // keep capacity
322 this.drain();
323 }
324
325 /** Tear down a worker that has hit its recycle threshold and replace it. Not a
326 * crash, so it doesn't count against the budget. */

Callers 1

spawnOneMethod · 0.95

Calls 7

removeWorkerMethod · 0.95
settleMethod · 0.95
spawnOneMethod · 0.95
drainMethod · 0.95
hasMethod · 0.80
getMethod · 0.65
terminateMethod · 0.65

Tested by

no test coverage detected