Searched refs:outgoing_queue_ (Results 1 – 7 of 7) sorted by relevance
82 PendingTask pending_task = std::move(outgoing_queue_.front()); in TakeTask()83 outgoing_queue_.pop(); in TakeTask()92 if (outgoing_queue_.empty()) { in HasTasks()94 incoming_queue_.swap(outgoing_queue_); in HasTasks()95 outgoing_queue_empty_ = outgoing_queue_.empty(); in HasTasks()98 return !outgoing_queue_.empty(); in HasTasks()
94 if (!outgoing_queue_.empty()) { in BlockUntilOutputQueueHasBuffer()189 outgoing_queue_ = std::queue<FakeV4L2Buffer*>(); in reqbufs()240 outgoing_queue_is_empty = outgoing_queue_.empty(); in dqbuf()248 auto* buffer = outgoing_queue_.front(); in dqbuf()249 outgoing_queue_.pop(); in dqbuf()283 outgoing_queue_ = std::queue<FakeV4L2Buffer*>(); in streamoff()312 outgoing_queue_.push(buffer); in MaybeProduceOneFrame()322 std::queue<FakeV4L2Buffer*> outgoing_queue_; member in media::FakeV4L2Impl::OpenedDevice
97 if (!outgoing_queue_.empty()) { in BlockUntilOutputQueueHasBuffer()214 outgoing_queue_ = std::queue<FakeV4L2Buffer*>(); in reqbufs()265 outgoing_queue_is_empty = outgoing_queue_.empty(); in dqbuf()273 auto* buffer = outgoing_queue_.front(); in dqbuf()274 outgoing_queue_.pop(); in dqbuf()308 outgoing_queue_ = std::queue<FakeV4L2Buffer*>(); in streamoff()359 outgoing_queue_.push(buffer); in MaybeProduceOneFrame()369 std::queue<FakeV4L2Buffer*> outgoing_queue_; member in media::FakeV4L2Impl::OpenedDevice
282 outgoing_queue_.push(header_buffer); in Queue()290 outgoing_queue_.push(body_buffer); in Queue()294 outgoing_queue_.push(base::MakeRefCounted<base::RefCountedBytes>(0)); in Queue()303 if (outgoing_queue_.empty() || !device_) in ProcessOutgoing()306 BulkMessage message = outgoing_queue_.front(); in ProcessOutgoing()307 outgoing_queue_.pop(); in ProcessOutgoing()
150 base::queue<BulkMessage> outgoing_queue_; variable