OnDrawHardware() implementation with async messages

content/browser/android/synchronous_compositor_host.cc

 // Copyright 2015 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/android/synchronous_compositor_host.h"
 
 #include <utility>
 
 #include "base/command_line.h"
 #include "base/containers/hash_tables.h"
@@ skipping 70 matching lines @@
 SynchronousCompositorHost::~SynchronousCompositorHost() {
   client_->DidDestroyCompositor(this, process_id_, routing_id_);
 }
 
 bool SynchronousCompositorHost::OnMessageReceived(const IPC::Message& message) {
   bool handled = true;
   IPC_BEGIN_MESSAGE_MAP(SynchronousCompositorHost, message)
     IPC_MESSAGE_HANDLER(SyncCompositorHostMsg_OutputSurfaceCreated,
                         OutputSurfaceCreated)
     IPC_MESSAGE_HANDLER(SyncCompositorHostMsg_UpdateState, ProcessCommonParams)
+    IPC_MESSAGE_HANDLER(CompositorHostMsg_Frame, ReceiveFrame)
     IPC_MESSAGE_UNHANDLED(handled = false)
   IPC_END_MESSAGE_MAP()
   return handled;
 }
 
 SynchronousCompositor::Frame SynchronousCompositorHost::DemandDrawHw(
     const gfx::Size& surface_size,
     const gfx::Transform& transform,
     const gfx::Rect& viewport,
     const gfx::Rect& clip,
     const gfx::Rect& viewport_rect_for_tile_priority,
     const gfx::Transform& transform_for_tile_priority) {
   SyncCompositorDemandDrawHwParams params(surface_size, transform, viewport,
                                           clip, viewport_rect_for_tile_priority,
                                           transform_for_tile_priority);
   SynchronousCompositor::Frame frame;
   frame.frame.reset(new cc::CompositorFrame);
   SyncCompositorCommonRendererParams common_renderer_params;
-  if (!sender_->Send(new SyncCompositorMsg_DemandDrawHw(
-          routing_id_, params, &common_renderer_params,
-          &frame.output_surface_id, frame.frame.get()))) {
-    return SynchronousCompositor::Frame();
-  }
-  ProcessCommonParams(common_renderer_params);
-  if (!frame.frame->delegated_frame_data) {
-    // This can happen if compositor did not swap in this draw.
-    frame.frame.reset();
-  }
-  if (frame.frame) {
-    UpdateFrameMetaData(frame.frame->metadata.Clone());
-  }
-  return frame;
+
+  /* Send an async message instead of a synchronous one.
+   * Currently not sure what to do in the analogous case
+   * when sending sync message returns false. */
+  //  if (!sender_->Send(new SyncCompositorMsg_DemandDrawHw(
+  //          routing_id_, params, &common_renderer_params,
+  //          &frame.output_surface_id, frame.frame.get()))) {
+  //    return SynchronousCompositor::Frame();
+  //  }
+
+  sender_->Send(new CompositorMsg_DemandDrawHw(routing_id_, params));
+  /* Now that the sent message is async, the following processing
+   * of the result has to be done upon receiving the reply. */
+
+  //  ProcessCommonParams(common_renderer_params);
+  //  if (!frame.frame->delegated_frame_data) {
+  //    // This can happen if compositor did not swap in this draw.
+  //    frame.frame.reset();
+  //  }
+  //  if (frame.frame) {
+  //    UpdateFrameMetaData(frame.frame->metadata.Clone());
+  //  }
+  //  return frame;
+  //
+  return nullptr;
+}
+
+void SynchronousCompositorHost::ReceiveFrame(
+    content::SyncCompositorCommonRendererParams params,
+    uint32_t output_surface_id,
+    cc::CompositorFrame) {
+  // TODO: the return message is received in this class, but
+  //  the received frame should be processed in BVR class (should it?)
+  //  because other data is stored there (e.g. current frame consumer)
+  //
+  //  Either:
+  //  1. pass the received frame back to browser view renderer (is it
+  //      appropriate?)
+  //  or
+  //  2. pass the necessary things from bvr to here
 }
 
 void SynchronousCompositorHost::UpdateFrameMetaData(
     cc::CompositorFrameMetadata frame_metadata) {
   rwhva_->SynchronousFrameMetadata(std::move(frame_metadata));
 }
 
 namespace {
 
 class ScopedSetSkCanvas {
@@ skipping 248 matching lines @@
   if (params.page_scale_factor) {
     client_->UpdateRootLayerState(
         this, gfx::ScrollOffsetToVector2dF(params.total_scroll_offset),
         gfx::ScrollOffsetToVector2dF(params.max_scroll_offset),
         params.scrollable_size, params.page_scale_factor,
         params.min_page_scale_factor, params.max_page_scale_factor);
   }
 }
 
 }  // namespace content