Struct SharedHandleTable 

pub struct SharedHandleTable<T: Copy + 'static> { /* private fields */ }

Implementations

impl<T: Copy + 'static> SharedHandleTable<T>

pub fn create( path: impl AsRef<Path>, capacity: usize, ) -> Result<Self, HandleTableError>

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

pub fn capacity(&self) -> usize

pub fn header(&self) -> &HandleHeader

pub fn insert(&self, value: T) -> Result<Handle, HandleTableError>

Insert value, returning a Handle. Errors with Full when the slot table is exhausted.

pub fn get(&self, h: Handle) -> Option<T>

Look up by handle. Returns None when the handle is stale (generation mismatch) or the slot is currently vacant.

pub fn contains(&self, h: Handle) -> bool

True when handle is currently live.

pub fn remove(&self, h: Handle) -> Option<T>

Remove the value at handle. Returns the value if live, None if stale or already removed.

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

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

Non-blocking flush: schedules a writeback via the OS. Note: Windows is only partially async (sync to page cache, not to disk).

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

Trait Implementations

impl<T: Copy + Send + Sync + 'static> AdaptiveInstance for SharedHandleTable<T>

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<T: Copy + Send + 'static> Send for SharedHandleTable<T>

impl<T: Copy + Sync + 'static> Sync for SharedHandleTable<T>