Struct ckb_sync::Relayer

pub struct Relayer { /* private fields */ }

Relayer protocol handle

Implementations

impl Relayer

pub fn new(chain: ChainController, shared: Arc<SyncShared>) -> Self

Init relay protocol handle

This is a runtime relay protocol shared state, and any relay messages will be processed and forwarded by it

pub fn v2(self) -> Self

set relay to v2

pub fn shared(&self) -> &Arc<SyncShared>

Get shared state

pub fn request_proposal_txs(
    &self,
    nc: &dyn CKBProtocolContext,
    peer: PeerIndex,
    block_hash_and_number: BlockNumberAndHash,
    proposals: Vec<ProposalShortId>
)

Request the transaction corresponding to the proposal id from the specified node

pub fn accept_block(
    &self,
    nc: &dyn CKBProtocolContext,
    peer: PeerIndex,
    block: BlockView
)

Accept a new block from network

pub fn reconstruct_block(
    &self,
    active_chain: &ActiveChain,
    compact_block: &CompactBlock,
    received_transactions: Vec<TransactionView>,
    uncles_index: &[u32],
    received_uncles: &[UncleBlockView]
) -> ReconstructionResult

Reorganize the full block according to the compact block/txs/uncles

pub fn ask_for_txs(&self, nc: &dyn CKBProtocolContext)

Ask for relay transaction by hash from all peers

pub fn send_bulk_of_tx_hashes(&self, nc: &dyn CKBProtocolContext)

Send bulk of tx hashes to selected peers

Trait Implementations

impl CKBProtocolHandler for Relayer

fn init(&mut self, nc: Arc<dyn CKBProtocolContext + Sync>)

Init action on service run

fn received(
    &mut self,
    nc: Arc<dyn CKBProtocolContext + Sync>,
    peer_index: PeerIndex,
    data: Bytes
)

Called when the corresponding protocol message is received

fn connected(
    &mut self,
    _nc: Arc<dyn CKBProtocolContext + Sync>,
    peer_index: PeerIndex,
    version: &str
)

Called when opening protocol

fn disconnected(
    &mut self,
    _nc: Arc<dyn CKBProtocolContext + Sync>,
    peer_index: PeerIndex
)

Called when closing protocol

fn notify(&mut self, nc: Arc<dyn CKBProtocolContext + Sync>, token: u64)

Called when the Service receives the notify task

fn poll(
    &mut self,
    _nc: Arc<dyn CKBProtocolContext + Sync + 'static>
) -> Poll<Option<()>>

Behave like Stream::poll

impl Clone for Relayer

fn clone(&self) -> Relayer

Returns a copy of the value.

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

Performs copy-assignment from source.