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