interprocess 2.4.0

Interprocess communication toolkit
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

use {
    crate::{AtomicEnum, ReprU8},
    std::sync::atomic::Ordering::{self, *},
};

#[derive(Debug)]
pub(crate) struct NeedsFlush(AtomicEnum<NeedsFlushVal>);
impl NeedsFlush {
    #[inline]
    pub(crate) fn mark_dirty(&self) {
        let _ = self.0.compare_exchange(
            NeedsFlushVal::No,
            NeedsFlushVal::Once,
            AcqRel,
            Relaxed, // We do not care about the loaded value
        );
    }
    #[inline]
    pub(crate) fn on_clone(&self) { self.0.store(NeedsFlushVal::Always, Release); }
    #[inline]
    pub(crate) fn take(&self) -> bool {
        match self.0.compare_exchange(NeedsFlushVal::Once, NeedsFlushVal::No, AcqRel, Acquire) {
            Ok(..) => true,
            Err(NeedsFlushVal::Always) => true,
            Err(.. /* NeedsFlushVal::No */) => false,
        }
    }
    #[inline]
    pub(crate) fn clear(&self) {
        let _ = self.0.compare_exchange(NeedsFlushVal::Once, NeedsFlushVal::No, AcqRel, Relaxed);
    }
    #[inline]
    pub(crate) fn get(&self, ordering: Ordering) -> bool {
        matches!(self.0.load(ordering), NeedsFlushVal::Once | NeedsFlushVal::Always)
    }
    #[inline]
    pub(crate) fn get_mut(&mut self) -> bool {
        matches!(self.0.get_mut(), NeedsFlushVal::Once | NeedsFlushVal::Always)
    }
}
impl From<NeedsFlushVal> for NeedsFlush {
    #[inline]
    fn from(val: NeedsFlushVal) -> Self { Self(AtomicEnum::new(val)) }
}

#[derive(Debug, PartialEq, Eq)]
#[repr(u8)]
pub(crate) enum NeedsFlushVal {
    No,
    Once,
    Always,
}
unsafe impl ReprU8 for NeedsFlushVal {}