Struct sc_network_sync::ChainSync

pub struct ChainSync<B: BlockT, Client> { /* private fields */ }

The main data structure which contains all the state for a chains active syncing strategy.

Implementations

impl<B, Client> ChainSync<B, Client>

where Self: ChainSyncT<B>, B: BlockT, Client: HeaderBackend<B> + BlockBackend<B> + HeaderMetadata<B, Error = Error> + ProofProvider<B> + Send + Sync + 'static,

pub fn new( mode: SyncMode, client: Arc<Client>, block_announce_protocol_name: ProtocolName, max_parallel_downloads: u32, max_blocks_per_request: u32, warp_sync_config: Option<WarpSyncConfig<B>>, network_service: NetworkServiceHandle ) -> Result<Self, ClientError>

Create a new instance.

pub fn is_peer_known(&self, peer_id: &PeerId) -> bool

Is the peer know to the sync state machine?

pub fn set_warp_sync_target_block(&mut self, header: B::Header)

Set warp sync target block externally in case we skip warp proof downloading.

pub fn on_state_response( &mut self, peer_id: PeerId, response: OpaqueStateResponse ) -> Option<ImportBlocksAction<B>>

Process state received in a response.

pub fn on_warp_sync_response(&mut self, peer_id: PeerId, response: EncodedProof)

Trait Implementations

impl<B, Client> ChainSync<B> for ChainSync<B, Client>

where B: BlockT, Client: HeaderBackend<B> + BlockBackend<B> + HeaderMetadata<B, Error = Error> + ProofProvider<B> + Send + Sync + 'static,

fn status(&self) -> SyncStatus<B>

Returns the current sync status.

fn peer_info(&self, who: &PeerId) -> Option<PeerInfo<B>>

Returns the state of the sync of the given peer.

fn num_sync_requests(&self) -> usize

Number of active forks requests. This includes requests that are pending or could be issued right away.

fn num_downloaded_blocks(&self) -> usize

Number of downloaded blocks.

fn num_peers(&self) -> usize

Returns the current number of peers stored within this state machine.

fn new_peer( &mut self, who: PeerId, best_hash: B::Hash, best_number: NumberFor<B> ) -> Result<Option<BlockRequest<B>>, BadPeer>

Handle a new connected peer.

fn update_chain_info(&mut self, best_hash: &B::Hash, best_number: NumberFor<B>)

Signal that a new best block has been imported.

fn request_justification(&mut self, hash: &B::Hash, number: NumberFor<B>)

Schedule a justification request for the given block.

fn clear_justification_requests(&mut self)

Clear all pending justification requests.

fn set_sync_fork_request( &mut self, peers: Vec<PeerId>, hash: &B::Hash, number: NumberFor<B> )

Request syncing for the given block from given set of peers.

fn on_block_data( &mut self, who: &PeerId, request: Option<BlockRequest<B>>, response: BlockResponse<B> ) -> Result<OnBlockData<B>, BadPeer>

Handle a response from the remote to a block request that we made.

fn on_block_justification( &mut self, who: PeerId, response: BlockResponse<B> ) -> Result<OnBlockJustification<B>, BadPeer>

Handle a response from the remote to a justification request that we made.

fn on_justification_import( &mut self, hash: B::Hash, number: NumberFor<B>, success: bool )

Call this when a justification has been processed by the import queue, with or without errors.

fn on_block_finalized(&mut self, hash: &B::Hash, number: NumberFor<B>)

Notify about finalization of the given block.

fn on_validated_block_announce( &mut self, is_best: bool, who: PeerId, announce: &BlockAnnounce<B::Header> )

Notify about pre-validated block announcement.

fn peer_disconnected(&mut self, who: &PeerId) -> Option<ImportBlocksAction<B>>

Call when a peer has disconnected. Canceled obsolete block request may result in some blocks being ready for import, so this functions checks for such blocks and returns them.

fn metrics(&self) -> Metrics

Return some key metrics.