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 94694b6b54e2884ab4580436370ed988d28582f6..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 |
@@ -336,7 +336,7 @@ void TaskQueueImpl::PushOntoImmediateIncomingQueueLocked( |
RunsTasksOnCurrentThread() && |
(!IsQueueEnabled() || main_thread_only().current_fence); |
any_thread().task_queue_manager->OnQueueHasIncomingImmediateWork( |
- this, queue_is_blocked); |
+ this, sequence_number, queue_is_blocked); |
any_thread().time_domain->OnQueueHasImmediateWork(this); |
} |
any_thread().immediate_incoming_queue.emplace_back( |
@@ -678,6 +678,16 @@ bool TaskQueueImpl::BlockedByFence() const { |
main_thread_only().current_fence; |
} |
+bool TaskQueueImpl::CouldTaskRun(EnqueueOrder enqueue_order) const { |
+ if (!IsQueueEnabled()) |
+ return false; |
+ |
+ if (!main_thread_only().current_fence) |
+ return true; |
+ |
+ return enqueue_order < main_thread_only().current_fence; |
+} |
+ |
EnqueueOrder TaskQueueImpl::GetFenceForTest() const { |
return main_thread_only().current_fence; |
} |