Searched refs:delayed_wake_up_queue_ (Results 1 – 3 of 3) sorted by relevance
60 if (!delayed_wake_up_queue_.empty()) in SetNextWakeUpForQueue()61 previous_wake_up = delayed_wake_up_queue_.Min().wake_up.time; in SetNextWakeUpForQueue()67 delayed_wake_up_queue_.ChangeKey(queue->heap_handle(), in SetNextWakeUpForQueue()71 delayed_wake_up_queue_.insert({wake_up.value(), queue}); in SetNextWakeUpForQueue()76 delayed_wake_up_queue_.erase(queue->heap_handle()); in SetNextWakeUpForQueue()80 if (!delayed_wake_up_queue_.empty()) in SetNextWakeUpForQueue()81 new_wake_up = delayed_wake_up_queue_.Min().wake_up.time; in SetNextWakeUpForQueue()105 while (!delayed_wake_up_queue_.empty() && in WakeUpReadyDelayedQueues()106 delayed_wake_up_queue_.Min().wake_up.time <= lazy_now->Now()) { in WakeUpReadyDelayedQueues()107 internal::TaskQueueImpl* queue = delayed_wake_up_queue_.Min().queue; in WakeUpReadyDelayedQueues()[all …]
69 return delayed_wake_up_queue_.size(); in NumberOfScheduledWakeUps()130 internal::IntrusiveHeap<ScheduledDelayedWakeUp> delayed_wake_up_queue_; variable
56 if (delayed_wake_up_queue_.empty()) in NextScheduledTaskQueue()58 return delayed_wake_up_queue_.Min().queue; in NextScheduledTaskQueue()