Implement WebFrameScheduler and WebPageScheduler

components/scheduler/child/task_queue_impl.cc

 // Copyright 2015 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "components/scheduler/child/task_queue_impl.h"
 
 #include "components/scheduler/child/task_queue_manager.h"
 
 namespace scheduler {
 namespace internal {
@@ skipping 318 matching lines @@
 
 void TaskQueueImpl::PumpQueue() {
   base::AutoLock lock(lock_);
   PumpQueueLocked();
 }
 
 const char* TaskQueueImpl::GetName() const {
   return name_;
 }
 
+void TaskQueueImpl::SetOrigin(const std::string& origin) {
+  DCHECK(main_thread_checker_.CalledOnValidThread());
+  origin_ = origin;
+}
+
+const std::string& TaskQueueImpl::GetOrigin() {
+  DCHECK(main_thread_checker_.CalledOnValidThread());
+  return origin_;
+}
+
 bool TaskQueueImpl::GetWorkQueueFrontTaskEnqueueOrder(
     int* enqueue_order) const {
   if (work_queue_.empty())
     return false;
   *enqueue_order = work_queue_.front().enqueue_order();
   return true;
 }
 
 void TaskQueueImpl::PushTaskOntoWorkQueueForTest(const Task& task) {
   work_queue_.push(task);
@@ skipping 57 matching lines @@
     default:
       NOTREACHED();
       return nullptr;
   }
 }
 
 void TaskQueueImpl::AsValueInto(base::trace_event::TracedValue* state) const {
   base::AutoLock lock(lock_);
   state->BeginDictionary();
   state->SetString("name", GetName());
+  state->SetString("origin", origin_);
   state->SetString("pump_policy", PumpPolicyToString(pump_policy_));
   state->SetString("wakeup_policy", WakeupPolicyToString(wakeup_policy_));
   bool verbose_tracing_enabled = false;
   TRACE_EVENT_CATEGORY_GROUP_ENABLED(
       disabled_by_default_verbose_tracing_category_, &verbose_tracing_enabled);
   state->SetInteger("incoming_queue_size", incoming_queue_.size());
   state->SetInteger("work_queue_size", work_queue_.size());
   state->SetInteger("delayed_task_queue_size", delayed_task_queue_.size());
   if (verbose_tracing_enabled) {
     state->BeginArray("incoming_queue");
@@ skipping 69 matching lines @@
   state->SetBoolean("nestable", task.nestable);
   state->SetBoolean("is_high_res", task.is_high_res);
   state->SetDouble(
       "delayed_run_time",
       (task.delayed_run_time - base::TimeTicks()).InMicroseconds() / 1000.0L);
   state->EndDictionary();
 }
 
 }  // namespace internal
 }  // namespace scheduler