Home
last modified time | relevance | path

Searched refs:lock_ (Results 1 – 10 of 10) sorted by relevance

/rocksdb-6.9/utilities/persistent_cache/
Dlrulist.h39 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()
116 lock_.AssertHeld(); in UnlinkImpl()
141 MutexLock _(&lock_); in PushBack()
150 lock_.AssertHeld(); in PushBackImpl()
167 mutable port::Mutex lock_; // synchronization primitive variable
Dblock_cache_tier_file_buffer.h66 : cond_empty_(&lock_), buffer_size_(buffer_size) { in CacheWriteBufferAllocator()
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()
121 port::Mutex lock_; // Sync lock
Dpersistent_cache_util.h25 : cond_empty_(&lock_), max_size_(max_size) {}
30 MutexLock _(&lock_); in Push()
43 MutexLock _(&lock_); in Pop()
55 MutexLock _(&lock_); in Size()
60 mutable port::Mutex lock_;
Dblock_cache_tier.cc27 WriteLock _(&lock_); in Open()
131 WriteLock _(&lock_); in Close()
227 WriteLock _(&lock_); in InsertImpl()
317 WriteLock _(&lock_); in Erase()
325 lock_.AssertHeld(); in NewCacheFile()
357 WriteLock _(&lock_); in Reserve()
Dpersistent_cache_test.cc79 MutexLock _(&lock_); in Logv()
84 port::Mutex lock_; member in ROCKSDB_NAMESPACE::ConsoleLogger
Dblock_cache_tier.h141 port::RWMutex lock_; // Synchronization variable
/rocksdb-6.9/util/
Dchannel.h24 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_; variable
/rocksdb-6.9/file/
Dreadahead_raf.cc45 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_; member in ROCKSDB_NAMESPACE::__anon832aeac60111::ReadaheadRandomAccessFile
Dsequence_file_reader.cc90 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_; member in ROCKSDB_NAMESPACE::__anon88823ea90111::ReadaheadSequentialFile
/rocksdb-6.9/db/
Ddb_test2.cc1784 MutexLock _(&lock_); in Insert()
1798 MutexLock _(&lock_); in Lookup()
1817 port::Mutex lock_; member in ROCKSDB_NAMESPACE::MockPersistentCache