Searched refs:write_mutex_ (Results 1 – 3 of 3) sorted by relevance
71 std::lock_guard<std::mutex> lock(this->write_mutex_); in Run()87 std::lock_guard<std::mutex> lock(this->write_mutex_); in Run()176 WriteResult DispatchWrites() REQUIRES(write_mutex_) { in DispatchWrites()203 std::lock_guard<std::mutex> lock(write_mutex_); in Write()232 std::mutex write_mutex_; member233 bool writable_ GUARDED_BY(write_mutex_) = true;234 IOVector write_buffer_ GUARDED_BY(write_mutex_);
186 std::lock_guard<std::mutex> lock(write_mutex_); in Write()425 std::lock_guard<std::mutex> lock(write_mutex_); in StartWorker()613 std::lock_guard<std::mutex> lock(write_mutex_); in HandleWrite()647 void SubmitWrites() REQUIRES(write_mutex_) { in SubmitWrites()718 std::mutex write_mutex_; member719 std::deque<IoWriteBlock> write_requests_ GUARDED_BY(write_mutex_);720 size_t next_write_id_ GUARDED_BY(write_mutex_) = 0;721 size_t writes_submitted_ GUARDED_BY(write_mutex_) = 0;
241 std::lock_guard<std::mutex> lock(self->write_mutex_); in write_cb()281 void SubmitWrite(Block&& block) REQUIRES(write_mutex_) { in SubmitWrite()306 std::lock_guard<std::mutex> lock(write_mutex_); in Write()601 std::unique_lock<std::mutex> lock(write_mutex_); in Stop()602 ScopedLockAssertion assumed_locked(write_mutex_); in Stop()610 ScopedLockAssertion assumed_locked(write_mutex_); in Stop()685 std::mutex write_mutex_; member686 std::unordered_map<TransferId, std::unique_ptr<WriteBlock>> writes_ GUARDED_BY(write_mutex_);