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 |