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 #ifndef COMPONENTS_SCHEDULER_RENDERER_RENDERER_SCHEDULER_IMPL_H_ | 5 #ifndef COMPONENTS_SCHEDULER_RENDERER_RENDERER_SCHEDULER_IMPL_H_ |
6 #define COMPONENTS_SCHEDULER_RENDERER_RENDERER_SCHEDULER_IMPL_H_ | 6 #define COMPONENTS_SCHEDULER_RENDERER_RENDERER_SCHEDULER_IMPL_H_ |
7 | 7 |
8 #include "base/atomicops.h" | 8 #include "base/atomicops.h" |
9 #include "base/synchronization/lock.h" | 9 #include "base/synchronization/lock.h" |
10 #include "components/scheduler/base/pollable_thread_safe_flag.h" | 10 #include "components/scheduler/base/pollable_thread_safe_flag.h" |
11 #include "components/scheduler/child/idle_helper.h" | 11 #include "components/scheduler/child/idle_helper.h" |
12 #include "components/scheduler/child/scheduler_helper.h" | 12 #include "components/scheduler/child/scheduler_helper.h" |
13 #include "components/scheduler/renderer/deadline_task_runner.h" | 13 #include "components/scheduler/renderer/deadline_task_runner.h" |
14 #include "components/scheduler/renderer/idle_time_estimator.h" | 14 #include "components/scheduler/renderer/idle_time_estimator.h" |
15 #include "components/scheduler/renderer/render_widget_signals.h" | 15 #include "components/scheduler/renderer/render_widget_signals.h" |
16 #include "components/scheduler/renderer/renderer_scheduler.h" | 16 #include "components/scheduler/renderer/renderer_scheduler.h" |
17 #include "components/scheduler/renderer/task_cost_estimator.h" | 17 #include "components/scheduler/renderer/task_cost_estimator.h" |
18 #include "components/scheduler/renderer/throttling_helper.h" | |
18 #include "components/scheduler/renderer/user_model.h" | 19 #include "components/scheduler/renderer/user_model.h" |
19 #include "components/scheduler/scheduler_export.h" | 20 #include "components/scheduler/scheduler_export.h" |
20 | 21 |
21 namespace base { | 22 namespace base { |
22 namespace trace_event { | 23 namespace trace_event { |
23 class ConvertableToTraceFormat; | 24 class ConvertableToTraceFormat; |
24 } | 25 } |
25 } | 26 } |
26 | 27 |
27 namespace scheduler { | 28 namespace scheduler { |
28 class RenderWidgetSchedulingState; | 29 class RenderWidgetSchedulingState; |
30 class ThrottlingHelper; | |
29 | 31 |
30 class SCHEDULER_EXPORT RendererSchedulerImpl | 32 class SCHEDULER_EXPORT RendererSchedulerImpl |
31 : public RendererScheduler, | 33 : public RendererScheduler, |
32 public IdleHelper::Delegate, | 34 public IdleHelper::Delegate, |
33 public SchedulerHelper::Observer, | 35 public SchedulerHelper::Observer, |
34 public RenderWidgetSignals::Observer { | 36 public RenderWidgetSignals::Observer { |
35 public: | 37 public: |
36 RendererSchedulerImpl(scoped_refptr<SchedulerTqmDelegate> main_task_runner); | 38 RendererSchedulerImpl(scoped_refptr<SchedulerTqmDelegate> main_task_runner); |
37 ~RendererSchedulerImpl() override; | 39 ~RendererSchedulerImpl() override; |
38 | 40 |
(...skipping 36 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
75 double MonotonicallyIncreasingTimeSeconds() const override; | 77 double MonotonicallyIncreasingTimeSeconds() const override; |
76 | 78 |
77 // RenderWidgetSignals::Observer implementation: | 79 // RenderWidgetSignals::Observer implementation: |
78 void SetAllRenderWidgetsHidden(bool hidden) override; | 80 void SetAllRenderWidgetsHidden(bool hidden) override; |
79 void SetHasVisibleRenderWidgetWithTouchHandler( | 81 void SetHasVisibleRenderWidgetWithTouchHandler( |
80 bool has_visible_render_widget_with_touch_handler) override; | 82 bool has_visible_render_widget_with_touch_handler) override; |
81 | 83 |
82 // TaskQueueManager::Observer implementation: | 84 // TaskQueueManager::Observer implementation: |
83 void OnUnregisterTaskQueue(const scoped_refptr<TaskQueue>& queue) override; | 85 void OnUnregisterTaskQueue(const scoped_refptr<TaskQueue>& queue) override; |
84 | 86 |
87 // Returns a task runner where tasks run at the highest possible priority. | |
88 scoped_refptr<TaskQueue> ControlTaskRunner(); | |
89 | |
90 void RegisterTimeDomain(const scoped_refptr<TimeDomain>& time_domain); | |
91 void UnregisterTimeDomain(const scoped_refptr<TimeDomain>& time_domain); | |
92 | |
85 // Test helpers. | 93 // Test helpers. |
86 SchedulerHelper* GetSchedulerHelperForTesting(); | 94 SchedulerHelper* GetSchedulerHelperForTesting(); |
87 TaskCostEstimator* GetLoadingTaskCostEstimatorForTesting(); | 95 TaskCostEstimator* GetLoadingTaskCostEstimatorForTesting(); |
88 TaskCostEstimator* GetTimerTaskCostEstimatorForTesting(); | 96 TaskCostEstimator* GetTimerTaskCostEstimatorForTesting(); |
89 IdleTimeEstimator* GetIdleTimeEstimatorForTesting(); | 97 IdleTimeEstimator* GetIdleTimeEstimatorForTesting(); |
90 base::TimeTicks CurrentIdleTaskDeadlineForTesting() const; | 98 base::TimeTicks CurrentIdleTaskDeadlineForTesting() const; |
91 | 99 |
100 const scoped_refptr<RealTimeDomain>& real_time_domain() const { | |
101 return helper_.real_time_domain(); | |
102 } | |
103 | |
104 ThrottlingHelper* throttling_helper() { return &throttling_helper_; } | |
105 | |
92 private: | 106 private: |
93 friend class RendererSchedulerImplTest; | 107 friend class RendererSchedulerImplTest; |
94 friend class RendererSchedulerImplForTest; | 108 friend class RendererSchedulerImplForTest; |
95 friend class RenderWidgetSchedulingState; | 109 friend class RenderWidgetSchedulingState; |
96 | 110 |
97 struct Policy { | 111 struct Policy { |
98 Policy(); | 112 Policy(); |
99 | 113 |
100 TaskQueue::QueuePriority compositor_queue_priority; | 114 TaskQueue::QueuePriority compositor_queue_priority; |
101 TaskQueue::QueuePriority loading_queue_priority; | 115 TaskQueue::QueuePriority loading_queue_priority; |
(...skipping 124 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
226 // background/foreground signal. | 240 // background/foreground signal. |
227 void SuspendTimerQueueWhenBackgrounded(); | 241 void SuspendTimerQueueWhenBackgrounded(); |
228 void ResumeTimerQueueWhenForegrounded(); | 242 void ResumeTimerQueueWhenForegrounded(); |
229 | 243 |
230 // The task cost estimators and the UserModel need to be reset upon page | 244 // The task cost estimators and the UserModel need to be reset upon page |
231 // nagigation. This function does that. Must be called from the main thread. | 245 // nagigation. This function does that. Must be called from the main thread. |
232 void ResetForNavigationLocked(); | 246 void ResetForNavigationLocked(); |
233 | 247 |
234 SchedulerHelper helper_; | 248 SchedulerHelper helper_; |
235 IdleHelper idle_helper_; | 249 IdleHelper idle_helper_; |
250 ThrottlingHelper throttling_helper_; | |
236 RenderWidgetSignals render_widget_scheduler_signals_; | 251 RenderWidgetSignals render_widget_scheduler_signals_; |
237 | 252 |
238 const scoped_refptr<TaskQueue> control_task_runner_; | 253 const scoped_refptr<TaskQueue> control_task_runner_; |
239 const scoped_refptr<TaskQueue> compositor_task_runner_; | 254 const scoped_refptr<TaskQueue> compositor_task_runner_; |
240 std::set<scoped_refptr<TaskQueue>> loading_task_runners_; | 255 std::set<scoped_refptr<TaskQueue>> loading_task_runners_; |
241 std::set<scoped_refptr<TaskQueue>> timer_task_runners_; | 256 std::set<scoped_refptr<TaskQueue>> timer_task_runners_; |
242 scoped_refptr<TaskQueue> default_loading_task_runner_; | 257 scoped_refptr<TaskQueue> default_loading_task_runner_; |
243 scoped_refptr<TaskQueue> default_timer_task_runner_; | 258 scoped_refptr<TaskQueue> default_timer_task_runner_; |
259 scoped_refptr<VirtualTimeDomain> virtual_time_domain_; | |
Sami
2015/11/24 12:48:48
Is this used for anything?
alex clarke (OOO till 29th)
2015/11/25 12:29:36
Done.
| |
244 | 260 |
245 base::Closure update_policy_closure_; | 261 base::Closure update_policy_closure_; |
246 DeadlineTaskRunner delayed_update_policy_runner_; | 262 DeadlineTaskRunner delayed_update_policy_runner_; |
247 CancelableClosureHolder end_renderer_hidden_idle_period_closure_; | 263 CancelableClosureHolder end_renderer_hidden_idle_period_closure_; |
248 CancelableClosureHolder suspend_timers_when_backgrounded_closure_; | 264 CancelableClosureHolder suspend_timers_when_backgrounded_closure_; |
249 | 265 |
250 // We have decided to improve thread safety at the cost of some boilerplate | 266 // We have decided to improve thread safety at the cost of some boilerplate |
251 // (the accessors) for the following data members. | 267 // (the accessors) for the following data members. |
252 | 268 |
253 struct MainThreadOnly { | 269 struct MainThreadOnly { |
(...skipping 88 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
342 | 358 |
343 PollableThreadSafeFlag policy_may_need_update_; | 359 PollableThreadSafeFlag policy_may_need_update_; |
344 base::WeakPtrFactory<RendererSchedulerImpl> weak_factory_; | 360 base::WeakPtrFactory<RendererSchedulerImpl> weak_factory_; |
345 | 361 |
346 DISALLOW_COPY_AND_ASSIGN(RendererSchedulerImpl); | 362 DISALLOW_COPY_AND_ASSIGN(RendererSchedulerImpl); |
347 }; | 363 }; |
348 | 364 |
349 } // namespace scheduler | 365 } // namespace scheduler |
350 | 366 |
351 #endif // COMPONENTS_SCHEDULER_RENDERER_RENDERER_SCHEDULER_IMPL_H_ | 367 #endif // COMPONENTS_SCHEDULER_RENDERER_RENDERER_SCHEDULER_IMPL_H_ |
OLD | NEW |