Struct PeerDiscovery 

struct PeerDiscovery {
    process: StoppableTaskPtr,
    init: CondVar,
    session: Weak<DirectSession>,
}

PeerDiscovery process for that sends GetAddrs messages to a random whitelist or greylist host (creating a channel in the direct session). If it’s unsuccessful after two attempts, connect to our seed nodes and perform SeedSyncSession.

Fields

process: StoppableTaskPtr

init: CondVar

session: Weak<DirectSession>

Implementations

impl PeerDiscovery

fn new(session: Weak<DirectSession>) -> Arc<Self>

impl PeerDiscovery

async fn start(self: Arc<Self>)

async fn stop(self: Arc<Self>)

async fn run(self: Arc<Self>)

Peer discovery’s main process. For the first two attempts, this will broadcast a GetAddrs message to request more peers. If we are not connected to any peer, we try to create a channel in the direct session to a random whitelist or greylist host. Other parts of the P2P stack will then handle the incoming addresses and place them in the hosts list.

On the third attempt, and if we still haven’t made any connections, this function will then call p2p.seed() which triggers a SeedSyncSession that will connect to configured seeds and request peers from them.

This function will also sleep outbound_peer_discovery_attempt_time seconds after broadcasting in order to let the P2P stack receive and work through the addresses it is expecting.

Peer discovery will only start once notify() is called.

pub fn notify(&self)

Init peer discovery by sending a notification to init. Uses the underlying CondVar method notify().

fn session(&self) -> DirectSessionPtr

fn p2p(&self) -> P2pPtr