Struct OutboundSession

pub struct OutboundSession {
    pub(in net) p2p: Weak<P2p>,
    slots: Mutex<Vec<Arc<Slot>>>,
    peer_discovery: Arc<PeerDiscovery>,
}

Defines outbound connections session.

Fields

p2p: Weak<P2p>

Weak pointer to parent p2p object

slots: Mutex<Vec<Arc<Slot>>>

Outbound connection slots

peer_discovery: Arc<PeerDiscovery>

Peer discovery task

Implementations

impl OutboundSession

pub(crate) fn new(p2p: Weak<P2p>) -> OutboundSessionPtr

Create a new outbound session.

pub(crate) async fn start(self: Arc<Self>)

Start the outbound session. Runs the channel connect loop.

pub(crate) async fn stop(&self)

Stops the outbound session.

pub async fn slot_info(&self) -> Vec<u32>

fn wakeup_peer_discovery(&self)

async fn wakeup_slots(&self)

Trait Implementations

impl Session for OutboundSession

fn p2p(&self) -> P2pPtr

Returns a pointer to the p2p network interface

fn type_id(&self) -> SessionBitFlag

Return the session bit flag for the session type

fn register_channel<'life0, 'life1, 'async_trait>( &'life0 self, channel: ChannelPtr, executor: Arc<Executor<'life1>>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Registers a new channel with the session. Performs a network handshake and starts the channel. If we need to pass Self as an Arc we can do so like this:

fn perform_handshake_protocols<'life0, 'life1, 'async_trait>( &'life0 self, protocol_version: Arc<ProtocolVersion>, channel: ChannelPtr, executor: Arc<Executor<'life1>>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Performs network handshake to initialize channel. Adds the channel to the list of connected channels, and prepares to remove the channel when a stop signal is received.