Struct ReadPlan 

pub struct ReadPlan {
    items: Vec<PlannedRead>,
    low_file: Option<File>,
}

Reads required between pool acquisition and residency completion. Built by the service thread, then moved or borrowed by reader threads.

Fields

items: Vec<PlannedRead>

low_file: Option<File>

Implementations

impl ReadPlan

pub(super) fn read_requests(&self) -> impl Iterator<Item = (usize, usize)> + '_

pub fn is_empty(&self) -> bool

pub fn len(&self) -> usize

pub fn run_tracked( &self, cached: &File, nocache: &File, need_len: usize, ) -> Vec<Landed>

Run the reads: copies go to their slots past the cache (nocache), cache reads pull pages in through cached. Run every read on its own detached thread; returns one flag per entry of the need list the plan was built for (need_len), set once that record is in memory (records that needed no read start set). The caller keeps the flags of reads it stops waiting for and checks them before the slot can be reused.

pub fn run(&self, cached: &File, nocache: &File)

fn file<'a>( &'a self, read: &PlannedRead, cached: &'a File, nocache: &'a File, ) -> &'a File

pub(super) fn observe( &mut self, tracker: &ReadTracker, layer: usize, source: ReadSource, )

pub(super) fn tickets(&self, need: &[usize]) -> Vec<(usize, ReadTicket)>