Unified BeginFrame scheduling

cc/scheduler/begin_frame_manager.cc

Index: cc/scheduler/begin_frame_manager.cc
diff --git a/cc/scheduler/begin_frame_manager.cc b/cc/scheduler/begin_frame_manager.cc
new file mode 100644
index 0000000000000000000000000000000000000000..bf7e79d3078849df83bbaa84261581eee877993f
--- /dev/null
+++ b/cc/scheduler/begin_frame_manager.cc
@@ -0,0 +1,67 @@
+// 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/scheduler/begin_frame_manager.h"
+
+namespace {
+bool IsSameBeginFrameArgs(const cc::BeginFrameArgs arg1,

[brianderson, 2014/08/27 01:34:07]

Can you move this to begin_frame_args.h, take in const references rather than
just consts, and overload ==?

[simonhong, 2014/08/27 07:56:12]

Done.

+                          const cc::BeginFrameArgs arg2) {
+  return (arg1.frame_time == arg2.frame_time &&
+          arg1.deadline == arg2.deadline &&
+          arg1.interval == arg2.interval);
+}
+}
+
+namespace cc {
+
+BeginFrameManager::BeginFrameManager() : delegate_(NULL),
+                                         num_of_observers_(0) {}
+
+BeginFrameManager::~BeginFrameManager() {
+  DCHECK_EQ(0, num_of_observers_);
+}
+
+void BeginFrameManager::SendBeginFrameToChildren(const BeginFrameArgs& args) {
+  DCHECK(CalledOnValidThread());
+  FOR_EACH_OBSERVER(Observer,
+                    observer_list_,
+                    OnSendBeginFrame(args));
+  last_begin_frame_args_ = args;
+}
+
+void BeginFrameManager::SetAuthoritativeVSyncInterval(
+    base::TimeDelta interval) const {
+  DCHECK(delegate_);
+  delegate_->SetAuthoritativeVSyncInterval(interval);
+}
+
+void BeginFrameManager::AddObserver(
+    Observer* observer,
+    const BeginFrameArgs& last_begin_frame_args_sent_to_observer) {
+  DCHECK(CalledOnValidThread());
+  DCHECK_GE(num_of_observers_, 0);
+
+  observer_list_.AddObserver(observer);
+  if (++num_of_observers_ == 1)
+    delegate_->SetChildrenNeedBeginFrames(true);
+
+  // If |last_begin_frame_args_| is still effective, send it to the new
+  // |observer| immediately.
+  if (!last_begin_frame_args_sent_to_observer.deadline.is_null() &&
+      !IsSameBeginFrameArgs(last_begin_frame_args_,
+                            last_begin_frame_args_sent_to_observer) &&
+      last_begin_frame_args_.deadline > base::TimeTicks::Now())
+    observer->OnSendBeginFrame(last_begin_frame_args_);
+}
+
+void BeginFrameManager::RemoveObserver(Observer* observer) {
+  DCHECK(CalledOnValidThread());
+  DCHECK_GE(num_of_observers_, 1);
+
+  observer_list_.RemoveObserver(observer);
+  if (--num_of_observers_ == 0)
+    delegate_->SetChildrenNeedBeginFrames(false);
+}
+
+}  // namespace cc