Struct stack_epic_p2p::Server

pub struct Server {
    pub config: P2PConfig,
    pub peers: Arc<Peers>,
    /* private fields */
}

P2P server implementation, handling bootstrapping to find and connect to peers, receiving connections from other peers and keep track of all of them.

Fields

config: P2PConfig

peers: Arc<Peers>

Implementations

impl Server

pub fn new( db_root: &str, capab: Capabilities, config: P2PConfig, adapter: Arc<dyn ChainAdapter>, genesis: Hash, stop_state: Arc<StopState> ) -> Result<Server, Error>

Creates a new idle p2p server with no peers

pub fn listen(&self) -> Result<(), Error>

Starts a new TCP server and listen to incoming connections. This is a blocking call until the TCP server stops.

pub fn connect(&self, addr: PeerAddr) -> Result<Arc<Peer>, Error>

Asks the server to connect to a new peer. Directly returns the peer if we’re already connected to the provided address.

pub fn stop(&self)

pub fn pause(&self)

Pause means: stop all the current peers connection, only for tests. Note:

1. must pause the ‘seed’ thread also, to avoid the new egress peer connection
2. must pause the ‘p2p-server’ thread also, to avoid the new ingress peer connection.