Struct ServerRuntime 

pub struct ServerRuntime { /* private fields */ }

Server-side runtime: owns the transport, tracks live sessions and worker threads, and records connection and message counters.

Implementations

impl ServerRuntime

pub fn new( transport: Arc<dyn ServerTransport>, cx: Cx, thread_mode: ThreadMode, max_inflight: usize, ) -> Self

Creates a runtime with the default session isolation policy.

pub fn new_with_isolation( transport: Arc<dyn ServerTransport>, cx: Cx, thread_mode: ThreadMode, max_inflight: usize, session_isolation: IsolationPolicy, ) -> Self

Creates a runtime with an explicit session isolation policy applied to new sessions.

pub fn transport(&self) -> &Arc<dyn ServerTransport>

Returns the transport this runtime accepts connections on.

pub fn thread_mode(&self) -> &ThreadMode

Returns the threading mode used to service connections.

pub fn session_count(&self) -> usize

Returns the number of currently open sessions.

pub fn sessions(&self) -> Result<Vec<Session>>

Returns a snapshot of all open sessions.

pub fn begin_stop(&self)

Signals that the runtime should stop accepting and servicing connections.

pub fn is_stopping(&self) -> bool

Returns whether a stop has been requested.

pub fn open_session( &self, negotiated_codec: Symbol, isolation: IsolationPolicy, ) -> Result<u64>

Opens a new session with the given codec and isolation policy, returning its id.

pub fn update_session_codec( &self, session_id: u64, negotiated_codec: Symbol, ) -> Result<()>

Updates the negotiated codec for an existing session; a no-op if the session is gone.

pub fn close_session(&self, session_id: u64) -> Result<()>

Removes the session with session_id from the runtime.

pub fn clear_sessions(&self) -> Result<()>

Removes all sessions from the runtime.

pub fn connection_count(&self) -> u64

Returns the total number of connections opened over the runtime’s lifetime.

pub fn messages_sent(&self) -> u64

Returns the total number of messages sent.

pub fn messages_received(&self) -> u64

Returns the total number of messages received.

pub fn max_inflight(&self) -> usize

Returns the maximum number of in-flight requests permitted.

pub fn session_isolation(&self) -> &IsolationPolicy

Returns the isolation policy applied to new sessions.

pub fn note_message_sent(&self)

Increments the sent-message counter.

pub fn note_message_received(&self)

Increments the received-message counter.

pub fn with_cx<T>(&self, f: impl FnOnce(&mut Cx) -> Result<T>) -> Result<T>

Runs f with exclusive access to the runtime’s shared evaluation context.

pub fn set_accept_thread(&self, handle: JoinHandle<()>) -> Result<()>

Stores the join handle for the connection-accept thread.

pub fn join_accept_thread(&self) -> Result<()>

Joins the accept thread if one is registered.

pub fn register_worker_thread(&self, handle: JoinHandle<()>) -> Result<()>

Records a worker thread’s join handle for later cleanup.

pub fn join_worker_threads(&self) -> Result<()>

Joins and drains all registered worker threads.

pub fn accept_timeout( &self, timeout: Duration, ) -> Result<Option<Box<dyn ConnectionTransport>>>

Waits up to timeout for an incoming connection, returning its transport if one arrives.