Struct ConnQueue 

pub struct ConnQueue {
    queue: Mutex<VecDeque<QueuedConn>>,
    conn_available: CondVar,
}

FIFO of pending connections awaiting handshake.

Fields

queue: Mutex<VecDeque<QueuedConn>>

conn_available: CondVar

Implementations

impl ConnQueue

pub fn new() -> Arc<Self>

pub async fn handle( &self, conn: FramedConn<PeerNetMsgCodec>, direction: ConnDirection, verified_peer_id: Option<PeerID>, ) -> Result<()>

Handle a stream connection: split into halves, push, and block until disconnect.

pub async fn handle_quic( &self, conn: FramedConn<PeerNetMsgCodec>, quic_conn: QuicConn, direction: ConnDirection, verified_peer_id: Option<PeerID>, ) -> Result<()>

Handle a QUIC connection. The conn is the handshake stream; quic_conn is the full QUIC connection for protocol streams.

pub async fn next(&self) -> QueuedConn

Waits for the next connection in the queue.