Home
last modified time | relevance | path

Searched refs:mutex_ (Results 1 – 25 of 74) sorted by relevance

123

/rocksdb-6.9/third-party/folly/folly/synchronization/detail/
DProxyLockable-inl.h57 mutex_ = std::addressof(mtx); in ProxyLockableUniqueLock()
70 mutex_ = folly::exchange(other.mutex_, nullptr);
78 mutex_ = std::addressof(mtx); in ProxyLockableUniqueLock()
85 mutex_ = std::addressof(mtx); in ProxyLockableUniqueLock()
96 mutex_ = std::addressof(mtx); in ProxyLockableUniqueLock()
107 mutex_ = std::addressof(mtx); in ProxyLockableUniqueLock()
118 proxy_.emplace(mutex_->lock()); in lock()
126 mutex_->unlock(std::move(*proxy_)); in unlock()
135 if (auto state = mutex_->try_lock()) { in try_lock()
176 std::swap(mutex_, other.mutex_); in swap()
[all …]
/rocksdb-6.9/db/db_impl/
Ddb_impl_debug.cc20 InstrumentedMutexLock l(&mutex_); in TEST_GetLevel0TotalSize()
26 InstrumentedMutexLock l(&mutex_); in TEST_SwitchWAL()
53 InstrumentedMutexLock l(&mutex_); in TEST_MaxNextLevelOverlappingBytes()
62 InstrumentedMutexLock l(&mutex_); in TEST_GetFilesMetaData()
106 InstrumentedMutexLock l(&mutex_); in TEST_SwitchMemtable()
168 InstrumentedMutexLock l(&mutex_); in TEST_WaitForCompact()
195 InstrumentedMutexLock l(&mutex_); in TEST_LogsToFreeSize()
200 InstrumentedMutexLock l(&mutex_); in TEST_LogfileNumber()
243 InstrumentedMutexLock l(&mutex_); in TEST_GetLatestMutableCFOptions()
251 InstrumentedMutexLock l(&mutex_); in TEST_BGCompactionsAllowed()
[all …]
Ddb_impl.cc278 mutex_.Unlock(); in Resume()
280 mutex_.Lock(); in Resume()
358 mutex_.Unlock(); in ResumeImpl()
369 mutex_.Lock(); in ResumeImpl()
446 mutex_.Lock(); in CloseHelper()
452 mutex_.Unlock(); in CloseHelper()
463 mutex_.Lock(); in CloseHelper()
1325 mutex_.Lock(); in NewInternalIterator()
1343 mutex_.Lock(); in BackgroundCallPurge()
2784 mutex_.Lock(); in GetPropertiesOfAllTables()
[all …]
Ddb_impl_compaction_flush.cc101 mutex_.Unlock(); in SyncClosedLogs()
123 mutex_.Lock(); in SyncClosedLogs()
605 mutex_.Unlock(); in NotifyOnFlushBegin()
627 mutex_.Lock(); in NotifyOnFlushBegin()
657 mutex_.Unlock(); in NotifyOnFlushCompleted()
668 mutex_.Lock(); in NotifyOnFlushCompleted()
1045 mutex_.Unlock(); in CompactFilesImpl()
1051 mutex_.Lock(); in CompactFilesImpl()
1163 mutex_.Unlock(); in NotifyOnCompactionBegin()
1208 mutex_.Lock(); in NotifyOnCompactionBegin()
[all …]
Ddb_impl_write.cc220 mutex_.Lock(); in WriteImpl()
243 mutex_.Unlock(); in WriteImpl()
424 mutex_.Lock(); in WriteImpl()
477 mutex_.Lock(); in PipelinedWriteImpl()
837 mutex_.Lock(); in WriteStatusCheck()
848 mutex_.Lock(); in IOStatusCheck()
861 mutex_.Lock(); in MemTableInsertStatusCheck()
1681 mutex_.Unlock(); in SwitchMemtable()
1697 mutex_.Lock(); in SwitchMemtable()
1774 mutex_.Unlock(); in SwitchMemtable()
[all …]
Ddb_impl_files.cc32 mutex_.AssertHeld(); in MinObsoleteSstNumberToKeep()
50 mutex_.AssertHeld(); in FindObsoleteFiles()
497 InstrumentedMutexLock guard_lock(&mutex_); in PurgeObsoleteFiles()
506 InstrumentedMutexLock guard_lock(&mutex_); in PurgeObsoleteFiles()
556 InstrumentedMutexLock l(&mutex_); in PurgeObsoleteFiles()
566 mutex_.AssertHeld(); in DeleteObsoleteFiles()
570 mutex_.Unlock(); in DeleteObsoleteFiles()
575 mutex_.Lock(); in DeleteObsoleteFiles()
669 mutex_.AssertHeld(); in CleanupFilesAfterRecovery()
707 mutex_.Unlock(); in CleanupFilesAfterRecovery()
[all …]
Ddb_impl_open.cc355 mutex_.AssertHeld(); in Recover()
602 mutex_.AssertHeld(); in PersistentStatsProcessFormatVersion()
606 mutex_.Unlock(); in PersistentStatsProcessFormatVersion()
662 mutex_.Lock(); in PersistentStatsProcessFormatVersion()
667 mutex_.AssertHeld(); in InitPersistStatsColumnFamily()
682 mutex_.Unlock(); in InitPersistStatsColumnFamily()
688 mutex_.Lock(); in InitPersistStatsColumnFamily()
712 mutex_.AssertHeld(); in RecoverLogFiles()
1142 mutex_.AssertHeld(); in RestoreAliveLogFiles()
1194 mutex_.AssertHeld(); in WriteLevel0TableForRecovery()
[all …]
Ddb_impl_secondary.cc33 mutex_.AssertHeld(); in Recover()
55 versions_->GetColumnFamilySet()->GetDefault(), this, &mutex_); in Recover()
180 mutex_.AssertHeld(); in RecoverLogFiles()
460 mutex_.AssertHeld(); in CheckConsistency()
510 InstrumentedMutexLock lock_guard(&mutex_); in TryCatchUpWithPrimary()
512 ->ReadAndApply(&mutex_, &manifest_reader_, &cfds_changed); in TryCatchUpWithPrimary()
545 cfd->InstallSuperVersion(&sv_context, &mutex_); in TryCatchUpWithPrimary()
555 InstrumentedMutexLock lock_guard(&mutex_); in TryCatchUpWithPrimary()
618 impl->mutex_.Lock(); in OpenAsSecondary()
635 cfd->InstallSuperVersion(&sv_context, &impl->mutex_); in OpenAsSecondary()
[all …]
/rocksdb-6.9/monitoring/
Dinstrumented_mutex.h23 : mutex_(adaptive), stats_(nullptr), env_(nullptr), in mutex_() function
29 : mutex_(adaptive), stats_(stats), env_(env), in mutex_() function
35 mutex_.Unlock(); in Unlock()
39 mutex_.AssertHeld(); in AssertHeld()
45 port::Mutex mutex_; variable
55 explicit InstrumentedMutexLock(InstrumentedMutex* mutex) : mutex_(mutex) { in InstrumentedMutexLock()
56 mutex_->Lock(); in InstrumentedMutexLock()
60 mutex_->Unlock(); in ~InstrumentedMutexLock()
64 InstrumentedMutex* const mutex_;
72 : cond_(&(instrumented_mutex->mutex_)), in InstrumentedCondVar()
/rocksdb-6.9/db/
Ddb_filesnapshot.cc27 InstrumentedMutexLock l(&mutex_); in DisableFileDeletions()
45 InstrumentedMutexLock l(&mutex_); in EnableFileDeletions()
82 mutex_.Lock(); in GetLiveFiles()
90 mutex_.Unlock(); in GetLiveFiles()
93 mutex_.Lock(); in GetLiveFiles()
100 mutex_.Unlock(); in GetLiveFiles()
104 mutex_.Lock(); in GetLiveFiles()
114 mutex_.Unlock(); in GetLiveFiles()
146 mutex_.Unlock(); in GetLiveFiles()
157 InstrumentedMutexLock l(&mutex_); in GetSortedWalFiles()
[all …]
Dflush_job_test.cc126 InstrumentedMutex mutex_; member in ROCKSDB_NAMESPACE::FlushJobTest
145 InstrumentedMutexLock l(&mutex_); in TEST_F()
230 mutex_.Lock(); in TEST_F()
233 mutex_.Unlock(); in TEST_F()
296 mutex_.Lock(); in TEST_F()
299 mutex_.Unlock(); in TEST_F()
360 &memtable_ids[k], env_options_, versions_.get(), &mutex_, in TEST_F()
372 mutex_.Lock(); in TEST_F()
402 mutex_.Unlock(); in TEST_F()
482 mutex_.Lock(); in TEST_F()
[all …]
/rocksdb-6.9/env/
Dmock_env.cc40 MutexLock lock(&mutex_); in Ref()
48 MutexLock lock(&mutex_); in Lock()
59 MutexLock lock(&mutex_); in Unlock()
82 MutexLock lock(&mutex_); in Truncate()
97 MutexLock lock(&mutex_); in CorruptBuffer()
104 MutexLock lock(&mutex_); in Read()
124 MutexLock lock(&mutex_); in Write()
136 MutexLock lock(&mutex_); in Append()
430 MutexLock lock(&mutex_); in NewSequentialFile()
447 MutexLock lock(&mutex_); in NewRandomAccessFile()
[all …]
/rocksdb-6.9/cache/
Dlru_cache.cc121 MutexLock l(&mutex_); in EraseUnRefEntries()
149 MutexLock l(&mutex_); in ApplyToAllCacheEntries()
157 MutexLock l(&mutex_); in TEST_GetLRUList()
163 MutexLock l(&mutex_); in TEST_GetLRUSize()
174 MutexLock l(&mutex_); in GetHighPriPoolRatio()
267 MutexLock l(&mutex_); in SetStrictCapacityLimit()
272 MutexLock l(&mutex_); in Lookup()
288 MutexLock l(&mutex_); in Ref()
296 MutexLock l(&mutex_); in SetHighPriorityPoolRatio()
445 MutexLock l(&mutex_); in GetUsage()
[all …]
Dclock_cache.cc348 mutable port::Mutex mutex_; member in ROCKSDB_NAMESPACE::__anon9da5ff120111::ClockCacheShard
409 mutex_.Lock(); in ApplyToAllCacheEntries()
420 mutex_.Unlock(); in ApplyToAllCacheEntries()
426 mutex_.AssertHeld(); in RecycleHandle()
486 MutexLock l(&mutex_); in Unref()
495 mutex_.AssertHeld(); in UnsetInCache()
509 mutex_.AssertHeld(); in TryEvict()
552 MutexLock l(&mutex_); in SetCapacity()
570 MutexLock l(&mutex_); in Insert()
679 MutexLock l(&mutex_); in EraseAndConfirm()
[all …]
/rocksdb-6.9/logging/
Denv_logger.h48 mutex_.AssertHeld(); in FlushLocked()
60 MutexLock l(&mutex_); in Flush()
67 mutex_.Lock(); in CloseHelper()
69 mutex_.Unlock(); in CloseHelper()
135 mutex_.Lock(); in Logv()
143 mutex_.Unlock(); in Logv()
152 MutexLock l(&mutex_); in GetLogFileSize()
158 mutable port::Mutex mutex_; // Mutex to protect the shared variables below. variable
Dauto_roll_logger.h50 MutexLock l(&mutex_); in GetLogFileSize()
60 MutexLock l(&mutex_); in Flush()
78 MutexLock l(&mutex_); in GetInfoLogLevel()
87 MutexLock lock(&mutex_); in SetInfoLogLevel()
155 mutable port::Mutex mutex_; variable
/rocksdb-6.9/util/
Drepeatable_thread.h31 mutex_(env), in function_()
32 cond_var_(&mutex_), in function_()
43 InstrumentedMutexLock l(&mutex_); in cancel()
65 InstrumentedMutexLock l(&mutex_);
82 InstrumentedMutexLock l(&mutex_); in wait()
121 InstrumentedMutexLock l(&mutex_); in thread()
137 InstrumentedMutex mutex_; variable
/rocksdb-6.9/utilities/transactions/
Dtransaction_db_mutex_impl.cc28 void UnLock() override { mutex_.unlock(); } in UnLock()
33 std::mutex mutex_; member in ROCKSDB_NAMESPACE::TransactionDBMutexImpl
65 mutex_.lock(); in Lock()
73 locked = mutex_.try_lock(); in TryLockFor()
82 mutex_.lock(); in TryLockFor()
97 std::unique_lock<std::mutex> lock(mutex_impl->mutex_, std::adopt_lock); in Wait()
111 std::unique_lock<std::mutex> lock(mutex_impl->mutex_, std::adopt_lock); in WaitFor()
/rocksdb-6.9/test_util/
Dsync_point_impl.cc34 std::lock_guard<std::mutex> lock(mutex_); in LoadDependency()
48 std::lock_guard<std::mutex> lock(mutex_); in LoadDependencyAndMarkers()
76 std::unique_lock<std::mutex> lock(mutex_); in ClearCallBack()
84 std::unique_lock<std::mutex> lock(mutex_); in ClearAllCallBacks()
96 std::unique_lock<std::mutex> lock(mutex_); in Process()
120 mutex_.unlock(); in Process()
122 mutex_.lock(); in Process()
Dfault_injection_test_fs.cc89 MutexLock l(&mutex_); in Append()
232 MutexLock l(&mutex_); in NewWritableFile()
253 MutexLock l(&mutex_); in ReopenWritableFile()
274 MutexLock l(&mutex_); in NewRandomRWFile()
338 MutexLock l(&mutex_); in WritableFileClosed()
346 MutexLock l(&mutex_); in WritableFileSynced()
357 MutexLock l(&mutex_); in WritableFileAppended()
369 MutexLock l(&mutex_); in DropUnsyncedFileData()
382 MutexLock l(&mutex_); in DropRandomUnsyncedFileData()
415 MutexLock l(&mutex_); in ResetState()
[all …]
Dfault_injection_test_env.cc243 MutexLock l(&mutex_); in NewWritableFile()
264 MutexLock l(&mutex_); in ReopenWritableFile()
285 MutexLock l(&mutex_); in NewRandomRWFile()
326 MutexLock l(&mutex_); in RenameFile()
345 MutexLock l(&mutex_); in WritableFileClosed()
353 MutexLock l(&mutex_); in WritableFileSynced()
364 MutexLock l(&mutex_); in WritableFileAppended()
379 MutexLock l(&mutex_); in DropFileData()
407 MutexLock l(&mutex_); in DeleteFilesCreatedAfterLastDirSync()
423 MutexLock l(&mutex_); in ResetState()
[all …]
Dfault_injection_test_fs.h92 port::Mutex mutex_; variable
208 MutexLock l(&mutex_); in SyncDir()
217 MutexLock l(&mutex_); in IsFilesystemActive()
229 MutexLock l(&mutex_);
237 MutexLock l(&mutex_); in SetFileSystemIOError()
242 port::Mutex mutex_;
/rocksdb-6.9/utilities/simulator_cache/
Dsim_cache.cc26 MutexLock l(&mutex_); in ~CacheActivityLogger()
40 MutexLock l(&mutex_); in StartLogging()
61 MutexLock l(&mutex_); in StopLogging()
74 MutexLock l(&mutex_); in ReportLookup()
99 MutexLock l(&mutex_); in ReportAdd()
113 MutexLock l(&mutex_); in bg_status()
119 mutex_.AssertHeld(); in MaxLoggingSizeReached()
126 mutex_.AssertHeld(); in StopLoggingInternal()
141 port::Mutex mutex_; member in ROCKSDB_NAMESPACE::__anona55187990111::CacheActivityLogger
/rocksdb-6.9/utilities/blob_db/
Dblob_db_impl.cc833 WriteLock wl(&mutex_); in SelectBlobFile()
871 WriteLock wl(&mutex_); in SelectBlobFileTTL()
1156 ReadLock l(&mutex_); in GetCompactionContext()
1165 ReadLock l(&mutex_); in GetCompactionContext()
1232 WriteLock l(&mutex_); in CheckSizeAndEvictBlobFiles()
1619 ReadLock rl(&mutex_); in SanityCheck()
1886 ReadLock rl(&mutex_); in ReclaimOpenFiles()
1981 ReadLock rl(&mutex_); in CopyBlobFiles()
2055 ReadLock l(&mutex_); in TEST_GetBlobFiles()
2065 ReadLock l(&mutex_); in TEST_GetLiveImmNonTTLFiles()
[all …]
/rocksdb-6.9/third-party/folly/folly/synchronization/
DParkingLot.h28 std::mutex mutex_; member
37 std::unique_lock<std::mutex> nodeLock(mutex_); in wait()
49 std::lock_guard<std::mutex> nodeLock(mutex_); in wake()
67 std::mutex mutex_; member
257 std::unique_lock<std::mutex> bucketLock(bucket.mutex_); in park_until()
274 std::lock_guard<std::mutex> bucketLock(bucket.mutex_); in park_until()
296 std::lock_guard<std::mutex> bucketLock(bucket.mutex_); in unpark()

123