| 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 #include "components/scheduler/renderer/task_cost_estimator.h" | 5 #include "components/scheduler/renderer/task_cost_estimator.h" |
| 6 | 6 |
| 7 #include "base/time/default_tick_clock.h" | 7 #include "base/time/default_tick_clock.h" |
| 8 | 8 |
| 9 namespace scheduler { | 9 namespace scheduler { |
| 10 | 10 |
| 11 TaskCostEstimator::TaskCostEstimator(int sample_count, | 11 TaskCostEstimator::TaskCostEstimator(base::TickClock* time_source, |
| 12 int sample_count, |
| 12 double estimation_percentile) | 13 double estimation_percentile) |
| 13 : rolling_time_delta_history_(sample_count), | 14 : rolling_time_delta_history_(sample_count), |
| 14 time_source_(new base::DefaultTickClock), | 15 time_source_(time_source), |
| 15 outstanding_task_count_(0), | 16 outstanding_task_count_(0), |
| 16 estimation_percentile_(estimation_percentile) {} | 17 estimation_percentile_(estimation_percentile) {} |
| 17 | 18 |
| 18 TaskCostEstimator::~TaskCostEstimator() {} | 19 TaskCostEstimator::~TaskCostEstimator() {} |
| 19 | 20 |
| 20 void TaskCostEstimator::WillProcessTask(const base::PendingTask& pending_task) { | 21 void TaskCostEstimator::WillProcessTask(const base::PendingTask& pending_task) { |
| 21 // Avoid measuring the duration in nested run loops. | 22 // Avoid measuring the duration in nested run loops. |
| 22 if (++outstanding_task_count_ == 1) | 23 if (++outstanding_task_count_ == 1) |
| 23 task_start_time_ = time_source_->NowTicks(); | 24 task_start_time_ = time_source_->NowTicks(); |
| 24 } | 25 } |
| 25 | 26 |
| 26 void TaskCostEstimator::DidProcessTask(const base::PendingTask& pending_task) { | 27 void TaskCostEstimator::DidProcessTask(const base::PendingTask& pending_task) { |
| 27 if (--outstanding_task_count_ == 0) { | 28 if (--outstanding_task_count_ == 0) { |
| 28 base::TimeDelta duration = time_source_->NowTicks() - task_start_time_; | 29 base::TimeDelta duration = time_source_->NowTicks() - task_start_time_; |
| 29 rolling_time_delta_history_.InsertSample(duration); | 30 rolling_time_delta_history_.InsertSample(duration); |
| 30 } | 31 } |
| 31 } | 32 } |
| 32 | 33 |
| 33 base::TimeDelta TaskCostEstimator::expected_task_duration() const { | 34 base::TimeDelta TaskCostEstimator::expected_task_duration() const { |
| 34 return rolling_time_delta_history_.Percentile(estimation_percentile_); | 35 return rolling_time_delta_history_.Percentile(estimation_percentile_); |
| 35 } | 36 } |
| 36 | 37 |
| 37 void TaskCostEstimator::Clear() { | 38 void TaskCostEstimator::Clear() { |
| 38 rolling_time_delta_history_.Clear(); | 39 rolling_time_delta_history_.Clear(); |
| 39 expected_task_duration_ = base::TimeDelta(); | 40 expected_task_duration_ = base::TimeDelta(); |
| 40 } | 41 } |
| 41 | 42 |
| 42 void TaskCostEstimator::SetTimeSourceForTesting( | |
| 43 scoped_ptr<base::TickClock> time_source) { | |
| 44 time_source_ = time_source.Pass(); | |
| 45 } | |
| 46 | |
| 47 } // namespace scheduler | 43 } // namespace scheduler |
| OLD | NEW |