Chromium Code Reviews| Index: cc/base/unique_notifier.cc |
| diff --git a/cc/base/unique_notifier.cc b/cc/base/unique_notifier.cc |
| new file mode 100644 |
| index 0000000000000000000000000000000000000000..44e7b772f14e0e31dc693a38be46d82f0a186eee |
| --- /dev/null |
| +++ b/cc/base/unique_notifier.cc |
| @@ -0,0 +1,66 @@ |
| +// 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/unique_notifier.h" |
| + |
| +#include "base/bind.h" |
| +#include "base/bind_helpers.h" |
| +#include "base/location.h" |
| +#include "base/sequenced_task_runner.h" |
| + |
| +namespace cc { |
| + |
| +UniqueNotifier::UniqueNotifier( |
| + const scoped_refptr<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) { |
| +} |
| + |
| +UniqueNotifier::~UniqueNotifier() { |
| + weak_ptr_factory_.InvalidateWeakPtrs(); |
|
reveman
2014/05/21 17:03:37
No need to do this explicitly. I think it's pretty
vmpstr
2014/05/21 17:41:02
Done.
|
| +} |
| + |
| +void UniqueNotifier::Schedule() { |
| + if (notification_pending_) { |
| + if (delay_ != base::TimeDelta()) |
| + next_notification_time_ = base::TimeTicks::Now() + delay_; |
| + return; |
| + } |
| + |
| + if (delay_ == base::TimeDelta()) { |
| + task_runner_->PostTask(FROM_HERE, |
| + base::Bind(&UniqueNotifier::NotifyIfTime, |
| + weak_ptr_factory_.GetWeakPtr())); |
| + } else { |
| + next_notification_time_ = base::TimeTicks::Now() + delay_; |
| + task_runner_->PostDelayedTask(FROM_HERE, |
| + base::Bind(&UniqueNotifier::NotifyIfTime, |
| + weak_ptr_factory_.GetWeakPtr()), |
| + delay_); |
| + } |
| + notification_pending_ = true; |
| +} |
| + |
| +void UniqueNotifier::NotifyIfTime() { |
| + if (!next_notification_time_.is_null()) { |
| + base::TimeTicks now = base::TimeTicks::Now(); |
| + if (next_notification_time_ > now) { |
| + task_runner_->PostDelayedTask(FROM_HERE, |
| + base::Bind(&UniqueNotifier::NotifyIfTime, |
| + weak_ptr_factory_.GetWeakPtr()), |
| + next_notification_time_ - now); |
| + return; |
| + } |
| + } |
| + |
| + notification_pending_ = false; |
| + closure_.Run(); |
| +} |
| + |
| +} // namespace cc |