Lines Matching refs:mutex_
157 mutex_(stats_, env_, DB_MUTEX_WAIT_MICROS, in DBImpl()
169 bg_cv_(&mutex_), in DBImpl()
174 log_sync_cv_(&mutex_), in DBImpl()
227 error_handler_(this, immutable_db_options_, &mutex_), in DBImpl()
228 atomic_flush_install_cv_(&mutex_) { in DBImpl()
266 InstrumentedMutexLock db_mutex(&mutex_); in Resume()
278 mutex_.Unlock(); in Resume()
280 mutex_.Lock(); in Resume()
297 mutex_.AssertHeld(); in ResumeImpl()
328 mutex_.Unlock(); in ResumeImpl()
330 mutex_.Lock(); in ResumeImpl()
337 mutex_.Unlock(); in ResumeImpl()
339 mutex_.Lock(); in ResumeImpl()
358 mutex_.Unlock(); in ResumeImpl()
369 mutex_.Lock(); in ResumeImpl()
411 InstrumentedMutexLock l(&mutex_); in CancelAllBackgroundWork()
418 mutex_.Unlock(); in CancelAllBackgroundWork()
420 mutex_.Lock(); in CancelAllBackgroundWork()
425 mutex_.Unlock(); in CancelAllBackgroundWork()
427 mutex_.Lock(); in CancelAllBackgroundWork()
446 mutex_.Lock(); in CloseHelper()
452 mutex_.Unlock(); in CloseHelper()
463 mutex_.Lock(); in CloseHelper()
495 mutex_.Unlock(); in CloseHelper()
504 mutex_.Lock(); in CloseHelper()
520 mutex_.Unlock(); in CloseHelper()
527 mutex_.Lock(); in CloseHelper()
572 mutex_.Unlock(); in CloseHelper()
647 InstrumentedMutexLock l(&mutex_); in StartTimedTasks()
697 InstrumentedMutexLock l(&mutex_); in PersistStats()
836 InstrumentedMutexLock l(&mutex_); in DumpStats()
928 InstrumentedMutexLock l(&mutex_); in SetOptions()
934 versions_->LogAndApply(cfd, new_options, &dummy_edit, &mutex_, in SetOptions()
989 InstrumentedMutexLock l(&mutex_); in SetDBOptions()
1045 mutex_.Unlock(); in SetDBOptions()
1047 mutex_.Lock(); in SetDBOptions()
1061 mutex_.Unlock(); in SetDBOptions()
1063 mutex_.Lock(); in SetDBOptions()
1092 write_thread_.EnterUnbatched(&w, &mutex_); in SetDBOptions()
1136 mutex_.AssertHeld(); in FindMinimumEmptyLevelFitting()
1189 InstrumentedMutexLock l(&mutex_); in SyncWAL()
1246 InstrumentedMutexLock l(&mutex_); in SyncWAL()
1275 mutex_.AssertHeld(); in MarkLogsSynced()
1325 mutex_.Lock(); in NewInternalIterator()
1327 mutex_.Unlock(); in NewInternalIterator()
1334 mutex_.AssertHeld(); in SchedulePurge()
1343 mutex_.Lock(); in BackgroundCallPurge()
1349 mutex_.Unlock(); in BackgroundCallPurge()
1351 mutex_.Lock(); in BackgroundCallPurge()
1357 mutex_.Unlock(); in BackgroundCallPurge()
1359 mutex_.Lock(); in BackgroundCallPurge()
1377 mutex_.Unlock(); in BackgroundCallPurge()
1379 mutex_.Lock(); in BackgroundCallPurge()
1389 mutex_.Unlock(); in BackgroundCallPurge()
1489 new IterState(this, &mutex_, super_version, in NewInternalIterator()
1900 mutex_.Lock(); in MultiCFSnapshot()
1940 mutex_.Unlock(); in MultiCFSnapshot()
2333 InstrumentedMutexLock l(&mutex_); in CreateColumnFamilyImpl()
2350 write_thread_.EnterUnbatched(&w, &mutex_); in CreateColumnFamilyImpl()
2354 &mutex_, directories_.GetDbDir(), false, in CreateColumnFamilyImpl()
2379 *handle = new ColumnFamilyHandleImpl(cfd, this, &mutex_); in CreateColumnFamilyImpl()
2445 InstrumentedMutexLock l(&mutex_); in DropColumnFamilyImpl()
2452 write_thread_.EnterUnbatched(&w, &mutex_); in DropColumnFamilyImpl()
2454 &mutex_); in DropColumnFamilyImpl()
2697 mutex_.Lock(); in GetSnapshotImpl()
2702 mutex_.Unlock(); in GetSnapshotImpl()
2713 mutex_.Unlock(); in GetSnapshotImpl()
2733 InstrumentedMutexLock l(&mutex_); in ReleaseSnapshot()
2784 mutex_.Lock(); in GetPropertiesOfAllTables()
2787 mutex_.Unlock(); in GetPropertiesOfAllTables()
2792 mutex_.Lock(); in GetPropertiesOfAllTables()
2794 mutex_.Unlock(); in GetPropertiesOfAllTables()
2806 mutex_.Lock(); in GetPropertiesOfTablesInRange()
2809 mutex_.Unlock(); in GetPropertiesOfTablesInRange()
2814 mutex_.Lock(); in GetPropertiesOfTablesInRange()
2816 mutex_.Unlock(); in GetPropertiesOfTablesInRange()
2837 InstrumentedMutexLock l(&mutex_); in GetOptions()
2844 InstrumentedMutexLock l(&mutex_); in GetDBOptions()
2864 InstrumentedMutexLock l(&mutex_); in GetProperty()
2890 InstrumentedMutexLock l(&mutex_); in GetMapProperty()
2915 mutex_.AssertHeld(); in GetIntPropertyInternal()
2918 InstrumentedMutexLock l(&mutex_); in GetIntPropertyInternal()
2952 InstrumentedMutexLock l(&mutex_); in ResetStats()
2972 InstrumentedMutexLock l(&mutex_); in GetAggregatedIntProperty()
3012 InstrumentedMutexLock l(&mutex_); in CleanupSuperVersion()
3061 InstrumentedMutexLock l(&mutex_); in GetColumnFamilyHandleUnlocked()
3070 new ColumnFamilyHandleImpl(cfd, this, &mutex_)); in GetColumnFamilyHandleUnlocked()
3193 InstrumentedMutexLock l(&mutex_); in DeleteFile()
3238 &edit, &mutex_, directories_.GetDbDir()); in DeleteFile()
3267 InstrumentedMutexLock l(&mutex_); in DeleteFilesInRanges()
3323 &edit, &mutex_, directories_.GetDbDir()); in DeleteFilesInRanges()
3347 InstrumentedMutexLock l(&mutex_); in GetLiveFilesMetaData()
3366 InstrumentedMutexLock l(&mutex_); in GetColumnFamilyMetaData()
3375 mutex_.AssertHeld(); in CheckConsistency()
3509 InstrumentedMutexLock l(&mutex_); in Close()
3656 mutex_.Lock(); in WriteOptionsFile()
3658 mutex_.AssertHeld(); in WriteOptionsFile()
3661 write_thread_.EnterUnbatched(&w, &mutex_); in WriteOptionsFile()
3680 mutex_.Unlock(); in WriteOptionsFile()
3695 mutex_.Lock(); in WriteOptionsFile()
3776 InstrumentedMutexLock l(&mutex_); in RenameTempFileToOptionsFile()
4025 InstrumentedMutexLock l(&mutex_); in IngestExternalFiles()
4076 InstrumentedMutexLock l(&mutex_); in IngestExternalFiles()
4089 InstrumentedMutexLock l(&mutex_); in IngestExternalFiles()
4094 write_thread_.EnterUnbatched(&w, &mutex_); in IngestExternalFiles()
4097 nonmem_write_thread_.EnterUnbatched(&nonmem_w, &mutex_); in IngestExternalFiles()
4139 mutex_.Unlock(); in IngestExternalFiles()
4143 mutex_.Lock(); in IngestExternalFiles()
4147 mutex_.Unlock(); in IngestExternalFiles()
4154 mutex_.Lock(); in IngestExternalFiles()
4216 edit_lists, &mutex_, directories_.GetDbDir()); in IngestExternalFiles()
4307 InstrumentedMutexLock l(&mutex_); in CreateColumnFamilyWithImport()
4324 status = versions_->LogAndApply(cfd, *cf_options, &dummy_edit, &mutex_, in CreateColumnFamilyWithImport()
4343 InstrumentedMutexLock l(&mutex_); in CreateColumnFamilyWithImport()
4347 write_thread_.EnterUnbatched(&w, &mutex_); in CreateColumnFamilyWithImport()
4350 nonmem_write_thread_.EnterUnbatched(&nonmem_w, &mutex_); in CreateColumnFamilyWithImport()
4361 &mutex_, directories_.GetDbDir()); in CreateColumnFamilyWithImport()
4384 InstrumentedMutexLock l(&mutex_); in CreateColumnFamilyWithImport()
4401 InstrumentedMutexLock l(&mutex_); in VerifyChecksum()
4418 InstrumentedMutexLock l(&mutex_); in VerifyChecksum()
4439 InstrumentedMutexLock l(&mutex_); in VerifyChecksum()
4480 mutex_.AssertHeld(); in WaitForIngestFile()
4547 InstrumentedMutexLock l(&mutex_); in ReserveFileNumbersBeforeIngestion()
4561 s = versions_->LogAndApply(cfd, *cf_options, &dummy_edit, &mutex_, in ReserveFileNumbersBeforeIngestion()