Searched refs:incoming_queue_ (Results 1 – 7 of 7) sorted by relevance
18 : incoming_queue_(incoming_queue), valid_thread_id_(kInvalidThreadId) { in MessageLoopTaskRunner()31 return incoming_queue_->AddToIncomingQueue(from_here, std::move(task), delay, in PostDelayedTask()40 return incoming_queue_->AddToIncomingQueue(from_here, std::move(task), delay, in PostNonNestableDelayedTask()
291 bool was_empty = incoming_queue_.empty(); in PostPendingTaskLockRequired()292 incoming_queue_.push(std::move(*pending_task)); in PostPendingTaskLockRequired()304 incoming_queue_.swap(*work_queue); in ReloadWorkQueue()
47 scoped_refptr<IncomingTaskQueue> incoming_queue_; variable
258 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
80 std::unique_ptr<TaskQueueImpl::TaskDeque> incoming_queue_; member in base::sequence_manager::internal::WorkQueueTest