Struct SyncNetworkContext 

pub struct SyncNetworkContext<DB> {
    network_send: Sender<NetworkMessage>,
    peer_manager: Arc<PeerManager>,
    db: Arc<DB>,
}

Context used in chain sync to handle network requests. This contains the peer manager, P2P service interface, and Blockstore required to make network requests.

Fields

network_send: Sender<NetworkMessage>

Channel to send network messages through P2P service

peer_manager: Arc<PeerManager>

Manages peers to send requests to and updates request stats for the respective peers.

db: Arc<DB>

Implementations

impl<DB> SyncNetworkContext<DB>

where DB: Blockstore,

pub fn new( network_send: Sender<NetworkMessage>, peer_manager: Arc<PeerManager>, db: Arc<DB>, ) -> Self

pub fn peer_manager(&self) -> &PeerManager

Returns a reference to the peer manager of the network context.

pub fn network_send(&self) -> &Sender<NetworkMessage>

Returns a reference to the channel for sending network messages through P2P service.

pub async fn chain_exchange_headers( &self, peer_id: Option<PeerId>, tsk: &TipsetKey, count: NonZeroU64, ) -> Result<Vec<Arc<Tipset>>, String>

Send a chain_exchange request for only block headers (ignore messages). If peer_id is None, requests will be sent to a set of shuffled peers.

pub async fn chain_exchange_messages( &self, peer_id: Option<PeerId>, ts: &Tipset, ) -> Result<FullTipset, String>

Send a chain_exchange request for messages to assemble a full tipset with a local tipset, If peer_id is None, requests will be sent to a set of shuffled peers.

pub async fn chain_exchange_full_tipset( &self, peer_id: Option<PeerId>, tsk: &TipsetKey, ) -> Result<FullTipset, String>

Send a chain_exchange request for a single full tipset (includes messages) If peer_id is None, requests will be sent to a set of shuffled peers.

pub async fn chain_exchange_full_tipsets( &self, peer_id: Option<PeerId>, tsk: &TipsetKey, ) -> Result<Vec<FullTipset>, String>

async fn handle_chain_exchange_request<T, F>( &self, peer_id: Option<PeerId>, tsk: &TipsetKey, request_len: NonZeroU64, options: u64, validate: F, ) -> Result<Vec<T>, String>

where T: TryFrom<TipsetBundle> + Send + Sync + 'static, <T as TryFrom<TipsetBundle>>::Error: Display, F: Fn(&Vec<T>) -> bool,

Helper function to handle the peer retrieval if no peer supplied as well as the logging and updating of the peer info in the PeerManager.

async fn chain_exchange_request( peer_manager: Arc<PeerManager>, network_send: Sender<NetworkMessage>, peer_id: PeerId, request: ChainExchangeRequest, ) -> Result<ChainExchangeResponse, String>

Send a chain_exchange request to the network and await response.

pub async fn hello_request( &self, peer_id: PeerId, request: HelloRequest, ) -> Result<(PeerId, Instant, Option<HelloResponse>)>

Send a hello request to the network (does not immediately await response).

Trait Implementations

impl<DB> Clone for SyncNetworkContext<DB>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.