Struct tikv::server::lock_manager::waiter_manager::WaiterManager

pub struct WaiterManager {
    wait_table: Rc<RefCell<WaitTable>>,
    detector_scheduler: DetectorScheduler,
    default_wait_for_lock_timeout: ReadableDuration,
    wake_up_delay_duration: ReadableDuration,
}

WaiterManager handles waiting and wake-up of pessimistic lock

Fields

wait_table: Rc<RefCell<WaitTable>>

detector_scheduler: DetectorScheduler

default_wait_for_lock_timeout: ReadableDuration

It is the default and maximum timeout of waiter.

wake_up_delay_duration: ReadableDuration

If more than one waiters are waiting for the same lock, only the oldest one will be waked up immediately when the lock is released. Others will be waked up after wake_up_delay_duration to reduce contention and make the oldest one more likely acquires the lock.

Implementations

impl WaiterManager

pub fn new(
    waiter_count: Arc<AtomicUsize>,
    detector_scheduler: DetectorScheduler,
    cfg: &Config
) -> Self

pub fn normalize_deadline(&self, timeout: WaitTimeout) -> Instant

fn handle_wait_for(&mut self, waiter: Waiter)

fn handle_wake_up(
    &mut self,
    lock_ts: TimeStamp,
    hashes: Vec<u64>,
    commit_ts: TimeStamp
)

fn handle_dump(&self, cb: Callback)

fn handle_deadlock(
    &mut self,
    waiter_ts: TimeStamp,
    lock: Lock,
    deadlock_key_hash: u64,
    wait_chain: Vec<WaitForEntry>
)

fn handle_config_change(
    &mut self,
    timeout: Option<ReadableDuration>,
    delay: Option<ReadableDuration>
)

Trait Implementations

impl Runnable<Task> for WaiterManager

fn run(&mut self, task: Task)

pub fn shutdown(&mut self)

impl Send for WaiterManager