Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(671)

Unified Diff: components/timers/rtc_alarm.cc

Issue 706993003: C++ readability review (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Address comments Created 5 years, 8 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « components/timers/rtc_alarm.h ('k') | no next file » | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: components/timers/rtc_alarm.cc
diff --git a/components/timers/rtc_alarm.cc b/components/timers/rtc_alarm.cc
deleted file mode 100644
index 0c3dfdf352456b35394ca5b3107723cb3562efb5..0000000000000000000000000000000000000000
--- a/components/timers/rtc_alarm.cc
+++ /dev/null
@@ -1,186 +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/rtc_alarm.h"
-
-#include <sys/timerfd.h>
-
-#include "base/bind.h"
-#include "base/files/file_util.h"
-#include "base/lazy_instance.h"
-#include "base/logging.h"
-#include "base/macros.h"
-#include "base/message_loop/message_loop_proxy.h"
-#include "base/threading/thread.h"
-
-namespace timers {
-
-namespace {
-// Helper class to ensure that the IO thread we will use for watching file
-// descriptors is started only once.
-class IOThreadStartHelper {
- public:
- IOThreadStartHelper() : thread_(new base::Thread("RTC Alarm IO Thread")) {
- CHECK(thread_->StartWithOptions(
- base::Thread::Options(base::MessageLoop::TYPE_IO, 0)));
- }
- ~IOThreadStartHelper() {}
-
- base::Thread& operator*() const { return *thread_.get(); }
-
- base::Thread* operator->() const { return thread_.get(); }
-
- private:
- scoped_ptr<base::Thread> thread_;
-};
-
-base::LazyInstance<IOThreadStartHelper> g_io_thread = LAZY_INSTANCE_INITIALIZER;
-
-} // namespace
-
-RtcAlarm::RtcAlarm()
- : alarm_fd_(timerfd_create(CLOCK_REALTIME_ALARM, 0)),
- origin_event_id_(0),
- io_event_id_(0) {
-}
-
-RtcAlarm::~RtcAlarm() {
- if (alarm_fd_ != -1)
- close(alarm_fd_);
-}
-
-bool RtcAlarm::Init(base::WeakPtr<AlarmTimer> parent) {
- parent_ = parent;
-
- return alarm_fd_ != -1;
-}
-
-void RtcAlarm::Stop() {
- // Make sure that we stop the RTC from a MessageLoopForIO.
- if (!base::MessageLoopForIO::IsCurrent()) {
- g_io_thread.Get()->task_runner()->PostTask(
- FROM_HERE,
- base::Bind(&RtcAlarm::Stop, scoped_refptr<RtcAlarm>(this)));
- return;
- }
-
- // Stop watching for events.
- fd_watcher_.reset();
-
- // Now clear the timer.
- DCHECK_NE(alarm_fd_, -1);
- itimerspec blank_time = {};
- timerfd_settime(alarm_fd_, 0, &blank_time, NULL);
-}
-
-void RtcAlarm::Reset(base::TimeDelta delay) {
- // Get a proxy for the current message loop. When the timer fires, we will
- // post tasks to this proxy to let the parent timer know.
- origin_message_loop_ = base::MessageLoopProxy::current();
-
- // Increment the event id. Used to invalidate any events that have been
- // queued but not yet run since the last time Reset() was called.
- origin_event_id_++;
-
- // Calling timerfd_settime with a zero delay actually clears the timer so if
- // the user has requested a zero delay timer, we need to handle it
- // differently. We queue the task here but we still go ahead and call
- // timerfd_settime with the zero delay anyway to cancel any previous delay
- // that might have been programmed.
- if (delay <= base::TimeDelta::FromMicroseconds(0)) {
- // The timerfd_settime documentation is vague on what happens when it is
- // passed a negative delay. We can sidestep the issue by ensuring that the
- // delay is 0.
- delay = base::TimeDelta::FromMicroseconds(0);
- origin_message_loop_->PostTask(FROM_HERE,
- base::Bind(&RtcAlarm::OnTimerFired,
- scoped_refptr<RtcAlarm>(this),
- origin_event_id_));
- }
-
- // Make sure that we are running on a MessageLoopForIO.
- if (!base::MessageLoopForIO::IsCurrent()) {
- g_io_thread.Get()->task_runner()->PostTask(
- FROM_HERE,
- base::Bind(&RtcAlarm::ResetImpl,
- scoped_refptr<RtcAlarm>(this),
- delay,
- origin_event_id_));
- return;
- }
-
- ResetImpl(delay, origin_event_id_);
-}
-
-void RtcAlarm::OnFileCanReadWithoutBlocking(int fd) {
- DCHECK_EQ(alarm_fd_, fd);
-
- // Read from the fd to ack the event.
- char val[sizeof(uint64_t)];
- base::ReadFromFD(alarm_fd_, val, sizeof(uint64_t));
-
- // Make sure that the parent timer is informed on the proper message loop.
- if (origin_message_loop_->RunsTasksOnCurrentThread()) {
- OnTimerFired(io_event_id_);
- return;
- }
-
- origin_message_loop_->PostTask(FROM_HERE,
- base::Bind(&RtcAlarm::OnTimerFired,
- scoped_refptr<RtcAlarm>(this),
- io_event_id_));
-}
-
-void RtcAlarm::OnFileCanWriteWithoutBlocking(int fd) {
- NOTREACHED();
-}
-
-void RtcAlarm::ResetImpl(base::TimeDelta delay, int event_id) {
- DCHECK(base::MessageLoopForIO::IsCurrent());
- DCHECK_NE(alarm_fd_, -1);
-
- // Store the event id in the IO thread variable. When the timer fires, we
- // will bind this value to the OnTimerFired callback to ensure that we do the
- // right thing if the timer gets reset.
- io_event_id_ = event_id;
-
- // If we were already watching the fd, this will stop watching it.
- fd_watcher_.reset(new base::MessageLoopForIO::FileDescriptorWatcher);
-
- // Start watching the fd to see when the timer fires.
- if (!base::MessageLoopForIO::current()->WatchFileDescriptor(
- alarm_fd_,
- false,
- base::MessageLoopForIO::WATCH_READ,
- fd_watcher_.get(),
- this)) {
- LOG(ERROR) << "Error while attempting to watch file descriptor for RTC "
- << "alarm. Timer will not fire.";
- }
-
- // Actually set the timer. This will also clear the pre-existing timer, if
- // any.
- itimerspec alarm_time = {};
- alarm_time.it_value.tv_sec = delay.InSeconds();
- alarm_time.it_value.tv_nsec =
- (delay.InMicroseconds() % base::Time::kMicrosecondsPerSecond) *
- base::Time::kNanosecondsPerMicrosecond;
- if (timerfd_settime(alarm_fd_, 0, &alarm_time, NULL) < 0)
- PLOG(ERROR) << "Error while setting alarm time. Timer will not fire";
-}
-
-void RtcAlarm::OnTimerFired(int event_id) {
- DCHECK(origin_message_loop_->RunsTasksOnCurrentThread());
-
- // Check to make sure that the timer was not reset in the time between when
- // this task was queued to run and now. If it was reset, then don't do
- // anything.
- if (event_id != origin_event_id_)
- return;
-
- if (parent_)
- parent_->OnTimerFired();
-}
-
-} // namespace timers
« no previous file with comments | « components/timers/rtc_alarm.h ('k') | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698