Struct TransportManager 

pub struct TransportManager {
    decision_matrix: [[TransportPolicyEntry; 3]; 3],
    policy_overrides: SpinLock<BTreeMap<(u32, u32), TransportPolicyEntry>>,
    active: SpinLock<BTreeMap<TransportId, TransportCreateResult>>,
    cache: SpinLock<TransportCache>,
    pub stats: SpinLock<TransportStats>,
}

Central transport manager : selects and creates IPC transports per silo pair.

Uses a static decision matrix (tier × tier) with optional dynamic overrides. A small FIFO cache avoids redundant creation for frequently used pairs.

Fields

decision_matrix: [[TransportPolicyEntry; 3]; 3]

Static decision matrix: [src_tier][dst_tier] -> policy.

policy_overrides: SpinLock<BTreeMap<(u32, u32), TransportPolicyEntry>>

Dynamic overrides (set by silo admin).

active: SpinLock<BTreeMap<TransportId, TransportCreateResult>>

Active transport registry.

cache: SpinLock<TransportCache>

Simple FIFO transport cache (no_std, no allocation).

stats: SpinLock<TransportStats>

Per-transport performance statistics.

Implementations

impl TransportManager

pub const fn new() -> Self

Create a new manager with the default decision matrix.

pub fn establish( &self, src: SiloId, dst: SiloId, config: TransportConfig, ) -> Result<TransportCreateResult, IpcError>

Establish a transport between src and dst.

Selection order:

1. Cache hit (fast path for repeated pairs).
2. Dynamic override (admin-configured policy).
3. Static decision matrix (safe default).

fn create( &self, _pair: (u32, u32), level: TransportLevel, capacity: u32, ) -> Result<TransportCreateResult, IpcError>

Create a transport at the given level.

pub fn get_endpoint(&self, id: TransportId) -> Option<TransportEndpoint>

Look up a transport endpoint by ID.

pub fn close(&self, id: TransportId) -> Result<(), IpcError>

Remove a transport from the registry (called when all handles close).

pub fn set_policy( &self, src: u32, dst: u32, level: TransportLevel, capacity: u32, )

Override the transport policy for a specific silo pair.