[−][src]Struct grin_p2p::Server
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
[src]
pub fn new(
db_root: &str,
capab: Capabilities,
config: P2PConfig,
adapter: Arc<dyn ChainAdapter>,
genesis: Hash,
stop_state: Arc<StopState>
) -> Result<Server, Error>
[src]
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>
[src]
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>
[src]
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)
[src]
pub fn pause(&self)
[src]
Pause means: stop all the current peers connection, only for tests. Note:
- must pause the 'seed' thread also, to avoid the new egress peer connection
- must pause the 'p2p-server' thread also, to avoid the new ingress peer connection.
Auto Trait Implementations
impl !RefUnwindSafe for Server
impl Send for Server
impl Sync for Server
impl Unpin for Server
impl !UnwindSafe for Server
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> SafeBorrow<T> for T where
T: ?Sized,
T: ?Sized,
fn borrow_replacement(ptr: &T) -> &T
impl<T> Same<T> for T
type Output = T
Should always be Self
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<T> UnsafeAny for T where
T: Any,
T: Any,
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,