Struct tikv::server::gc_worker::applied_lock_collector::AppliedLockCollector

pub struct AppliedLockCollector {
    worker: Mutex<Worker>,
    scheduler: Scheduler<LockCollectorTask>,
    concurrency_manager: ConcurrencyManager,
}

Fields

worker: Mutex<Worker>

scheduler: Scheduler<LockCollectorTask>

concurrency_manager: ConcurrencyManager

Implementations

impl AppliedLockCollector

pub fn new(
    coprocessor_host: &mut CoprocessorHost<RocksEngine>,
    concurrency_manager: ConcurrencyManager
) -> Result<Self>

pub fn stop(&self)

pub fn start_collecting(
    &self,
    max_ts: TimeStamp,
    callback: Box<dyn FnOnce(Result<()>) + Send>
) -> Result<()>

Starts collecting applied locks whose start_ts <= max_ts. Only one max_ts is valid at one time.

pub fn get_collected_locks(
    &self,
    max_ts: TimeStamp,
    callback: Box<dyn FnOnce(Result<(Vec<LockInfo>, bool)>) + Send>
) -> Result<()>

Get the collected locks after start_collecting. Only valid when max_ts matches the max_ts provided to start_collecting. Collects at most MAX_COLLECT_SIZE locks. If there are (even potentially) more locks than MAX_COLLECT_SIZE or any error happens, the flag is_clean will be unset, which represents AppliedLockCollector cannot collect all locks.

pub fn stop_collecting(
    &self,
    max_ts: TimeStamp,
    callback: Box<dyn FnOnce(Result<()>) + Send>
) -> Result<()>

Stop collecting locks. Only valid when max_ts matches the max_ts provided to start_collecting.

Trait Implementations

impl Drop for AppliedLockCollector

fn drop(&mut self)

Executes the destructor for this type.