Skip to main content

Module pipeline

Module pipeline 

Source
Expand description

Read-ahead pipeline (ADR-0011): record-aligned chunk planning over the $MFT run map, plus the dedicated I/O thread that reads chunk N+1 while chunk N parses. If the thread can’t start, the scan degrades to inline sequential reads (scan_pipeline_fallbacks).

Structs§

Chunk 🔒
Record-aligned read unit of the $MFT data stream.

Constants§

PIPELINE_BUFFERS 🔒
Chunk buffers cycling between the I/O thread and the parser (one being read, one queued, one being parsed) — bounds peak RAM at 3 chunks.
SCAN_CHUNK 🔒

Functions§

plan_chunks 🔒
Pure chunk-plan arithmetic: record-aligned chunking, sparse-hole skipping, no I/O.
run_chunk_pipeline 🔒
Read chunks on a dedicated I/O thread while the caller parses the previous one; buffers cycle through a bounded channel pair. Returns the accumulated device-read time and the fallback count (1 when the thread couldn’t start and the scan degraded to inline sequential reads).