Struct BlockFetchBehavior 

pub struct BlockFetchBehavior { /* private fields */ }

Sub-behavior that manages block fetching from peers.

Implementations

impl BlockFetchBehavior

pub fn new(_config: ()) -> BlockFetchBehavior

Creates a new block-fetch behavior with the given configuration.

pub fn enqueue(&mut self, request: (Point, Point))

Adds a block range request to the pending queue.

pub fn request_block_batch( &self, pid: &PeerId, range: (Point, Point), outbound: &mut OutboundQueue<InitiatorBehavior>, )

Sends a block range request to the specified peer.

pub fn dispatch_block( &self, pid: &PeerId, state: &InitiatorState, outbound: &mut OutboundQueue<InitiatorBehavior>, )

Emits a BlockBodyReceived event if the peer’s block-fetch state contains a new block.

Trait Implementations

impl Default for BlockFetchBehavior

fn default() -> BlockFetchBehavior

Returns the “default value” for a type.

impl PeerVisitor for BlockFetchBehavior

fn visit_inbound_msg( &mut self, pid: &PeerId, state: &mut InitiatorState, outbound: &mut OutboundQueue<InitiatorBehavior>, )

Called when a message has been received from the peer.

fn visit_housekeeping( &mut self, pid: &PeerId, state: &mut InitiatorState, outbound: &mut OutboundQueue<InitiatorBehavior>, )

Called during periodic housekeeping for each tracked peer.

fn visit_connected( &mut self, pid: &PeerId, state: &mut InitiatorState, outbound: &mut OutboundQueue<InitiatorBehavior>, )

Called when a TCP connection to the peer is established.

fn visit_disconnected( &mut self, pid: &PeerId, state: &mut InitiatorState, outbound: &mut OutboundQueue<InitiatorBehavior>, )

Called when the peer has been disconnected.

fn visit_errored( &mut self, pid: &PeerId, state: &mut InitiatorState, outbound: &mut OutboundQueue<InitiatorBehavior>, )

Called when an error occurred on the peer’s connection.

fn visit_discovered( &mut self, pid: &PeerId, state: &mut InitiatorState, outbound: &mut OutboundQueue<InitiatorBehavior>, )

Called when a new peer has been discovered.

fn visit_outbound_msg( &mut self, pid: &PeerId, state: &mut InitiatorState, outbound: &mut OutboundQueue<InitiatorBehavior>, )

Called after a message has been sent to the peer.

fn visit_tagged( &mut self, pid: &PeerId, state: &mut InitiatorState, outbound: &mut OutboundQueue<InitiatorBehavior>, )

Called when a peer’s state has been modified by a tag function.