Searched refs:db_mutex_ (Results 1 – 6 of 6) sorted by relevance
| /rocksdb-6.9/db/ |
| D | error_handler.cc | 125 db_mutex_->AssertHeld(); in CancelErrorRecovery()
134 db_mutex_->Unlock(); in CancelErrorRecovery()
136 db_mutex_->Lock(); in CancelErrorRecovery()
163 db_mutex_->AssertHeld(); in SetBGError()
220 db_mutex_, &auto_recovery); in SetBGError()
243 db_mutex_->AssertHeld(); in SetBGError()
259 db_mutex_, &auto_recovery); in SetBGError()
270 db_mutex_, &auto_recovery); in SetBGError()
332 db_mutex_->AssertHeld(); in ClearBGError()
340 old_bg_error, db_mutex_); in ClearBGError()
[all …]
|
| D | flush_job.cc | 108 db_mutex_(db_mutex), in FlushJob()
164 db_mutex_->AssertHeld(); in PickMemTable()
196 db_mutex_->AssertHeld(); in Run()
243 cfd_, mutable_cf_options_, mems_, prep_tracker, versions_, db_mutex_, in Run()
291 db_mutex_->AssertHeld(); in Cancel()
299 db_mutex_->AssertHeld(); in WriteLevel0Table()
305 db_mutex_->Unlock(); in WriteLevel0Table()
411 db_mutex_->Lock(); in WriteLevel0Table()
450 db_mutex_->AssertHeld(); in GetFlushJobInfo()
|
| D | error_handler.h | 25 db_mutex_(db_mutex), in ErrorHandler()
69 InstrumentedMutex* db_mutex_; variable
|
| D | flush_job.h | 117 InstrumentedMutex* db_mutex_; variable
|
| /rocksdb-6.9/db/compaction/ |
| D | compaction_job.cc | 328 db_mutex_(db_mutex), in CompactionJob()
518 db_mutex_->Unlock(); in GenSubcompactionBoundaries()
522 db_mutex_->Lock(); in GenSubcompactionBoundaries()
715 db_mutex_->AssertHeld(); in Install()
1400 InstrumentedMutexLock l(db_mutex_); in FinishCompactionOutputFile()
1413 db_mutex_->AssertHeld(); in InstallCompactionResults()
1447 db_mutex_, db_directory_); in InstallCompactionResults()
|
| D | compaction_job.h | 170 InstrumentedMutex* db_mutex_; variable
|