hibana 0.2.0

Const-projected Affine Multiparty Session Types for choreography-first Rust protocols
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54

//! Control-context scaffolding for endpoints (B+ execution plan).
//!
//! The typestate rewrite stores rendezvous-scoped control context directly
//! inside [`Endpoint`](super::Endpoint) so that operations like reroute,
//! state snapshot, state restore, and abort no longer require the caller to thread
//! additional parameters.  This module provides the control context that
//! carries both policy configuration and a reference to the control plane.

use core::ptr::NonNull;

use crate::{control::types::Lane, transport::Transport};

/// Rendezvous-scoped control context stored inside endpoints.
///
/// This holds references to the control plane (SessionCluster), allowing
/// control operations to be invoked directly from the endpoint without
/// requiring external references.
pub(crate) struct SessionControlCtx<'rv, T, U, C, E, const MAX_RV: usize = 8>
where
    T: Transport,
    U: crate::runtime::consts::LabelUniverse,
    C: crate::runtime::config::Clock,
    E: crate::control::cap::mint::EpochTable,
{
    cluster: Option<NonNull<crate::control::cluster::core::SessionCluster<'rv, T, U, C, MAX_RV>>>,
    _marker: core::marker::PhantomData<E>,
}

impl<'rv, T, U, C, E, const MAX_RV: usize> SessionControlCtx<'rv, T, U, C, E, MAX_RV>
where
    T: Transport,
    U: crate::runtime::consts::LabelUniverse,
    C: crate::runtime::config::Clock,
    E: crate::control::cap::mint::EpochTable,
{
    pub(crate) fn new(
        _lane: Lane,
        cluster: Option<&'rv crate::control::cluster::core::SessionCluster<'rv, T, U, C, MAX_RV>>,
        _liveness_policy: crate::runtime::config::LivenessPolicy,
        _resolver: Option<()>,
    ) -> Self {
        Self {
            cluster: cluster.map(NonNull::from),
            _marker: core::marker::PhantomData,
        }
    }

    #[inline]
    pub(crate) fn cluster(
        &self,
    ) -> Option<&'rv crate::control::cluster::core::SessionCluster<'rv, T, U, C, MAX_RV>> {
        self.cluster.map(|ptr| unsafe { ptr.as_ref() })
    }
}