Index: third_party/WebKit/Source/platform/scheduler/base/task_queue_manager.cc |
diff --git a/components/scheduler/base/task_queue_manager.cc b/third_party/WebKit/Source/platform/scheduler/base/task_queue_manager.cc |
similarity index 94% |
rename from components/scheduler/base/task_queue_manager.cc |
rename to third_party/WebKit/Source/platform/scheduler/base/task_queue_manager.cc |
index 08eb78234b31a524623c090ab710d088a18efa28..31adb7257af790faa8ed72b0ed0487afd98a3768 100644 |
--- a/components/scheduler/base/task_queue_manager.cc |
+++ b/third_party/WebKit/Source/platform/scheduler/base/task_queue_manager.cc |
@@ -2,7 +2,7 @@ |
// 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_manager.h" |
+#include "platform/scheduler/base/task_queue_manager.h" |
#include <queue> |
#include <set> |
@@ -10,14 +10,15 @@ |
#include "base/bind.h" |
#include "base/metrics/histogram_macros.h" |
#include "base/trace_event/trace_event.h" |
-#include "components/scheduler/base/real_time_domain.h" |
-#include "components/scheduler/base/task_queue_impl.h" |
-#include "components/scheduler/base/task_queue_manager_delegate.h" |
-#include "components/scheduler/base/task_queue_selector.h" |
-#include "components/scheduler/base/task_time_tracker.h" |
-#include "components/scheduler/base/work_queue.h" |
-#include "components/scheduler/base/work_queue_sets.h" |
- |
+#include "platform/scheduler/base/real_time_domain.h" |
+#include "platform/scheduler/base/task_queue_impl.h" |
+#include "platform/scheduler/base/task_queue_manager_delegate.h" |
+#include "platform/scheduler/base/task_queue_selector.h" |
+#include "platform/scheduler/base/task_time_tracker.h" |
+#include "platform/scheduler/base/work_queue.h" |
+#include "platform/scheduler/base/work_queue_sets.h" |
+ |
+namespace blink { |
namespace scheduler { |
namespace { |
@@ -92,8 +93,8 @@ void TaskQueueManager::UnregisterTimeDomain(TimeDomain* time_domain) { |
scoped_refptr<internal::TaskQueueImpl> TaskQueueManager::NewTaskQueue( |
const TaskQueue::Spec& spec) { |
- TRACE_EVENT1(tracing_category_, |
- "TaskQueueManager::NewTaskQueue", "queue_name", spec.name); |
+ TRACE_EVENT1(tracing_category_, "TaskQueueManager::NewTaskQueue", |
+ "queue_name", spec.name); |
DCHECK(main_thread_checker_.CalledOnValidThread()); |
TimeDomain* time_domain = |
spec.time_domain ? spec.time_domain : real_time_domain_.get(); |
@@ -114,9 +115,8 @@ void TaskQueueManager::SetObserver(Observer* observer) { |
void TaskQueueManager::UnregisterTaskQueue( |
scoped_refptr<internal::TaskQueueImpl> task_queue) { |
- TRACE_EVENT1(tracing_category_, |
- "TaskQueueManager::UnregisterTaskQueue", "queue_name", |
- task_queue->GetName()); |
+ TRACE_EVENT1(tracing_category_, "TaskQueueManager::UnregisterTaskQueue", |
+ "queue_name", task_queue->GetName()); |
DCHECK(main_thread_checker_.CalledOnValidThread()); |
if (observer_) |
observer_->OnUnregisterTaskQueue(task_queue); |
@@ -235,7 +235,7 @@ void TaskQueueManager::DoWork(base::TimeTicks run_time, bool from_main_thread) { |
task_start_time = task_end_time; |
} |
- work_queue = nullptr; // The queue may have been unregistered. |
+ work_queue = nullptr; // The queue may have been unregistered. |
UpdateWorkQueues(should_trigger_wakeup, &previous_task, lazy_now); |
@@ -304,8 +304,8 @@ TaskQueueManager::ProcessTaskResult TaskQueueManager::ProcessTaskFromWorkQueue( |
WillProcessTask(pending_task)); |
queue->NotifyWillProcessTask(pending_task); |
} |
- TRACE_EVENT1(tracing_category_, |
- "TaskQueueManager::RunTask", "queue", queue->GetName()); |
+ TRACE_EVENT1(tracing_category_, "TaskQueueManager::RunTask", "queue", |
+ queue->GetName()); |
// NOTE when TaskQueues get unregistered a reference ends up getting retained |
// by |queues_to_delete_| which is cleared at the top of |DoWork|. This means |
// we are OK to use raw pointers here. |
@@ -440,3 +440,4 @@ void TaskQueueManager::OnTriedToSelectBlockedWorkQueue( |
} |
} // namespace scheduler |
+} // namespace blink |