OLD | NEW |
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 #ifndef CONTENT_CHILD_SCHEDULER_SCHEDULER_HELPER_H_ | 5 #ifndef CONTENT_CHILD_SCHEDULER_SCHEDULER_HELPER_H_ |
6 #define CONTENT_CHILD_SCHEDULER_SCHEDULER_HELPER_H_ | 6 #define CONTENT_CHILD_SCHEDULER_SCHEDULER_HELPER_H_ |
7 | 7 |
8 #include "cc/test/test_now_source.h" | |
9 #include "content/child/scheduler/cancelable_closure_holder.h" | 8 #include "content/child/scheduler/cancelable_closure_holder.h" |
10 #include "content/child/scheduler/single_thread_idle_task_runner.h" | 9 #include "content/child/scheduler/single_thread_idle_task_runner.h" |
11 #include "content/child/scheduler/task_queue_manager.h" | 10 #include "content/child/scheduler/task_queue_manager.h" |
| 11 #include "content/child/scheduler/time_source.h" |
12 | 12 |
13 namespace content { | 13 namespace content { |
14 | 14 |
15 class PrioritizingTaskQueueSelector; | 15 class PrioritizingTaskQueueSelector; |
16 class NestableSingleThreadTaskRunner; | 16 class NestableSingleThreadTaskRunner; |
17 | 17 |
18 // Common scheduler functionality for Default and Idle tasks. | 18 // Common scheduler functionality for Default and Idle tasks. |
19 class CONTENT_EXPORT SchedulerHelper { | 19 class CONTENT_EXPORT SchedulerHelper { |
20 public: | 20 public: |
21 // Used to by scheduler implementations to customize idle behaviour. | 21 // Used to by scheduler implementations to customize idle behaviour. |
(...skipping 136 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
158 // Accessor methods. | 158 // Accessor methods. |
159 base::TimeTicks Now() const; | 159 base::TimeTicks Now() const; |
160 IdlePeriodState SchedulerIdlePeriodState() const; | 160 IdlePeriodState SchedulerIdlePeriodState() const; |
161 PrioritizingTaskQueueSelector* SchedulerTaskQueueSelector() const; | 161 PrioritizingTaskQueueSelector* SchedulerTaskQueueSelector() const; |
162 scoped_refptr<base::SingleThreadTaskRunner> TaskRunnerForQueue( | 162 scoped_refptr<base::SingleThreadTaskRunner> TaskRunnerForQueue( |
163 size_t queue_index) const; | 163 size_t queue_index) const; |
164 void SetQueueName(size_t queue_index, const char* name); | 164 void SetQueueName(size_t queue_index, const char* name); |
165 bool IsQueueEmpty(size_t queue_index) const; | 165 bool IsQueueEmpty(size_t queue_index) const; |
166 | 166 |
167 // Test helpers. | 167 // Test helpers. |
168 void SetTimeSourceForTesting(scoped_refptr<cc::TestNowSource> time_source); | 168 void SetTimeSourceForTesting(scoped_ptr<TimeSource> time_source); |
169 void SetWorkBatchSizeForTesting(size_t work_batch_size); | 169 void SetWorkBatchSizeForTesting(size_t work_batch_size); |
| 170 TaskQueueManager* GetTaskQueueManagerForTesting(); |
170 | 171 |
171 private: | 172 private: |
172 friend class SchedulerHelperTest; | 173 friend class SchedulerHelperTest; |
173 | 174 |
174 bool ShouldWaitForQuiescence(); | 175 bool ShouldWaitForQuiescence(); |
175 void EnableLongIdlePeriodAfterWakeup(); | 176 void EnableLongIdlePeriodAfterWakeup(); |
176 | 177 |
177 base::ThreadChecker thread_checker_; | 178 base::ThreadChecker thread_checker_; |
178 scoped_ptr<PrioritizingTaskQueueSelector> task_queue_selector_; | 179 scoped_ptr<PrioritizingTaskQueueSelector> task_queue_selector_; |
179 scoped_ptr<TaskQueueManager> task_queue_manager_; | 180 scoped_ptr<TaskQueueManager> task_queue_manager_; |
180 | 181 |
181 CancelableClosureHolder end_idle_period_closure_; | 182 CancelableClosureHolder end_idle_period_closure_; |
182 CancelableClosureHolder enable_next_long_idle_period_closure_; | 183 CancelableClosureHolder enable_next_long_idle_period_closure_; |
183 CancelableClosureHolder enable_next_long_idle_period_after_wakeup_closure_; | 184 CancelableClosureHolder enable_next_long_idle_period_after_wakeup_closure_; |
184 | 185 |
185 IdlePeriodState idle_period_state_; | 186 IdlePeriodState idle_period_state_; |
186 SchedulerHelperDelegate* scheduler_helper_delegate_; // NOT OWNED | 187 SchedulerHelperDelegate* scheduler_helper_delegate_; // NOT OWNED |
187 | 188 |
188 scoped_refptr<base::SingleThreadTaskRunner> control_task_runner_; | 189 scoped_refptr<base::SingleThreadTaskRunner> control_task_runner_; |
189 scoped_refptr<base::SingleThreadTaskRunner> control_task_after_wakeup_runner_; | 190 scoped_refptr<base::SingleThreadTaskRunner> control_task_after_wakeup_runner_; |
190 scoped_refptr<base::SingleThreadTaskRunner> default_task_runner_; | 191 scoped_refptr<base::SingleThreadTaskRunner> default_task_runner_; |
191 scoped_refptr<SingleThreadIdleTaskRunner> idle_task_runner_; | 192 scoped_refptr<SingleThreadIdleTaskRunner> idle_task_runner_; |
192 | 193 |
193 // A bitmap which controls the set of queues that are checked for quiescence | 194 // A bitmap which controls the set of queues that are checked for quiescence |
194 // before triggering a long idle period. | 195 // before triggering a long idle period. |
195 uint64 quiescence_monitored_task_queue_mask_; | 196 uint64 quiescence_monitored_task_queue_mask_; |
196 base::TimeDelta required_quiescence_duration_before_long_idle_period_; | 197 base::TimeDelta required_quiescence_duration_before_long_idle_period_; |
197 | 198 |
198 base::TimeTicks idle_period_deadline_; | 199 base::TimeTicks idle_period_deadline_; |
199 scoped_refptr<cc::TestNowSource> time_source_; | 200 scoped_ptr<TimeSource> time_source_; |
200 | 201 |
201 const char* tracing_category_; | 202 const char* tracing_category_; |
202 const char* disabled_by_default_tracing_category_; | 203 const char* disabled_by_default_tracing_category_; |
203 const char* idle_period_tracing_name_; | 204 const char* idle_period_tracing_name_; |
204 | 205 |
205 base::WeakPtr<SchedulerHelper> weak_scheduler_ptr_; | 206 base::WeakPtr<SchedulerHelper> weak_scheduler_ptr_; |
206 base::WeakPtrFactory<SchedulerHelper> weak_factory_; | 207 base::WeakPtrFactory<SchedulerHelper> weak_factory_; |
207 | 208 |
208 DISALLOW_COPY_AND_ASSIGN(SchedulerHelper); | 209 DISALLOW_COPY_AND_ASSIGN(SchedulerHelper); |
209 }; | 210 }; |
210 | 211 |
211 } // namespace content | 212 } // namespace content |
212 | 213 |
213 #endif // CONTENT_CHILD_SCHEDULER_SCHEDULER_HELPER_H_ | 214 #endif // CONTENT_CHILD_SCHEDULER_SCHEDULER_HELPER_H_ |
OLD | NEW |