NOT READY FOR REVIEW - switch to a subscriber model for rendering stats

cc/thread_proxy.cc

 // Copyright 2011 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 "config.h"
 
 #include "cc/thread_proxy.h"
 
 #include "base/bind.h"
 #include "base/debug/trace_event.h"
 #include "cc/delay_based_time_source.h"
 #include "cc/draw_quad.h"
 #include "cc/frame_rate_controller.h"
 #include "cc/graphics_context.h"
 #include "cc/input_handler.h"
 #include "cc/layer_tree_host.h"
+#include "cc/rendering_stats_subscriber.h"
 #include "cc/scheduler.h"
 #include "cc/scoped_thread_proxy.h"
 #include <public/WebSharedGraphicsContext3D.h>
 
 using WebKit::WebSharedGraphicsContext3D;
 
 namespace {
 
 // Measured in seconds.
 const double contextRecreationTickRate = 0.03;
@@ skipping 224 matching lines @@
     DebugScopedSetMainThreadBlocked mainThreadBlocked;
     CompletionEvent completion;
     Proxy::implThread()->postTask(base::Bind(&ThreadProxy::renderingStatsOnImplThread,
                                              base::Unretained(this),  &completion, stats));
     stats->totalCommitTimeInSeconds = m_totalCommitTime.InSecondsF();
     stats->totalCommitCount = m_totalCommitCount;
 
     completion.wait();
 }
 
+void ThreadProxy::startRecordingRenderingStats()
+{
+    DCHECK(isMainThread());
+
+    DebugScopedSetMainThreadBlocked mainThreadBlocked;
+    CompletionEvent completion;
+    Proxy::implThread()->postTask(base::Bind(&ThreadProxy::startRecordingRenderingStatsOnImplThread,
+                                             base::Unretained(this), &completion));
+
+    // This subscriber will collect total commit time and total commit count.
+    m_renderingStatsSubscriber = RenderingStatsSubscriber::create();
+    completion.wait();
+}
+
+void ThreadProxy::stopRecordingRenderingStats(RenderingStats* stats)
+{
+    DCHECK(isMainThread());
+
+    // TODO(vollick) populate stats based on subscriber here.
+    m_renderingStatsSubscriber.reset();
+
+    DebugScopedSetMainThreadBlocked mainThreadBlocked;
+    CompletionEvent completion;
+    Proxy::implThread()->postTask(base::Bind(&ThreadProxy::stopRecordingRenderingStatsOnImplThread,
+                                             base::Unretained(this), &completion, stats));
+    completion.wait();
+}
+
 const RendererCapabilities& ThreadProxy::rendererCapabilities() const
 {
     DCHECK(m_rendererInitialized);
     return m_RendererCapabilitiesMainThreadCopy;
 }
 
 void ThreadProxy::loseContext()
 {
     Proxy::implThread()->postTask(base::Bind(&ThreadProxy::didLoseContextOnImplThread, base::Unretained(this)));
 }
@@ skipping 703 matching lines @@
     completion->signal();
 }
 
 void ThreadProxy::renderingStatsOnImplThread(CompletionEvent* completion, RenderingStats* stats)
 {
     DCHECK(isImplThread());
     m_layerTreeHostImpl->renderingStats(stats);
     completion->signal();
 }
 
+void ThreadProxy::startRecordingRenderingStatsOnImplThread(CompletionEvent* completion)
+{
+    DCHECK(isImplThread());
+    m_layerTreeHostImpl->startRecordingRenderingStats();
+    completion->signal();
+}
+
+void ThreadProxy::stopRecordingRenderingStatsOnImplThread(CompletionEvent* completion, RenderingStats* stats)
+{
+    DCHECK(isImplThread());
+    m_layerTreeHostImpl->stopRecordingRenderingStats(stats);
+    completion->signal();
+}
+
 ThreadProxy::BeginFrameAndCommitState::BeginFrameAndCommitState()
 {
 }
 
 ThreadProxy::BeginFrameAndCommitState::~BeginFrameAndCommitState()
 {
 }
 
 }  // namespace cc