Chromium Code Reviews| Index: cc/base/delayed_unique_notifier.cc |
| diff --git a/cc/base/delayed_unique_notifier.cc b/cc/base/delayed_unique_notifier.cc |
| new file mode 100644 |
| index 0000000000000000000000000000000000000000..beeb0b1a43f29e3e4d2fd14f93cf6864b836bfb4 |
| --- /dev/null |
| +++ b/cc/base/delayed_unique_notifier.cc |
| @@ -0,0 +1,63 @@ |
| +// 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 "cc/base/delayed_unique_notifier.h" |
| + |
| +#include "base/bind.h" |
| +#include "base/bind_helpers.h" |
| +#include "base/location.h" |
| +#include "base/sequenced_task_runner.h" |
| + |
| +namespace cc { |
| + |
| +DelayedUniqueNotifier::DelayedUniqueNotifier( |
| + base::SequencedTaskRunner* task_runner, |
| + const base::Closure& closure, |
| + const base::TimeDelta& delay) |
| + : task_runner_(task_runner), |
| + closure_(closure), |
| + delay_(delay), |
| + notification_pending_(false), |
| + weak_ptr_factory_(this) { |
| +} |
| + |
| +DelayedUniqueNotifier::~DelayedUniqueNotifier() { |
| +} |
| + |
| +void DelayedUniqueNotifier::Schedule() { |
| + if (notification_pending_) { |
| + next_notification_time_ = base::TimeTicks::Now() + delay_; |
| + return; |
| + } |
| + |
| + next_notification_time_ = base::TimeTicks::Now() + delay_; |
| + task_runner_->PostDelayedTask(FROM_HERE, |
| + base::Bind(&DelayedUniqueNotifier::NotifyIfTime, |
| + weak_ptr_factory_.GetWeakPtr()), |
| + delay_); |
| + notification_pending_ = true; |
| +} |
| + |
| +void DelayedUniqueNotifier::Cancel() { |
| + weak_ptr_factory_.InvalidateWeakPtrs(); |
|
reveman
2014/05/22 23:24:28
This is going to be a problem as calling Schedule(
vmpstr
2014/05/27 18:14:59
Makes sense. Done. Now it should only ever have on
|
| + notification_pending_ = false; |
| +} |
| + |
| +void DelayedUniqueNotifier::NotifyIfTime() { |
| + base::TimeTicks now = base::TimeTicks::Now(); |
| + if (next_notification_time_ > now) { |
| + task_runner_->PostDelayedTask( |
| + FROM_HERE, |
| + base::Bind(&DelayedUniqueNotifier::NotifyIfTime, |
| + weak_ptr_factory_.GetWeakPtr()), |
| + next_notification_time_ - now); |
| + return; |
| + } |
| + |
| + // Note the order here is important since closure might schedule another run. |
| + notification_pending_ = false; |
| + closure_.Run(); |
| +} |
| + |
| +} // namespace cc |