Plumb cc::LatencyInfo through command buffer and output surface

content/browser/renderer_host/image_transport_factory.cc

 // Copyright (c) 2012 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 "content/browser/renderer_host/image_transport_factory.h"
 
 #include <algorithm>
 #include <map>
 
 #include "base/bind.h"
@@ skipping 291 matching lines @@
   BrowserCompositorOutputSurface(
       WebGraphicsContext3DCommandBufferImpl* context,
       int surface_id,
       BrowserCompositorOutputSurfaceProxy* output_surface_proxy,
       base::MessageLoopProxy* compositor_message_loop,
       base::WeakPtr<ui::Compositor> compositor)
       : OutputSurface(scoped_ptr<WebKit::WebGraphicsContext3D>(context)),
         surface_id_(surface_id),
         output_surface_proxy_(output_surface_proxy),
         compositor_message_loop_(compositor_message_loop),
-        compositor_(compositor) {
+        compositor_(compositor),
+        context_(context) {
     CommandLine* command_line = CommandLine::ForCurrentProcess();
     if (command_line->HasSwitch(switches::kUIMaxFramesPending)) {
       std::string string_value = command_line->GetSwitchValueASCII(
         switches::kUIMaxFramesPending);
       int int_value;
       if (base::StringToInt(string_value, &int_value))
         capabilities_.max_frames_pending = int_value;
       else
         LOG(ERROR) << "Trouble parsing --" << switches::kUIMaxFramesPending;
     }
     DetachFromThread();
   }
 
   virtual ~BrowserCompositorOutputSurface() {
     DCHECK(CalledOnValidThread());
     if (!client_)
       return;
     output_surface_proxy_->RemoveSurface(surface_id_);
   }
 
   virtual bool BindToClient(
       cc::OutputSurfaceClient* client) OVERRIDE {
     DCHECK(CalledOnValidThread());
 
     if (!OutputSurface::BindToClient(client))
       return false;
 
     output_surface_proxy_->AddSurface(this, surface_id_);
+    context_->GetCommandBufferProxy()->SetLatencyInfoCallback(
+        base::Bind(&BrowserCompositorOutputSurface::OnReceivedLatencyInfo,
+                   base::Unretained(this)));
     return true;
   }
 
+  virtual void SetLatencyInfo(
+      const cc::LatencyInfo& latency_info) OVERRIDE {
+    context_->GetCommandBufferProxy()->SetLatencyInfo(latency_info);
+  }
+
   void OnUpdateVSyncParameters(
       base::TimeTicks timebase, base::TimeDelta interval) {
     DCHECK(CalledOnValidThread());
     DCHECK(client_);
     client_->OnVSyncParametersChanged(timebase, interval);
     compositor_message_loop_->PostTask(
         FROM_HERE,
         base::Bind(&ui::Compositor::OnUpdateVSyncParameters,
                    compositor_, timebase, interval));
   }
 
  private:
+
+  void OnReceivedLatencyInfo(const cc::LatencyInfo& latency_info) {
+    client_->OnReceivedLatencyInfo(latency_info);
+  }
+
   int surface_id_;
   scoped_refptr<BrowserCompositorOutputSurfaceProxy> output_surface_proxy_;
 
   scoped_refptr<base::MessageLoopProxy> compositor_message_loop_;
   base::WeakPtr<ui::Compositor> compositor_;
+  WebGraphicsContext3DCommandBufferImpl* context_;
 };
 
 void BrowserCompositorOutputSurfaceProxy::OnUpdateVSyncParameters(
     int surface_id, base::TimeTicks timebase, base::TimeDelta interval) {
   BrowserCompositorOutputSurface* surface = surface_map_.Lookup(surface_id);
   if (surface)
     surface->OnUpdateVSyncParameters(timebase, interval);
 }
 
 class GpuProcessTransportFactory
@@ skipping 408 matching lines @@
   delete g_factory;
   g_factory = NULL;
 }
 
 // static
 ImageTransportFactory* ImageTransportFactory::GetInstance() {
   return g_factory;
 }
 
 }  // namespace content