shaq 3.0.0

SPSC FIFO queue backed by shared memory for IPC
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

#![deny(unsafe_op_in_unsafe_fn)]

use core::sync::atomic::AtomicUsize;

// NB: To simplify casting we only support 64bit or wider systems.
const _: () = assert!(size_of::<usize>() >= size_of::<u64>());

pub mod error;
pub mod mpmc;
mod shmem;
pub mod spsc;

pub(crate) const VERSION_MAJOR: u16 = 2;
pub(crate) const VERSION_PATCH: u16 = 0;
pub(crate) const VERSION: u32 = (VERSION_MAJOR as u32) << 16 | VERSION_PATCH as u32;

pub(crate) const fn normalized_capacity(capacity: usize) -> usize {
    if capacity == 0 {
        0
    } else {
        capacity.next_power_of_two()
    }
}

/// `AtomicUsize` with 64-byte alignment for better performance.
#[derive(Default)]
#[repr(C, align(64))]
struct CacheAlignedAtomicSize {
    inner: AtomicUsize,
}

impl core::ops::Deref for CacheAlignedAtomicSize {
    type Target = AtomicUsize;

    fn deref(&self) -> &Self::Target {
        &self.inner
    }
}