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

Side by Side Diff: third_party/WebKit/Source/platform/scheduler/base/task_queue_manager.cc

Issue 2437003002: [scheduler] Add type to scheduler::TaskQueue (Closed)
Patch Set: fix windows compilation Created 4 years, 1 month 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 unified diff | Download patch
OLDNEW
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
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
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
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698