Struct BlockingRWLock 

pub struct BlockingRWLock { /* private fields */ }

Cross-process reader-writer lock with kernel-park slow path.

Implementations

impl BlockingRWLock

pub fn create(base_path: impl AsRef<Path>) -> Result<Self, BlockingRWLockError>

Create a blocking rwlock. Lays out three files under one base path: <base>.rwlock.bin for the state atom, <base>.waker.bin for the waker slots, <base>.wakeup.bin for the magic + generation atom.

pub fn open(base_path: impl AsRef<Path>) -> Result<Self, BlockingRWLockError>

Open an existing blocking rwlock.

pub fn try_read_lock( &self, ) -> Result<BlockingReadGuard<'_>, BlockingRWLockError>

Non-blocking read-lock attempt.

pub fn try_write_lock( &self, ) -> Result<BlockingWriteGuard<'_>, BlockingRWLockError>

Non-blocking write-lock attempt.

pub fn read_park(&self) -> Result<BlockingReadGuard<'_>, BlockingRWLockError>

Read-lock with kernel-park slow path.

pub fn read_park_timeout( &self, timeout: Duration, ) -> Result<BlockingReadGuard<'_>, BlockingRWLockError>

Read-lock with bounded wait.

pub fn write_park(&self) -> Result<BlockingWriteGuard<'_>, BlockingRWLockError>

Write-lock with kernel-park slow path.

pub fn write_park_timeout( &self, timeout: Duration, ) -> Result<BlockingWriteGuard<'_>, BlockingRWLockError>

Write-lock with bounded wait.

pub fn inner(&self) -> &Arc<SharedRWLock>

Inner primitive (sidecar / observability access).