Struct grin_p2p::Server

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

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>

Methods

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.