Struct cfxcore::sync::SynchronizationState

pub struct SynchronizationState {
    pub peers: RwLock<HashMap<NodeId, Arc<RwLock<SynchronizationPeerState>>>>,
    pub handshaking_peers: RwLock<HashMap<NodeId, (ProtocolVersion, Instant)>>,
    pub last_sent_transaction_hashes: RwLock<HashSet<H256>>,
    /* private fields */
}

Fields

peers: RwLock<HashMap<NodeId, Arc<RwLock<SynchronizationPeerState>>>>

handshaking_peers: RwLock<HashMap<NodeId, (ProtocolVersion, Instant)>>

last_sent_transaction_hashes: RwLock<HashSet<H256>>

Implementations

impl SynchronizationState

pub fn new( is_consortium: bool, node_type: NodeType, allow_phase_change_without_peer: bool, min_phase_change_normal_peer_count: usize ) -> Self

pub fn is_consortium(&self) -> bool

pub fn on_status_in_handshaking( &self, node_id: &NodeId ) -> Option<ProtocolVersion>

pub fn peer_connected(&self, node_id: NodeId, state: SynchronizationPeerState)

pub fn contains_peer(&self, node_id: &NodeId) -> bool

pub fn get_peer_info( &self, node_id: &NodeId ) -> Result<Arc<RwLock<SynchronizationPeerState>>, Error>

pub fn get_peer_version( &self, peer: &NodeId ) -> Result<ProtocolVersion, NetworkError>

pub fn update_heartbeat(&self, node_id: &NodeId)

Updates the heartbeat for the specified peer. It takes no effect if the peer is in handshaking status or not found.

pub fn get_heartbeat_timeout_peers(&self, timeout: Duration) -> Vec<NodeId>

Retrieves the heartbeat timeout peers, including handshaking timeout peers and inactive peers after handshake.

pub fn is_full_node(&self) -> bool

pub fn allow_phase_change_without_peer(&self) -> bool

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

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

Trait Implementations

impl MallocSizeOf for SynchronizationState

fn size_of(&self, ops: &mut MallocSizeOfOps) -> usize

Measure the heap usage of all descendant heap-allocated structures, but not the space taken up by the value itself.