Lines Matching refs:mutex_
84 mutex_.AssertHeld(); in SyncClosedLogs()
101 mutex_.Unlock(); in SyncClosedLogs()
123 mutex_.Lock(); in SyncClosedLogs()
145 mutex_.AssertHeld(); in FlushMemTableToOutputFile()
152 &mutex_, &shutting_down_, snapshot_seqs, earliest_write_conflict_snapshot, in FlushMemTableToOutputFile()
291 mutex_.AssertHeld(); in AtomicFlushMemTablesToOutputFiles()
342 max_memtable_id, file_options_for_compaction_, versions_.get(), &mutex_, in AtomicFlushMemTablesToOutputFiles()
525 versions_.get(), &mutex_, tmp_file_meta, in AtomicFlushMemTablesToOutputFiles()
594 mutex_.AssertHeld(); in NotifyOnFlushBegin()
605 mutex_.Unlock(); in NotifyOnFlushBegin()
627 mutex_.Lock(); in NotifyOnFlushBegin()
646 mutex_.AssertHeld(); in NotifyOnFlushCompleted()
657 mutex_.Unlock(); in NotifyOnFlushCompleted()
668 mutex_.Lock(); in NotifyOnFlushCompleted()
705 mutex_.Lock(); in CompactRange()
707 mutex_.Unlock(); in CompactRange()
841 InstrumentedMutexLock l(&mutex_); in CompactRange()
882 InstrumentedMutexLock l(&mutex_); in CompactFiles()
902 InstrumentedMutexLock l(&mutex_); in CompactFiles()
937 mutex_.AssertHeld(); in CompactFilesImpl()
1029 GetDataDir(c->column_family_data(), c->output_path_id()), stats_, &mutex_, in CompactFilesImpl()
1045 mutex_.Unlock(); in CompactFilesImpl()
1051 mutex_.Lock(); in CompactFilesImpl()
1117 InstrumentedMutexLock guard_lock(&mutex_); in PauseBackgroundWork()
1128 InstrumentedMutexLock guard_lock(&mutex_); in ContinueBackgroundWork()
1152 mutex_.AssertHeld(); in NotifyOnCompactionBegin()
1163 mutex_.Unlock(); in NotifyOnCompactionBegin()
1208 mutex_.Lock(); in NotifyOnCompactionBegin()
1226 mutex_.AssertHeld(); in NotifyOnCompactionCompleted()
1237 mutex_.Unlock(); in NotifyOnCompactionCompleted()
1247 mutex_.Lock(); in NotifyOnCompactionCompleted()
1272 InstrumentedMutexLock guard_lock(&mutex_); in ReFitLevel()
1323 status = versions_->LogAndApply(cfd, mutable_cf_options, &edit, &mutex_, in ReFitLevel()
1354 InstrumentedMutexLock l(&mutex_); in Level0StopWriteTrigger()
1466 InstrumentedMutexLock l(&mutex_); in RunManualCompaction()
1483 TEST_SYNC_POINT_CALLBACK("DBImpl::RunManualCompaction:NotScheduled", &mutex_); in RunManualCompaction()
1595 InstrumentedMutexLock guard_lock(&mutex_); in FlushMemTable()
1600 write_thread_.EnterUnbatched(&w, &mutex_); in FlushMemTable()
1602 nonmem_write_thread_.EnterUnbatched(&nonmem_w, &mutex_); in FlushMemTable()
1683 InstrumentedMutexLock lock_guard(&mutex_); in FlushMemTable()
1718 InstrumentedMutexLock guard_lock(&mutex_); in AtomicFlushMemTables()
1723 write_thread_.EnterUnbatched(&w, &mutex_); in AtomicFlushMemTables()
1725 nonmem_write_thread_.EnterUnbatched(&nonmem_w, &mutex_); in AtomicFlushMemTables()
1785 InstrumentedMutexLock lock_guard(&mutex_); in AtomicFlushMemTables()
1803 InstrumentedMutexLock l(&mutex_); in WaitUntilFlushWouldNotStallWrites()
1883 InstrumentedMutexLock l(&mutex_); in WaitForFlushMemTables()
1950 mutex_.AssertHeld(); in MaybeScheduleFlushOrCompaction()
2032 mutex_.AssertHeld(); in GetBGJobLimits()
2135 mutex_.AssertHeld(); in SchedulePendingPurge()
2202 mutex_.AssertHeld(); in BackgroundFlush()
2288 InstrumentedMutexLock l(&mutex_); in BackgroundCallFlush()
2308 mutex_.Unlock(); in BackgroundCallFlush()
2316 mutex_.Lock(); in BackgroundCallFlush()
2329 mutex_.Unlock(); in BackgroundCallFlush()
2341 mutex_.Lock(); in BackgroundCallFlush()
2367 InstrumentedMutexLock l(&mutex_); in BackgroundCallCompaction()
2387 mutex_.Unlock(); in BackgroundCallCompaction()
2389 mutex_.Lock(); in BackgroundCallCompaction()
2399 mutex_.Unlock(); in BackgroundCallCompaction()
2407 mutex_.Lock(); in BackgroundCallCompaction()
2428 mutex_.Unlock(); in BackgroundCallCompaction()
2440 mutex_.Lock(); in BackgroundCallCompaction()
2485 mutex_.AssertHeld(); in BackgroundCompaction()
2694 &mutex_, directories_.GetDbDir()); in BackgroundCompaction()
2752 &mutex_, directories_.GetDbDir()); in BackgroundCompaction()
2821 &mutex_, &error_handler_, snapshot_seqs, in BackgroundCompaction()
2832 mutex_.Unlock(); in BackgroundCompaction()
2837 mutex_.Lock(); in BackgroundCompaction()
3101 mutex_.AssertHeld(); in InstallSuperVersionAndScheduleWork()
3115 cfd->InstallSuperVersion(sv_context, &mutex_, mutable_cf_options); in InstallSuperVersionAndScheduleWork()
3157 InstrumentedMutexLock l(&mutex_); in SetSnapshotChecker()
3169 mutex_.AssertHeld(); in GetSnapshotContext()