Fork cc::OutputSurface into cc::CompositorFrameSink.

cc/trees/remote_channel_impl.cc

 // Copyright 2016 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/trees/remote_channel_impl.h"
 
 #include "base/bind_helpers.h"
 #include "base/memory/ptr_util.h"
 #include "base/single_thread_task_runner.h"
 #include "cc/animation/animation_events.h"
@@ skipping 36 matching lines @@
                                      task_runner_provider,
                                      std::move(external_begin_frame_source));
 }
 
 void RemoteChannelImpl::OnProtoReceived(
     std::unique_ptr<proto::CompositorMessage> proto) {
   DCHECK(task_runner_provider_->IsMainThread());
   DCHECK(main().started);
   DCHECK(proto->has_to_impl());
 
-  // If we don't have an output surface, queue the message and defer processing
-  // it till we initialize a new output surface.
-  if (main().waiting_for_output_surface_initialization) {
-    VLOG(1) << "Queueing message proto since output surface was released.";
+  // If we don't have an CompositorFrameSink, queue the message and defer
+  // processing

[enne (OOO), 2016/09/14 00:35:45]

@_@

+  // it till we initialize a new CompositorFrameSink.
+  if (main().waiting_for_compositor_frame_sink_initialization) {
+    VLOG(1) << "Queueing message proto since CompositorFrameSink was released.";
     main().pending_messages.push(proto->to_impl());
   } else {
     HandleProto(proto->to_impl());
   }
 }
 
 void RemoteChannelImpl::HandleProto(
     const proto::CompositorMessageToImpl& proto) {
   DCHECK(task_runner_provider_->IsMainThread());
   DCHECK(proto.has_message_type());
-  DCHECK(!main().waiting_for_output_surface_initialization);
+  DCHECK(!main().waiting_for_compositor_frame_sink_initialization);
 
   switch (proto.message_type()) {
     case proto::CompositorMessageToImpl::UNKNOWN:
       NOTIMPLEMENTED() << "Ignoring message of UNKNOWN type";
       break;
     case proto::CompositorMessageToImpl::SET_NEEDS_COMMIT:
       VLOG(1) << "Received commit request from the engine.";
       ImplThreadTaskRunner()->PostTask(
           FROM_HERE,
           base::Bind(&ProxyImpl::SetNeedsCommitOnImpl, proxy_impl_weak_ptr_));
@@ skipping 58 matching lines @@
 
 bool RemoteChannelImpl::IsStarted() const {
   DCHECK(task_runner_provider_->IsMainThread());
   return main().started;
 }
 
 bool RemoteChannelImpl::CommitToActiveTree() const {
   return false;
 }
 
-void RemoteChannelImpl::SetOutputSurface(OutputSurface* output_surface) {
+void RemoteChannelImpl::SetCompositorFrameSink(
+    CompositorFrameSink* compositor_frame_sink) {
   DCHECK(task_runner_provider_->IsMainThread());
 
   ImplThreadTaskRunner()->PostTask(
-      FROM_HERE, base::Bind(&ProxyImpl::InitializeOutputSurfaceOnImpl,
-                            proxy_impl_weak_ptr_, output_surface));
+      FROM_HERE, base::Bind(&ProxyImpl::InitializeCompositorFrameSinkOnImpl,
+                            proxy_impl_weak_ptr_, compositor_frame_sink));
 }
 
-void RemoteChannelImpl::ReleaseOutputSurface() {
+void RemoteChannelImpl::ReleaseCompositorFrameSink() {
   DCHECK(task_runner_provider_->IsMainThread());
-  DCHECK(!main().waiting_for_output_surface_initialization);
-  VLOG(1) << "Releasing Output Surface";
+  DCHECK(!main().waiting_for_compositor_frame_sink_initialization);
+  VLOG(1) << "Releasing CompositorFrameSink";
 
   {
     CompletionEvent completion;
     DebugScopedSetMainThreadBlocked main_thread_blocked(task_runner_provider_);
     ImplThreadTaskRunner()->PostTask(
-        FROM_HERE, base::Bind(&ProxyImpl::ReleaseOutputSurfaceOnImpl,
+        FROM_HERE, base::Bind(&ProxyImpl::ReleaseCompositorFrameSinkOnImpl,
                               proxy_impl_weak_ptr_, &completion));
     completion.Wait();
   }
 
-  main().waiting_for_output_surface_initialization = true;
+  main().waiting_for_compositor_frame_sink_initialization = true;
 }
 
 void RemoteChannelImpl::SetVisible(bool visible) {
   DCHECK(task_runner_provider_->IsMainThread());
   VLOG(1) << "Setting visibility to: " << visible;
 
   ImplThreadTaskRunner()->PostTask(
       FROM_HERE,
       base::Bind(&ProxyImpl::SetVisibleOnImpl, proxy_impl_weak_ptr_, visible));
 }
 
 void RemoteChannelImpl::SetNeedsAnimate() {
   NOTREACHED() << "Should not be called on the remote client LayerTreeHost";
 }
 
 void RemoteChannelImpl::SetNeedsUpdateLayers() {
   NOTREACHED() << "Should not be called on the remote client LayerTreeHost";
 }
 
 void RemoteChannelImpl::SetNeedsCommit() {
   // Ideally commits should be requested only on the server. But we have to
   // allow this call since the LayerTreeHost will currently ask for a commit in
   // 2 cases:
   // 1) When it is being initialized from a protobuf for a commit.
-  // 2) When it loses the output surface.
+  // 2) When it loses the CompositorFrameSink.
   NOTIMPLEMENTED() << "Commits should not be requested on the client";
 }
 
 void RemoteChannelImpl::SetNeedsRedraw(const gfx::Rect& damage_rect) {
   NOTREACHED() << "Should not be called on the remote client LayerTreeHost";
 }
 
 void RemoteChannelImpl::SetNextCommitWaitsForActivation() {
   NOTREACHED() << "Should not be called on the remote client LayerTreeHost";
 }
@@ skipping 104 matching lines @@
 void RemoteChannelImpl::DidCommitAndDrawFrame() {
   DCHECK(task_runner_provider_->IsImplThread());
   MainThreadTaskRunner()->PostTask(
       FROM_HERE, base::Bind(&RemoteChannelImpl::DidCommitAndDrawFrameOnMain,
                             impl().remote_channel_weak_ptr));
 }
 
 void RemoteChannelImpl::SetAnimationEvents(
     std::unique_ptr<AnimationEvents> queue) {}
 
-void RemoteChannelImpl::DidLoseOutputSurface() {
-  DCHECK(task_runner_provider_->IsImplThread());
-
-  MainThreadTaskRunner()->PostTask(
-      FROM_HERE, base::Bind(&RemoteChannelImpl::DidLoseOutputSurfaceOnMain,
-                            impl().remote_channel_weak_ptr));
-}
-
-void RemoteChannelImpl::RequestNewOutputSurface() {
-  DCHECK(task_runner_provider_->IsImplThread());
-
-  MainThreadTaskRunner()->PostTask(
-      FROM_HERE, base::Bind(&RemoteChannelImpl::RequestNewOutputSurfaceOnMain,
-                            impl().remote_channel_weak_ptr));
-}
-
-void RemoteChannelImpl::DidInitializeOutputSurface(bool success) {
+void RemoteChannelImpl::DidLoseCompositorFrameSink() {
   DCHECK(task_runner_provider_->IsImplThread());
 
   MainThreadTaskRunner()->PostTask(
       FROM_HERE,
-      base::Bind(&RemoteChannelImpl::DidInitializeOutputSurfaceOnMain,
+      base::Bind(&RemoteChannelImpl::DidLoseCompositorFrameSinkOnMain,
+                 impl().remote_channel_weak_ptr));
+}
+
+void RemoteChannelImpl::RequestNewCompositorFrameSink() {
+  DCHECK(task_runner_provider_->IsImplThread());
+
+  MainThreadTaskRunner()->PostTask(
+      FROM_HERE,
+      base::Bind(&RemoteChannelImpl::RequestNewCompositorFrameSinkOnMain,
+                 impl().remote_channel_weak_ptr));
+}
+
+void RemoteChannelImpl::DidInitializeCompositorFrameSink(bool success) {
+  DCHECK(task_runner_provider_->IsImplThread());
+
+  MainThreadTaskRunner()->PostTask(
+      FROM_HERE,
+      base::Bind(&RemoteChannelImpl::DidInitializeCompositorFrameSinkOnMain,
                  impl().remote_channel_weak_ptr, success));
 }
 
 void RemoteChannelImpl::DidCompletePageScaleAnimation() {}
 
 void RemoteChannelImpl::BeginMainFrame(
     std::unique_ptr<BeginMainFrameAndCommitState> begin_main_frame_state) {
   std::unique_ptr<proto::CompositorMessage> proto;
   proto.reset(new proto::CompositorMessage);
   proto::CompositorMessageToMain* to_main_proto = proto->mutable_to_main();
@@ skipping 21 matching lines @@
 void RemoteChannelImpl::DidCompleteSwapBuffersOnMain() {
   DCHECK(task_runner_provider_->IsMainThread());
   main().layer_tree_host->DidCompleteSwapBuffers();
 }
 
 void RemoteChannelImpl::DidCommitAndDrawFrameOnMain() {
   DCHECK(task_runner_provider_->IsMainThread());
   main().layer_tree_host->DidCommitAndDrawFrame();
 }
 
-void RemoteChannelImpl::DidLoseOutputSurfaceOnMain() {
+void RemoteChannelImpl::DidLoseCompositorFrameSinkOnMain() {
   DCHECK(task_runner_provider_->IsMainThread());
 
-  main().layer_tree_host->DidLoseOutputSurface();
+  main().layer_tree_host->DidLoseCompositorFrameSink();
 }
 
-void RemoteChannelImpl::RequestNewOutputSurfaceOnMain() {
+void RemoteChannelImpl::RequestNewCompositorFrameSinkOnMain() {
   DCHECK(task_runner_provider_->IsMainThread());
 
-  main().layer_tree_host->RequestNewOutputSurface();
+  main().layer_tree_host->RequestNewCompositorFrameSink();
 }
 
-void RemoteChannelImpl::DidInitializeOutputSurfaceOnMain(bool success) {
+void RemoteChannelImpl::DidInitializeCompositorFrameSinkOnMain(bool success) {
   DCHECK(task_runner_provider_->IsMainThread());
 
   if (!success) {
-    main().layer_tree_host->DidFailToInitializeOutputSurface();
+    main().layer_tree_host->DidFailToInitializeCompositorFrameSink();
     return;
   }
 
-  VLOG(1) << "OutputSurface initialized successfully";
-  main().layer_tree_host->DidInitializeOutputSurface();
+  VLOG(1) << "CompositorFrameSink initialized successfully";
+  main().layer_tree_host->DidInitializeCompositorFrameSink();
 
-  // If we were waiting for output surface initialization, we might have queued
-  // some messages. Relay them now that a new output surface has been
+  // If we were waiting for CompositorFrameSink initialization, we might have
+  // queued

[enne (OOO), 2016/09/14 00:35:45]

@_@

+  // some messages. Relay them now that a new CompositorFrameSink has been
   // initialized.
-  main().waiting_for_output_surface_initialization = false;
+  main().waiting_for_compositor_frame_sink_initialization = false;
   while (!main().pending_messages.empty()) {
     VLOG(1) << "Handling queued message";
     HandleProto(main().pending_messages.front());
     main().pending_messages.pop();
   }
 
-  // The commit after a new output surface can early out, in which case we will
+  // The commit after a new CompositorFrameSink can early out, in which case we
+  // will

[enne (OOO), 2016/09/14 00:35:45]

@_@

   // never redraw. Schedule one just to be safe.
   PostSetNeedsRedrawToImpl(gfx::Rect(
       main().layer_tree_host->GetLayerTree()->device_viewport_size()));
 }
 
 void RemoteChannelImpl::SendMessageProtoOnMain(
     std::unique_ptr<proto::CompositorMessage> proto) {
   DCHECK(task_runner_provider_->IsMainThread());
   VLOG(1) << "Sending BeginMainFrame request to the engine.";
 
@@ skipping 64 matching lines @@
   return task_runner_provider_->ImplThreadTaskRunner();
 }
 
 RemoteChannelImpl::MainThreadOnly::MainThreadOnly(
     RemoteChannelImpl* remote_channel_impl,
     LayerTreeHost* layer_tree_host,
     RemoteProtoChannel* remote_proto_channel)
     : layer_tree_host(layer_tree_host),
       remote_proto_channel(remote_proto_channel),
       started(false),
-      waiting_for_output_surface_initialization(false),
+      waiting_for_compositor_frame_sink_initialization(false),
       remote_channel_weak_factory(remote_channel_impl) {
   DCHECK(layer_tree_host);
   DCHECK(remote_proto_channel);
 }
 
 RemoteChannelImpl::MainThreadOnly::~MainThreadOnly() {}
 
 RemoteChannelImpl::CompositorThreadOnly::CompositorThreadOnly(
     base::WeakPtr<RemoteChannelImpl> remote_channel_weak_ptr)
     : proxy_impl(nullptr),
       proxy_impl_weak_factory(nullptr),
       remote_channel_weak_ptr(remote_channel_weak_ptr) {}
 
 RemoteChannelImpl::CompositorThreadOnly::~CompositorThreadOnly() {}
 
 }  // namespace cc