Struct SharedAtomicU32 

pub struct SharedAtomicU32 { /* private fields */ }

Implementations

impl SharedAtomicU32

pub fn create( path: impl AsRef<Path>, init: u32, ) -> Result<Self, SharedAtomicError>

Obtain the atomic at path, initializing it to init if the path does not yet exist and attaching to it if it does. Attaching leaves the live value in place; init is then unused. A region built for a different width is a LayoutMismatch. reset reinitializes.

pub fn reset( path: impl AsRef<Path>, init: u32, ) -> Result<Self, SharedAtomicError>

Truncate the atomic at path and initialize it to init, discarding the value a live peer holds. For a caller that knows it owns the path.

pub fn open(path: impl AsRef<Path>) -> Result<Self, SharedAtomicError>

pub fn load(&self, ord: Ordering) -> u32

pub fn store(&self, v: u32, ord: Ordering)

pub fn fetch_add(&self, v: u32, ord: Ordering) -> u32

pub fn fetch_sub(&self, v: u32, ord: Ordering) -> u32

pub fn fetch_or(&self, v: u32, ord: Ordering) -> u32

pub fn fetch_and(&self, v: u32, ord: Ordering) -> u32

pub fn fetch_xor(&self, v: u32, ord: Ordering) -> u32

pub fn swap(&self, v: u32, ord: Ordering) -> u32

pub fn compare_exchange( &self, current: u32, new: u32, success: Ordering, failure: Ordering, ) -> Result<u32, u32>

pub fn flush(&self) -> Result<(), SharedAtomicError>

pub fn flush_async(&self) -> Result<(), SharedAtomicError>

Non-blocking flush: schedules a writeback via the OS (msync(MS_ASYNC) on Linux; FlushViewOfFile without FlushFileBuffers on Windows). Note: Windows is only partially async (sync to page cache, not to disk).

Trait Implementations

impl AdaptiveInstance for SharedAtomicU32

fn header(&self) -> &HandshakeHeader

fn ring(&self) -> &ObservationRing

fn make_policy(&self) -> Box<dyn Policy>

fn apply_migration(&self, new_tag: u32)

Called by the sidecar when the policy returns a new strategy tag. Default implementation: just set the tag on the header. Primitives that need heavier migration (data-layout swap) override this to perform the swap before (or after) updating the tag.

impl Send for SharedAtomicU32

impl Sync for SharedAtomicU32