Enum BlockSyncEvent

Source

pub enum BlockSyncEvent {
    PeerConnected(BlockSyncPeerSession),
    PeerDisconnected(ZakuraPeerId),
    HeaderTipChanged {
        height: Height,
        hash: Hash,
    },
    StateFrontiersChanged(BlockSyncFrontiers),
    ChainTipGrow(BlockSyncFrontiers),
    ChainTipReset(BlockSyncFrontiers),
    NeededBlocks(Vec<BlockSyncBlockMeta>),
    BlockApplyFinished {
        token: BlockApplyToken,
        height: Height,
        hash: Hash,
        result: BlockApplyResult,
        local_frontier: Option<BlockSyncFrontiers>,
    },
    BlockRangeResponseFinished {
        peer: ZakuraPeerId,
        start_height: Height,
        requested_count: u32,
        returned_count: u32,
    },
    BlockRangeResponseReady {
        peer: ZakuraPeerId,
        start_height: Height,
        requested_count: u32,
        blocks: Vec<(Height, Arc<Block>, usize)>,
    },
}

Expand description

Facts accepted by the block-sync scaffold and later reactor.

The inbound data flow is inverted: a peer’s stream-6 frames are decoded and the download logic runs in the per-peer pipe-routine (PeerRoutine). Inbound messages no longer flow through the reactor as a WireMessage; the routine forwards only shared concerns to the reactor over [RoutineToReactor].

Variants§

§

PeerConnected(BlockSyncPeerSession)

A peer became available for stream-6 block sync.

§

PeerDisconnected(ZakuraPeerId)

A peer disconnected; all of its outstanding work is dropped.

§

HeaderTipChanged

Header sync advanced the committed header target.

Fields

§height: Height

Current best header height.

§hash: Hash

Current best header hash.

§

StateFrontiersChanged(BlockSyncFrontiers)

Locally observed finalized or verified-body frontiers changed.

§

ChainTipGrow(BlockSyncFrontiers)

State grew the verified body chain tip.

§

ChainTipReset(BlockSyncFrontiers)

State reset the verified body chain tip after a rollback, best-chain switch, activation boundary, or coalesced multi-block tip update.

§

NeededBlocks(Vec<BlockSyncBlockMeta>)

Driver returned the current body-missing, header-known heights with committed hashes.

§

BlockApplyFinished

Node wiring finished applying a submitted block body.

Fields

§token: BlockApplyToken

Submission token from the matching BlockSyncAction::SubmitBlock.

§height: Height

Submitted block height.

§hash: Hash

Submitted block hash.

§result: BlockApplyResult

Apply result from the verifier driver.

§local_frontier: Option<BlockSyncFrontiers>

Locally observed chain frontier after the apply attempt completed.

§

BlockRangeResponseFinished

Node wiring finished or abandoned a Block response to an inbound GetBlocks.

Fields

§peer: ZakuraPeerId

Peer whose served-response slot can be released.

§start_height: Height

First requested height.

§requested_count: u32

Requested block count.

§returned_count: u32

Number of blocks read from state and sent in the response.

§

BlockRangeResponseReady

State returned committed bodies requested by a peer and the reactor should send them.

Fields

§peer: ZakuraPeerId

Peer whose inbound request is being served.

§start_height: Height

First requested height.

§requested_count: u32

Requested block count.

§blocks: Vec<(Height, Arc<Block>, usize)>

Bounded committed blocks returned by state.

BlockSyncEvent

Enum BlockSyncEvent Copy item path

Variants§

PeerConnected(BlockSyncPeerSession)

PeerDisconnected(ZakuraPeerId)

HeaderTipChanged

Fields

StateFrontiersChanged(BlockSyncFrontiers)

ChainTipGrow(BlockSyncFrontiers)

ChainTipReset(BlockSyncFrontiers)

NeededBlocks(Vec<BlockSyncBlockMeta>)

BlockApplyFinished

Fields

BlockRangeResponseFinished

Fields

BlockRangeResponseReady

Fields

Trait Implementations§

impl Clone for BlockSyncEvent

fn clone(&self) -> BlockSyncEvent

fn clone_from(&mut self, source: &Self)

impl Debug for BlockSyncEvent

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

Auto Trait Implementations§

impl Freeze for BlockSyncEvent

impl RefUnwindSafe for BlockSyncEvent

impl Send for BlockSyncEvent

impl Sync for BlockSyncEvent

impl Unpin for BlockSyncEvent

impl UnsafeUnpin for BlockSyncEvent

impl UnwindSafe for BlockSyncEvent

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DTwhere ST: ?Sized, DT: ?Sized,

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DTwhere ST: ?Sized, DT: ?Sized,

impl<T> CloneToUninit for Twhere T: Clone,

unsafe fn clone_to_uninit(&self, dest: *mut u8)

impl<T> CompatExt for T

fn compat(self) -> Compat<T>where T: Sized,

fn compat_ref(&self) -> Compat<&T>

fn compat_mut(&mut self) -> Compat<&mut T>

impl<T> Conv for T

fn conv<T>(self) -> Twhere Self: Into<T>,

impl<T> DynClone for Twhere T: Clone,

fn __clone_box(&self, _: Private) -> *mut ()

impl<T> FmtForward for T

fn fmt_binary(self) -> FmtBinary<Self>where Self: Binary,

fn fmt_display(self) -> FmtDisplay<Self>where Self: Display,

fn fmt_lower_exp(self) -> FmtLowerExp<Self>where Self: LowerExp,

fn fmt_lower_hex(self) -> FmtLowerHex<Self>where Self: LowerHex,

fn fmt_octal(self) -> FmtOctal<Self>where Self: Octal,

fn fmt_pointer(self) -> FmtPointer<Self>where Self: Pointer,

fn fmt_upper_exp(self) -> FmtUpperExp<Self>where Self: UpperExp,

fn fmt_upper_hex(self) -> FmtUpperHex<Self>where Self: UpperHex,

fn fmt_list(self) -> FmtList<Self>where &'a Self: for<'a> IntoIterator,

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self>

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>where F: FnOnce(&Self) -> bool,

impl<T> Pipe for Twhere T: ?Sized,

fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere Self: Sized,

fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere R: 'a,

fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere R: 'a,

fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> Rwhere Self: Borrow<B>, B: 'a + ?Sized, R: 'a,

fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R, ) -> Rwhere Self: BorrowMut<B>, B: 'a + ?Sized, R: 'a,

fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> Rwhere Self: AsRef<U>, U: 'a + ?Sized, R: 'a,

Enum BlockSyncEvent

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
where ST: ?Sized, DT: ?Sized,

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
where ST: ?Sized, DT: ?Sized,

impl<T> CloneToUninit for T
where T: Clone,

fn compat(self) -> Compat<T>
where T: Sized,

fn conv<T>(self) -> T
where Self: Into<T>,

impl<T> DynClone for T
where T: Clone,

fn fmt_binary(self) -> FmtBinary<Self>
where Self: Binary,

fn fmt_display(self) -> FmtDisplay<Self>
where Self: Display,

fn fmt_lower_exp(self) -> FmtLowerExp<Self>
where Self: LowerExp,

fn fmt_lower_hex(self) -> FmtLowerHex<Self>
where Self: LowerHex,

fn fmt_octal(self) -> FmtOctal<Self>
where Self: Octal,

fn fmt_pointer(self) -> FmtPointer<Self>
where Self: Pointer,

fn fmt_upper_exp(self) -> FmtUpperExp<Self>
where Self: UpperExp,

fn fmt_upper_hex(self) -> FmtUpperHex<Self>
where Self: UpperHex,

fn fmt_list(self) -> FmtList<Self>
where &'a Self: for<'a> IntoIterator,

impl<T, U> Into<U> for T
where U: From<T>,

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

impl<T> Pipe for T
where T: ?Sized,

fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> R
where Self: Sized,

fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> R
where R: 'a,

fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> R
where R: 'a,

fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
where Self: Borrow<B>, B: 'a + ?Sized, R: 'a,

fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R, ) -> R
where Self: BorrowMut<B>, B: 'a + ?Sized, R: 'a,

fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
where Self: AsRef<U>, U: 'a + ?Sized, R: 'a,

fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
where Self: AsMut<U>, U: 'a + ?Sized, R: 'a,

fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
where Self: Deref<Target = T>, T: 'a + ?Sized, R: 'a,

fn pipe_deref_mut<'a, T, R>( &'a mut self, func: impl FnOnce(&'a mut T) -> R, ) -> R
where Self: DerefMut<Target = T> + Deref, T: 'a + ?Sized, R: 'a,

impl<T> PolicyExt for T
where T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

impl<T> Read<Exclusive, BecauseExclusive> for T
where T: ?Sized,

fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
where Self: Borrow<B>, B: ?Sized,

fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
where Self: BorrowMut<B>, B: ?Sized,

fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
where Self: AsRef<R>, R: ?Sized,

fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
where Self: AsMut<R>, R: ?Sized,

fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
where Self: Deref<Target = T>, T: ?Sized,

fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
where Self: DerefMut<Target = T> + Deref, T: ?Sized,

fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
where Self: Borrow<B>, B: ?Sized,

fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
where Self: BorrowMut<B>, B: ?Sized,

fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
where Self: AsRef<R>, R: ?Sized,

fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
where Self: AsMut<R>, R: ?Sized,

fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
where Self: Deref<Target = T>, T: ?Sized,

fn tap_deref_mut_dbg<T>(self, func: impl FnOnce(&mut T)) -> Self
where Self: DerefMut<Target = T> + Deref, T: ?Sized,

impl<T> ToOwned for T
where T: Clone,

fn try_conv<T>(self) -> Result<T, Self::Error>
where Self: TryInto<T>,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,