| /rocksdb-6.9/third-party/folly/folly/synchronization/detail/ |
| D | ProxyLockable-inl.h | 46 template <typename Mutex>
53 template <typename Mutex>
60 template <typename Mutex>
66 template <typename Mutex>
67 ProxyLockableUniqueLock<Mutex>& ProxyLockableUniqueLock<Mutex>::operator=(
74 template <typename Mutex>
81 template <typename Mutex>
91 template <typename Mutex>
102 template <typename Mutex>
113 template <typename Mutex>
[all …]
|
| D | ProxyLockable.h | 31 template <typename Mutex>
34 using mutex_type = Mutex;
138 template <typename Mutex>
139 class ProxyLockableLockGuard : private ProxyLockableUniqueLock<Mutex> {
141 using mutex_type = Mutex;
|
| /rocksdb-6.9/util/ |
| D | thread_local.cc | 102 static port::Mutex* Mutex();
142 port::Mutex mutex_;
353 Mutex()->AssertHeld(); in AddThreadData()
362 Mutex()->AssertHeld(); in RemoveThreadData()
441 MutexLock l(Mutex()); in Scrape()
454 MutexLock l(Mutex()); in Fold()
470 MutexLock l(Mutex()); in SetHandler()
475 Mutex()->AssertHeld(); in GetHandler()
484 MutexLock l(Mutex()); in GetId()
495 MutexLock l(Mutex()); in PeekId()
[all …]
|
| D | thread_local_test.cc | 30 Params(port::Mutex* m, port::CondVar* c, int* u, int n, in Params()
42 port::Mutex* mu;
65 port::Mutex mu; in TEST_F()
116 port::Mutex mu; in TEST_F()
161 port::Mutex mu1; in TEST_F()
166 port::Mutex mu2; in TEST_F()
264 port::Mutex mu; in TEST_F()
299 port::Mutex mu; in TEST_F()
349 port::Mutex mu; in TEST_F()
424 port::Mutex mu; in TEST_F()
[all …]
|
| D | mutexlock.h | 31 explicit MutexLock(port::Mutex *mu) : mu_(mu) { in MutexLock()
41 port::Mutex *const mu_;
|
| D | repeatable_thread_test.cc | 28 ROCKSDB_NAMESPACE::port::Mutex mutex; in TEST_F()
|
| D | rate_limiter.h | 79 mutable port::Mutex request_mutex_;
|
| /rocksdb-6.9/port/ |
| D | port_posix.h | 108 class Mutex {
110 explicit Mutex(bool adaptive = kDefaultToAdaptiveMutex);
112 Mutex(const Mutex&) = delete;
113 void operator=(const Mutex&) = delete;
115 ~Mutex();
152 explicit CondVar(Mutex* mu);
161 Mutex* mu_;
|
| D | port_posix.cc | 54 Mutex::Mutex(bool adaptive) { in Mutex() function in ROCKSDB_NAMESPACE::port::Mutex
74 Mutex::~Mutex() { PthreadCall("destroy mutex", pthread_mutex_destroy(&mu_)); } in ~Mutex()
76 void Mutex::Lock() { in Lock()
83 void Mutex::Unlock() { in Unlock()
90 void Mutex::AssertHeld() { in AssertHeld()
96 CondVar::CondVar(Mutex* mu) in CondVar()
|
| D | port_example.h | 30 class Mutex {
32 Mutex();
33 ~Mutex();
51 explicit CondVar(Mutex* mu);
|
| /rocksdb-6.9/port/win/ |
| D | port_win.h | 124 class Mutex {
127 /* implicit */ Mutex(bool adaptive = kDefaultToAdaptiveMutex)
133 ~Mutex();
158 Mutex(const Mutex&) = delete;
159 void operator=(const Mutex&) = delete;
199 explicit CondVar(Mutex* mu) : mu_(mu) { in CondVar()
217 Mutex* mu_;
|
| D | port_win.cc | 69 Mutex::~Mutex() {} in ~Mutex()
|
| /rocksdb-6.9/java/rocksjni/ |
| D | comparatorjnicallback.h | 105 inline void MaybeLockForReuse(const std::unique_ptr<port::Mutex>& mutex,
107 inline void MaybeUnlockForReuse(const std::unique_ptr<port::Mutex>& mutex,
116 std::unique_ptr<port::Mutex> mtx_compare;
118 std::unique_ptr<port::Mutex> mtx_shortest;
120 std::unique_ptr<port::Mutex> mtx_short;
|
| D | comparatorjnicallback.cc | 103 mtx_compare = std::unique_ptr<port::Mutex>(new port::Mutex(adaptive)); in ComparatorJniCallback()
104 mtx_shortest = std::unique_ptr<port::Mutex>(new port::Mutex(adaptive)); in ComparatorJniCallback()
105 mtx_short = std::unique_ptr<port::Mutex>(new port::Mutex(adaptive)); in ComparatorJniCallback()
540 const std::unique_ptr<port::Mutex>& mutex, const bool cond) const { in MaybeLockForReuse()
549 const std::unique_ptr<port::Mutex>& mutex, const bool cond) const { in MaybeUnlockForReuse()
|
| /rocksdb-6.9/db_stress_tool/ |
| D | db_stress_shared_state.h | 163 ptr.reset(new port::Mutex); in SharedState()
178 port::Mutex* GetMutex() { return &mu_; } in GetMutex()
220 port::Mutex* GetMutexForKey(int cf, int64_t key) { in GetMutexForKey()
332 port::Mutex mu_;
358 std::vector<std::vector<std::unique_ptr<port::Mutex>>> key_locks_;
|
| /rocksdb-6.9/third-party/folly/folly/synchronization/test/ |
| D | DistributedMutexTest.cpp | 92 using Mutex = _t<std::decay<decltype(mutex)>>; in lockWithTryAndTimedNThreads() typedef
93 auto lck = std::unique_lock<Mutex>{mutex, std::defer_lock}; in lockWithTryAndTimedNThreads()
104 using Mutex = _t<std::decay<decltype(mutex)>>; in lockWithTryAndTimedNThreads() typedef
105 auto lck = std::unique_lock<Mutex>{mutex, std::defer_lock}; in lockWithTryAndTimedNThreads()
273 using Mutex = _t<std::decay<decltype(mutex)>>; in combineWithTryLockNThreads() typedef
274 auto lck = std::unique_lock<Mutex>{mutex, std::defer_lock}; in combineWithTryLockNThreads()
359 using Mutex = _t<std::decay<decltype(mutex)>>; in combineWithLockTryAndTimedNThreads() typedef
360 auto lck = std::unique_lock<Mutex>{mutex, std::defer_lock}; in combineWithLockTryAndTimedNThreads()
371 using Mutex = _t<std::decay<decltype(mutex)>>; in combineWithLockTryAndTimedNThreads() typedef
372 auto lck = std::unique_lock<Mutex>{mutex, std::defer_lock}; in combineWithLockTryAndTimedNThreads()
|
| /rocksdb-6.9/cache/ |
| D | cache_bench.cc | 68 port::Mutex* GetMutex() { in GetMutex()
105 port::Mutex mu_;
|
| /rocksdb-6.9/test_util/ |
| D | fault_injection_test_fs.h | 92 port::Mutex mutex_;
242 port::Mutex mutex_;
|
| /rocksdb-6.9/utilities/persistent_cache/ |
| D | persistent_cache_util.h | 60 mutable port::Mutex lock_;
|
| D | block_cache_tier_file_buffer.h | 121 port::Mutex lock_; // Sync lock
|
| /rocksdb-6.9/monitoring/ |
| D | instrumented_mutex.h | 45 port::Mutex mutex_;
|
| /rocksdb-6.9/utilities/blob_db/ |
| D | blob_db_impl.h | 421 mutable port::Mutex write_mutex_;
481 mutable port::Mutex delete_file_mutex_;
|
| /rocksdb-6.9/db/ |
| D | wal_manager.h | 99 port::Mutex read_first_record_cache_mutex_;
|
| /rocksdb-6.9/logging/ |
| D | auto_roll_logger.h | 155 mutable port::Mutex mutex_;
|
| /rocksdb-6.9/file/ |
| D | sst_file_manager_impl.h | 154 port::Mutex mu_;
|