Struct VidReconstructor 

pub struct VidReconstructor<T: NodeType> {
    pending: BTreeMap<ViewNumber, BTreeMap<T::SignatureKey, VidDisperseShare2<T>>>,
    accumulators: BTreeMap<ViewNumber, VidShareAccumulator<T>>,
    reconstructed: BTreeSet<ViewNumber>,
    tasks: JoinSet<Result<VidReconstructOutput<T>, VidReconstructError<<T as NodeType>::SignatureKey>>>,
    calculations: BTreeMap<ViewNumber, AbortHandle>,
}

Fields

pending: BTreeMap<ViewNumber, BTreeMap<T::SignatureKey, VidDisperseShare2<T>>>

Shares that arrived before their view’s proposal, one per voter: admitted (or dropped) once the proposal pins the view’s commitment.

accumulators: BTreeMap<ViewNumber, VidShareAccumulator<T>>

One accumulator per view, created when its validated proposal arrives: reconstruction needs the proposal’s metadata, so only the proposal’s commitment is worth accumulating.

reconstructed: BTreeSet<ViewNumber>

tasks: JoinSet<Result<VidReconstructOutput<T>, VidReconstructError<<T as NodeType>::SignatureKey>>>

calculations: BTreeMap<ViewNumber, AbortHandle>

Implementations

impl<T: NodeType> VidReconstructor<T>

pub fn new() -> Self

pub(crate) fn handle_proposal( &mut self, view: ViewNumber, payload_commitment: VidCommitment2, metadata: <<T as NodeType>::BlockPayload as BlockPayload<T>>::Metadata, epoch: EpochNumber, expected_param: Option<AvidmGf2Param>, )

Pin view to its validated proposal’s payload commitment and metadata, and admit any shares that arrived before the proposal.

pub(crate) fn handle_vid_share( &mut self, sender: T::SignatureKey, share: VidDisperseShare2<T>, )

pub async fn next( &mut self, ) -> Option<Result<VidReconstructOutput<T>, VidReconstructError<<T as NodeType>::SignatureKey>>>

fn handle_failed_attempt(&mut self, err: &VidReconstructError<T::SignatureKey>)

Apply the outcome of a failed attempt: weed the bad shares out of the accumulator, then either mark the payload as unrecoverable or retry (try_reconstruct re-checks coverage, which shares that arrived while the attempt ran may already restore).

fn try_reconstruct(&mut self, view: ViewNumber)

pub fn gc(&mut self, view_number: ViewNumber)

pub fn retire_view(&mut self, view: ViewNumber)

Stop tracking view.

Either because its payload was reconstructed (or obtained elsewhere) or because it timed out and will never be decided: record it so handle_vid_share ignores later shares, drop its accumulator and pending shares, and abort any in-flight reconstruction task.

Trait Implementations

impl<T: Default + NodeType> Default for VidReconstructor<T>

where T::SignatureKey: Default,

fn default() -> VidReconstructor<T>

Returns the “default value” for a type.