Enum zebra_network::peer::connection::Handler

pub(super) enum Handler {
    Finished(Result<Response, PeerError>),
    Ping(Nonce),
    Peers,
    FindBlocks,
    FindHeaders,
    BlocksByHash {
        pending_hashes: HashSet<Hash>,
        blocks: Vec<Arc<Block>>,
    },
    TransactionsById {
        pending_ids: HashSet<UnminedTxId>,
        transactions: Vec<UnminedTx>,
    },
    MempoolTransactionIds,
}

Variants

Finished(Result<Response, PeerError>)

Indicates that the handler has finished processing the request. An error here is scoped to the request.

Ping(Nonce)

Peers

FindBlocks

FindHeaders

BlocksByHash

Fields

pending_hashes: HashSet<Hash>

blocks: Vec<Arc<Block>>

TransactionsById

Fields

pending_ids: HashSet<UnminedTxId>

transactions: Vec<UnminedTx>

MempoolTransactionIds

Implementations

impl Handler

pub fn command(&self) -> Cow<'static, str>

Returns the Zebra internal handler type as a string.

fn process_message( &mut self, msg: Message, cached_addrs: &mut Vec<MetaAddr>, ) -> Option<Message>

Try to handle msg as a response to a client request, possibly consuming it in the process.

This function is where we statefully interpret Bitcoin/Zcash messages into responses to messages in the internal request/response protocol. This conversion is done by a sequence of (request, message) match arms, each of which contains the conversion logic for that pair.

Taking ownership of the message means that we can pass ownership of its contents to responses without additional copies. If the message is not interpretable as a response, we return ownership to the caller.

Unexpected messages are left unprocessed, and may be rejected later.

addr responses are limited to avoid peer set takeover. Any excess addresses are stored in cached_addrs.

fn update_addr_cache<'new>( cached_addrs: &mut Vec<MetaAddr>, new_addrs: impl IntoIterator<Item = &'new MetaAddr>, response_size: impl Into<Option<usize>>, ) -> Vec<MetaAddr>

Adds new_addrs to the cached_addrs cache, then takes and returns response_size addresses from that cache.

cached_addrs can be empty if the cache is empty. new_addrs can be empty or None if there are no new addresses. response_size can be zero or None if there is no response needed.

Trait Implementations

impl Debug for Handler

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Display for Handler

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.