rtipc 0.5.1

Real-Time IPC, based on a zero-copy, wait-free circular message queue implementation
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use std::sync::atomic::{AtomicUsize, Ordering};

use crate::log::*;

pub(crate) fn max_cacheline_size() -> usize {
    static CLS: AtomicUsize = AtomicUsize::new(0);

    let mut cls = CLS.load(Ordering::Relaxed);

    if cls != 0 {
        return cls;
    }

    let cls_str = env!("CACHELINE_SIZE");
    cls = cls_str.parse::<usize>().unwrap();

    CLS.store(cls, Ordering::Relaxed);

    info!("cache line size = {cls}");
    cls
}