Struct grin_p2p::Peer

pub struct Peer {
    pub info: PeerInfo,
    // some fields omitted
}

Fields

info: PeerInfo

Methods

impl Peer

pub fn accept(     conn: &mut TcpStream,     capab: Capabilities,     total_difficulty: Difficulty,     hs: &Handshake,     adapter: Arc<dyn NetAdapter> ) -> Result<Peer, Error>

pub fn connect(     conn: &mut TcpStream,     capab: Capabilities,     total_difficulty: Difficulty,     self_addr: SocketAddr,     hs: &Handshake,     na: Arc<dyn NetAdapter> ) -> Result<Peer, Error>

pub fn start(&mut self, conn: TcpStream)

Main peer loop listening for messages and forwarding to the rest of the system.

pub fn is_denied(config: &P2PConfig, peer_addr: &SocketAddr) -> bool

pub fn is_connected(&self) -> bool

Whether this peer is still connected.

pub fn is_banned(&self) -> bool

Whether this peer has been banned.

pub fn is_stuck(&self) -> (bool, Difficulty)

Whether this peer is stuck on sync.

pub fn sent_bytes(&self) -> Option<u64>

Number of bytes sent to the peer

pub fn received_bytes(&self) -> Option<u64>

Number of bytes received from the peer

pub fn set_banned(&self)

Set this peer status to banned

pub fn send_ping(     &self,     total_difficulty: Difficulty,     height: u64 ) -> Result<(), Error>

Send a ping to the remote peer, providing our local difficulty and height

pub fn send_ban_reason(&self, ban_reason: ReasonForBan)

Send the ban reason before banning

pub fn send_block(&self, b: &Block) -> Result<bool, Error>

Sends the provided block to the remote peer. The request may be dropped if the remote peer is known to already have the block.

pub fn send_compact_block(&self, b: &CompactBlock) -> Result<bool, Error>

pub fn send_header(&self, bh: &BlockHeader) -> Result<bool, Error>

pub fn send_transaction(&self, tx: &Transaction) -> Result<bool, Error>

Sends the provided transaction to the remote peer. The request may be dropped if the remote peer is known to already have the transaction.

pub fn send_stem_transaction(&self, tx: &Transaction) -> Result<(), Error>

Sends the provided stem transaction to the remote peer. Note: tracking adapter is ignored for stem transactions (while under embargo).

pub fn send_header_request(&self, locator: Vec<Hash>) -> Result<(), Error>

Sends a request for block headers from the provided block locator

pub fn send_block_request(&self, h: Hash) -> Result<(), Error>

Sends a request for a specific block by hash

pub fn send_compact_block_request(&self, h: Hash) -> Result<(), Error>

Sends a request for a specific compact block by hash

pub fn send_peer_request(&self, capab: Capabilities) -> Result<(), Error>

pub fn send_txhashset_request(     &self,     height: u64,     hash: Hash ) -> Result<(), Error>

pub fn stop(&self)

Stops the peer, closing its connection

Trait Implementations

impl Send for Peer

impl Sync for Peer