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/macros.h" | 9 #include "base/macros.h" |
10 #include "base/synchronization/lock.h" | 10 #include "base/synchronization/lock.h" |
11 #include "components/scheduler/base/pollable_thread_safe_flag.h" | 11 #include "components/scheduler/base/pollable_thread_safe_flag.h" |
12 #include "components/scheduler/child/idle_helper.h" | 12 #include "components/scheduler/child/idle_helper.h" |
13 #include "components/scheduler/child/scheduler_helper.h" | 13 #include "components/scheduler/child/scheduler_helper.h" |
14 #include "components/scheduler/renderer/deadline_task_runner.h" | 14 #include "components/scheduler/renderer/deadline_task_runner.h" |
15 #include "components/scheduler/renderer/idle_time_estimator.h" | 15 #include "components/scheduler/renderer/idle_time_estimator.h" |
| 16 #include "components/scheduler/renderer/queueing_time_estimator.h" |
16 #include "components/scheduler/renderer/render_widget_signals.h" | 17 #include "components/scheduler/renderer/render_widget_signals.h" |
17 #include "components/scheduler/renderer/renderer_scheduler.h" | 18 #include "components/scheduler/renderer/renderer_scheduler.h" |
18 #include "components/scheduler/renderer/task_cost_estimator.h" | 19 #include "components/scheduler/renderer/task_cost_estimator.h" |
19 #include "components/scheduler/renderer/throttling_helper.h" | 20 #include "components/scheduler/renderer/throttling_helper.h" |
20 #include "components/scheduler/renderer/user_model.h" | 21 #include "components/scheduler/renderer/user_model.h" |
21 #include "components/scheduler/renderer/web_view_scheduler_impl.h" | 22 #include "components/scheduler/renderer/web_view_scheduler_impl.h" |
22 #include "components/scheduler/scheduler_export.h" | 23 #include "components/scheduler/scheduler_export.h" |
23 | 24 |
24 namespace base { | 25 namespace base { |
25 namespace trace_event { | 26 namespace trace_event { |
26 class ConvertableToTraceFormat; | 27 class ConvertableToTraceFormat; |
27 } | 28 } |
28 } | 29 } |
29 | 30 |
30 namespace scheduler { | 31 namespace scheduler { |
31 class RenderWidgetSchedulingState; | 32 class RenderWidgetSchedulingState; |
32 class WebViewSchedulerImpl; | 33 class WebViewSchedulerImpl; |
33 class ThrottlingHelper; | 34 class ThrottlingHelper; |
34 | 35 |
35 class SCHEDULER_EXPORT RendererSchedulerImpl | 36 class SCHEDULER_EXPORT RendererSchedulerImpl |
36 : public RendererScheduler, | 37 : public RendererScheduler, |
37 public IdleHelper::Delegate, | 38 public IdleHelper::Delegate, |
38 public SchedulerHelper::Observer, | 39 public SchedulerHelper::Observer, |
39 public RenderWidgetSignals::Observer { | 40 public RenderWidgetSignals::Observer, |
| 41 public QueueingTimeEstimator::QueueingTimeEstimatorClient { |
40 public: | 42 public: |
41 RendererSchedulerImpl(scoped_refptr<SchedulerTqmDelegate> main_task_runner); | 43 RendererSchedulerImpl(scoped_refptr<SchedulerTqmDelegate> main_task_runner); |
42 ~RendererSchedulerImpl() override; | 44 ~RendererSchedulerImpl() override; |
43 | 45 |
44 // RendererScheduler implementation: | 46 // RendererScheduler implementation: |
45 scoped_ptr<blink::WebThread> CreateMainThread() override; | 47 scoped_ptr<blink::WebThread> CreateMainThread() override; |
46 scoped_refptr<TaskQueue> DefaultTaskRunner() override; | 48 scoped_refptr<TaskQueue> DefaultTaskRunner() override; |
47 scoped_refptr<SingleThreadIdleTaskRunner> IdleTaskRunner() override; | 49 scoped_refptr<SingleThreadIdleTaskRunner> IdleTaskRunner() override; |
48 scoped_refptr<TaskQueue> CompositorTaskRunner() override; | 50 scoped_refptr<TaskQueue> CompositorTaskRunner() override; |
49 scoped_refptr<TaskQueue> LoadingTaskRunner() override; | 51 scoped_refptr<TaskQueue> LoadingTaskRunner() override; |
(...skipping 32 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
82 // RenderWidgetSignals::Observer implementation: | 84 // RenderWidgetSignals::Observer implementation: |
83 void SetAllRenderWidgetsHidden(bool hidden) override; | 85 void SetAllRenderWidgetsHidden(bool hidden) override; |
84 void SetHasVisibleRenderWidgetWithTouchHandler( | 86 void SetHasVisibleRenderWidgetWithTouchHandler( |
85 bool has_visible_render_widget_with_touch_handler) override; | 87 bool has_visible_render_widget_with_touch_handler) override; |
86 | 88 |
87 // SchedulerHelper::Observer implementation: | 89 // SchedulerHelper::Observer implementation: |
88 void OnUnregisterTaskQueue(const scoped_refptr<TaskQueue>& queue) override; | 90 void OnUnregisterTaskQueue(const scoped_refptr<TaskQueue>& queue) override; |
89 void OnTriedToExecuteBlockedTask(const TaskQueue& queue, | 91 void OnTriedToExecuteBlockedTask(const TaskQueue& queue, |
90 const base::PendingTask& task) override; | 92 const base::PendingTask& task) override; |
91 | 93 |
| 94 // QueueingTimeEstimator::QueueingTimeEstimatorClient implementation: |
| 95 void OnQueueingTimeForWindowEstimated(base::TimeDelta queueing_time) override; |
| 96 |
92 // Returns a task runner where tasks run at the highest possible priority. | 97 // Returns a task runner where tasks run at the highest possible priority. |
93 scoped_refptr<TaskQueue> ControlTaskRunner(); | 98 scoped_refptr<TaskQueue> ControlTaskRunner(); |
94 | 99 |
95 void RegisterTimeDomain(TimeDomain* time_domain); | 100 void RegisterTimeDomain(TimeDomain* time_domain); |
96 void UnregisterTimeDomain(TimeDomain* time_domain); | 101 void UnregisterTimeDomain(TimeDomain* time_domain); |
97 | 102 |
98 void SetExpensiveTaskBlockingAllowed(bool allowed); | 103 void SetExpensiveTaskBlockingAllowed(bool allowed); |
99 | 104 |
100 void AddWebViewScheduler(WebViewSchedulerImpl* web_view_scheduler); | 105 void AddWebViewScheduler(WebViewSchedulerImpl* web_view_scheduler); |
101 void RemoveWebViewScheduler(WebViewSchedulerImpl* web_view_scheduler); | 106 void RemoveWebViewScheduler(WebViewSchedulerImpl* web_view_scheduler); |
(...skipping 207 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
309 | 314 |
310 base::Closure update_policy_closure_; | 315 base::Closure update_policy_closure_; |
311 DeadlineTaskRunner delayed_update_policy_runner_; | 316 DeadlineTaskRunner delayed_update_policy_runner_; |
312 CancelableClosureHolder end_renderer_hidden_idle_period_closure_; | 317 CancelableClosureHolder end_renderer_hidden_idle_period_closure_; |
313 CancelableClosureHolder suspend_timers_when_backgrounded_closure_; | 318 CancelableClosureHolder suspend_timers_when_backgrounded_closure_; |
314 | 319 |
315 // We have decided to improve thread safety at the cost of some boilerplate | 320 // We have decided to improve thread safety at the cost of some boilerplate |
316 // (the accessors) for the following data members. | 321 // (the accessors) for the following data members. |
317 | 322 |
318 struct MainThreadOnly { | 323 struct MainThreadOnly { |
319 MainThreadOnly(const scoped_refptr<TaskQueue>& compositor_task_runner, | 324 MainThreadOnly(RendererSchedulerImpl* renderer_scheduler_impl, |
| 325 const scoped_refptr<TaskQueue>& compositor_task_runner, |
320 base::TickClock* time_source); | 326 base::TickClock* time_source); |
321 ~MainThreadOnly(); | 327 ~MainThreadOnly(); |
322 | 328 |
323 TaskCostEstimator loading_task_cost_estimator; | 329 TaskCostEstimator loading_task_cost_estimator; |
324 TaskCostEstimator timer_task_cost_estimator; | 330 TaskCostEstimator timer_task_cost_estimator; |
325 IdleTimeEstimator idle_time_estimator; | 331 IdleTimeEstimator idle_time_estimator; |
| 332 QueueingTimeEstimator queueing_time_estimator; |
326 UseCase current_use_case; | 333 UseCase current_use_case; |
327 Policy current_policy; | 334 Policy current_policy; |
328 base::TimeTicks current_policy_expiration_time; | 335 base::TimeTicks current_policy_expiration_time; |
329 base::TimeTicks estimated_next_frame_begin; | 336 base::TimeTicks estimated_next_frame_begin; |
330 base::TimeDelta compositor_frame_interval; | 337 base::TimeDelta compositor_frame_interval; |
331 base::TimeDelta longest_jank_free_task_duration; | 338 base::TimeDelta longest_jank_free_task_duration; |
332 int timer_queue_suspend_count; // TIMER_TASK_QUEUE suspended if non-zero. | 339 int timer_queue_suspend_count; // TIMER_TASK_QUEUE suspended if non-zero. |
333 int navigation_task_expected_count; | 340 int navigation_task_expected_count; |
334 ExpensiveTaskPolicy expensive_task_policy; | 341 ExpensiveTaskPolicy expensive_task_policy; |
335 bool renderer_hidden; | 342 bool renderer_hidden; |
(...skipping 79 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
415 | 422 |
416 PollableThreadSafeFlag policy_may_need_update_; | 423 PollableThreadSafeFlag policy_may_need_update_; |
417 base::WeakPtrFactory<RendererSchedulerImpl> weak_factory_; | 424 base::WeakPtrFactory<RendererSchedulerImpl> weak_factory_; |
418 | 425 |
419 DISALLOW_COPY_AND_ASSIGN(RendererSchedulerImpl); | 426 DISALLOW_COPY_AND_ASSIGN(RendererSchedulerImpl); |
420 }; | 427 }; |
421 | 428 |
422 } // namespace scheduler | 429 } // namespace scheduler |
423 | 430 |
424 #endif // COMPONENTS_SCHEDULER_RENDERER_RENDERER_SCHEDULER_IMPL_H_ | 431 #endif // COMPONENTS_SCHEDULER_RENDERER_RENDERER_SCHEDULER_IMPL_H_ |
OLD | NEW |