subetha-core 0.3.0

Substrate for the CXC / SubEtha IPC stack: handshake header, observation ring, migration generation, marshal trait, CPU-feature CPUID helpers, and the AxisSignature direction catalog.
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

//! Substrate for adaptive primitives.
//!
//! The four core abstractions actually consumed by the IPC stack:
//!
//! - [`HandshakeHeader`] - per-instance generation counter and in-flight tracker.
//! - [`ObservationRing`] - TLS-local ring buffer for op observations.
//! - [`migration`] - dual-stack migration protocol primitives.
//! - [`Marshal`] - type-system contract for "this value can cross an
//!   address-space boundary byte-identically." Stricter than `Send`;
//!   required by every cross-process primitive in `subetha-cxc` that
//!   stores typed values (e.g. `SharedDeque<T>`).
//!
//! Plus the architecture catalog ([`Axis`] / [`AxisMask`]) for direction
//! signatures and the [`cpuid`] helpers for CPU-feature detection.
//!
//! Every adaptive primitive in `subetha-pointers` and `subetha-cxc`
//! carries a `HandshakeHeader` at a known offset.

#![forbid(unsafe_op_in_unsafe_fn)]

// The crate links std: the per-thread sequential id machinery in
// [`observation::thread_id`] needs `thread_local!`.

pub mod axis_signature;
pub mod cpuid;
pub mod handshake;
pub mod marshal;
pub mod migration;
pub mod observation;

pub use axis_signature::{Axis, AxisMask, Fusion};
pub use cpuid::{has_movdir64b, has_waitpkg};
pub use handshake::HandshakeHeader;
pub use marshal::{Marshal, MarshalError};
pub use migration::{Generation, MigrationGuard};
pub use observation::{Observation, ObservationRing, any_observer_armed, thread_id};