Struct NetworkServiceInner

pub struct NetworkServiceInner {
    pub sessions: SessionManager,
    pub metadata: HostMetadata,
    pub config: NetworkConfiguration,
    pub node_db: RwLock<NodeDatabase>,
    /* private fields */
}

The inner implementation of NetworkService. Note that all accesses to the RWLocks of the fields have to follow the defined order to avoid race

Fields

sessions: SessionManager

metadata: HostMetadata

config: NetworkConfiguration

node_db: RwLock<NodeDatabase>

Implementations

impl NetworkServiceInner

pub fn new( config: &NetworkConfiguration, pos_pub_keys: (ConsensusPublicKey, ConsensusVRFPublicKey), ) -> Result<NetworkServiceInner, Error>

pub fn new_with_latency( config: &NetworkConfiguration, pos_pub_keys: (ConsensusPublicKey, ConsensusVRFPublicKey), ) -> Result<NetworkServiceInner, Error>

pub fn add_latency(&self, peer: NodeId, latency_ms: f64) -> Result<(), Error>

pub fn get_ip_filter(&self) -> &IpFilter

pub fn local_addr(&self) -> SocketAddr

pub fn get_peer_info(&self) -> Vec<PeerInfo>

pub fn get_peer_connection_origin(&self, node_id: &NodeId) -> Option<bool>

pub fn with_context<F, R>( &self, handler: Arc<dyn NetworkProtocolHandler + Sync>, protocol: ProtocolId, io: &IoContext<NetworkIoMessage>, action: F, ) -> R

where F: FnOnce(&NetworkContext<'_>) -> R,

Trait Implementations

impl IoHandler<NetworkIoMessage> for NetworkServiceInner

fn initialize(&self, io: &IoContext<NetworkIoMessage>)

Initialize the handler

fn stream_hup(&self, io: &IoContext<NetworkIoMessage>, stream: StreamToken)

Called when an IO stream gets closed

fn stream_readable(&self, io: &IoContext<NetworkIoMessage>, stream: StreamToken)

Called when an IO stream can be read from

fn stream_writable(&self, io: &IoContext<NetworkIoMessage>, stream: StreamToken)

Called when an IO stream can be written to

fn timeout(&self, io: &IoContext<NetworkIoMessage>, token: TimerToken)

Timer function called after a timeout created with HandlerIo::timeout.

fn message(&self, io: &IoContext<NetworkIoMessage>, message: &NetworkIoMessage)

Called when a broadcasted message is received. The message can only be sent from a different IO handler.

fn register_stream( &self, stream: StreamToken, reg: Token, poll_registry: &Registry, )

Register a new stream with the event loop

fn deregister_stream(&self, stream: StreamToken, poll_registry: &Registry)

Deregister a stream. Called when stream is removed from event loop

fn update_stream( &self, stream: StreamToken, reg: Token, poll_registry: &Registry, )

Re-register a stream with the event loop