Struct sc_network_sync::blocks::BlockCollection

pub struct BlockCollection<B: BlockT> { /* private fields */ }

A collection of blocks being downloaded.

Implementations

impl<B: BlockT> BlockCollection<B>

pub fn new() -> Self

Create a new instance.

pub fn clear(&mut self)

Clear everything.

pub fn insert( &mut self, start: NumberFor<B>, blocks: Vec<BlockData<B>>, who: PeerId )

Insert a set of blocks into collection.

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.

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

impl<B: Default + BlockT> Default for BlockCollection<B>where B::Hash: Default,

fn default() -> BlockCollection<B>

Returns the “default value” for a type.