cc: Create ProxyBeginFrameSource

cc/scheduler/begin_frame_source.cc

 // 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_source.h"
 
 #include "base/auto_reset.h"
 #include "base/location.h"
 #include "base/logging.h"
 #include "base/strings/string_number_conversions.h"
@@ skipping 119 matching lines @@
         const_cast<bool*>(&inside_as_value_into_), true);
     dict->BeginDictionary("observer");
     observer_->AsValueInto(dict);
     dict->EndDictionary();
   } else {
     dict->SetString("observer", "NULL");
   }
   dict->SetBoolean("needs_begin_frames", NeedsBeginFrames());
 }
 
+// ProxyBeginFrameSource
+ProxyBeginFrameSource::ProxyBeginFrameSource() : delegate_(nullptr) {
+}
+
+ProxyBeginFrameSource::~ProxyBeginFrameSource() {
+  DCHECK(!observer_list_.might_have_observers());
+}
+
+bool ProxyBeginFrameSource::NeedsBeginFrames() const {
+  return observer_list_.might_have_observers();
+}
+
+void ProxyBeginFrameSource::AddObserver(BeginFrameObserver* obs) {
+  // If |missed_begin_frame_args_| is still effective, send it to the new
+  // |obs| immediately.
+  if (!obs->LastUsedBeginFrameArgs().deadline.is_null() &&
+      obs->LastUsedBeginFrameArgs() != missed_begin_frame_args_) {
+    missed_begin_frame_args_.type = BeginFrameArgs::MISSED;
+    obs->OnBeginFrame(missed_begin_frame_args_);
+  }
+
+  if (!observer_list_.might_have_observers() && delegate_)
+    delegate_->SetChildrenNeedBeginFrames(true);
+  observer_list_.AddObserver(obs);
+}
+
+void ProxyBeginFrameSource::RemoveObserver(BeginFrameObserver* obs) {
+  DCHECK(observer_list_.HasObserver(obs));
+  observer_list_.RemoveObserver(obs);
+
+  if (!observer_list_.might_have_observers() && delegate_)
+    delegate_->SetChildrenNeedBeginFrames(false);
+}
+
+void ProxyBeginFrameSource::AsValueInto(base::debug::TracedValue* dict) const {
+  dict->SetString("type", "ProxyBeginFrameSource");
+  dict->SetBoolean("has_observers", observer_list_.might_have_observers());
+}
+
+void ProxyBeginFrameSource::BeginFrames(const BeginFrameArgs& args) {
+  FOR_EACH_OBSERVER(BeginFrameObserver,
+                    observer_list_,
+                    OnBeginFrame(args));
+  missed_begin_frame_args_ = args;
+}
+
 // BackToBackBeginFrameSourceMixIn --------------------------------------------
 scoped_ptr<BackToBackBeginFrameSource> BackToBackBeginFrameSource::Create(
     base::SingleThreadTaskRunner* task_runner) {
   return make_scoped_ptr(new BackToBackBeginFrameSource(task_runner));
 }
 
 BackToBackBeginFrameSource::BackToBackBeginFrameSource(
     base::SingleThreadTaskRunner* task_runner)
     : BeginFrameSourceMixIn(),
       task_runner_(task_runner),
@@ skipping 333 matching lines @@
   if (!observer_->LastUsedBeginFrameArgs().IsValid())
     return true;
 
   // Only allow new args have a *strictly bigger* frame_time value and statisfy
   // minimum interval requirement.
   return (args.frame_time >=
           observer_->LastUsedBeginFrameArgs().frame_time + minimum_interval_);
 }
 
 }  // namespace cc