arctic-map 0.1.0

Lock-free adaptive radix tree
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
50
51
52
53
54
55
56
57
58
59
60
61
62

//! <https://pvk.ca/Blog/2020/07/07/flatter-wait-free-hazard-pointers/>
//! <https://docs.rs/membarrier/latest/membarrier/>

use core::sync::atomic::Ordering;

#[inline(always)]
pub(crate) fn fast_store_ordering(membarrier: bool) -> Ordering {
    if cfg!(feature = "opt-membarrier") && membarrier {
        Ordering::Relaxed
    } else {
        Ordering::SeqCst
    }
}

#[inline(always)]
pub(crate) fn fast_barrier(membarrier: bool) {
    if cfg!(feature = "opt-membarrier") && membarrier {
        core::sync::atomic::compiler_fence(Ordering::SeqCst);
    }
}

#[cfg(feature = "opt-membarrier")]
pub(crate) fn slow(membarrier: bool) {
    if !membarrier {
        core::sync::atomic::fence(Ordering::SeqCst);
        return;
    }

    static INIT: std::sync::Once = std::sync::Once::new();

    INIT.call_once(|| {
        match unsafe {
            libc::syscall(
                libc::SYS_membarrier,
                libc::MEMBARRIER_CMD_REGISTER_PRIVATE_EXPEDITED,
                0,
                0,
            )
        } {
            0 => (),
            _ => panic!("membarrier register: {:?}", std::io::Error::last_os_error()),
        }
    });

    match unsafe {
        libc::syscall(
            libc::SYS_membarrier,
            libc::MEMBARRIER_CMD_PRIVATE_EXPEDITED,
            0,
            0,
        )
    } {
        0 => (),
        _ => panic!("membarrier: {:?}", std::io::Error::last_os_error()),
    }
}

#[cfg(not(feature = "opt-membarrier"))]
#[inline(always)]
pub(crate) fn slow(_membarrier: bool) {
    core::sync::atomic::fence(Ordering::SeqCst);
}