Struct Session 

pub struct Session<Role, State> { /* private fields */ }

Role- and state-typed session owner.

The role aliases CoordinatorSession and ReceiverSession are the ordinary spellings. Session values are movable but deliberately not shareable between threads; every control transition requires &mut self.

Implementations

impl Session<Coordinator, Negotiating>

pub fn spawn( command: SessionCommand, options: SessionOptions, ) -> Result<Self, SessionFailure>

Spawns and authenticates the selected helper under the target’s documented executable-identity policy through both HELLOs.

pub fn peer_application_payload(&self) -> &[u8]

Peer HELLO application payload, available before the coordinator decides.

pub fn decide( self, decision: NegotiationDecision, ) -> Result<NegotiationOutcome<Session<Coordinator, Ready>>, SessionFailure>

Makes the explicit coordinator decision and awaits the receiver decision.

impl Session<Receiver, Negotiating>

pub fn from_bootstrap( bootstrap: ReceiverBootstrap, options: SessionOptions, ) -> Result<Self, SessionFailure>

Consumes the unique process-entry bootstrap and exchanges HELLOs.

pub fn peer_application_payload(&self) -> &[u8]

Peer HELLO application payload, available before awaiting the decision.

pub fn decide_after_coordinator( self, decide: impl FnOnce(&[u8]) -> NegotiationDecision, ) -> Result<NegotiationOutcome<Session<Receiver, Ready>>, SessionFailure>

Awaits exact coordinator ACCEPT before invoking the receiver decision.

impl Session<Coordinator, Ready>

pub fn negotiated_limits(&self) -> SessionLimits

Effective finite limits bound into the accepted transcript.

pub fn atomic_capabilities(&self) -> AtomicCapabilities

Effective lock-free atomic and layout alignment facts bound into ACCEPT.

pub fn protocol_version(&self) -> ProtocolVersion

Accepted protocol version from the exact challenged transcript.

pub fn state(&self) -> SessionState

Current local reducer/liveness state.

pub fn active_leases(&self) -> ActiveLeaseFacts

Bounded current active-mapping lease counters.

pub fn poll_peer(&mut self) -> Result<PeerStatus, SessionFailure>

Performs one nonblocking authenticated peer observation.

pub fn wait_for_exit(&mut self, deadline: AbsoluteDeadline) -> ChildCleanupFacts

Boundedly waits for and reaps the exact direct child without consuming the session.

pub fn try_close(self, deadline: AbsoluteDeadline) -> CoordinatorCloseOutcome

Gracefully closes only after active leases are gone and the exact child is reaped.

pub fn abort(self, deadline: AbsoluteDeadline) -> CoordinatorAbortOutcome

Terminally poisons live mappings, terminates the exact child, and returns cleanup facts.

pub fn new_transfer_batch(&self) -> Result<TransferBatch, BatchError>

Starts a local batch builder bounded by this accepted session.

pub fn transfer_batch( &mut self, batch: TransferBatch, deadline: AbsoluteDeadline, ) -> Result<ActiveRegionSet, SessionFailure>

Completes one atomic capability transaction and activates its full set.

pub fn send_control( &mut self, kind: u32, payload: &[u8], deadline: AbsoluteDeadline, ) -> Result<(), SessionFailure>

Sends one bounded opaque application record under the supplied deadline.

pub fn receive_control( &mut self, deadline: AbsoluteDeadline, ) -> Result<ControlFrame, SessionFailure>

Receives one bounded opaque peer record under the supplied deadline.

impl Session<Receiver, Ready>

pub fn negotiated_limits(&self) -> SessionLimits

Effective finite limits bound into the accepted transcript.

pub fn atomic_capabilities(&self) -> AtomicCapabilities

Effective lock-free atomic and layout alignment facts bound into ACCEPT.

pub fn protocol_version(&self) -> ProtocolVersion

Accepted protocol version from the exact challenged transcript.

pub fn state(&self) -> SessionState

Current local reducer/liveness state.

pub fn active_leases(&self) -> ActiveLeaseFacts

Bounded current active-mapping lease counters.

pub fn poll_peer(&mut self) -> Result<PeerStatus, SessionFailure>

Performs one nonblocking authenticated peer observation.

pub fn wait_for_exit( &mut self, deadline: AbsoluteDeadline, ) -> Result<PeerStatus, SessionFailure>

Boundedly waits for authenticated peer endpoint closure under one deadline.

pub fn try_close(self) -> ReceiverCloseOutcome

Closes the inherited endpoint only after every active mapping lease is gone.

pub fn abort(self)

Terminally poisons every live mapping and closes the inherited endpoint.

pub fn receive_batch( &mut self, expected: ExpectedBatch, deadline: AbsoluteDeadline, ) -> Result<ActiveRegionSet, SessionFailure>

Receives, validates, commits, and activates one exact expected batch.

pub fn send_control( &mut self, kind: u32, payload: &[u8], deadline: AbsoluteDeadline, ) -> Result<(), SessionFailure>

Sends one bounded opaque application record under the supplied deadline.

pub fn receive_control( &mut self, deadline: AbsoluteDeadline, ) -> Result<ControlFrame, SessionFailure>

Receives one bounded opaque peer record under the supplied deadline.