Struct cfxcore::pos::protocol::network_sender::NetworkSender

pub struct NetworkSender {
    pub network: Arc<NetworkService>,
    pub protocol_handler: Arc<HotStuffSynchronizationProtocol>,
}

The interface from Consensus to Networking layer.

This is a thin wrapper around a NetworkSender<ConsensusMsg>, so it is easy to clone and send off to a separate task. For example, the rpc requests return Futures that encapsulate the whole flow, from sending the request to remote, to finally receiving the response and deserializing. It therefore makes the most sense to make the rpc call on a separate async task, which requires the NetworkSender to be Clone and Send.

Fields

network: Arc<NetworkService>

network service

protocol_handler: Arc<HotStuffSynchronizationProtocol>

hotstuff protocol handler

Implementations

impl NetworkSender

pub fn send_to( &mut self, recipient: AccountAddress, msg: &dyn Message ) -> Result<(), Error>

Send a single message to the destination peer using the CONSENSUS_DIRECT_SEND_PROTOCOL ProtocolId.

pub fn send_to_many( &mut self, recipients: impl Iterator<Item = AccountAddress>, msg: &dyn Message ) -> Result<(), Error>

Send a single message to the destination peers using the CONSENSUS_DIRECT_SEND_PROTOCOL ProtocolId.

pub fn send_to_others( &mut self, msg: &dyn Message, exclude: &Vec<AccountAddress> ) -> Result<(), Error>

Send a msg to all connected PoS nodes. They may or may not be validators.

pub async fn send_rpc( &self, recipient: Option<NodeId>, request: Box<dyn Request> ) -> Result<Box<dyn RpcResponse>, Error>

Send a RPC to the destination peer using the CONSENSUS_RPC_PROTOCOL ProtocolId.

pub async fn send_self_msg( &self, self_author: AccountAddress, msg: ConsensusMsg ) -> Result<(), Error>

Send msg to self

pub fn send_message_with_peer_id( &self, peer_id: &NodeId, msg: &dyn Message ) -> Result<(), Error>

Send msg to peer

Trait Implementations

impl Clone for NetworkSender

fn clone(&self) -> NetworkSender

Returns a copy of the value.

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

Performs copy-assignment from source.