Index: base/timer.cc |
diff --git a/base/timer.cc b/base/timer.cc |
deleted file mode 100644 |
index c7dcce04bfa6b6c47908d9cc310a9c2c49b58a6e..0000000000000000000000000000000000000000 |
--- a/base/timer.cc |
+++ /dev/null |
@@ -1,186 +0,0 @@ |
-// Copyright (c) 2012 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 "base/timer.h" |
- |
-#include "base/logging.h" |
-#include "base/single_thread_task_runner.h" |
-#include "base/thread_task_runner_handle.h" |
-#include "base/threading/platform_thread.h" |
- |
-namespace base { |
- |
-// BaseTimerTaskInternal is a simple delegate for scheduling a callback to |
-// Timer in the thread's default task runner. It also handles the following |
-// edge cases: |
-// - deleted by the task runner. |
-// - abandoned (orphaned) by Timer. |
-class BaseTimerTaskInternal { |
- public: |
- explicit BaseTimerTaskInternal(Timer* timer) |
- : timer_(timer) { |
- } |
- |
- ~BaseTimerTaskInternal() { |
- // This task may be getting cleared because the task runner has been |
- // destructed. If so, don't leave Timer with a dangling pointer |
- // to this. |
- if (timer_) |
- timer_->StopAndAbandon(); |
- } |
- |
- void Run() { |
- // timer_ is NULL if we were abandoned. |
- if (!timer_) |
- return; |
- |
- // *this will be deleted by the task runner, so Timer needs to |
- // forget us: |
- timer_->scheduled_task_ = NULL; |
- |
- // Although Timer should not call back into *this, let's clear |
- // the timer_ member first to be pedantic. |
- Timer* timer = timer_; |
- timer_ = NULL; |
- timer->RunScheduledTask(); |
- } |
- |
- // The task remains in the MessageLoop queue, but nothing will happen when it |
- // runs. |
- void Abandon() { |
- timer_ = NULL; |
- } |
- |
- private: |
- Timer* timer_; |
-}; |
- |
-Timer::Timer(bool retain_user_task, bool is_repeating) |
- : scheduled_task_(NULL), |
- thread_id_(0), |
- is_repeating_(is_repeating), |
- retain_user_task_(retain_user_task), |
- is_running_(false) { |
-} |
- |
-Timer::Timer(const tracked_objects::Location& posted_from, |
- TimeDelta delay, |
- const base::Closure& user_task, |
- bool is_repeating) |
- : scheduled_task_(NULL), |
- posted_from_(posted_from), |
- delay_(delay), |
- user_task_(user_task), |
- thread_id_(0), |
- is_repeating_(is_repeating), |
- retain_user_task_(true), |
- is_running_(false) { |
-} |
- |
-Timer::~Timer() { |
- StopAndAbandon(); |
-} |
- |
-void Timer::Start(const tracked_objects::Location& posted_from, |
- TimeDelta delay, |
- const base::Closure& user_task) { |
- SetTaskInfo(posted_from, delay, user_task); |
- Reset(); |
-} |
- |
-void Timer::Stop() { |
- is_running_ = false; |
- if (!retain_user_task_) |
- user_task_.Reset(); |
-} |
- |
-void Timer::Reset() { |
- DCHECK(!user_task_.is_null()); |
- |
- // If there's no pending task, start one up and return. |
- if (!scheduled_task_) { |
- PostNewScheduledTask(delay_); |
- return; |
- } |
- |
- // Set the new desired_run_time_. |
- desired_run_time_ = TimeTicks::Now() + delay_; |
- |
- // We can use the existing scheduled task if it arrives before the new |
- // desired_run_time_. |
- if (desired_run_time_ > scheduled_run_time_) { |
- is_running_ = true; |
- return; |
- } |
- |
- // We can't reuse the scheduled_task_, so abandon it and post a new one. |
- AbandonScheduledTask(); |
- PostNewScheduledTask(delay_); |
-} |
- |
-void Timer::SetTaskInfo(const tracked_objects::Location& posted_from, |
- TimeDelta delay, |
- const base::Closure& user_task) { |
- posted_from_ = posted_from; |
- delay_ = delay; |
- user_task_ = user_task; |
-} |
- |
-void Timer::PostNewScheduledTask(TimeDelta delay) { |
- DCHECK(scheduled_task_ == NULL); |
- is_running_ = true; |
- scheduled_task_ = new BaseTimerTaskInternal(this); |
- ThreadTaskRunnerHandle::Get()->PostDelayedTask(posted_from_, |
- base::Bind(&BaseTimerTaskInternal::Run, base::Owned(scheduled_task_)), |
- delay); |
- scheduled_run_time_ = desired_run_time_ = TimeTicks::Now() + delay; |
- // Remember the thread ID that posts the first task -- this will be verified |
- // later when the task is abandoned to detect misuse from multiple threads. |
- if (!thread_id_) |
- thread_id_ = static_cast<int>(PlatformThread::CurrentId()); |
-} |
- |
-void Timer::AbandonScheduledTask() { |
- DCHECK(thread_id_ == 0 || |
- thread_id_ == static_cast<int>(PlatformThread::CurrentId())); |
- if (scheduled_task_) { |
- scheduled_task_->Abandon(); |
- scheduled_task_ = NULL; |
- } |
-} |
- |
-void Timer::RunScheduledTask() { |
- // Task may have been disabled. |
- if (!is_running_) |
- return; |
- |
- // First check if we need to delay the task because of a new target time. |
- if (desired_run_time_ > scheduled_run_time_) { |
- // TimeTicks::Now() can be expensive, so only call it if we know the user |
- // has changed the desired_run_time_. |
- TimeTicks now = TimeTicks::Now(); |
- // Task runner may have called us late anyway, so only post a continuation |
- // task if the desired_run_time_ is in the future. |
- if (desired_run_time_ > now) { |
- // Post a new task to span the remaining time. |
- PostNewScheduledTask(desired_run_time_ - now); |
- return; |
- } |
- } |
- |
- // Make a local copy of the task to run. The Stop method will reset the |
- // user_task_ member if retain_user_task_ is false. |
- base::Closure task = user_task_; |
- |
- if (is_repeating_) |
- PostNewScheduledTask(delay_); |
- else |
- Stop(); |
- |
- task.Run(); |
- |
- // No more member accesses here: *this could be deleted at this point. |
-} |
- |
-} // namespace base |