Index: components/timers/alarm_timer.cc |
diff --git a/components/timers/alarm_timer.cc b/components/timers/alarm_timer.cc |
deleted file mode 100644 |
index 8b46020af5496fe191e405218098defaf1166a75..0000000000000000000000000000000000000000 |
--- a/components/timers/alarm_timer.cc |
+++ /dev/null |
@@ -1,127 +0,0 @@ |
-// Copyright 2014 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 "components/timers/alarm_timer.h" |
- |
-#include "base/bind.h" |
-#include "base/bind_helpers.h" |
-#include "base/files/file_util.h" |
-#include "base/logging.h" |
-#include "base/pending_task.h" |
-#include "components/timers/rtc_alarm.h" |
- |
-namespace timers { |
- |
-AlarmTimer::AlarmTimer(bool retain_user_task, bool is_repeating) |
- : base::Timer(retain_user_task, is_repeating), |
- delegate_(new RtcAlarm()), |
- can_wake_from_suspend_(false), |
- origin_message_loop_(NULL), |
- weak_factory_(this) { |
- can_wake_from_suspend_ = delegate_->Init(weak_factory_.GetWeakPtr()); |
-} |
- |
-AlarmTimer::AlarmTimer(const tracked_objects::Location& posted_from, |
- base::TimeDelta delay, |
- const base::Closure& user_task, |
- bool is_repeating) |
- : base::Timer(posted_from, delay, user_task, is_repeating), |
- delegate_(new RtcAlarm()), |
- can_wake_from_suspend_(false), |
- origin_message_loop_(NULL), |
- weak_factory_(this) { |
- can_wake_from_suspend_ = delegate_->Init(weak_factory_.GetWeakPtr()); |
-} |
- |
-AlarmTimer::~AlarmTimer() { |
- Stop(); |
-} |
- |
-void AlarmTimer::OnTimerFired() { |
- if (!base::Timer::IsRunning()) |
- return; |
- |
- DCHECK(pending_task_.get()); |
- |
- // Take ownership of the pending user task, which is going to be cleared by |
- // the Stop() or Reset() functions below. |
- scoped_ptr<base::PendingTask> pending_user_task(pending_task_.Pass()); |
- |
- // Re-schedule or stop the timer as requested. |
- if (base::Timer::is_repeating()) |
- Reset(); |
- else |
- Stop(); |
- |
- // Now run the user task. |
- base::MessageLoop::current()->task_annotator()->RunTask( |
- "AlarmTimer::Reset", "AlarmTimer::OnTimerFired", *pending_user_task); |
-} |
- |
-void AlarmTimer::Stop() { |
- if (!can_wake_from_suspend_) { |
- base::Timer::Stop(); |
- return; |
- } |
- |
- // Clear the running flag, stop the delegate, and delete the pending task. |
- base::Timer::set_is_running(false); |
- delegate_->Stop(); |
- pending_task_.reset(); |
- |
- // Stop is called when the AlarmTimer is destroyed so we need to remove |
- // ourselves as a MessageLoop::DestructionObserver to prevent a segfault |
- // later. |
- if (origin_message_loop_) { |
- origin_message_loop_->RemoveDestructionObserver(this); |
- origin_message_loop_ = NULL; |
- } |
- |
- if (!base::Timer::retain_user_task()) |
- base::Timer::set_user_task(base::Closure()); |
-} |
- |
-void AlarmTimer::Reset() { |
- if (!can_wake_from_suspend_) { |
- base::Timer::Reset(); |
- return; |
- } |
- |
- DCHECK(!base::Timer::user_task().is_null()); |
- DCHECK(!origin_message_loop_ || |
- origin_message_loop_->task_runner()->RunsTasksOnCurrentThread()); |
- |
- // Make sure that the timer will stop if the underlying message loop is |
- // destroyed. |
- if (!origin_message_loop_) { |
- origin_message_loop_ = base::MessageLoop::current(); |
- origin_message_loop_->AddDestructionObserver(this); |
- } |
- |
- // Set up the pending task. |
- if (base::Timer::GetCurrentDelay() > base::TimeDelta::FromMicroseconds(0)) { |
- base::Timer::set_desired_run_time( |
- base::TimeTicks::Now() + base::Timer::GetCurrentDelay()); |
- pending_task_.reset(new base::PendingTask(base::Timer::posted_from(), |
- base::Timer::user_task(), |
- base::Timer::desired_run_time(), |
- true /* nestable */)); |
- } else { |
- base::Timer::set_desired_run_time(base::TimeTicks()); |
- pending_task_.reset(new base::PendingTask(base::Timer::posted_from(), |
- base::Timer::user_task())); |
- } |
- base::MessageLoop::current()->task_annotator()->DidQueueTask( |
- "AlarmTimer::Reset", *pending_task_); |
- |
- // Now start up the timer. |
- delegate_->Reset(base::Timer::GetCurrentDelay()); |
- base::Timer::set_is_running(true); |
-} |
- |
-void AlarmTimer::WillDestroyCurrentMessageLoop() { |
- Stop(); |
-} |
- |
-} // namespace timers |