Searched refs:incoming_queue_ (Results 1 – 6 of 6) sorted by relevance
93 return incoming_queue_.empty(); in IsIdleForTesting()102 if (incoming_queue_.empty()) { in ReloadWorkQueue()108 incoming_queue_.swap(*work_queue); in ReloadWorkQueue()128 schedule_work = !incoming_queue_.empty(); in StartScheduling()173 bool was_empty = incoming_queue_.empty(); in PostPendingTask()174 incoming_queue_.push(std::move(*pending_task)); in PostPendingTask()
16 : incoming_queue_(incoming_queue), valid_thread_id_(kInvalidThreadId) { in MessageLoopTaskRunner()30 return incoming_queue_->AddToIncomingQueue(from_here, task, delay, true); in PostDelayedTask()38 return incoming_queue_->AddToIncomingQueue(from_here, task, delay, false); in PostNonNestableDelayedTask()
46 scoped_refptr<IncomingTaskQueue> incoming_queue_; variable
90 TaskQueue incoming_queue_; variable
72 incoming_queue_.push(std::move(packet)); in AddReadPacketData()90 incoming_queue_.push(std::move(packet)); in QueueReadErrorWithMessage()94 std::queue<InputDataPacket>().swap(incoming_queue_); in ClearReadQueue()186 if (incoming_queue_.empty()) in PopReadPacket()188 const InputDataPacket& packet = incoming_queue_.front(); in PopReadPacket()192 incoming_queue_.pop(); in PopReadPacket()
151 std::queue<InputDataPacket> incoming_queue_; variable