use crate::atomic::StaticAtomicPtr;
use ref_cast::RefCast;
use std::ops::Deref;
use std::sync::atomic::{AtomicUsize, Ordering};
pub struct Flag<T> {
atomic: StaticAtomicPtr<T>,
present: AtomicUsize,
}
impl<T: 'static> Flag<T> {
pub fn is_present(&self) -> bool {
self.present.load(Ordering::Acquire) != 0
}
pub fn repeat_count(&self) -> u32 {
self.present.load(Ordering::Acquire) as u32
}
}
#[derive(RefCast)]
#[repr(transparent)]
pub struct Accessor<T> {
pub flag: T,
}
impl<T: 'static> Flag<T> {
#[doc(hidden)]
pub const fn new(default: &'static T) -> Self {
Flag {
atomic: StaticAtomicPtr::new(default),
present: AtomicUsize::new(0),
}
}
#[doc(hidden)]
pub const fn null() -> Self {
Flag {
atomic: StaticAtomicPtr::null(),
present: AtomicUsize::new(0),
}
}
pub(crate) fn set(&self, value: T) {
let ptr = Box::leak(Box::new(value));
self.atomic.store(ptr, Ordering::Release);
self.present.fetch_add(1, Ordering::Release);
}
}
impl Flag<bool> {
#[allow(clippy::trivially_copy_pass_by_ref)]
pub(crate) fn set_bool(&self, value: &'static bool) {
self.atomic.store(value, Ordering::Release);
self.present.fetch_add(1, Ordering::Release);
}
}
impl<T: 'static> Deref for Flag<T> {
type Target = Accessor<T>;
fn deref(&self) -> &Self::Target {
Accessor::ref_cast(self.atomic.load(Ordering::Acquire))
}
}