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 2885ccdf52c2ec39fe0b6c21178b6b8002374722..79abf5825ec41f93c405525b4f4e9f457db508cb 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,11 +276,15 @@ void TaskQueueImpl::PushOntoDelayedIncomingQueueFromMainThread( |
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. |
+ // 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. |
if (main_thread_only().delayed_incoming_queue.top().delayed_run_time == |
- delayed_run_time) { |
+ delayed_run_time && |
+ IsQueueEnabled()) { |
+ LazyNow lazy_now(now); |
main_thread_only().time_domain->ScheduleDelayedWork( |
- this, pending_task.delayed_run_time, now); |
+ this, pending_task.delayed_run_time, &lazy_now); |
} |
TraceQueueSize(false); |
@@ -816,10 +820,19 @@ void TaskQueueImpl::EnableOrDisableWithSelector(bool enable) { |
return; |
if (enable) { |
+ if (!main_thread_only().delayed_incoming_queue.empty()) { |
+ LazyNow lazy_now = main_thread_only().time_domain->CreateLazyNow(); |
+ main_thread_only().time_domain->ScheduleDelayedWork( |
+ this, |
+ main_thread_only().delayed_incoming_queue.top().delayed_run_time, |
+ &lazy_now); |
+ } |
// Note it's the job of the selector to tell the TaskQueueManager if |
- // a DoWork needs posting. |
+ // an immediate DoWork needs posting. |
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); |
} |
} |