slotbus 0.1.1

Lock-free shared memory IPC with slotted request/response. Sub-microsecond wake latency, zero-copy payloads, 32 concurrent in-flight requests per worker.
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

/// Errors that can occur during slotbus operations.
#[derive(Debug, thiserror::Error)]
pub enum SlotBusError {
    /// Failed to create or open a shared memory region.
    #[error("shared memory error: {0}")]
    SharedMemory(String),

    /// Failed to create or open an OS event.
    #[error("event error: {0}")]
    Event(String),

    /// The control region has an invalid magic number or version.
    #[error("invalid control region: {0}")]
    InvalidRegion(String),

    /// No free slots available for a new request.
    #[error("no free slots available (all {0} slots in use)")]
    NoFreeSlots(usize),

    /// Serialization or deserialization failed.
    #[error("serialization error: {0}")]
    Serialization(String),

    /// A request timed out waiting for a response.
    #[error("request timed out after {0}ms")]
    Timeout(u32),

    /// The slot state machine encountered an unexpected transition.
    #[error("unexpected slot state: expected {expected}, found {found}")]
    BadSlotState { expected: u32, found: u32 },

    /// A CAS (compare-and-swap) operation on a slot failed.
    #[error("CAS failed on slot {slot}: expected {expected}, found {found}")]
    CasFailed {
        slot: usize,
        expected: u32,
        found: u32,
    },

    /// The worker receive loop has stopped.
    #[error("receive loop stopped")]
    ReceiveLoopStopped,
}

impl From<postcard::Error> for SlotBusError {
    fn from(e: postcard::Error) -> Self {
        Self::Serialization(e.to_string())
    }
}