Struct SessionManager 

pub struct SessionManager { /* private fields */ }

Thread-safe registry of active sessions.

Backed by parking_lot::RwLock for fast concurrent reads. Session lookups happen on every RTP delivery cycle, so read performance matters.

Implementations

impl SessionManager

pub fn new() -> Self

pub fn create_session(&self, uri: &str) -> Arc<Session>

Create a new session for the given URI and register it.

pub fn get_session(&self, id: &str) -> Option<Arc<Session>>

Look up a session by ID.

pub fn remove_session(&self, id: &str) -> Option<Arc<Session>>

Remove and return a session by ID (used by TEARDOWN).

pub fn remove_sessions(&self, ids: &[String]) -> usize

Remove multiple sessions at once (used during TCP disconnect cleanup).

pub fn allocate_server_ports(&self) -> Result<(u16, u16)>

Allocate a pair of (RTP, RTCP) server ports.

Ports are allocated from a monotonic counter starting at 5000. When the range is exhausted (> 65534), it wraps back to 5000. Per RFC 3550 §11, RTP ports should be even and RTCP = RTP + 1.

pub fn get_playing_sessions(&self) -> Vec<Arc<Session>>

Returns all sessions currently in the SessionState::Playing state.

Trait Implementations

impl Clone for SessionManager

fn clone(&self) -> SessionManager

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for SessionManager

fn default() -> Self

Returns the “default value” for a type.