WIP: Surface Synchronization System

services/ui/public/cpp/window_compositor_frame_sink.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 "services/ui/public/cpp/window_compositor_frame_sink.h"
 
 #include "base/bind.h"
 #include "base/memory/ptr_util.h"
 #include "cc/output/compositor_frame.h"
 #include "cc/output/compositor_frame_sink_client.h"
@@ skipping 17 matching lines @@
       MakeRequest(&compositor_frame_sink),
       compositor_frame_sink_client.PassInterface()));
   return base::WrapUnique(new WindowCompositorFrameSink(
       frame_sink_id, std::move(context_provider), gpu_memory_buffer_manager,
       compositor_frame_sink.PassInterface(),
       std::move(compositor_frame_sink_client_request)));
 }
 
 WindowCompositorFrameSink::~WindowCompositorFrameSink() {}
 
+base::WeakPtr<WindowCompositorFrameSink>
+WindowCompositorFrameSink::GetWeakPtr() {
+  return factory_.GetWeakPtr();
+}
+
+void WindowCompositorFrameSink::SetLocalFrameId(
+    const cc::LocalFrameId& local_frame_id) {
+  // if (local_frame_id == local_frame_id_)
+  //  return;
+  fprintf(stderr, ">>>WindowCompositorFrameSink::SetLocalFrameId(%s)\n",
+          local_frame_id.ToString().c_str());
+  DCHECK(local_frame_id.is_valid());
+  local_frame_id_ = local_frame_id;
+  if (pending_compositor_frame_) {
+    SubmitCompositorFrame(std::move(pending_compositor_frame_.value()));
+    pending_compositor_frame_.reset();
+  }
+}
+
 bool WindowCompositorFrameSink::BindToClient(
     cc::CompositorFrameSinkClient* client) {
   if (!cc::CompositorFrameSink::BindToClient(client))
     return false;
 
   DCHECK(!thread_checker_);
   thread_checker_.reset(new base::ThreadChecker());
   compositor_frame_sink_.Bind(std::move(compositor_frame_sink_info_));
   client_binding_.reset(
       new mojo::Binding<cc::mojom::MojoCompositorFrameSinkClient>(
@@ skipping 16 matching lines @@
 void WindowCompositorFrameSink::SubmitCompositorFrame(
     cc::CompositorFrame frame) {
   DCHECK(thread_checker_);
   DCHECK(thread_checker_->CalledOnValidThread());
   if (!compositor_frame_sink_)
     return;
 
   gfx::Size frame_size = last_submitted_frame_size_;
   if (!frame.render_pass_list.empty())
     frame_size = frame.render_pass_list[0]->output_rect.size();
-  if (!local_frame_id_.is_valid() || frame_size != last_submitted_frame_size_)
-    local_frame_id_ = id_allocator_.GenerateId();
 
-  compositor_frame_sink_->SubmitCompositorFrame(local_frame_id_,
-                                                std::move(frame));
+  // LocalFrameId is invalid if this Window has not been embedded anywhere yet.
+  if (local_frame_id_.is_valid()) {
+    // frame.metadata.respect_deadline = false;
+    fprintf(stderr, ">>>Submitting Frame %s\n",
+            cc::SurfaceId(frame_sink_id_, local_frame_id_).ToString().c_str());
+    compositor_frame_sink_->SubmitCompositorFrame(local_frame_id_,
+                                                  std::move(frame));
 
-  last_submitted_frame_size_ = frame_size;
+    last_submitted_frame_size_ = frame_size;
+  } else {
+    pending_compositor_frame_ = std::move(frame);
+  }
 }
 
 WindowCompositorFrameSink::WindowCompositorFrameSink(
     const cc::FrameSinkId& frame_sink_id,
     scoped_refptr<cc::ContextProvider> context_provider,
     gpu::GpuMemoryBufferManager* gpu_memory_buffer_manager,
     cc::mojom::MojoCompositorFrameSinkPtrInfo compositor_frame_sink_info,
     cc::mojom::MojoCompositorFrameSinkClientRequest client_request)
     : cc::CompositorFrameSink(std::move(context_provider),
                               nullptr,
                               gpu_memory_buffer_manager,
                               nullptr),
       compositor_frame_sink_info_(std::move(compositor_frame_sink_info)),
       client_request_(std::move(client_request)),
-      frame_sink_id_(frame_sink_id) {}
+      frame_sink_id_(frame_sink_id),
+      factory_(this) {}
 
 void WindowCompositorFrameSink::DidReceiveCompositorFrameAck() {
   DCHECK(thread_checker_);
   DCHECK(thread_checker_->CalledOnValidThread());
   if (!client_)
     return;
   client_->DidReceiveCompositorFrameAck();
 }
 
 void WindowCompositorFrameSink::OnBeginFrame(
@@ skipping 31 matching lines @@
 WindowCompositorFrameSinkBinding::TakeFrameSinkRequest() {
   return std::move(compositor_frame_sink_request_);
 }
 
 cc::mojom::MojoCompositorFrameSinkClientPtrInfo
 WindowCompositorFrameSinkBinding::TakeFrameSinkClient() {
   return std::move(compositor_frame_sink_client_);
 }
 
 }  // namespace ui