Searched refs:wake_up_queue_ (Results 1 – 3 of 3) sorted by relevance
63 if (wake_up_queue_.empty()) in NextScheduledTaskQueue()65 return wake_up_queue_.top().queue; in NextScheduledTaskQueue()69 if (wake_up_queue_.empty()) in NextScheduledRunTime()71 return wake_up_queue_.top().wake_up.time; in NextScheduledRunTime()82 wake_up_queue_ = std::make_unique<MockWakeUpQueue>(); in SetUp()84 nullptr, wake_up_queue_.get(), TaskQueue::Spec(QueueName::TEST_TQ)); in SetUp()92 std::unique_ptr<MockWakeUpQueue> wake_up_queue_; member in base::sequence_manager::internal::WakeUpQueueTest101 EXPECT_TRUE(wake_up_queue_->empty()); in TEST_F()102 EXPECT_CALL(*wake_up_queue_.get(), in TEST_F()107 EXPECT_FALSE(wake_up_queue_->empty()); in TEST_F()[all …]
29 while (!wake_up_queue_.empty()) { in RemoveAllCanceledDelayedTasksFromFront()30 auto* top_queue = wake_up_queue_.top().queue.get(); in RemoveAllCanceledDelayedTasksFromFront()54 wake_up_queue_.at(queue->heap_handle()).wake_up.resolution; in SetNextWakeUpForQueue()61 wake_up_queue_.Replace(queue->heap_handle(), {wake_up.value(), queue}); in SetNextWakeUpForQueue()64 wake_up_queue_.insert({wake_up.value(), queue}); in SetNextWakeUpForQueue()69 wake_up_queue_.erase(queue->heap_handle()); in SetNextWakeUpForQueue()91 while (!wake_up_queue_.empty() && in MoveReadyDelayedTasksToWorkQueues()92 wake_up_queue_.top().wake_up.earliest_time() <= lazy_now->Now()) { in MoveReadyDelayedTasksToWorkQueues()93 internal::TaskQueueImpl* queue = wake_up_queue_.top().queue; in MoveReadyDelayedTasksToWorkQueues()100 if (!update_needed || wake_up_queue_.empty()) in MoveReadyDelayedTasksToWorkQueues()[all …]
51 bool empty() const { return wake_up_queue_.empty(); } in empty()109 IntrusiveHeap<ScheduledWakeUp, std::greater<>> wake_up_queue_; variable