Struct BuildSharedWal 

pub struct BuildSharedWal { /* private fields */ }

Stream through frames in chunks, building frame_cache incrementally Track last valid commit frame for consistency Non-blocking driver for WAL recovery on open.

Created by BuildSharedWal::begin (which performs only synchronous setup and may complete immediately for an empty/headerless WAL), then driven via BuildSharedWal::poll until it returns Done. All recovery state lives in the [StreamingWalReader] (atomics + RwLock<StreamingState>) and is updated by the read completions’ callbacks, so the only state this driver tracks is which phase/completion it’s waiting on.

Implementations

impl BuildSharedWal

pub fn begin(file: &Arc<dyn File>) -> Result<Self>

Synchronous setup: read the file size, build the (initially unloaded) WalFileShared, and decide the starting phase. For a WAL smaller than the header it marks the shared state loaded and starts in Done.

pub fn poll(&mut self) -> Result<IOResult<Arc<RwLock<WalFileShared>>>>

Drive the recovery state machine. Yields the in-flight read completion when it must wait; returns Done(wal_file_shared) once the full WAL has been scanned (or recovery short-circuited).