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

Method requestParse

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

* Parse one file on the pool. Resolves with the extraction result, or REJECTS * if the parse times out or its worker crashes — the caller records the error * and (for worker-exit/OOM/timeout rejections) re-attempts in its retry pass.

(task: ParseTask)

Source from the content-addressed store, hash-verified

259 * and (for worker-exit/OOM/timeout rejections) re-attempts in its retry pass.
260 */
261 requestParse(task: ParseTask): Promise<ExtractionResult> {
262 if (this.destroyed) return Promise.reject(new Error('Parse pool destroyed'));
263 return new Promise<ExtractionResult>((resolve, reject) => {
264 this.queue.push({ id: this.nextId++, task, resolve, reject, settled: false });
265 this.drain();
266 });
267 }
268
269 private spawnOne(): void {
270 if (this.destroyed || this.workers.size >= this.maxSize || !this.healthy) return;

Callers 2

parseFileMethod · 0.80
parse-pool.test.tsFile · 0.80

Calls 1

drainMethod · 0.95

Tested by

no test coverage detected