Lines Matching refs:read_mutex_

144     void Cleanup(ReadBlock* read_block) REQUIRES(read_mutex_) {  in Cleanup()
153     bool MaybeCleanup(ReadBlock* read_block) REQUIRES(read_mutex_) {  in MaybeCleanup()
169         std::lock_guard<std::mutex> lock(self->read_mutex_);  in header_read_cb()
218         std::lock_guard<std::mutex> lock(self->read_mutex_);  in payload_read_cb()
647     void CancelReadTransfer(ReadBlock* read_block) REQUIRES(read_mutex_) {  in CancelReadTransfer()
713             std::unique_lock<std::mutex> lock(read_mutex_);  in CloseDevice()
714             ScopedLockAssertion assumed_locked(read_mutex_);  in CloseDevice()
720                 ScopedLockAssertion assumed_locked(read_mutex_);  in CloseDevice()
744         std::lock_guard lock(read_mutex_);  in StartImpl()
875     std::mutex read_mutex_;  member
876     ReadBlock header_read_ GUARDED_BY(read_mutex_);
877     ReadBlock payload_read_ GUARDED_BY(read_mutex_);
878     std::optional<amessage> incoming_header_ GUARDED_BY(read_mutex_);
879     IOVector incoming_payload_ GUARDED_BY(read_mutex_);