| /rocksdb-6.9/file/ |
| D | sst_file_manager_impl.cc | 50 MutexLock l(&mu_); in Close()
67 MutexLock l(&mu_); in OnAddFile()
76 MutexLock l(&mu_); in OnAddFile()
84 MutexLock l(&mu_); in OnDeleteFile()
92 MutexLock l(&mu_); in OnCompactionCompletion()
132 MutexLock l(&mu_); in SetMaxAllowedSpaceUsage()
138 MutexLock l(&mu_); in SetCompactionBufferSize()
143 MutexLock l(&mu_); in IsMaxAllowedSpaceReached()
151 MutexLock l(&mu_); in IsMaxAllowedSpaceReachedIncludingCompactions()
162 MutexLock l(&mu_); in EnoughRoomForCompaction()
[all …]
|
| /rocksdb-6.9/env/ |
| D | mock_env.cc | 40 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/ |
| D | lru_cache.cc | 121 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 …]
|
| D | sharded_cache.cc | 30 MutexLock l(&capacity_mutex_); in SetCapacity()
39 MutexLock l(&capacity_mutex_); in SetStrictCapacityLimit()
79 MutexLock l(&capacity_mutex_); in GetCapacity()
84 MutexLock l(&capacity_mutex_); in HasStrictCapacityLimit()
133 MutexLock l(&capacity_mutex_); in GetPrintableOptions()
|
| D | cache_bench.cc | 166 MutexLock l(shared.GetMutex()); in Run()
201 MutexLock l(shared->GetMutex()); in ThreadBody()
213 MutexLock l(shared->GetMutex()); in ThreadBody()
|
| D | clock_cache.cc | 486 MutexLock l(&mutex_); in Unref()
552 MutexLock l(&mutex_); in SetCapacity()
570 MutexLock l(&mutex_); in Insert()
679 MutexLock l(&mutex_); in EraseAndConfirm()
693 MutexLock l(&mutex_); in EraseUnRefEntries()
|
| /rocksdb-6.9/util/ |
| D | thread_local.cc | 382 MutexLock l(Mutex()); in GetThreadLocal()
389 MutexLock l(Mutex()); in GetThreadLocal()
411 MutexLock l(Mutex()); in Reset()
421 MutexLock l(Mutex()); in Swap()
432 MutexLock l(Mutex()); in CompareAndSwap()
441 MutexLock l(Mutex()); in Scrape()
454 MutexLock l(Mutex()); in Fold()
470 MutexLock l(Mutex()); in SetHandler()
484 MutexLock l(Mutex()); in GetId()
495 MutexLock l(Mutex()); in PeekId()
[all …]
|
| D | mutexlock.h | 29 class MutexLock {
31 explicit MutexLock(port::Mutex *mu) : mu_(mu) { in MutexLock() function
35 MutexLock(const MutexLock &) = delete;
36 void operator=(const MutexLock &) = delete;
38 ~MutexLock() { this->mu_->Unlock(); } in ~MutexLock()
|
| /rocksdb-6.9/utilities/persistent_cache/ |
| D | lrulist.h | 39 MutexLock _(&lock_); in ~LRUList()
50 MutexLock _(&lock_); in Push()
69 MutexLock _(&lock_); in Unlink()
75 MutexLock _(&lock_); in Pop()
100 MutexLock _(&lock_); in Touch()
107 MutexLock _(&lock_); in IsEmpty()
141 MutexLock _(&lock_); in PushBack()
|
| D | block_cache_tier_file_buffer.h | 67 MutexLock _(&lock_); in CacheWriteBufferAllocator()
80 MutexLock _(&lock_); in ~CacheWriteBufferAllocator()
89 MutexLock _(&lock_); in Allocate()
102 MutexLock _(&lock_); in Deallocate()
110 MutexLock _(&lock_); in WaitUntilUsable()
|
| D | persistent_cache_util.h | 30 MutexLock _(&lock_); in Push()
43 MutexLock _(&lock_); in Pop()
55 MutexLock _(&lock_); in Size()
|
| /rocksdb-6.9/test_util/ |
| D | fault_injection_test_fs.cc | 89 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 …]
|
| D | fault_injection_test_env.cc | 243 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 …]
|
| D | testutil.h | 412 MutexLock l(&mutex_); in IsSleeping()
416 MutexLock l(&mutex_); in DoSleep()
427 MutexLock l(&mutex_); in WaitUntilSleeping()
438 MutexLock l(&mutex_); in TimedWaitUntilSleeping()
447 MutexLock l(&mutex_); in WakeUp()
452 MutexLock l(&mutex_); in WaitUntilDone()
461 MutexLock l(&mutex_); in TimedWaitUntilDone()
470 MutexLock l(&mutex_); in WokenUp()
475 MutexLock l(&mutex_); in Reset()
|
| D | fault_injection_test_fs.h | 208 MutexLock l(&mutex_); in SyncDir()
217 MutexLock l(&mutex_); in IsFilesystemActive()
229 MutexLock l(&mutex_);
237 MutexLock l(&mutex_); in SetFileSystemIOError()
|
| D | fault_injection_test_env.h | 188 MutexLock l(&mutex_); in SyncDir()
197 MutexLock l(&mutex_); in IsFilesystemActive()
209 MutexLock l(&mutex_);
|
| /rocksdb-6.9/monitoring/ |
| D | statistics.cc | 242 MutexLock lock(&aggregate_lock_); in getTickerCount()
257 MutexLock lock(&aggregate_lock_); in histogramData()
273 MutexLock lock(&aggregate_lock_); in getHistogramString()
279 MutexLock lock(&aggregate_lock_); in setTickerCount()
301 MutexLock lock(&aggregate_lock_); in getAndResetTickerCount()
336 MutexLock lock(&aggregate_lock_); in Reset()
356 MutexLock lock(&aggregate_lock_); in ToString()
394 MutexLock lock(&aggregate_lock_); in getTickerMap()
|
| /rocksdb-6.9/db_stress_tool/ |
| D | no_batched_ops_stress.cc | 110 MutexLock l(thread->shared->GetMutex()); in MaybeClearOneColumnFamily()
306 std::unique_ptr<MutexLock>& lock) override { in TestPut()
317 new MutexLock(shared->GetMutexForKey(rand_column_family, rand_key))); in TestPut()
384 std::unique_ptr<MutexLock>& lock) override { in TestDelete()
460 std::unique_ptr<MutexLock>& lock) override { in TestDeleteRange()
462 std::vector<std::unique_ptr<MutexLock>> range_locks; in TestDeleteRange()
482 range_locks.emplace_back(new MutexLock( in TestDeleteRange()
513 std::unique_ptr<MutexLock>& /* lock */) override { in TestIngestExternalFile() argument
524 std::unique_ptr<MutexLock>& lock) override { in TestIngestExternalFile()
540 std::vector<std::unique_ptr<MutexLock>> range_locks; in TestIngestExternalFile()
[all …]
|
| D | db_stress_driver.cc | 23 MutexLock l(shared->GetMutex()); in ThreadBody()
35 MutexLock l(shared->GetMutex()); in ThreadBody()
48 MutexLock l(shared->GetMutex()); in ThreadBody()
89 MutexLock l(shared.GetMutex()); in RunStressTest()
145 MutexLock l(shared.GetMutex()); in RunStressTest()
|
| D | db_stress_test_base.h | 90 std::unique_ptr<MutexLock>& lock) = 0;
95 std::unique_ptr<MutexLock>& lock) = 0;
100 std::unique_ptr<MutexLock>& lock) = 0;
105 std::unique_ptr<MutexLock>& lock) = 0;
|
| D | batched_ops_stress.cc | 26 std::unique_ptr<MutexLock>& /* lock */) override { in TestPut() argument
66 std::unique_ptr<MutexLock>& /* lock */) override { in TestDelete() argument
93 std::unique_ptr<MutexLock>& /* lock */) override { in TestDeleteRange() argument
104 std::unique_ptr<MutexLock>& /* lock */) override { in TestIngestExternalFile() argument
|
| /rocksdb-6.9/logging/ |
| D | auto_roll_logger.h | 50 MutexLock l(&mutex_); in GetLogFileSize()
60 MutexLock l(&mutex_); in Flush()
78 MutexLock l(&mutex_); in GetInfoLogLevel()
87 MutexLock lock(&mutex_); in SetInfoLogLevel()
|
| /rocksdb-6.9/utilities/simulator_cache/ |
| D | sim_cache.cc | 26 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()
|
| /rocksdb-6.9/db/ |
| D | wal_manager.cc | 42 MutexLock l(&read_first_record_cache_mutex_); in DeleteFile()
197 MutexLock l(&read_first_record_cache_mutex_); in PurgeObsoleteWALFiles()
225 MutexLock l(&read_first_record_cache_mutex_); in PurgeObsoleteWALFiles()
265 MutexLock l(&read_first_record_cache_mutex_); in PurgeObsoleteWALFiles()
381 MutexLock l(&read_first_record_cache_mutex_); in ReadFirstRecord()
412 MutexLock l(&read_first_record_cache_mutex_); in ReadFirstRecord()
|
| /rocksdb-6.9/utilities/backupable/ |
| D | backupable_db_test.cc | 172 MutexLock l(&mutex_); in NewSequentialFile()
191 MutexLock l(&mutex_); in NewWritableFile()
210 MutexLock l(&mutex_); in NewRandomAccessFile()
222 MutexLock l(&mutex_); in DeleteFile()
232 MutexLock l(&mutex_); in DeleteDir()
240 MutexLock l(&mutex_); in AssertWrittenFiles()
248 MutexLock l(&mutex_); in ClearWrittenFiles()
253 MutexLock l(&mutex_); in SetLimitWrittenFiles()
258 MutexLock l(&mutex_); in SetLimitDeleteFiles()
263 MutexLock l(&mutex_); in SetDeleteFileFailure()
[all …]
|