| 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/base/task_time_tracker.h" |
| 12 #include "components/scheduler/child/idle_helper.h" | 13 #include "components/scheduler/child/idle_helper.h" |
| 13 #include "components/scheduler/child/scheduler_helper.h" | 14 #include "components/scheduler/child/scheduler_helper.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" |
| 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 TaskTimeTracker::Observer, |
| 42 public QueueingTimeEstimator::Client { |
| 40 public: | 43 public: |
| 41 // Keep RendererScheduler::UseCaseToString in sync with this enum. | 44 // Keep RendererScheduler::UseCaseToString in sync with this enum. |
| 42 enum class UseCase { | 45 enum class UseCase { |
| 43 // No active use case detected. | 46 // No active use case detected. |
| 44 NONE, | 47 NONE, |
| 45 // A continuous gesture (e.g., scroll, pinch) which is being driven by the | 48 // A continuous gesture (e.g., scroll, pinch) which is being driven by the |
| 46 // compositor thread. | 49 // compositor thread. |
| 47 COMPOSITOR_GESTURE, | 50 COMPOSITOR_GESTURE, |
| 48 // An unspecified touch gesture which is being handled by the main thread. | 51 // An unspecified touch gesture which is being handled by the main thread. |
| 49 // Note that since we don't have a full view of the use case, we should be | 52 // Note that since we don't have a full view of the use case, we should be |
| (...skipping 69 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 119 // RenderWidgetSignals::Observer implementation: | 122 // RenderWidgetSignals::Observer implementation: |
| 120 void SetAllRenderWidgetsHidden(bool hidden) override; | 123 void SetAllRenderWidgetsHidden(bool hidden) override; |
| 121 void SetHasVisibleRenderWidgetWithTouchHandler( | 124 void SetHasVisibleRenderWidgetWithTouchHandler( |
| 122 bool has_visible_render_widget_with_touch_handler) override; | 125 bool has_visible_render_widget_with_touch_handler) override; |
| 123 | 126 |
| 124 // SchedulerHelper::Observer implementation: | 127 // SchedulerHelper::Observer implementation: |
| 125 void OnUnregisterTaskQueue(const scoped_refptr<TaskQueue>& queue) override; | 128 void OnUnregisterTaskQueue(const scoped_refptr<TaskQueue>& queue) override; |
| 126 void OnTriedToExecuteBlockedTask(const TaskQueue& queue, | 129 void OnTriedToExecuteBlockedTask(const TaskQueue& queue, |
| 127 const base::PendingTask& task) override; | 130 const base::PendingTask& task) override; |
| 128 | 131 |
| 132 // TaskTimeTracker::Observer implementation: |
| 133 void ReportTaskTime(base::TimeTicks start_time, |
| 134 base::TimeTicks end_time) override; |
| 135 |
| 136 // QueueingTimeEstimator::Client implementation: |
| 137 void OnQueueingTimeForWindowEstimated(base::TimeDelta queueing_time) override; |
| 138 |
| 129 // Returns a task runner where tasks run at the highest possible priority. | 139 // Returns a task runner where tasks run at the highest possible priority. |
| 130 scoped_refptr<TaskQueue> ControlTaskRunner(); | 140 scoped_refptr<TaskQueue> ControlTaskRunner(); |
| 131 | 141 |
| 132 void RegisterTimeDomain(TimeDomain* time_domain); | 142 void RegisterTimeDomain(TimeDomain* time_domain); |
| 133 void UnregisterTimeDomain(TimeDomain* time_domain); | 143 void UnregisterTimeDomain(TimeDomain* time_domain); |
| 134 | 144 |
| 135 void SetExpensiveTaskBlockingAllowed(bool allowed); | 145 void SetExpensiveTaskBlockingAllowed(bool allowed); |
| 136 | 146 |
| 137 void AddWebViewScheduler(WebViewSchedulerImpl* web_view_scheduler); | 147 void AddWebViewScheduler(WebViewSchedulerImpl* web_view_scheduler); |
| 138 void RemoveWebViewScheduler(WebViewSchedulerImpl* web_view_scheduler); | 148 void RemoveWebViewScheduler(WebViewSchedulerImpl* web_view_scheduler); |
| (...skipping 187 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 326 | 336 |
| 327 void ApplyTaskQueuePolicy(TaskQueue* task_queue, | 337 void ApplyTaskQueuePolicy(TaskQueue* task_queue, |
| 328 const TaskQueuePolicy& old_task_queue_policy, | 338 const TaskQueuePolicy& old_task_queue_policy, |
| 329 const TaskQueuePolicy& new_task_queue_policy) const; | 339 const TaskQueuePolicy& new_task_queue_policy) const; |
| 330 | 340 |
| 331 static const char* ExpensiveTaskPolicyToString( | 341 static const char* ExpensiveTaskPolicyToString( |
| 332 ExpensiveTaskPolicy expensive_task_policy); | 342 ExpensiveTaskPolicy expensive_task_policy); |
| 333 | 343 |
| 334 SchedulerHelper helper_; | 344 SchedulerHelper helper_; |
| 335 IdleHelper idle_helper_; | 345 IdleHelper idle_helper_; |
| 346 TaskTimeTracker task_time_tracker_; |
| 336 std::unique_ptr<ThrottlingHelper> throttling_helper_; | 347 std::unique_ptr<ThrottlingHelper> throttling_helper_; |
| 337 RenderWidgetSignals render_widget_scheduler_signals_; | 348 RenderWidgetSignals render_widget_scheduler_signals_; |
| 338 | 349 |
| 339 const scoped_refptr<TaskQueue> control_task_runner_; | 350 const scoped_refptr<TaskQueue> control_task_runner_; |
| 340 const scoped_refptr<TaskQueue> compositor_task_runner_; | 351 const scoped_refptr<TaskQueue> compositor_task_runner_; |
| 341 std::set<scoped_refptr<TaskQueue>> loading_task_runners_; | 352 std::set<scoped_refptr<TaskQueue>> loading_task_runners_; |
| 342 std::set<scoped_refptr<TaskQueue>> timer_task_runners_; | 353 std::set<scoped_refptr<TaskQueue>> timer_task_runners_; |
| 343 scoped_refptr<TaskQueue> default_loading_task_runner_; | 354 scoped_refptr<TaskQueue> default_loading_task_runner_; |
| 344 scoped_refptr<TaskQueue> default_timer_task_runner_; | 355 scoped_refptr<TaskQueue> default_timer_task_runner_; |
| 345 | 356 |
| 346 base::Closure update_policy_closure_; | 357 base::Closure update_policy_closure_; |
| 347 DeadlineTaskRunner delayed_update_policy_runner_; | 358 DeadlineTaskRunner delayed_update_policy_runner_; |
| 348 CancelableClosureHolder end_renderer_hidden_idle_period_closure_; | 359 CancelableClosureHolder end_renderer_hidden_idle_period_closure_; |
| 349 CancelableClosureHolder suspend_timers_when_backgrounded_closure_; | 360 CancelableClosureHolder suspend_timers_when_backgrounded_closure_; |
| 350 | 361 |
| 351 // We have decided to improve thread safety at the cost of some boilerplate | 362 // We have decided to improve thread safety at the cost of some boilerplate |
| 352 // (the accessors) for the following data members. | 363 // (the accessors) for the following data members. |
| 353 | 364 |
| 354 struct MainThreadOnly { | 365 struct MainThreadOnly { |
| 355 MainThreadOnly(const scoped_refptr<TaskQueue>& compositor_task_runner, | 366 MainThreadOnly(RendererSchedulerImpl* renderer_scheduler_impl, |
| 367 const scoped_refptr<TaskQueue>& compositor_task_runner, |
| 356 base::TickClock* time_source); | 368 base::TickClock* time_source); |
| 357 ~MainThreadOnly(); | 369 ~MainThreadOnly(); |
| 358 | 370 |
| 359 TaskCostEstimator loading_task_cost_estimator; | 371 TaskCostEstimator loading_task_cost_estimator; |
| 360 TaskCostEstimator timer_task_cost_estimator; | 372 TaskCostEstimator timer_task_cost_estimator; |
| 373 QueueingTimeEstimator queueing_time_estimator; |
| 361 IdleTimeEstimator idle_time_estimator; | 374 IdleTimeEstimator idle_time_estimator; |
| 362 UseCase current_use_case; | 375 UseCase current_use_case; |
| 363 Policy current_policy; | 376 Policy current_policy; |
| 364 base::TimeTicks current_policy_expiration_time; | 377 base::TimeTicks current_policy_expiration_time; |
| 365 base::TimeTicks estimated_next_frame_begin; | 378 base::TimeTicks estimated_next_frame_begin; |
| 366 base::TimeDelta compositor_frame_interval; | 379 base::TimeDelta compositor_frame_interval; |
| 367 base::TimeDelta longest_jank_free_task_duration; | 380 base::TimeDelta longest_jank_free_task_duration; |
| 368 int timer_queue_suspend_count; // TIMER_TASK_QUEUE suspended if non-zero. | 381 int timer_queue_suspend_count; // TIMER_TASK_QUEUE suspended if non-zero. |
| 369 int navigation_task_expected_count; | 382 int navigation_task_expected_count; |
| 370 ExpensiveTaskPolicy expensive_task_policy; | 383 ExpensiveTaskPolicy expensive_task_policy; |
| (...skipping 83 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 454 | 467 |
| 455 PollableThreadSafeFlag policy_may_need_update_; | 468 PollableThreadSafeFlag policy_may_need_update_; |
| 456 base::WeakPtrFactory<RendererSchedulerImpl> weak_factory_; | 469 base::WeakPtrFactory<RendererSchedulerImpl> weak_factory_; |
| 457 | 470 |
| 458 DISALLOW_COPY_AND_ASSIGN(RendererSchedulerImpl); | 471 DISALLOW_COPY_AND_ASSIGN(RendererSchedulerImpl); |
| 459 }; | 472 }; |
| 460 | 473 |
| 461 } // namespace scheduler | 474 } // namespace scheduler |
| 462 | 475 |
| 463 #endif // COMPONENTS_SCHEDULER_RENDERER_RENDERER_SCHEDULER_IMPL_H_ | 476 #endif // COMPONENTS_SCHEDULER_RENDERER_RENDERER_SCHEDULER_IMPL_H_ |
| OLD | NEW |