Struct ckb_sync::Relayer

source · [−]

pub struct Relayer { /* private fields */ }

Expand description

Relayer protocol handle

Implementations

source

impl Relayer

source

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

source

pub fn v2(self) -> Self

set relay to v2

source

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

Get shared state

source

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

source

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

Accept a new block from network

source

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

source

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

Ask for relay transaction by hash from all peers

source

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

Send bulk of tx hashes to selected peers

Trait Implementations

source

impl CKBProtocolHandler for Relayer

source

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

Init action on service run

source

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

Called when the corresponding protocol message is received

source

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

Called when opening protocol

source

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

Called when closing protocol

source

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

Called when the Service receives the notify task

source

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

Behave like Stream::poll

source

impl Clone for Relayer

source

fn clone(&self) -> Relayer

Returns a copy of the value. Read more

1.0.0 · source

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

Performs copy-assignment from source. Read more

Auto Trait Implementations

impl !RefUnwindSafe for Relayer

impl Send for Relayer

impl Sync for Relayer

impl Unpin for Relayer

impl !UnwindSafe for Relayer

Blanket Implementations

source

impl<T> Any for T where
T: 'static + ?Sized,

source

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

impl<T> AsAny for T where
T: Any,

fn as_any(&self) -> &(dyn Any + 'static)

TODO(doc): @quake

source

impl<T> Borrow<T> for T where
T: ?Sized,

const: unstable · source

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

source

impl<T> BorrowMut<T> for T where
T: ?Sized,

const: unstable · source

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

source

impl<T> From<T> for T

const: unstable · source

fn from(t: T) -> T

Returns the argument unchanged.

source

impl<T> Instrument for T

source

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

source

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

source

impl<T, U> Into for T where
U: From<T>,

const: unstable · source

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

impl<T> Pointable for T

const ALIGN: usize

The alignment of pointer.

type Init = T

The type for initializers.

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more

source

impl<T> ToOwned for T where
T: Clone,

type Owned = T

The resulting type after obtaining ownership.

source

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more

source

fn clone_into(&self, target: &mut T)

🔬 This is a nightly-only experimental API. (toowned_clone_into)

Uses borrowed data to replace owned data, usually by cloning. Read more

source

impl<T, U> TryFrom for T where
U: Into<T>,

type Error = Infallible

The type returned in the event of a conversion error.

const: unstable · source

fn try_from(value: U) -> Result<T, <T as TryFrom>::Error>

Performs the conversion.

source

impl<T, U> TryInto for T where
U: TryFrom<T>,

type Error = >::Error

The type returned in the event of a conversion error.

const: unstable · source

fn try_into(self) -> Result<U, >::Error>

Performs the conversion.

impl<V, T> VZip<V> for T where
V: MultiLane<T>,

fn vzip(self) -> V

source

impl<T> WithSubscriber for T

source

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

source

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more

Struct ckb_sync::Relayer

Implementations

impl Relayer

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

pub fn v2(self) -> Self

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

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

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

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

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

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

Trait Implementations

impl CKBProtocolHandler for Relayer

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

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

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

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

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

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

impl Clone for Relayer

fn clone(&self) -> Relayer

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

Auto Trait Implementations

impl !RefUnwindSafe for Relayer

impl Send for Relayer

impl Sync for Relayer

impl Unpin for Relayer

impl !UnwindSafe for Relayer

Blanket Implementations

impl<T> Any for T where T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> AsAny for T where T: Any,

fn as_any(&self) -> &(dyn Any + 'static)

impl<T> Borrow<T> for T where T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for T where T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for T where U: From<T>,

fn into(self) -> U

impl<T> Pointable for T

const ALIGN: usize

type Init = T

unsafe fn init(init: <T as Pointable>::Init) -> usize

unsafe fn deref<'a>(ptr: usize) -> &'a T

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

unsafe fn drop(ptr: usize)

impl<T> ToOwned for T where T: Clone,

type Owned = T

fn to_owned(&self) -> T

fn clone_into(&self, target: &mut T)

impl<T, U> TryFrom<U> for T where U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for T where U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<V, T> VZip<V> for T where V: MultiLane<T>,

fn vzip(self) -> V

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

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

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

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

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

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

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

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

impl<T> Any for T where
T: 'static + ?Sized,

impl<T> AsAny for T where
T: Any,

impl<T> Borrow<T> for T where
T: ?Sized,

impl<T> BorrowMut<T> for T where
T: ?Sized,

impl<T, U> Into<U> for T where
U: From<T>,

impl<T> ToOwned for T where
T: Clone,

impl<T, U> TryFrom<U> for T where
U: Into<T>,

impl<T, U> TryInto<U> for T where
U: TryFrom<T>,

impl<V, T> VZip<V> for T where
V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,