Struct PeerSessionManager 

pub struct PeerSessionManager { /* private fields */ }

Manages the lifecycle of peer sessions with per-peer caps and idle eviction.

Index maintenance

peer_sessions is a secondary index mapping each peer_id to its list of session_ids. Closed entries are not removed from this index; instead, query methods filter by session state on the fly. This makes the index append-only and avoids the bookkeeping cost of removal.

Implementations

impl PeerSessionManager

pub fn new(config: SessionManagerConfig) -> Self

Create a new manager with the supplied configuration.

pub fn open_session( &mut self, peer_id: &str, direction: SessionDirection, current_tick: u64, ) -> Result<u64, String>

Open a new session for peer_id.

Checks global active capacity first, then per-peer active capacity.

Errors

• "global session limit reached" — the total number of active sessions would exceed SessionManagerConfig::global_max_sessions.
• "per-peer session limit reached" — this peer already has SessionManagerConfig::max_sessions_per_peer active sessions.

pub fn transition( &mut self, session_id: u64, new_state: PeerSessionState, ) -> Result<(), String>

Advance a session’s lifecycle state.

Errors

• "session not found" — no session with session_id exists.
• "invalid transition" — the session is already in the Closed terminal state and cannot transition further.

pub fn record_activity( &mut self, session_id: u64, bytes_sent: u64, bytes_recv: u64, current_tick: u64, ) -> bool

Record I/O activity for a session.

Accumulates bytes_sent and bytes_recv onto the session totals and updates last_active_tick to current_tick.

Returns false if no session with session_id exists (no-op).

pub fn evict_idle(&mut self, current_tick: u64) -> Vec<u64>

Mark idle sessions as Closed and return their IDs.

A session is considered idle when idle_ticks(current_tick) >= config.session_idle_timeout_ticks. Only non-Closed sessions are evaluated.

pub fn sessions_for_peer(&self, peer_id: &str) -> Vec<&PeerSessionEntry>

Return references to all sessions (including closed) associated with peer_id.

pub fn active_count_for_peer(&self, peer_id: &str) -> usize

Count of non-Closed sessions for peer_id.

pub fn get_session(&self, session_id: u64) -> Option<&PeerSessionEntry>

Look up a session by its ID.

pub fn stats(&self) -> SessionManagerStats

Compute a statistics snapshot reflecting the current state of all sessions.