Struct SessionManager 

pub struct SessionManager { /* private fields */ }

Tracks open sessions, identity staleness, and the mutation lease.

Implementations

impl SessionManager

pub fn new( identity: ProxyIdentity, resources: BTreeMap<ResourceId, MmioResource>, ceiling: BTreeMap<ResourceId, ResourceCeiling>, allow_mutating_sessions: bool, ) -> Self

Creates a manager for one proxy instance.

pub fn with_limits( identity: ProxyIdentity, resources: BTreeMap<ResourceId, MmioResource>, ceiling: BTreeMap<ResourceId, ResourceCeiling>, allow_mutating_sessions: bool, limit_enforcer: AccessLimitEnforcer, ) -> Self

Creates a manager with explicit access limit enforcer.

pub fn set_quiesce_hook(&mut self, hook: QuiesceHook)

Registers a synchronous quiesce callback invoked with true when a mutating session opens and false when it closes.

pub fn is_quiesced(&self) -> bool

Returns whether the driver is currently quiesced due to an active mutating session.

pub fn quiesce_flag(&self) -> Arc<AtomicBool>

Returns a cloneable handle to the atomic quiesce flag so driver background loops can check quiesce state without locking.

pub fn identity(&self) -> &ProxyIdentity

The identity Describe reports and expectations are checked against.

pub fn resources(&self) -> &BTreeMap<ResourceId, MmioResource>

The resource descriptions offered by this instance.

pub fn open_session( &mut self, context: RunContext, mode: SessionMode, expectations: &ProxyIdentity, allowlist: impl IntoIterator<Item = AccessRule>, ) -> Result<u64, OpenError>

Opens a session. Stale identity is rejected before allowlist validation; a rejected allowlist creates no session.

pub fn check_access( &mut self, session_id: u64, class: AccessClass, now_ns: i64, ) -> Result<(), Denial>

Enforces access-class rate limit for session_id.

pub fn check_deadline( &self, session_id: u64, requested_timeout_ns: i64, ) -> Result<(), Denial>

Enforces deadline limit for session_id.

pub fn session(&self, id: u64) -> Option<&Session>

The session with id, if open.

pub fn close_session(&mut self, id: u64) -> bool

Closes a session, releasing the mutation lease and unquiescing the driver if it held the lease. Returns whether the session existed.

pub fn reject_new_sessions(&mut self)

Stop path: reject all new sessions and release any active mutation lease / quiesce state.

pub fn is_accepting(&self) -> bool

Whether new sessions are being accepted.

pub fn open_count(&self) -> usize

Number of open sessions.

Trait Implementations

impl Debug for SessionManager

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.