MCPcopy Index your code
hub / github.com/colbymchenry/codegraph / onWorkerGone

Method onWorkerGone

src/extraction/parse-pool.ts:237–247  ·  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

235 /** A worker died (crash hook / OOM exit / spawn error). Reject its in-flight
236 * parse so the caller's retry pass can re-attempt it, then respawn. */
237 private onWorkerGone(w: ParsePoolWorker, message: string): void {
238 if (!this.workers.has(w)) return; // already handled (error+exit both fire), or recycled
239 this.removeWorker(w);
240 this.totalCrashes++;
241 const job = this.inflight.get(w);
242 this.inflight.delete(w);
243 try { void w.terminate(); } catch { /* already gone */ }
244 if (job) this.settle(job, undefined, new Error(message));
245 if (this.healthy) this.spawnOne(); // keep capacity
246 this.drain();
247 }
248
249 /** Tear down a worker that has hit its recycle threshold and replace it. Not a
250 * 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