Struct PrefetchedSectorSource 

pub struct PrefetchedSectorSource { /* private fields */ }

Producer-thread-backed SectorSource decorator. Construct it with the real reader, the extent list to walk, and the batch size; the wrapper spawns the producer immediately and starts filling the channel.

Implementations

impl PrefetchedSectorSource

pub fn new<S>( reader: S, extents: Vec<Extent>, batch_sectors: u16, halt: Option<Halt>, ) -> Result<Self>

where S: SectorSource + Send + 'static,

Spawn the producer thread. reader must already be the fully composed read+decrypt stack (e.g. DecryptingSectorSource) — every byte the producer emits is what the consumer’s demux will feed to its codec parsers.

Unit-alignment precondition

Each extent’s sector_count should be a multiple of [SECTOR_ALIGNMENT] (3 sectors / one 6144-byte AACS aligned unit). Blu-ray m2ts extents satisfy this by spec. If an extent has a trailing 1-2 sectors that cannot fill a complete unit, the producer surfaces Error::ExtentNotUnitAligned through the channel rather than handing the decrypt step a sub-unit chunk it would silently leave encrypted.

pub fn new_with_events<S>( reader: S, extents: Vec<Extent>, batch_sectors: u16, halt: Option<Halt>, event_fn: Option<EventFn>, ) -> Result<Self>

where S: SectorSource + Send + 'static,

Same as [new] but with a callback fired from the producer thread after each successful batch — used by autorip’s mux path to surface BytesRead progress to the UI without the consumer thread having to poll.

pub fn into_channels(self) -> (Receiver<Batch>, Sender<Vec<u8>>, PrefetchShell)

Peel off the receivers for zero-copy pipeline mode. The caller (typically [super::super::mux::demux_thread::DemuxThread]) pulls buffers from rx, consumes them, and pushes the empty Vec<u8> back through recycle_tx so the producer can re-fill it. The producer-thread JoinHandle stays with the returned PrefetchedSectorSource shell; drop that to join.

Returns (forward_rx, recycle_tx, shell). The shell only holds the join handle and total_sectors for capacity_sectors queries; its SectorSource impl becomes invalid after this call (data has been moved out).

Trait Implementations

impl Drop for PrefetchedSectorSource

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl SectorSource for PrefetchedSectorSource

fn capacity_sectors(&self) -> u32

Total capacity in sectors, if known. Default 0 = unknown (e.g. live drives that haven’t completed READ CAPACITY yet).

fn read_sectors( &mut self, _lba: u32, _count: u16, buf: &mut [u8], _recovery: bool, ) -> Result<usize>

Read count sectors starting at lba into buf. buf must be at least count * 2048 bytes. recovery: true = full retry/reset loop (ripping), false = single attempt (verify). File-backed sources ignore the flag.

fn set_speed(&mut self, _kbs: u16)

Optional speed control for sources that map to a physical drive. No-op for everything else.