Struct concurrency_manager::ConcurrencyManager

pub struct ConcurrencyManager {
    max_ts: Arc<AtomicU64>,
    lock_table: LockTable,
}

Fields

max_ts: Arc<AtomicU64>

lock_table: LockTable

Implementations

impl ConcurrencyManager

pub fn new(latest_ts: TimeStamp) -> Self

pub fn max_ts(&self) -> TimeStamp

pub fn update_max_ts(&self, new_ts: TimeStamp)

Updates max_ts with the given new_ts. It has no effect if max_ts >= new_ts or new_ts is TimeStamp::max().

pub async fn lock_key(&self, key: &Key) -> KeyHandleGuard

Acquires a mutex of the key and returns an RAII guard. When the guard goes out of scope, the mutex will be unlocked.

The guard can be used to store Lock in the table. The stored lock is visible to read_key_check and read_range_check.

pub async fn lock_keys(
    &self,
    keys: impl Iterator<Item = &Key>
) -> Vec<KeyHandleGuard>

Acquires mutexes of the keys and returns the RAII guards. The order of the guards is the same with the given keys.

The guards can be used to store Lock in the table. The stored lock is visible to read_key_check and read_range_check.

pub fn read_key_check<E>(
    &self,
    key: &Key,
    check_fn: impl FnOnce(&Lock) -> Result<(), E>
) -> Result<(), E>

Checks if there is a memory lock of the key which blocks the read. The given check_fn should return false iff the lock passed in blocks the read.

pub fn read_range_check<E>(
    &self,
    start_key: Option<&Key>,
    end_key: Option<&Key>,
    check_fn: impl FnMut(&Key, &Lock) -> Result<(), E>
) -> Result<(), E>

Checks if there is a memory lock in the range which blocks the read. The given check_fn should return false iff the lock passed in blocks the read.

pub fn global_min_lock_ts(&self) -> Option<TimeStamp>

Find the minimum start_ts among all locks in memory.

Trait Implementations

impl Clone for ConcurrencyManager

fn clone(&self) -> ConcurrencyManager

Returns a copy of the value.

pub fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.