Index: cc/scheduler/delay_based_time_source.cc |
diff --git a/cc/scheduler/delay_based_time_source.cc b/cc/scheduler/delay_based_time_source.cc |
deleted file mode 100644 |
index ef43524a878288d72e4b89a5fdf6ce485fc18e33..0000000000000000000000000000000000000000 |
--- a/cc/scheduler/delay_based_time_source.cc |
+++ /dev/null |
@@ -1,301 +0,0 @@ |
-// Copyright 2011 The Chromium Authors. All rights reserved. |
-// Use of this source code is governed by a BSD-style license that can be |
-// found in the LICENSE file. |
- |
-#include "cc/scheduler/delay_based_time_source.h" |
- |
-#include <algorithm> |
-#include <cmath> |
-#include <string> |
- |
-#include "base/bind.h" |
-#include "base/location.h" |
-#include "base/logging.h" |
-#include "base/single_thread_task_runner.h" |
-#include "base/trace_event/trace_event.h" |
-#include "base/trace_event/trace_event_argument.h" |
- |
-namespace cc { |
- |
-namespace { |
- |
-// kDoubleTickDivisor prevents ticks from running within the specified |
-// fraction of an interval. This helps account for jitter in the timebase as |
-// well as quick timer reactivation. |
-static const int kDoubleTickDivisor = 2; |
- |
-// kIntervalChangeThreshold is the fraction of the interval that will trigger an |
-// immediate interval change. kPhaseChangeThreshold is the fraction of the |
-// interval that will trigger an immediate phase change. If the changes are |
-// within the thresholds, the change will take place on the next tick. If |
-// either change is outside the thresholds, the next tick will be canceled and |
-// reissued immediately. |
-static const double kIntervalChangeThreshold = 0.25; |
-static const double kPhaseChangeThreshold = 0.25; |
- |
-} // namespace |
- |
-// The following methods correspond to the DelayBasedTimeSource that uses |
-// the base::TimeTicks::Now as the timebase. |
-scoped_refptr<DelayBasedTimeSourceHighRes> DelayBasedTimeSourceHighRes::Create( |
- base::TimeDelta interval, |
- base::SingleThreadTaskRunner* task_runner) { |
- return make_scoped_refptr( |
- new DelayBasedTimeSourceHighRes(interval, task_runner)); |
-} |
- |
-DelayBasedTimeSourceHighRes::DelayBasedTimeSourceHighRes( |
- base::TimeDelta interval, |
- base::SingleThreadTaskRunner* task_runner) |
- : DelayBasedTimeSource(interval, task_runner) { |
-} |
- |
-DelayBasedTimeSourceHighRes::~DelayBasedTimeSourceHighRes() {} |
- |
-base::TimeTicks DelayBasedTimeSourceHighRes::Now() const { |
- return base::TimeTicks::Now(); |
-} |
- |
-// The following methods correspond to the DelayBasedTimeSource that uses |
-// the base::TimeTicks::Now as the timebase. |
-scoped_refptr<DelayBasedTimeSource> DelayBasedTimeSource::Create( |
- base::TimeDelta interval, |
- base::SingleThreadTaskRunner* task_runner) { |
- return make_scoped_refptr(new DelayBasedTimeSource(interval, task_runner)); |
-} |
- |
-DelayBasedTimeSource::DelayBasedTimeSource( |
- base::TimeDelta interval, |
- base::SingleThreadTaskRunner* task_runner) |
- : client_(NULL), |
- last_tick_time_(base::TimeTicks() - interval), |
- current_parameters_(interval, base::TimeTicks()), |
- next_parameters_(interval, base::TimeTicks()), |
- active_(false), |
- task_runner_(task_runner), |
- weak_factory_(this) { |
- DCHECK_GT(interval.ToInternalValue(), 0); |
-} |
- |
-DelayBasedTimeSource::~DelayBasedTimeSource() {} |
- |
-base::TimeTicks DelayBasedTimeSource::SetActive(bool active) { |
- TRACE_EVENT1("cc", "DelayBasedTimeSource::SetActive", "active", active); |
- if (active == active_) |
- return base::TimeTicks(); |
- active_ = active; |
- |
- if (!active_) { |
- weak_factory_.InvalidateWeakPtrs(); |
- return base::TimeTicks(); |
- } |
- |
- PostNextTickTask(Now()); |
- |
- // Determine if there was a tick that was missed while not active. |
- base::TimeTicks last_tick_time_if_always_active = |
- current_parameters_.tick_target - current_parameters_.interval; |
- base::TimeTicks new_tick_time_threshold = |
- last_tick_time_ + current_parameters_.interval / kDoubleTickDivisor; |
- if (last_tick_time_if_always_active > new_tick_time_threshold) { |
- last_tick_time_ = last_tick_time_if_always_active; |
- return last_tick_time_; |
- } |
- |
- return base::TimeTicks(); |
-} |
- |
-bool DelayBasedTimeSource::Active() const { return active_; } |
- |
-base::TimeTicks DelayBasedTimeSource::LastTickTime() const { |
- return last_tick_time_; |
-} |
- |
-base::TimeTicks DelayBasedTimeSource::NextTickTime() const { |
- return Active() ? current_parameters_.tick_target : base::TimeTicks(); |
-} |
- |
-void DelayBasedTimeSource::OnTimerFired() { |
- DCHECK(active_); |
- |
- last_tick_time_ = current_parameters_.tick_target; |
- |
- PostNextTickTask(Now()); |
- |
- // Fire the tick. |
- if (client_) |
- client_->OnTimerTick(); |
-} |
- |
-void DelayBasedTimeSource::SetClient(TimeSourceClient* client) { |
- client_ = client; |
-} |
- |
-void DelayBasedTimeSource::SetTimebaseAndInterval(base::TimeTicks timebase, |
- base::TimeDelta interval) { |
- DCHECK_GT(interval.ToInternalValue(), 0); |
- next_parameters_.interval = interval; |
- next_parameters_.tick_target = timebase; |
- |
- if (!active_) { |
- // If we aren't active, there's no need to reset the timer. |
- return; |
- } |
- |
- // If the change in interval is larger than the change threshold, |
- // request an immediate reset. |
- double interval_delta = |
- std::abs((interval - current_parameters_.interval).InSecondsF()); |
- double interval_change = interval_delta / interval.InSecondsF(); |
- if (interval_change > kIntervalChangeThreshold) { |
- TRACE_EVENT_INSTANT0("cc", "DelayBasedTimeSource::IntervalChanged", |
- TRACE_EVENT_SCOPE_THREAD); |
- SetActive(false); |
- SetActive(true); |
- return; |
- } |
- |
- // If the change in phase is greater than the change threshold in either |
- // direction, request an immediate reset. This logic might result in a false |
- // negative if there is a simultaneous small change in the interval and the |
- // fmod just happens to return something near zero. Assuming the timebase |
- // is very recent though, which it should be, we'll still be ok because the |
- // old clock and new clock just happen to line up. |
- double target_delta = |
- std::abs((timebase - current_parameters_.tick_target).InSecondsF()); |
- double phase_change = |
- fmod(target_delta, interval.InSecondsF()) / interval.InSecondsF(); |
- if (phase_change > kPhaseChangeThreshold && |
- phase_change < (1.0 - kPhaseChangeThreshold)) { |
- TRACE_EVENT_INSTANT0("cc", "DelayBasedTimeSource::PhaseChanged", |
- TRACE_EVENT_SCOPE_THREAD); |
- SetActive(false); |
- SetActive(true); |
- return; |
- } |
-} |
- |
-base::TimeTicks DelayBasedTimeSource::Now() const { |
- return base::TimeTicks::Now(); |
-} |
- |
-// This code tries to achieve an average tick rate as close to interval_ as |
-// possible. To do this, it has to deal with a few basic issues: |
-// 1. PostDelayedTask can delay only at a millisecond granularity. So, 16.666 |
-// has to posted as 16 or 17. |
-// 2. A delayed task may come back a bit late (a few ms), or really late |
-// (frames later) |
-// |
-// The basic idea with this scheduler here is to keep track of where we *want* |
-// to run in tick_target_. We update this with the exact interval. |
-// |
-// Then, when we post our task, we take the floor of (tick_target_ and Now()). |
-// If we started at now=0, and 60FPs (all times in milliseconds): |
-// now=0 target=16.667 PostDelayedTask(16) |
-// |
-// When our callback runs, we figure out how far off we were from that goal. |
-// Because of the flooring operation, and assuming our timer runs exactly when |
-// it should, this yields: |
-// now=16 target=16.667 |
-// |
-// Since we can't post a 0.667 ms task to get to now=16, we just treat this as a |
-// tick. Then, we update target to be 33.333. We now post another task based on |
-// the difference between our target and now: |
-// now=16 tick_target=16.667 new_target=33.333 --> |
-// PostDelayedTask(floor(33.333 - 16)) --> PostDelayedTask(17) |
-// |
-// Over time, with no late tasks, this leads to us posting tasks like this: |
-// now=0 tick_target=0 new_target=16.667 --> |
-// tick(), PostDelayedTask(16) |
-// now=16 tick_target=16.667 new_target=33.333 --> |
-// tick(), PostDelayedTask(17) |
-// now=33 tick_target=33.333 new_target=50.000 --> |
-// tick(), PostDelayedTask(17) |
-// now=50 tick_target=50.000 new_target=66.667 --> |
-// tick(), PostDelayedTask(16) |
-// |
-// We treat delays in tasks differently depending on the amount of delay we |
-// encounter. Suppose we posted a task with a target=16.667: |
-// Case 1: late but not unrecoverably-so |
-// now=18 tick_target=16.667 |
-// |
-// Case 2: so late we obviously missed the tick |
-// now=25.0 tick_target=16.667 |
-// |
-// We treat the first case as a tick anyway, and assume the delay was unusual. |
-// Thus, we compute the new_target based on the old timebase: |
-// now=18 tick_target=16.667 new_target=33.333 --> |
-// tick(), PostDelayedTask(floor(33.333-18)) --> PostDelayedTask(15) |
-// This brings us back to 18+15 = 33, which was where we would have been if the |
-// task hadn't been late. |
-// |
-// For the really late delay, we we move to the next logical tick. The timebase |
-// is not reset. |
-// now=37 tick_target=16.667 new_target=50.000 --> |
-// tick(), PostDelayedTask(floor(50.000-37)) --> PostDelayedTask(13) |
-base::TimeTicks DelayBasedTimeSource::NextTickTarget(base::TimeTicks now) { |
- base::TimeTicks new_tick_target = now.SnappedToNextTick( |
- next_parameters_.tick_target, next_parameters_.interval); |
- DCHECK(now <= new_tick_target) |
- << "now = " << now.ToInternalValue() |
- << "; new_tick_target = " << new_tick_target.ToInternalValue() |
- << "; new_interval = " << next_parameters_.interval.InMicroseconds() |
- << "; tick_target = " << next_parameters_.tick_target.ToInternalValue(); |
- |
- // Avoid double ticks when: |
- // 1) Turning off the timer and turning it right back on. |
- // 2) Jittery data is passed to SetTimebaseAndInterval(). |
- if (new_tick_target - last_tick_time_ <= |
- next_parameters_.interval / kDoubleTickDivisor) |
- new_tick_target += next_parameters_.interval; |
- |
- return new_tick_target; |
-} |
- |
-void DelayBasedTimeSource::PostNextTickTask(base::TimeTicks now) { |
- base::TimeTicks new_tick_target = NextTickTarget(now); |
- |
- // Post another task *before* the tick and update state |
- base::TimeDelta delay; |
- if (now <= new_tick_target) |
- delay = new_tick_target - now; |
- task_runner_->PostDelayedTask(FROM_HERE, |
- base::Bind(&DelayBasedTimeSource::OnTimerFired, |
- weak_factory_.GetWeakPtr()), |
- delay); |
- |
- next_parameters_.tick_target = new_tick_target; |
- current_parameters_ = next_parameters_; |
-} |
- |
-std::string DelayBasedTimeSource::TypeString() const { |
- return "DelayBasedTimeSource"; |
-} |
- |
-std::string DelayBasedTimeSourceHighRes::TypeString() const { |
- return "DelayBasedTimeSourceHighRes"; |
-} |
- |
-void DelayBasedTimeSource::AsValueInto( |
- base::trace_event::TracedValue* state) const { |
- state->SetString("type", TypeString()); |
- state->SetDouble("last_tick_time_us", LastTickTime().ToInternalValue()); |
- state->SetDouble("next_tick_time_us", NextTickTime().ToInternalValue()); |
- |
- state->BeginDictionary("current_parameters"); |
- state->SetDouble("interval_us", |
- current_parameters_.interval.InMicroseconds()); |
- state->SetDouble("tick_target_us", |
- current_parameters_.tick_target.ToInternalValue()); |
- state->EndDictionary(); |
- |
- state->BeginDictionary("next_parameters"); |
- state->SetDouble("interval_us", next_parameters_.interval.InMicroseconds()); |
- state->SetDouble("tick_target_us", |
- next_parameters_.tick_target.ToInternalValue()); |
- state->EndDictionary(); |
- |
- state->SetBoolean("active", active_); |
-} |
- |
-} // namespace cc |