Searched refs:callback_queue_ (Results 1 – 4 of 4) sorted by relevance
173 return !callback_queue_.empty(); in CallbackQueueNotEmpty()222 std::queue<std::unique_ptr<OutfeedData>> callback_queue_ TF_GUARDED_BY(mu_);336 << literal_size_bytes << " bytes; " << (1 + callback_queue_.size()) in EnqueueReceivedData()339 callback_queue_.push(std::move(received)); in EnqueueReceivedData()361 received = std::move(callback_queue_.front()); in CallbackThreadLoop()362 callback_queue_.pop(); in CallbackThreadLoop()365 << callback_queue_.size() << " callbacks in queue of total size " in CallbackThreadLoop()372 CHECK(callback_queue_.empty()); in CallbackThreadLoop()
56 callback_queue_(nullptr), in FrameBuffer()92 callback_queue_ = callback_queue; in NextFrame()97 RTC_DCHECK(callback_queue_); in StartWaitForNextFrameOnQueue()101 callback_queue_->Get(), TimeDelta::Millis(wait_ms), [this] { in StartWaitForNextFrameOnQueue()383 callback_queue_ = nullptr; in CancelCallback()530 if (callback_queue_) { in InsertFrame()531 callback_queue_->PostTask([this] { in InsertFrame()
173 rtc::TaskQueue* callback_queue_ RTC_GUARDED_BY(mutex_);
185 callback_queue_.emplace_back(std::move(cert_name), root_being_watched, in SetUp()215 return std::move(callback_queue_); in GetCallbackQueue()222 std::deque<CallbackStatus> callback_queue_; member in grpc_core::testing::GrpcTlsCertificateDistributorTest