pub struct BlockCollection<B: BlockT> { /* private fields */ }
Expand description
A collection of blocks being downloaded.
Implementations§
Source§impl<B: BlockT> BlockCollection<B>
impl<B: BlockT> BlockCollection<B>
Sourcepub fn insert(
&mut self,
start: NumberFor<B>,
blocks: Vec<BlockData<B>>,
who: PeerId,
)
pub fn insert( &mut self, start: NumberFor<B>, blocks: Vec<BlockData<B>>, who: PeerId, )
Insert a set of blocks into collection.
Sourcepub fn needed_blocks(
&mut self,
who: PeerId,
count: u32,
peer_best: NumberFor<B>,
common: NumberFor<B>,
max_parallel: u32,
max_ahead: u32,
) -> Option<Range<NumberFor<B>>>
pub fn needed_blocks( &mut self, who: PeerId, count: u32, peer_best: NumberFor<B>, common: NumberFor<B>, max_parallel: u32, max_ahead: u32, ) -> Option<Range<NumberFor<B>>>
Returns a set of block hashes that require a header download. The returned set is marked as being downloaded.
Sourcepub fn ready_blocks(&mut self, from: NumberFor<B>) -> Vec<BlockData<B>>
pub fn ready_blocks(&mut self, from: NumberFor<B>) -> Vec<BlockData<B>>
Get a valid chain of blocks ordered in descending order and ready for importing into
the blockchain.
from
is the maximum block number for the start of the range that we are interested in.
The function will return empty Vec if the first block ready is higher than from
.
For each returned block hash clear_queued
must be called at some later stage.
pub fn clear_queued(&mut self, hash: &B::Hash)
pub fn clear_peer_download(&mut self, who: &PeerId)
Trait Implementations§
Auto Trait Implementations§
impl<B> Freeze for BlockCollection<B>
impl<B> RefUnwindSafe for BlockCollection<B>where
<<B as Block>::Header as Header>::Number: RefUnwindSafe,
<B as Block>::Hash: RefUnwindSafe,
<B as Block>::Header: RefUnwindSafe,
<B as Block>::Extrinsic: RefUnwindSafe,
impl<B> Send for BlockCollection<B>
impl<B> Sync for BlockCollection<B>
impl<B> Unpin for BlockCollection<B>
impl<B> UnwindSafe for BlockCollection<B>where
<<B as Block>::Header as Header>::Number: RefUnwindSafe + UnwindSafe,
<B as Block>::Hash: UnwindSafe + RefUnwindSafe,
<B as Block>::Header: RefUnwindSafe,
<B as Block>::Extrinsic: RefUnwindSafe,
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> CheckedConversion for T
impl<T> CheckedConversion for T
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self
into a Left
variant of Either<Self, Self>
if into_left
is true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self
into a Left
variant of Either<Self, Self>
if into_left(&self)
returns true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moreSource§impl<Src, Dest> IntoTuple<Dest> for Srcwhere
Dest: FromTuple<Src>,
impl<Src, Dest> IntoTuple<Dest> for Srcwhere
Dest: FromTuple<Src>,
fn into_tuple(self) -> Dest
Source§impl<T, Outer> IsWrappedBy<Outer> for T
impl<T, Outer> IsWrappedBy<Outer> for T
Source§impl<T> Pointable for T
impl<T> Pointable for T
Source§impl<T> SaturatedConversion for T
impl<T> SaturatedConversion for T
Source§fn saturated_from<T>(t: T) -> Selfwhere
Self: UniqueSaturatedFrom<T>,
fn saturated_from<T>(t: T) -> Selfwhere
Self: UniqueSaturatedFrom<T>,
Source§fn saturated_into<T>(self) -> Twhere
Self: UniqueSaturatedInto<T>,
fn saturated_into<T>(self) -> Twhere
Self: UniqueSaturatedInto<T>,
Consume self to return an equivalent value of
T
. Read moreSource§impl<S, T> UncheckedInto<T> for Swhere
T: UncheckedFrom<S>,
impl<S, T> UncheckedInto<T> for Swhere
T: UncheckedFrom<S>,
Source§fn unchecked_into(self) -> T
fn unchecked_into(self) -> T
The counterpart to
unchecked_from
.Source§impl<T, S> UniqueSaturatedInto<T> for S
impl<T, S> UniqueSaturatedInto<T> for S
Source§fn unique_saturated_into(self) -> T
fn unique_saturated_into(self) -> T
Consume self to return an equivalent value of
T
.