interprocess 2.2.2

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
54
55
56
57
58
59
60
61
62
63
64
65
66

use crate::{AtomicEnum, ReprU8};
use 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 {}