Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(1390)

Unified Diff: third_party/WebKit/Source/platform/scheduler/base/task_queue_impl.cc

Issue 2118903002: scheduler: Move the Blink scheduler into Blink (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Rebased Created 4 years, 4 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: third_party/WebKit/Source/platform/scheduler/base/task_queue_impl.cc
diff --git a/components/scheduler/base/task_queue_impl.cc b/third_party/WebKit/Source/platform/scheduler/base/task_queue_impl.cc
similarity index 96%
rename from components/scheduler/base/task_queue_impl.cc
rename to third_party/WebKit/Source/platform/scheduler/base/task_queue_impl.cc
index 7d684fb000c3aac28cd4fa0087eedc8cbb1f1232..02f5cef63fd6d4e0bf78028c66cfaef0c708a1f0 100644
--- a/components/scheduler/base/task_queue_impl.cc
+++ b/third_party/WebKit/Source/platform/scheduler/base/task_queue_impl.cc
@@ -2,14 +2,15 @@
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
-#include "components/scheduler/base/task_queue_impl.h"
+#include "platform/scheduler/base/task_queue_impl.h"
#include "base/trace_event/blame_context.h"
-#include "components/scheduler/base/task_queue_manager.h"
-#include "components/scheduler/base/task_queue_manager_delegate.h"
-#include "components/scheduler/base/time_domain.h"
-#include "components/scheduler/base/work_queue.h"
+#include "platform/scheduler/base/task_queue_manager.h"
+#include "platform/scheduler/base/task_queue_manager_delegate.h"
+#include "platform/scheduler/base/time_domain.h"
+#include "platform/scheduler/base/work_queue.h"
+namespace blink {
namespace scheduler {
namespace internal {
@@ -223,8 +224,8 @@ void TaskQueueImpl::PushOntoDelayedIncomingQueueFromMainThread(
// Schedule a later call to MoveReadyDelayedTasksToDelayedWorkQueue.
base::TimeTicks delayed_run_time = pending_task.delayed_run_time;
main_thread_only().delayed_incoming_queue.push(std::move(pending_task));
- main_thread_only().time_domain->ScheduleDelayedWork(
- this, delayed_run_time, now);
+ main_thread_only().time_domain->ScheduleDelayedWork(this, delayed_run_time,
+ now);
TraceQueueSize(false);
}
@@ -233,12 +234,11 @@ void TaskQueueImpl::PushOntoDelayedIncomingQueueLocked(Task pending_task) {
int thread_hop_task_sequence_number =
any_thread().task_queue_manager->GetNextSequenceNumber();
- PushOntoImmediateIncomingQueueLocked(Task(
- FROM_HERE,
- base::Bind(&TaskQueueImpl::ScheduleDelayedWorkTask, this,
- base::Passed(&pending_task)),
- base::TimeTicks(), thread_hop_task_sequence_number, false,
- thread_hop_task_sequence_number));
+ PushOntoImmediateIncomingQueueLocked(
+ Task(FROM_HERE, base::Bind(&TaskQueueImpl::ScheduleDelayedWorkTask, this,
+ base::Passed(&pending_task)),
+ base::TimeTicks(), thread_hop_task_sequence_number, false,
+ thread_hop_task_sequence_number));
}
void TaskQueueImpl::PushOntoImmediateIncomingQueueLocked(Task pending_task) {
@@ -258,8 +258,7 @@ void TaskQueueImpl::ScheduleDelayedWorkTask(Task pending_task) {
base::TimeTicks delayed_run_time = pending_task.delayed_run_time;
main_thread_only().delayed_incoming_queue.push(std::move(pending_task));
main_thread_only().time_domain->ScheduleDelayedWork(
- this, delayed_run_time,
- main_thread_only().time_domain->Now());
+ this, delayed_run_time, main_thread_only().time_domain->Now());
}
void TaskQueueImpl::SetQueueEnabled(bool enabled) {
@@ -580,7 +579,7 @@ void TaskQueueImpl::AsValueInto(base::trace_event::TracedValue* state) const {
(main_thread_only().delayed_incoming_queue.top().delayed_run_time -
main_thread_only().time_domain->CreateLazyNow().Now());
state->SetDouble("delay_to_next_task_ms",
- delay_to_next_task.InMillisecondsF());
+ delay_to_next_task.InMillisecondsF());
}
if (verbose_tracing_enabled) {
state->BeginArray("immediate_incoming_queue");
@@ -715,3 +714,4 @@ void TaskQueueImpl::TaskAsValueInto(const Task& task,
} // namespace internal
} // namespace scheduler
+} // namespace blink

Powered by Google App Engine
This is Rietveld 408576698