Searched refs:WriteLock (Results 1 – 18 of 18) sorted by relevance
85 class WriteLock {87 explicit WriteLock(port::RWMutex *mu) : mu_(mu) { in WriteLock() function88 this->mu_->WriteLock(); in WriteLock()91 WriteLock(const WriteLock &) = delete;92 void operator=(const WriteLock &) = delete;94 ~WriteLock() { this->mu_->WriteUnlock(); } in ~WriteLock()
48 WriteLock _(&lock); in Insert()89 WriteLock _(&hash_table::locks_[idx]);114 WriteLock _(&hash_table::locks_[lock_idx]); in Clear()130 WriteLock _(&hash_table::locks_[i]); in AssertEmptyLRU()
104 WriteLock _(&locks_[lock_idx]); in Insert()140 WriteLock _(&locks_[lock_idx]); in Erase()160 WriteLock _(&locks_[lock_idx]); in Clear()224 WriteLock _(&locks_[i % nlocks_]); in AssertEmptyBuckets()
27 WriteLock _(&lock_); in Open()131 WriteLock _(&lock_); in Close()227 WriteLock _(&lock_); in InsertImpl()317 WriteLock _(&lock_); in Erase()357 WriteLock _(&lock_); in Reserve()
204 WriteLock _(&rwlock_); in Open()273 WriteLock _(&rwlock_); in ~WriteableCacheFile()289 WriteLock _(&rwlock_); in Create()318 WriteLock _(&rwlock_); in Append()427 WriteLock _(&rwlock_); in BufferWriteDone()
193 WriteLock _(&rwlock_); in Insert()199 WriteLock _(&rwlock_); in Erase()
129 WriteLock _(&rwlock_); in Add()
459 WriteLock lock(&mutex_); in ProcessFlushJobInfo()498 WriteLock lock(&mutex_); in ProcessCompactionJobInfo()833 WriteLock wl(&mutex_); in SelectBlobFile()871 WriteLock wl(&mutex_); in SelectBlobFileTTL()1232 WriteLock l(&mutex_); in CheckSizeAndEvictBlobFiles()1733 WriteLock lock(&mutex_); in CloseBlobFileIfNeeded()1820 WriteLock lock(&mutex_); in EvictExpiredFiles()1910 WriteLock wl(&mutex_); in DeleteObsoleteFiles()1935 WriteLock wl(&mutex_); in DeleteObsoleteFiles()1969 WriteLock wl(&mutex_); in DeleteObsoleteFiles()[all …]
261 WriteLock wl(&blob_db_impl->mutex_); in CloseAndRegisterNewBlobFile()
204 WriteLock lockbfile_w(&mutex_); in GetReader()
111 WriteLock l(&rwlock_); in Insert()123 WriteLock l(&rwlock_); in MarkReadOnly()158 WriteLock l(&vrep_->rwlock_); in DoSort()
426 WriteLock wl(&prepared_mutex_); in CheckPreparedAgainstMax()514 WriteLock wl(&prepared_mutex_); in AddCommitted()558 WriteLock wl(&prepared_mutex_); in RemovePrepared()642 WriteLock wl(&old_commit_map_mutex_); in AdvanceMaxEvictedSeq()777 WriteLock wl(&old_commit_map_mutex_); in ReleaseSnapshotInternal()823 WriteLock wl(&snapshots_mutex_); in UpdateSnapshots()957 WriteLock wl(&old_commit_map_mutex_); in MaybeUpdateOldCommitMap()
187 WriteLock wl(&prepared_mutex); in TEST()
141 void WriteLock();
150 void RWMutex::WriteLock() { PthreadCall("write lock", pthread_rwlock_wrlock(&mu_)); } in WriteLock() function in ROCKSDB_NAMESPACE::port::RWMutex
184 void WriteLock() { AcquireSRWLockExclusive(&srwLock_); } in WriteLock() function
979 WriteLock wl(GetLock(lkey.user_key())); in Update()1037 WriteLock wl(GetLock(lkey.user_key())); in UpdateCallback()
410 WriteLock lock(&cache_mutex_); in RefAndCacheLogicalBlockSize()430 WriteLock lock(&cache_mutex_); in UnrefAndTryRemoveCachedLogicalBlockSize()