Struct CommFileLock 

pub struct CommFileLock { /* private fields */ }

Advisory file lock for concurrent access to .acomm files.

Uses fs2 advisory locks so that multiple processes can safely read/write the same .acomm file without corruption. The sidecar lock file lives at <data_path>.acomm.lock.

Implementations

impl CommFileLock

pub fn acquire(data_path: &Path) -> CommResult<Self>

Acquire an exclusive lock on the .acomm file (blocks until available).

pub fn try_acquire(data_path: &Path) -> CommResult<Self>

Try to acquire an exclusive lock without blocking.

Returns an error immediately if the lock is already held by another process.

pub fn acquire_shared(data_path: &Path) -> CommResult<Self>

Acquire a shared (read) lock on the .acomm file (blocks until available).

Multiple readers can hold a shared lock simultaneously, but a shared lock blocks exclusive writers.

pub fn release(self) -> CommResult<()>

Explicitly release the lock and attempt to clean up the lock file.

pub fn recover_stale(data_path: &Path, max_age_secs: u64) -> CommResult<bool>

Check if the lock file is stale (older than max_age_secs seconds) and remove it if so.

Returns Ok(true) if a stale lock was recovered, Ok(false) otherwise.

Trait Implementations

impl Drop for CommFileLock

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.