Struct PersistenceOrchestrator

pub struct PersistenceOrchestrator {
    state: OrchestratorState,
    disk_writer: DiskWriterState,
    start_sector: u64,
    expected_size: u64,
    verify_checksum: bool,
    expected_checksum: Option<[u8; 32]>,
    bytes_downloaded: u64,
    start_tsc: u64,
    download_start_tsc: u64,
    result: PersistenceResult,
    error: Option<OrchestratorError>,
    cancelled: bool,
}

Persistence orchestrator.

Coordinates HTTP download with disk writing for ISO persistence. This is a simplified version that manages disk writing state.

Fields

state: OrchestratorState

Current state.

disk_writer: DiskWriterState

Disk writer state machine.

start_sector: u64

Configuration.

expected_size: u64

verify_checksum: bool

expected_checksum: Option<[u8; 32]>

bytes_downloaded: u64

Tracking.

start_tsc: u64

Timing.

download_start_tsc: u64

result: PersistenceResult

Result.

error: Option<OrchestratorError>

Error.

cancelled: bool

Whether cancelled.

Implementations

impl PersistenceOrchestrator

pub fn new(config: PersistenceConfig<'_>) -> Self

Create new orchestrator with configuration.

pub fn phase(&self) -> PersistencePhase

Get current phase.

pub fn progress(&self) -> PersistenceProgress

Get combined progress.

pub fn result(&self) -> Option<PersistenceResult>

Get result (if complete).

pub fn error(&self) -> Option<OrchestratorError>

Get error (if failed).

pub fn is_complete(&self) -> bool

Check if complete.

pub fn is_failed(&self) -> bool

Check if failed.

pub fn cancel(&mut self)

Cancel the operation.

pub fn start<B: BlockDriver>( &mut self, block_driver: &B, now_tsc: u64, ) -> Result<(), OrchestratorError>

Start the orchestrator.

Must be called before step().

pub fn dhcp_complete(&mut self, now_tsc: u64)

Signal that DHCP is complete.

pub fn connected(&mut self)

Signal that HTTP connection is established.

pub fn set_total_bytes(&mut self, total: u64)

Set total expected size (from HTTP Content-Length).

pub fn step<B: BlockDriver>( &mut self, block_driver: &mut B, now_tsc: u64, ) -> OrchestratorResult

Step the orchestrator (poll completions).

fn finalize(&mut self, now_tsc: u64)

Finalize results.

pub fn write_data<B: BlockDriver>( &mut self, block_driver: &mut B, buffer_phys: u64, len: usize, ) -> Result<(), DiskWriterError>

Write a chunk of data to disk.

Called when HTTP data is received.

pub fn http_complete(&mut self)

Signal that HTTP download is complete.

pub fn http_failed(&mut self)

Signal HTTP failure.

pub fn can_write(&self) -> bool

Check if writer can accept more data (backpressure).

pub fn disk_writer(&self) -> &DiskWriterState

Get disk writer state.

pub fn disk_writer_mut(&mut self) -> &mut DiskWriterState

Get mutable disk writer.