| /rocksdb-6.9/third-party/folly/folly/synchronization/test/ |
| D | DistributedMutexTest.cpp | 49 auto lck = std::unique_lock<_t<std::decay<decltype(mutex)>>>{mutex}; in basicNThreads()
83 auto lck = std::unique_lock<_t<std::decay<decltype(mutex)>>>{mutex}; in lockWithTryAndTimedNThreads()
185 auto lck = std::unique_lock<_t<std::decay<decltype(mutex)>>>{mutex}; in combineWithLockNThreads()
240 auto lck = std::unique_lock<_t<std::decay<decltype(mutex)>>>{mutex}; in combineWithTryLockNThreads()
312 auto lck = std::unique_lock<_t<std::decay<decltype(mutex)>>>{mutex}; in combineWithLockTryAndTimedNThreads()
413 auto state = mutex.lock(); in TEST()
414 mutex.unlock(std::move(state)); in TEST()
421 auto state = mutex.try_lock(); in TEST()
627 auto state = mutex.lock(); in TEST()
645 auto state = mutex.lock(); in TEST()
[all …]
|
| /rocksdb-6.9/utilities/transactions/ |
| D | transaction_db_mutex_impl.cc | 33 std::mutex mutex_;
41 Status Wait(std::shared_ptr<TransactionDBMutex> mutex) override;
43 Status WaitFor(std::shared_ptr<TransactionDBMutex> mutex,
94 std::shared_ptr<TransactionDBMutex> mutex) { in Wait() argument
95 auto mutex_impl = reinterpret_cast<TransactionDBMutexImpl*>(mutex.get()); in Wait()
97 std::unique_lock<std::mutex> lock(mutex_impl->mutex_, std::adopt_lock); in Wait()
107 std::shared_ptr<TransactionDBMutex> mutex, int64_t timeout_time) { in WaitFor() argument
110 auto mutex_impl = reinterpret_cast<TransactionDBMutexImpl*>(mutex.get()); in WaitFor()
111 std::unique_lock<std::mutex> lock(mutex_impl->mutex_, std::adopt_lock); in WaitFor()
|
| D | optimistic_transaction_db_impl.h | 32 std::unique_ptr<std::mutex>(new std::mutex)); in OptimisticTransactionDB()
53 std::unique_lock<std::mutex> LockBucket(size_t idx);
58 std::vector<std::unique_ptr<std::mutex>> bucketed_locks_;
|
| D | pessimistic_transaction.h | 74 std::lock_guard<std::mutex> lock(wait_mutex_); in GetWaitingTxns()
84 std::lock_guard<std::mutex> lock(wait_mutex_); in SetWaitingTxn()
91 std::lock_guard<std::mutex> lock(wait_mutex_); in ClearWaitingTxn()
179 mutable std::mutex wait_mutex_;
|
| D | pessimistic_transaction_db.cc | 548 std::lock_guard<std::mutex> lock(map_mutex_); in InsertExpirableTransaction()
553 std::lock_guard<std::mutex> lock(map_mutex_); in RemoveExpirableTransaction()
559 std::lock_guard<std::mutex> lock(map_mutex_); in TryStealingExpiredTransactionLocks()
580 std::lock_guard<std::mutex> lock(name_map_mutex_); in GetTransactionByName()
593 std::lock_guard<std::mutex> lock(name_map_mutex_); in GetAllPreparedTransactions()
619 std::lock_guard<std::mutex> lock(name_map_mutex_); in RegisterTransaction()
625 std::lock_guard<std::mutex> lock(name_map_mutex_); in UnregisterTransaction()
|
| /rocksdb-6.9/util/ |
| D | channel.h | 24 std::lock_guard<std::mutex> lk(lock_); in sendEof()
30 std::lock_guard<std::mutex> lk(lock_); in eof()
35 std::lock_guard<std::mutex> lk(lock_); in size()
41 std::unique_lock<std::mutex> lk(lock_); in write()
50 std::unique_lock<std::mutex> lk(lock_); in read()
63 mutable std::mutex lock_;
|
| D | threadpool_imp.cc | 124 std::mutex mu_;
152 std::unique_lock<std::mutex> lock(mu_); in JoinThreads()
177 std::lock_guard<std::mutex> lock(mu_); in LowerIOPriority()
183 std::lock_guard<std::mutex> lock(mu_); in LowerCPUPriority()
193 std::unique_lock<std::mutex> lock(mu_); in BGThread()
316 std::lock_guard<std::mutex> lock(mu_); in SetBackgroundThreadsInternal()
329 std::unique_lock<std::mutex> lock(mu_); in GetBackgroundThreads()
361 std::lock_guard<std::mutex> lock(mu_); in Submit()
395 std::lock_guard<std::mutex> lock(mu_); in UnSchedule()
|
| D | timer_queue.h | 82 std::unique_lock<std::mutex> lk(m_mtx); in add()
103 std::unique_lock<std::mutex> lk(m_mtx); in cancel()
128 std::unique_lock<std::mutex> lk(m_mtx); in cancelAll()
148 std::unique_lock<std::mutex> lk(m_mtx); in run()
186 void checkWork(std::unique_lock<std::mutex>* lk) { in checkWork()
221 std::mutex m_mtx;
|
| D | repeatable_thread_test.cc | 28 ROCKSDB_NAMESPACE::port::Mutex mutex; in TEST_F() local
29 ROCKSDB_NAMESPACE::port::CondVar test_cv(&mutex); in TEST_F()
34 ROCKSDB_NAMESPACE::MutexLock l(&mutex); in TEST_F()
46 ROCKSDB_NAMESPACE::MutexLock l(&mutex); in TEST_F()
|
| /rocksdb-6.9/docs/_posts/ |
| D | 2014-05-14-lock.markdown | 12 … writer and multiple readers. There is only one single major lock, the DB mutex (DBImpl.mutex_) pr…
25 This DB mutex used to be scalability bottleneck preventing us from scaling to more than 16 threads.…
27 1. Consolidate reference counters and introduce "super version". For every read operation, mutex wa…
31 … that decreasing reference count of an object usually doesn’t need to be inside the mutex any more.
35 …mutex. As we know, each disk I/O to hard drives takes several milliseconds. It can be even longer …
36 We identified in two situations, we might do disk I/O inside mutex and we removed them:
37 (1) Opening and closing transactional log files. We moved those operations out of the mutex.
38 …mutex. There is a chance that file write will wait for disk I/O to finish before finishing, even i…
40 5. Reduce object creation inside the mutex.
41 …tructors. For these reasons, we try to reduce object creations inside the mutex. Here are two exam…
[all …]
|
| /rocksdb-6.9/test_util/ |
| D | sync_point_impl.cc | 34 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()
|
| D | sync_point_impl.h | 36 std::mutex mutex_;
49 std::lock_guard<std::mutex> lock(mutex_); in SetCallBack()
62 std::lock_guard<std::mutex> lock(mutex_); in ClearTrace()
|
| /rocksdb-6.9/db/ |
| D | logs_with_prep_tracker.cc | 13 std::lock_guard<std::mutex> lock(prepared_section_completed_mutex_); in MarkLogAsHavingPrepSectionFlushed()
24 std::lock_guard<std::mutex> lock(logs_with_prep_mutex_); in MarkLogAsContainingPrepSection()
44 std::lock_guard<std::mutex> lock(logs_with_prep_mutex_); in FindMinLogContainingOutstandingPrep()
50 std::lock_guard<std::mutex> lock2(prepared_section_completed_mutex_); in FindMinLogContainingOutstandingPrep()
|
| D | db_write_test.cc | 48 port::Mutex mutex; in TEST_P() local
49 port::CondVar cv(&mutex); in TEST_P()
68 mutex.Lock(); in TEST_P()
70 mutex.Unlock(); in TEST_P()
104 mutex.Lock(); in TEST_P()
119 mutex.Unlock(); in TEST_P()
|
| D | write_thread.h | 133 std::aligned_storage<sizeof(std::mutex)>::type state_mutex_bytes;
179 StateMutex().~mutex(); in ~Writer()
197 new (&state_mutex_bytes) std::mutex; in CreateMutex()
236 std::mutex& StateMutex() { in StateMutex()
238 return *static_cast<std::mutex*>(static_cast<void*>(&state_mutex_bytes)); in StateMutex()
|
| D | flush_scheduler.cc | 17 std::lock_guard<std::mutex> lock(checking_mutex_); in ScheduleWork()
50 std::lock_guard<std::mutex> lock(checking_mutex_); in TakeNextColumnFamily()
70 std::lock_guard<std::mutex> lock(checking_mutex_); in Empty()
|
| D | forward_iterator_bench.cc | 107 std::lock_guard<std::mutex> guard(queue_mutex_); in run()
176 std::lock_guard<std::mutex> guard(queue_mutex_); in onWrite()
197 std::mutex queue_mutex_;
280 std::unique_lock<std::mutex> lock(cvm_); in run()
305 std::lock_guard<std::mutex> guard(cvm_); in ~StatsThread()
314 std::mutex cvm_;
|
| D | perf_context_test.cc | 588 InstrumentedMutex mutex(nullptr, Env::Default(), stats_code[c]); in TEST_F() local
589 mutex.Lock(); in TEST_F()
594 mutex.Lock(); in TEST_F()
595 mutex.Unlock(); in TEST_F()
605 mutex.Unlock(); in TEST_F()
615 InstrumentedMutex mutex(nullptr, Env::Default(), stats_code[c]); in TEST_F() local
616 InstrumentedCondVar lock(&mutex); in TEST_F()
618 mutex.Lock(); in TEST_F()
620 mutex.Unlock(); in TEST_F()
|
| D | logs_with_prep_tracker.h | 45 std::mutex logs_with_prep_mutex_;
60 std::mutex prepared_section_completed_mutex_;
|
| /rocksdb-6.9/third-party/folly/folly/synchronization/ |
| D | ParkingLot.h | 28 std::mutex mutex_;
37 std::unique_lock<std::mutex> nodeLock(mutex_); in wait()
49 std::lock_guard<std::mutex> nodeLock(mutex_); in wake()
67 std::mutex mutex_;
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()
|
| /rocksdb-6.9/monitoring/ |
| D | thread_status_updater.cc | 24 std::lock_guard<std::mutex> lck(thread_list_mutex_); in RegisterThread()
33 std::lock_guard<std::mutex> lck(thread_list_mutex_); in UnregisterThread()
164 std::lock_guard<std::mutex> lck(thread_list_mutex_); in GetThreadList()
224 std::lock_guard<std::mutex> lck(thread_list_mutex_); in NewColumnFamilyInfo()
234 std::lock_guard<std::mutex> lck(thread_list_mutex_); in EraseColumnFamilyInfo()
254 std::lock_guard<std::mutex> lck(thread_list_mutex_); in EraseDatabaseInfo()
|
| /rocksdb-6.9/file/ |
| D | readahead_raf.cc | 45 std::unique_lock<std::mutex> lk(lock_); in Read()
81 std::unique_lock<std::mutex> lk(lock_); in Prefetch()
99 std::unique_lock<std::mutex> lk(lock_); in InvalidateCache()
148 mutable std::mutex lock_;
|
| D | sequence_file_reader.cc | 90 std::unique_lock<std::mutex> lk(lock_); in Read()
128 std::unique_lock<std::mutex> lk(lock_); in Skip()
161 std::unique_lock<std::mutex> lk(lock_); in InvalidateCache()
210 std::mutex lock_;
|
| /rocksdb-6.9/memory/ |
| D | concurrent_arena.h | 90 mutable SpinMutex mutex; member
152 if (!s->mutex.try_lock()) { in AllocateImpl()
154 s->mutex.lock(); in AllocateImpl()
156 std::unique_lock<SpinMutex> lock(s->mutex, std::adopt_lock); in AllocateImpl()
|
| /rocksdb-6.9/memtable/ |
| D | write_buffer_manager.cc | 25 std::mutex cache_mutex_;
84 std::lock_guard<std::mutex> lock(cache_rep_->cache_mutex_); in ReserveMemWithCache()
107 std::lock_guard<std::mutex> lock(cache_rep_->cache_mutex_); in FreeMemWithCache()
|