| Index: third_party/WebKit/Source/platform/scheduler/base/task_queue_impl.cc
|
| diff --git a/third_party/WebKit/Source/platform/scheduler/base/task_queue_impl.cc b/third_party/WebKit/Source/platform/scheduler/base/task_queue_impl.cc
|
| index 2d1e2957ba8e952bb9ea551885832899c9524103..762f079bfccb32600c6b51b777f00741c92f19d8 100644
|
| --- a/third_party/WebKit/Source/platform/scheduler/base/task_queue_impl.cc
|
| +++ b/third_party/WebKit/Source/platform/scheduler/base/task_queue_impl.cc
|
| @@ -276,14 +276,11 @@
|
| main_thread_only().delayed_incoming_queue.push(std::move(pending_task));
|
|
|
| // If |pending_task| is at the head of the queue, then make sure a wakeup
|
| - // is requested if the queue is enabled. Note we still want to schedule a
|
| - // wakeup even if blocked by a fence, because we'd break throttling logic
|
| - // otherwise.
|
| - base::TimeTicks next_delayed_task =
|
| - main_thread_only().delayed_incoming_queue.top().delayed_run_time;
|
| - if (next_delayed_task == delayed_run_time && IsQueueEnabled()) {
|
| - main_thread_only().time_domain->ScheduleDelayedWork(this, delayed_run_time,
|
| - now);
|
| + // is requested.
|
| + if (main_thread_only().delayed_incoming_queue.top().delayed_run_time ==
|
| + delayed_run_time) {
|
| + main_thread_only().time_domain->ScheduleDelayedWork(
|
| + this, pending_task.delayed_run_time, now);
|
| }
|
|
|
| TraceQueueSize(false);
|
| @@ -407,8 +404,7 @@
|
| }
|
|
|
| base::Optional<base::TimeTicks> TaskQueueImpl::GetNextScheduledWakeUp() {
|
| - // Note we don't scheduled a wakeup for disabled queues.
|
| - if (main_thread_only().delayed_incoming_queue.empty() || !IsQueueEnabled())
|
| + if (main_thread_only().delayed_incoming_queue.empty())
|
| return base::nullopt;
|
|
|
| return main_thread_only().delayed_incoming_queue.top().delayed_run_time;
|
| @@ -803,18 +799,10 @@
|
| return;
|
|
|
| if (enable) {
|
| - if (!main_thread_only().delayed_incoming_queue.empty()) {
|
| - main_thread_only().time_domain->ScheduleDelayedWork(
|
| - this,
|
| - main_thread_only().delayed_incoming_queue.top().delayed_run_time,
|
| - main_thread_only().time_domain->Now());
|
| - }
|
| // Note the selector calls TaskQueueManager::OnTaskQueueEnabled which posts
|
| // a DoWork if needed.
|
| main_thread_only().task_queue_manager->selector_.EnableQueue(this);
|
| } else {
|
| - if (!main_thread_only().delayed_incoming_queue.empty())
|
| - main_thread_only().time_domain->CancelDelayedWork(this);
|
| main_thread_only().task_queue_manager->selector_.DisableQueue(this);
|
| }
|
| }
|
|
|