Struct History

pub struct History { /* private fields */ }

The history of invocations sent by the client to be executed on the workers. This is used to track dependencies between invocations and to propagate exceptions. It purges history for completed invocations to avoid memory bloat. TODO: Revisit this setup around purging refs automatically once we start doing more complex data dependency tracking. We will want to be more aware of things like borrows, drops etc. directly.

Implementations

impl History

pub fn new(world_size: usize) -> Self

pub fn first_incomplete_seqs_controller(&self) -> &[Seq]

pub fn min_incomplete_seq_reported(&self) -> Seq

pub fn world_size(&self) -> usize

pub fn delete_invocations_for_refs(&mut self, refs: Vec<Ref>)

pub fn add_invocation( &mut self, seq: Seq, uses: Vec<Ref>, defs: Vec<Ref>, ) -> Vec<(Seq, Option<Result<Serialized, Exception>>)>

Add an invocation to the history.

pub fn propagate_exception(&mut self, seq: Seq, exception: Exception)

Propagate worker error to the invocation with the given Seq. This will also propagate to all seqs that depend on this seq directly or indirectly.

pub fn report_deadline_missed(&mut self)

pub fn deadline( &mut self, expected_progress: u64, timeout: Duration, clock: &impl Clock, ) -> Option<(Seq, Instant, bool)>

pub fn update_deadline_tracking(&mut self, rank: usize, seq: Seq)

pub fn rank_completed( &mut self, rank: usize, seq: Seq, ) -> Vec<(Seq, Option<Result<Serialized, Exception>>)>

Mark the given rank as completed up to but excluding the given Seq. This will also purge history for any Seqs that are no longer relevant (completed on all ranks).

pub fn set_result(&mut self, seq: Seq, result: Result<Serialized, WorkerError>)

Trait Implementations

impl Debug for History

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.