pub(super) fn run_chunk_pipeline(
volume_path: &str,
chunks: &[Chunk],
on_chunk: &mut dyn FnMut(usize, &mut [u8]),
) -> Result<(Duration, u64), NtfsReaderError>Expand description
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).