| /rocksdb-6.9/util/ |
| D | thread_local_test.cc | 147 mu.Lock(); in TEST_F()
175 p.mu->Lock(); in TEST_F()
210 p.mu->Lock(); in TEST_F()
227 mu1.Lock(); in TEST_F()
233 mu2.Lock(); in TEST_F()
360 mu.Lock(); in TEST_F()
373 mu.Lock(); in TEST_F()
435 mu.Lock(); in TEST_F()
450 mu.Lock(); in TEST_F()
494 mu.Lock(); in TEST_F()
[all …]
|
| D | mutexlock.h | 32 this->mu_->Lock(); in MutexLock()
|
| /rocksdb-6.9/db/ |
| D | db_filesnapshot.cc | 82 mutex_.Lock(); in GetLiveFiles()
93 mutex_.Lock(); in GetLiveFiles()
104 mutex_.Lock(); in GetLiveFiles()
|
| D | event_helpers.cc | 58 db_mutex->Lock(); in NotifyOnBackgroundError()
215 db_mutex->Lock(); in NotifyOnErrorRecoveryCompleted()
|
| D | flush_job_test.cc | 230 mutex_.Lock(); in TEST_F()
296 mutex_.Lock(); in TEST_F()
372 mutex_.Lock(); in TEST_F()
482 mutex_.Lock(); in TEST_F()
|
| D | db_write_test.cc | 68 mutex.Lock(); in TEST_P()
104 mutex.Lock(); in TEST_P()
|
| D | column_family.cc | 62 mutex_->Lock(); in ~ColumnFamilyHandleImpl()
75 mutex_->Lock(); in ~ColumnFamilyHandleImpl()
663 sv->db_mutex->Lock(); in UnrefAndTryDelete()
1180 db->mutex()->Lock(); in GetThreadLocalSuperVersion()
1191 db->mutex()->Lock(); in GetThreadLocalSuperVersion()
|
| D | version_set_test.cc | 822 mutex_.Lock(); in TEST_F()
1013 mu.Lock(); in TEST_F()
1070 mu.Lock(); in TEST_F()
1099 mu.Lock(); in TEST_F()
1157 mu.Lock(); in TEST_F()
1207 mu.Lock(); in TEST_F()
1266 mutex_.Lock(); in TEST_P()
1317 mutex_.Lock(); in TEST_P()
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_write.cc | 220 mutex_.Lock(); in WriteImpl()
424 mutex_.Lock(); in WriteImpl()
477 mutex_.Lock(); in PipelinedWriteImpl()
548 mutex_.Lock(); in PipelinedWriteImpl()
837 mutex_.Lock(); in WriteStatusCheck()
848 mutex_.Lock(); in IOStatusCheck()
861 mutex_.Lock(); in MemTableInsertStatusCheck()
1182 mutex_.Lock(); in WriteRecoverableState()
1431 mutex_.Lock(); in DelayWrite()
1697 mutex_.Lock(); in SwitchMemtable()
[all …]
|
| D | db_impl.cc | 280 mutex_.Lock(); in Resume()
369 mutex_.Lock(); in ResumeImpl()
446 mutex_.Lock(); in CloseHelper()
463 mutex_.Lock(); in CloseHelper()
504 mutex_.Lock(); in CloseHelper()
1325 mutex_.Lock(); in NewInternalIterator()
1343 mutex_.Lock(); in BackgroundCallPurge()
2784 mutex_.Lock(); in GetPropertiesOfAllTables()
2792 mutex_.Lock(); in GetPropertiesOfAllTables()
2806 mutex_.Lock(); in GetPropertiesOfTablesInRange()
[all …]
|
| D | db_impl_open.cc | 662 mutex_.Lock(); in PersistentStatsProcessFormatVersion()
688 mutex_.Lock(); in InitPersistStatsColumnFamily()
1145 log_write_mutex_.Lock(); in RestoreAliveLogFiles()
1261 mutex_.Lock(); in WriteLevel0TableForRecovery()
1425 impl->mutex_.Lock(); in Open()
1458 impl->mutex_.Lock(); in Open()
1479 impl->log_write_mutex_.Lock(); in Open()
1579 impl->mutex_.Lock(); in Open()
|
| D | db_impl_compaction_flush.cc | 123 mutex_.Lock(); in SyncClosedLogs()
627 mutex_.Lock(); in NotifyOnFlushBegin()
668 mutex_.Lock(); in NotifyOnFlushCompleted()
705 mutex_.Lock(); in CompactRange()
1051 mutex_.Lock(); in CompactFilesImpl()
1208 mutex_.Lock(); in NotifyOnCompactionBegin()
1247 mutex_.Lock(); in NotifyOnCompactionCompleted()
2316 mutex_.Lock(); in BackgroundCallFlush()
2341 mutex_.Lock(); in BackgroundCallFlush()
2389 mutex_.Lock(); in BackgroundCallCompaction()
[all …]
|
| D | db_impl_debug.cc | 34 log_write_mutex_.Lock(); in TEST_WALBufferIsEmpty()
178 void DBImpl::TEST_LockMutex() { mutex_.Lock(); } in TEST_LockMutex()
|
| D | db_impl_files.cc | 205 log_write_mutex_.Lock(); in FindObsoleteFiles()
575 mutex_.Lock(); in DeleteObsoleteFiles()
715 mutex_.Lock(); in CleanupFilesAfterRecovery()
|
| /rocksdb-6.9/monitoring/ |
| D | instrumented_mutex.cc | 23 void InstrumentedMutex::Lock() { in Lock() function in ROCKSDB_NAMESPACE::InstrumentedMutex
34 mutex_.Lock(); in LockInternal()
|
| D | instrumented_mutex.h | 32 void Lock();
56 mutex_->Lock(); in InstrumentedMutexLock()
|
| /rocksdb-6.9/utilities/transactions/ |
| D | transaction_db_mutex_impl.cc | 24 Status Lock() override;
64 Status TransactionDBMutexImpl::Lock() { in Lock() function in ROCKSDB_NAMESPACE::TransactionDBMutexImpl
|
| D | transaction_lock_mgr.cc | 328 result = stripe->stripe_mutex->Lock(); in AcquireWithTimeout()
641 stripe->stripe_mutex->Lock(); in UnLock()
682 stripe->stripe_mutex->Lock(); in UnLock()
713 j->stripe_mutex->Lock(); in GetLockStatusData()
|
| /rocksdb-6.9/logging/ |
| D | env_logger.h | 67 mutex_.Lock(); in CloseHelper()
135 mutex_.Lock(); in Logv()
|
| /rocksdb-6.9/memtable/ |
| D | inlineskiplist_test.cc | 532 mu_.Lock(); in Wait()
540 mu_.Lock(); in Change()
547 mu_.Lock(); in AdjustPendingWriters()
556 mu_.Lock(); in WaitForPendingWriters()
|
| D | skiplist_test.cc | 324 mu_.Lock(); in Wait()
332 mu_.Lock(); in Change()
|
| /rocksdb-6.9/port/ |
| D | port_example.h | 37 void Lock();
|
| /rocksdb-6.9/include/rocksdb/utilities/ |
| D | transaction_db_mutex.h | 28 virtual Status Lock() = 0;
|
| /rocksdb-6.9/docs/_posts/ |
| D | 2014-06-27-avoid-expensive-locks-in-get.markdown | 19 <span class="zw-portion">mutex_.Lock();
46 mutex_.Lock();
|
| /rocksdb-6.9/file/ |
| D | sst_file_manager_impl.cc | 321 mu_.Lock(); in ClearError()
394 mu_.Lock(); in StartErrorRecovery()
|