Searched refs:queue_mutex_ (Results 1 – 3 of 3) sorted by relevance
122 void LockMutex() { queue_mutex_.lock(); } in LockMutex()123 void UnlockMutex() { queue_mutex_.unlock(); } in UnlockMutex()126 std::unique_lock<std::mutex> queue_lock(queue_mutex_, std::adopt_lock); in Wait()135 std::mutex queue_mutex_; variable139 void LockMutex() ABSL_EXCLUSIVE_LOCK_FUNCTION() { queue_mutex_.Lock(); } in LockMutex()140 void UnlockMutex() ABSL_UNLOCK_FUNCTION() { queue_mutex_.Unlock(); } in UnlockMutex()141 void Wait() { condition_.Wait(&queue_mutex_); } in Wait()146 absl::Mutex queue_mutex_; variable150 UnboundedQueue<std::function<void()>> queue_ LIBGAV1_GUARDED_BY(queue_mutex_);155 bool exit_threads_ LIBGAV1_GUARDED_BY(queue_mutex_) = false;
68 std::unique_lock<std::mutex> lock(queue_mutex_); in get_batch()97 std::unique_lock<std::mutex> lock(queue_mutex_); in add_chunk_data()160 std::unique_lock<std::mutex> lock(queue_mutex_); in add_chunk_data()192 std::lock_guard<std::mutex> lock(queue_mutex_); in stop()231 std::mutex queue_mutex_; variable
64 std::lock_guard lock(impl->queue_mutex_); in Transmit()78 std::lock_guard lock(impl->queue_mutex_); in Receive()177 std::mutex queue_mutex_; member in cuttlefish::InProcessTpm::Impl