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

[+] Show declaration

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

[−] Expand description

WaiterManager handles waiting and wake-up of pessimistic lock

Fields

wait_table: Rc<RefCell<WaitTable>>

detector_scheduler: DetectorScheduler

default_wait_for_lock_timeout: ReadableDuration

[−] Expand description

It is the default and maximum timeout of waiter.

wake_up_delay_duration: ReadableDuration

[−] Expand description

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[+]

[+] Show hidden undocumented items

fn run(&mut self, task: Task)

pub fn shutdown(&mut self)

impl Send for WaiterManager