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

Side by Side Diff: third_party/WebKit/Source/platform/scheduler/child/scheduler_helper.cc

Issue 2840873002: [scheduler] Rename member variables from task_runner_ to task_queue_. (Closed)
Patch Set: Created 3 years, 7 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 unified diff | Download patch
OLDNEW
1 // Copyright 2015 The Chromium Authors. All rights reserved. 1 // Copyright 2015 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/child/scheduler_helper.h" 5 #include "platform/scheduler/child/scheduler_helper.h"
6 6
7 #include "base/time/default_tick_clock.h" 7 #include "base/time/default_tick_clock.h"
8 #include "base/trace_event/trace_event.h" 8 #include "base/trace_event/trace_event.h"
9 #include "base/trace_event/trace_event_argument.h" 9 #include "base/trace_event/trace_event_argument.h"
10 #include "platform/scheduler/base/task_queue_impl.h" 10 #include "platform/scheduler/base/task_queue_impl.h"
(...skipping 19 matching lines...) Expand all
30 const char* tracing_category, 30 const char* tracing_category,
31 const char* disabled_by_default_tracing_category, 31 const char* disabled_by_default_tracing_category,
32 const char* disabled_by_default_verbose_tracing_category, 32 const char* disabled_by_default_verbose_tracing_category,
33 TaskQueue::Spec default_task_queue_spec) 33 TaskQueue::Spec default_task_queue_spec)
34 : task_queue_manager_delegate_(task_queue_manager_delegate), 34 : task_queue_manager_delegate_(task_queue_manager_delegate),
35 task_queue_manager_( 35 task_queue_manager_(
36 new TaskQueueManager(task_queue_manager_delegate, 36 new TaskQueueManager(task_queue_manager_delegate,
37 tracing_category, 37 tracing_category,
38 disabled_by_default_tracing_category, 38 disabled_by_default_tracing_category,
39 disabled_by_default_verbose_tracing_category)), 39 disabled_by_default_verbose_tracing_category)),
40 control_task_runner_( 40 control_task_queue_(
41 NewTaskQueue(TaskQueue::Spec(TaskQueue::QueueType::CONTROL) 41 NewTaskQueue(TaskQueue::Spec(TaskQueue::QueueType::CONTROL)
42 .SetShouldNotifyObservers(false))), 42 .SetShouldNotifyObservers(false))),
43 default_task_runner_(NewTaskQueue(default_task_queue_spec)), 43 default_task_queue_(NewTaskQueue(default_task_queue_spec)),
44 observer_(nullptr), 44 observer_(nullptr),
45 tracing_category_(tracing_category), 45 tracing_category_(tracing_category),
46 disabled_by_default_tracing_category_( 46 disabled_by_default_tracing_category_(
47 disabled_by_default_tracing_category) { 47 disabled_by_default_tracing_category) {
48 control_task_runner_->SetQueuePriority(TaskQueue::CONTROL_PRIORITY); 48 control_task_queue_->SetQueuePriority(TaskQueue::CONTROL_PRIORITY);
49 49
50 task_queue_manager_->SetWorkBatchSize(4); 50 task_queue_manager_->SetWorkBatchSize(4);
51 51
52 DCHECK(task_queue_manager_delegate_); 52 DCHECK(task_queue_manager_delegate_);
53 task_queue_manager_delegate_->SetDefaultTaskRunner( 53 task_queue_manager_delegate_->SetDefaultTaskRunner(default_task_queue_.get());
54 default_task_runner_.get());
55 } 54 }
56 55
57 SchedulerHelper::~SchedulerHelper() { 56 SchedulerHelper::~SchedulerHelper() {
58 Shutdown(); 57 Shutdown();
59 } 58 }
60 59
61 void SchedulerHelper::Shutdown() { 60 void SchedulerHelper::Shutdown() {
62 CheckOnValidThread(); 61 CheckOnValidThread();
63 if (task_queue_manager_) 62 if (task_queue_manager_)
64 task_queue_manager_->SetObserver(nullptr); 63 task_queue_manager_->SetObserver(nullptr);
(...skipping 11 matching lines...) Expand all
76 } 75 }
77 76
78 scoped_refptr<TaskQueue> SchedulerHelper::NewTaskQueue( 77 scoped_refptr<TaskQueue> SchedulerHelper::NewTaskQueue(
79 const TaskQueue::Spec& spec) { 78 const TaskQueue::Spec& spec) {
80 DCHECK(task_queue_manager_.get()); 79 DCHECK(task_queue_manager_.get());
81 return task_queue_manager_->NewTaskQueue(spec); 80 return task_queue_manager_->NewTaskQueue(spec);
82 } 81 }
83 82
84 scoped_refptr<TaskQueue> SchedulerHelper::DefaultTaskQueue() { 83 scoped_refptr<TaskQueue> SchedulerHelper::DefaultTaskQueue() {
85 CheckOnValidThread(); 84 CheckOnValidThread();
86 return default_task_runner_; 85 return default_task_queue_;
87 } 86 }
88 87
89 scoped_refptr<TaskQueue> SchedulerHelper::ControlTaskQueue() { 88 scoped_refptr<TaskQueue> SchedulerHelper::ControlTaskQueue() {
90 return control_task_runner_; 89 return control_task_queue_;
91 } 90 }
92 91
93 size_t SchedulerHelper::GetNumberOfPendingTasks() const { 92 size_t SchedulerHelper::GetNumberOfPendingTasks() const {
94 return task_queue_manager_->GetNumberOfPendingTasks(); 93 return task_queue_manager_->GetNumberOfPendingTasks();
95 } 94 }
96 95
97 void SchedulerHelper::SetWorkBatchSizeForTesting(size_t work_batch_size) { 96 void SchedulerHelper::SetWorkBatchSizeForTesting(size_t work_batch_size) {
98 CheckOnValidThread(); 97 CheckOnValidThread();
99 DCHECK(task_queue_manager_.get()); 98 DCHECK(task_queue_manager_.get());
100 task_queue_manager_->SetWorkBatchSize(work_batch_size); 99 task_queue_manager_->SetWorkBatchSize(work_batch_size);
(...skipping 86 matching lines...) Expand 10 before | Expand all | Expand 10 after
187 } 186 }
188 187
189 TaskQueue* SchedulerHelper::CurrentlyExecutingTaskQueue() const { 188 TaskQueue* SchedulerHelper::CurrentlyExecutingTaskQueue() const {
190 if (!task_queue_manager_) 189 if (!task_queue_manager_)
191 return nullptr; 190 return nullptr;
192 return task_queue_manager_->currently_executing_task_queue(); 191 return task_queue_manager_->currently_executing_task_queue();
193 } 192 }
194 193
195 } // namespace scheduler 194 } // namespace scheduler
196 } // namespace blink 195 } // namespace blink
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698