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

Side by Side Diff: components/scheduler/child/scheduler_helper.cc

Issue 1424053002: Adds a flag to support "Virtual Time" to the blink scheduler (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Added a test Created 5 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 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 "components/scheduler/child/scheduler_helper.h" 5 #include "components/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 "components/scheduler/base/task_queue_impl.h" 10 #include "components/scheduler/base/task_queue_impl.h"
(...skipping 16 matching lines...) Expand all
27 TaskQueue::Spec("control_tq") 27 TaskQueue::Spec("control_tq")
28 .SetWakeupPolicy(TaskQueue::WakeupPolicy::DONT_WAKE_OTHER_QUEUES) 28 .SetWakeupPolicy(TaskQueue::WakeupPolicy::DONT_WAKE_OTHER_QUEUES)
29 .SetShouldNotifyObservers(false))), 29 .SetShouldNotifyObservers(false))),
30 control_after_wakeup_task_runner_(NewTaskQueue( 30 control_after_wakeup_task_runner_(NewTaskQueue(
31 TaskQueue::Spec("control_after_wakeup_tq") 31 TaskQueue::Spec("control_after_wakeup_tq")
32 .SetPumpPolicy(TaskQueue::PumpPolicy::AFTER_WAKEUP) 32 .SetPumpPolicy(TaskQueue::PumpPolicy::AFTER_WAKEUP)
33 .SetWakeupPolicy(TaskQueue::WakeupPolicy::DONT_WAKE_OTHER_QUEUES) 33 .SetWakeupPolicy(TaskQueue::WakeupPolicy::DONT_WAKE_OTHER_QUEUES)
34 .SetShouldNotifyObservers(false))), 34 .SetShouldNotifyObservers(false))),
35 default_task_runner_(NewTaskQueue(TaskQueue::Spec("default_tq") 35 default_task_runner_(NewTaskQueue(TaskQueue::Spec("default_tq")
36 .SetShouldMonitorQuiescence(true))), 36 .SetShouldMonitorQuiescence(true))),
37 time_source_(new base::DefaultTickClock),
38 observer_(nullptr), 37 observer_(nullptr),
39 tracing_category_(tracing_category), 38 tracing_category_(tracing_category),
40 disabled_by_default_tracing_category_( 39 disabled_by_default_tracing_category_(
41 disabled_by_default_tracing_category) { 40 disabled_by_default_tracing_category) {
42 control_task_runner_->SetQueuePriority(TaskQueue::CONTROL_PRIORITY); 41 control_task_runner_->SetQueuePriority(TaskQueue::CONTROL_PRIORITY);
43 control_after_wakeup_task_runner_->SetQueuePriority( 42 control_after_wakeup_task_runner_->SetQueuePriority(
44 TaskQueue::CONTROL_PRIORITY); 43 TaskQueue::CONTROL_PRIORITY);
45 44
46 task_queue_manager_->SetWorkBatchSize(4); 45 task_queue_manager_->SetWorkBatchSize(4);
47 46
(...skipping 24 matching lines...) Expand all
72 } 71 }
73 72
74 scoped_refptr<TaskQueue> SchedulerHelper::ControlTaskRunner() { 73 scoped_refptr<TaskQueue> SchedulerHelper::ControlTaskRunner() {
75 return control_task_runner_; 74 return control_task_runner_;
76 } 75 }
77 76
78 scoped_refptr<TaskQueue> SchedulerHelper::ControlAfterWakeUpTaskRunner() { 77 scoped_refptr<TaskQueue> SchedulerHelper::ControlAfterWakeUpTaskRunner() {
79 return control_after_wakeup_task_runner_; 78 return control_after_wakeup_task_runner_;
80 } 79 }
81 80
82 void SchedulerHelper::SetTimeSourceForTesting(
83 scoped_ptr<base::TickClock> time_source) {
84 CheckOnValidThread();
85 time_source_ = time_source.Pass();
86 }
87
88 void SchedulerHelper::SetWorkBatchSizeForTesting(size_t work_batch_size) { 81 void SchedulerHelper::SetWorkBatchSizeForTesting(size_t work_batch_size) {
89 CheckOnValidThread(); 82 CheckOnValidThread();
90 DCHECK(task_queue_manager_.get()); 83 DCHECK(task_queue_manager_.get());
91 task_queue_manager_->SetWorkBatchSize(work_batch_size); 84 task_queue_manager_->SetWorkBatchSize(work_batch_size);
92 } 85 }
93 86
94 TaskQueueManager* SchedulerHelper::GetTaskQueueManagerForTesting() { 87 TaskQueueManager* SchedulerHelper::GetTaskQueueManagerForTesting() {
95 CheckOnValidThread(); 88 CheckOnValidThread();
96 return task_queue_manager_.get(); 89 return task_queue_manager_.get();
97 } 90 }
98 91
99 base::TimeTicks SchedulerHelper::Now() const { 92 base::TimeTicks SchedulerHelper::Now() const {
100 return time_source_->NowTicks(); 93 return task_queue_manager_->tick_clock()->NowTicks();
94 }
95
96 base::TickClock* SchedulerHelper::tick_clock() const {
97 return task_queue_manager_->tick_clock();
101 } 98 }
102 99
103 base::TimeTicks SchedulerHelper::NextPendingDelayedTaskRunTime() const { 100 base::TimeTicks SchedulerHelper::NextPendingDelayedTaskRunTime() const {
104 CheckOnValidThread(); 101 CheckOnValidThread();
105 DCHECK(task_queue_manager_.get()); 102 DCHECK(task_queue_manager_.get());
106 return task_queue_manager_->NextPendingDelayedTaskRunTime(); 103 return task_queue_manager_->NextPendingDelayedTaskRunTime();
107 } 104 }
108 105
109 bool SchedulerHelper::GetAndClearSystemIsQuiescentBit() { 106 bool SchedulerHelper::GetAndClearSystemIsQuiescentBit() {
110 CheckOnValidThread(); 107 CheckOnValidThread();
(...skipping 22 matching lines...) Expand all
133 task_queue_manager_->SetObserver(this); 130 task_queue_manager_->SetObserver(this);
134 } 131 }
135 132
136 void SchedulerHelper::OnUnregisterTaskQueue( 133 void SchedulerHelper::OnUnregisterTaskQueue(
137 const scoped_refptr<internal::TaskQueueImpl>& queue) { 134 const scoped_refptr<internal::TaskQueueImpl>& queue) {
138 if (observer_) 135 if (observer_)
139 observer_->OnUnregisterTaskQueue(queue); 136 observer_->OnUnregisterTaskQueue(queue);
140 } 137 }
141 138
142 } // namespace scheduler 139 } // namespace scheduler
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698