| /rocksdb-6.9/monitoring/ |
| D | statistics.cc | 242 MutexLock lock(&aggregate_lock_); in getTickerCount() local
257 MutexLock lock(&aggregate_lock_); in histogramData() local
273 MutexLock lock(&aggregate_lock_); in getHistogramString() local
279 MutexLock lock(&aggregate_lock_); in setTickerCount() local
301 MutexLock lock(&aggregate_lock_); in getAndResetTickerCount() local
336 MutexLock lock(&aggregate_lock_); in Reset() local
356 MutexLock lock(&aggregate_lock_); in ToString() local
394 MutexLock lock(&aggregate_lock_); in getTickerMap() local
|
| D | thread_status_updater_debug.cc | 17 std::unique_lock<std::mutex> lock(thread_list_mutex_); in TEST_VerifyColumnFamilyInfoMap() local
|
| D | histogram_windowing.cc | 40 std::lock_guard<std::mutex> lock(mutex_); in Clear() local
75 std::lock_guard<std::mutex> lock(mutex_); in Merge() local
|
| D | histogram.cc | 240 std::lock_guard<std::mutex> lock(mutex_); in Clear() local
260 std::lock_guard<std::mutex> lock(mutex_); in Merge() local
|
| /rocksdb-6.9/env/ |
| D | mock_env.cc | 40 MutexLock lock(&mutex_); in Ref() local
48 MutexLock lock(&mutex_); in Lock() local
59 MutexLock lock(&mutex_); in Unlock() local
82 MutexLock lock(&mutex_); in Truncate() local
97 MutexLock lock(&mutex_); in CorruptBuffer() local
104 MutexLock lock(&mutex_); in Read() local
124 MutexLock lock(&mutex_); in Write() local
136 MutexLock lock(&mutex_); in Append() local
430 MutexLock lock(&mutex_); in NewSequentialFile() local
447 MutexLock lock(&mutex_); in NewRandomAccessFile() local
[all …]
|
| D | fs_posix.cc | 98 static int LockOrUnlock(int fd, bool lock) { in LockOrUnlock()
748 FileLock** lock, IODebugContext* /*dbg*/) override { in LockFile()
810 IOStatus UnlockFile(FileLock* lock, const IOOptions& /*opts*/, in UnlockFile()
|
| /rocksdb-6.9/test_util/ |
| D | sync_point_impl.cc | 34 std::lock_guard<std::mutex> lock(mutex_); in LoadDependency() local
48 std::lock_guard<std::mutex> lock(mutex_); in LoadDependencyAndMarkers() local
76 std::unique_lock<std::mutex> lock(mutex_); in ClearCallBack() local
84 std::unique_lock<std::mutex> lock(mutex_); in ClearAllCallBacks() local
96 std::unique_lock<std::mutex> lock(mutex_); in Process() local
|
| /rocksdb-6.9/db/ |
| D | flush_scheduler.cc | 17 std::lock_guard<std::mutex> lock(checking_mutex_); in ScheduleWork() local
50 std::lock_guard<std::mutex> lock(checking_mutex_); in TakeNextColumnFamily() local
70 std::lock_guard<std::mutex> lock(checking_mutex_); in Empty() local
|
| D | logs_with_prep_tracker.cc | 13 std::lock_guard<std::mutex> lock(prepared_section_completed_mutex_); in MarkLogAsHavingPrepSectionFlushed() local
24 std::lock_guard<std::mutex> lock(logs_with_prep_mutex_); in MarkLogAsContainingPrepSection() local
44 std::lock_guard<std::mutex> lock(logs_with_prep_mutex_); in FindMinLogContainingOutstandingPrep() local
|
| D | trim_history_scheduler.cc | 15 std::lock_guard<std::mutex> lock(checking_mutex_); in ScheduleWork() local
22 std::lock_guard<std::mutex> lock(checking_mutex_); in TakeNextColumnFamily() local
|
| D | compact_files_test.cc | 41 std::lock_guard<std::mutex> lock(mutex_); in OnFlushCompleted() local
46 std::lock_guard<std::mutex> lock(mutex_); in GetFlushedFiles() local
54 std::lock_guard<std::mutex> lock(mutex_); in ClearFlushedFiles() local
|
| D | write_thread.cc | 240 MutexLock lock(&stall_mu_); in LinkOne() local
359 MutexLock lock(&stall_mu_); in EndWriteStall() local
|
| /rocksdb-6.9/util/ |
| D | threadpool_imp.cc | 152 std::unique_lock<std::mutex> lock(mu_); in JoinThreads() local
177 std::lock_guard<std::mutex> lock(mu_); in LowerIOPriority() local
183 std::lock_guard<std::mutex> lock(mu_); in LowerCPUPriority() local
193 std::unique_lock<std::mutex> lock(mu_); in BGThread() local
316 std::lock_guard<std::mutex> lock(mu_); in SetBackgroundThreadsInternal() local
329 std::unique_lock<std::mutex> lock(mu_); in GetBackgroundThreads() local
361 std::lock_guard<std::mutex> lock(mu_); in Submit() local
395 std::lock_guard<std::mutex> lock(mu_); in UnSchedule() local
|
| D | mutexlock.h | 116 void lock() { in lock() function
|
| /rocksdb-6.9/utilities/transactions/ |
| D | pessimistic_transaction_db.cc | 548 std::lock_guard<std::mutex> lock(map_mutex_); in InsertExpirableTransaction() local
553 std::lock_guard<std::mutex> lock(map_mutex_); in RemoveExpirableTransaction() local
559 std::lock_guard<std::mutex> lock(map_mutex_); in TryStealingExpiredTransactionLocks() local
580 std::lock_guard<std::mutex> lock(name_map_mutex_); in GetTransactionByName() local
593 std::lock_guard<std::mutex> lock(name_map_mutex_); in GetAllPreparedTransactions() local
619 std::lock_guard<std::mutex> lock(name_map_mutex_); in RegisterTransaction() local
625 std::lock_guard<std::mutex> lock(name_map_mutex_); in UnregisterTransaction() local
|
| D | transaction_db_mutex_impl.cc | 97 std::unique_lock<std::mutex> lock(mutex_impl->mutex_, std::adopt_lock); in Wait() local
111 std::unique_lock<std::mutex> lock(mutex_impl->mutex_, std::adopt_lock); in WaitFor() local
|
| D | transaction_lock_mgr.cc | 97 std::lock_guard<std::mutex> lock(paths_buffer_mutex_); in AddNewPath() local
108 std::lock_guard<std::mutex> lock(paths_buffer_mutex_); in Resize() local
145 std::lock_guard<std::mutex> lock(paths_buffer_mutex_); in PrepareBuffer() local
418 std::lock_guard<std::mutex> lock(wait_txn_map_mutex_); in DecrementWaiters() local
444 std::lock_guard<std::mutex> lock(wait_txn_map_mutex_); in IncrementWaiters() local
|
| /rocksdb-6.9/memtable/ |
| D | write_buffer_manager.cc | 84 std::lock_guard<std::mutex> lock(cache_rep_->cache_mutex_); in ReserveMemWithCache() local
107 std::lock_guard<std::mutex> lock(cache_rep_->cache_mutex_); in FreeMemWithCache() local
|
| /rocksdb-6.9/utilities/persistent_cache/ |
| D | hash_table_evictable.h | 46 port::RWMutex& lock = GetMutex(h); in Insert() local
66 port::RWMutex& lock = GetMutex(h); in Find() local
|
| D | hash_table.h | 119 port::RWMutex& lock = locks_[lock_idx]; in Find() local
|
| /rocksdb-6.9/utilities/ |
| D | env_timed.cc | 120 Status LockFile(const std::string& fname, FileLock** lock) override { in LockFile()
125 Status UnlockFile(FileLock* lock) override { in UnlockFile()
|
| D | env_librados.cc | 332 std::lock_guard<std::mutex> lock(_mutex); in Append() local
366 std::lock_guard<std::mutex> lock(_mutex); in Truncate() local
409 std::lock_guard<std::mutex> lock(_mutex); in Flush() local
431 std::lock_guard<std::mutex> lock(_mutex); in Sync() local
466 std::lock_guard<std::mutex> lock(_mutex); in GetFileSize() local
1420 FileLock** lock) in LockFile()
1458 Status EnvLibrados::UnlockFile(FileLock* lock) in UnlockFile()
|
| D | env_mirror_test.cc | 154 FileLock* lock; in TEST_F() local
|
| /rocksdb-6.9/db_stress_tool/ |
| D | no_batched_ops_stress.cc | 306 std::unique_ptr<MutexLock>& lock) override { in TestPut()
384 std::unique_ptr<MutexLock>& lock) override { in TestDelete()
460 std::unique_ptr<MutexLock>& lock) override { in TestDeleteRange()
524 std::unique_ptr<MutexLock>& lock) override { in TestIngestExternalFile()
|
| /rocksdb-6.9/third-party/folly/folly/synchronization/detail/ |
| D | ProxyLockable-inl.h | 114 void ProxyLockableUniqueLock<Mutex>::lock() { in lock() function
|