Searched refs:RWMutex (Results 1 – 19 of 19) sorted by relevance
142 RWMutex::RWMutex() { in RWMutex() function in ROCKSDB_NAMESPACE::port::RWMutex146 RWMutex::~RWMutex() { PthreadCall("destroy mutex", pthread_rwlock_destroy(&mu_)); } in ~RWMutex()148 void RWMutex::ReadLock() { PthreadCall("read lock", pthread_rwlock_rdlock(&mu_)); } in ReadLock()150 void RWMutex::WriteLock() { PthreadCall("write lock", pthread_rwlock_wrlock(&mu_)); } in WriteLock()152 void RWMutex::ReadUnlock() { PthreadCall("read unlock", pthread_rwlock_unlock(&mu_)); } in ReadUnlock()154 void RWMutex::WriteUnlock() { PthreadCall("write unlock", pthread_rwlock_unlock(&mu_)); } in WriteUnlock()
131 class RWMutex {133 RWMutex();135 RWMutex(const RWMutex&) = delete;136 void operator=(const RWMutex&) = delete;138 ~RWMutex();
51 explicit ReadLock(port::RWMutex *mu) : mu_(mu) { in ReadLock()61 port::RWMutex *const mu_;69 explicit ReadUnlock(port::RWMutex *mu) : mu_(mu) { mu->AssertHeld(); } in ReadUnlock()77 port::RWMutex *const mu_;87 explicit WriteLock(port::RWMutex *mu) : mu_(mu) { in WriteLock()97 port::RWMutex *const mu_;
84 locks_.reset(new port::RWMutex[nlocks_]);86 mlock(locks_.get(), nlocks_ * sizeof(port::RWMutex));114 bool Find(const T& t, T* ret, port::RWMutex** ret_lock) { in Find()119 port::RWMutex& lock = locks_[lock_idx]; in Find()149 port::RWMutex* GetMutex(const T& t) { in GetMutex()233 std::unique_ptr<port::RWMutex[]> locks_; // Granular locks
46 port::RWMutex& lock = GetMutex(h); in Insert()66 port::RWMutex& lock = GetMutex(h); in Find()141 port::RWMutex* GetMutex(T* t) { return hash_table::GetMutex(t); } in GetMutex()157 port::RWMutex& GetMutex(const uint64_t h) { in GetMutex()
94 port::RWMutex* rlock = nullptr; in TEST_F()123 port::RWMutex* rlock = nullptr; in TEST_F()
218 port::RWMutex rwlock_;240 port::RWMutex* rlock; in Lookup()
50 port::RWMutex* rlock = nullptr; in Lookup()
141 port::RWMutex lock_; // Synchronization
138 port::RWMutex rwlock_; // synchronization mutex
175 class RWMutex {177 RWMutex() { InitializeSRWLock(&srwLock_); } in RWMutex() function179 RWMutex(const RWMutex&) = delete;180 void operator=(const RWMutex&) = delete;
409 port::RWMutex* GetLock(const Slice& key);499 std::vector<port::RWMutex> locks_;
446 port::RWMutex* MemTable::GetLock(const Slice& key) { in GetLock()
786 mutable port::RWMutex prepared_mutex_;787 mutable port::RWMutex old_commit_map_mutex_;788 mutable port::RWMutex commit_cache_mutex_;789 mutable port::RWMutex snapshots_mutex_;
162 port::RWMutex prepared_mutex; in TEST()
95 mutable port::RWMutex mutex_;
418 mutable port::RWMutex mutex_;
103 mutable port::RWMutex rwlock_;
121 port::RWMutex cache_mutex_;