OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "platform/scheduler/base/task_queue_manager.h" | 5 #include "platform/scheduler/base/task_queue_manager.h" |
6 | 6 |
7 #include <queue> | 7 #include <queue> |
8 #include <set> | 8 #include <set> |
9 | 9 |
10 #include "base/bind.h" | 10 #include "base/bind.h" |
(...skipping 94 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
105 time_domain->OnRegisterWithTaskQueueManager(this); | 105 time_domain->OnRegisterWithTaskQueueManager(this); |
106 } | 106 } |
107 | 107 |
108 void TaskQueueManager::UnregisterTimeDomain(TimeDomain* time_domain) { | 108 void TaskQueueManager::UnregisterTimeDomain(TimeDomain* time_domain) { |
109 time_domains_.erase(time_domain); | 109 time_domains_.erase(time_domain); |
110 } | 110 } |
111 | 111 |
112 scoped_refptr<internal::TaskQueueImpl> TaskQueueManager::NewTaskQueue( | 112 scoped_refptr<internal::TaskQueueImpl> TaskQueueManager::NewTaskQueue( |
113 const TaskQueue::Spec& spec) { | 113 const TaskQueue::Spec& spec) { |
114 TRACE_EVENT1(tracing_category_, "TaskQueueManager::NewTaskQueue", | 114 TRACE_EVENT1(tracing_category_, "TaskQueueManager::NewTaskQueue", |
115 "queue_name", spec.name); | 115 "queue_name", TaskQueue::NameForQueueType(spec.type)); |
116 DCHECK(main_thread_checker_.CalledOnValidThread()); | 116 DCHECK(main_thread_checker_.CalledOnValidThread()); |
117 TimeDomain* time_domain = | 117 TimeDomain* time_domain = |
118 spec.time_domain ? spec.time_domain : real_time_domain_.get(); | 118 spec.time_domain ? spec.time_domain : real_time_domain_.get(); |
119 DCHECK(time_domains_.find(time_domain) != time_domains_.end()); | 119 DCHECK(time_domains_.find(time_domain) != time_domains_.end()); |
120 scoped_refptr<internal::TaskQueueImpl> queue( | 120 scoped_refptr<internal::TaskQueueImpl> queue( |
121 make_scoped_refptr(new internal::TaskQueueImpl( | 121 make_scoped_refptr(new internal::TaskQueueImpl( |
122 this, time_domain, spec, disabled_by_default_tracing_category_, | 122 this, time_domain, spec, disabled_by_default_tracing_category_, |
123 disabled_by_default_verbose_tracing_category_))); | 123 disabled_by_default_verbose_tracing_category_))); |
124 queues_.insert(queue); | 124 queues_.insert(queue); |
125 selector_.AddQueue(queue.get()); | 125 selector_.AddQueue(queue.get()); |
(...skipping 360 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
486 DCHECK(main_thread_checker_.CalledOnValidThread()); | 486 DCHECK(main_thread_checker_.CalledOnValidThread()); |
487 DCHECK(!work_queue->Empty()); | 487 DCHECK(!work_queue->Empty()); |
488 if (observer_) { | 488 if (observer_) { |
489 observer_->OnTriedToExecuteBlockedTask(*work_queue->task_queue(), | 489 observer_->OnTriedToExecuteBlockedTask(*work_queue->task_queue(), |
490 *work_queue->GetFrontTask()); | 490 *work_queue->GetFrontTask()); |
491 } | 491 } |
492 } | 492 } |
493 | 493 |
494 } // namespace scheduler | 494 } // namespace scheduler |
495 } // namespace blink | 495 } // namespace blink |
OLD | NEW |