Mus+Ash: Replace (Server)WindowSurface with (Server)WindowCompositorFrameSink

services/ui/public/cpp/window_compositor_frame_sink.cc

Index: services/ui/public/cpp/window_compositor_frame_sink.cc
diff --git a/services/ui/public/cpp/window_compositor_frame_sink.cc b/services/ui/public/cpp/window_compositor_frame_sink.cc
new file mode 100644
index 0000000000000000000000000000000000000000..36e1dea6efacdd631c7346f6af29d50525cdf52f
--- /dev/null
+++ b/services/ui/public/cpp/window_compositor_frame_sink.cc
@@ -0,0 +1,108 @@
+// 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 "cc/output/compositor_frame.h"
+#include "cc/output/compositor_frame_sink_client.h"
+#include "gpu/ipc/client/gpu_channel_host.h"
+#include "services/ui/public/cpp/gpu_service.h"
+
+namespace ui {
+
+// static
+std::unique_ptr<WindowCompositorFrameSink> WindowCompositorFrameSink::Create(
+    scoped_refptr<cc::ContextProvider> context_provider,
+    std::unique_ptr<WindowCompositorFrameSinkBinding>*
+        compositor_frame_sink_binding) {
+  cc::mojom::MojoCompositorFrameSinkPtr compositor_frame_sink;
+  cc::mojom::MojoCompositorFrameSinkClientPtr compositor_frame_sink_client;
+  cc::mojom::MojoCompositorFrameSinkClientRequest
+      compositor_frame_sink_client_request =
+          GetProxy(&compositor_frame_sink_client);
+
+  compositor_frame_sink_binding->reset(new WindowCompositorFrameSinkBinding(
+      GetProxy(&compositor_frame_sink),
+      compositor_frame_sink_client.PassInterface()));
+  return base::WrapUnique(new WindowCompositorFrameSink(
+      std::move(context_provider), compositor_frame_sink.PassInterface(),
+      std::move(compositor_frame_sink_client_request)));
+}
+
+WindowCompositorFrameSink::~WindowCompositorFrameSink() {}
+
+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>(
+          this, std::move(client_request_)));
+
+  // TODO(enne): Get this from the WindowSurface via ServerWindowSurface.
+  begin_frame_source_.reset(new cc::DelayBasedBeginFrameSource(
+      base::MakeUnique<cc::DelayBasedTimeSource>(
+          base::ThreadTaskRunnerHandle::Get().get())));
+
+  client->SetBeginFrameSource(begin_frame_source_.get());
+  return true;
+}
+
+void WindowCompositorFrameSink::DetachFromClient() {
+  client_->SetBeginFrameSource(nullptr);
+  begin_frame_source_.reset();
+  compositor_frame_sink_.reset();
+  cc::CompositorFrameSink::DetachFromClient();
+}
+
+void WindowCompositorFrameSink::SubmitCompositorFrame(
+    cc::CompositorFrame frame) {
+  DCHECK(thread_checker_);
+  DCHECK(thread_checker_->CalledOnValidThread());
+  if (!compositor_frame_sink_)
+    return;
+  compositor_frame_sink_->SubmitCompositorFrame(std::move(frame));
+}
+
+WindowCompositorFrameSink::WindowCompositorFrameSink(
+    scoped_refptr<cc::ContextProvider> context_provider,
+    mojo::InterfacePtrInfo<cc::mojom::MojoCompositorFrameSink>
+        compositor_frame_sink_info,
+    cc::mojom::MojoCompositorFrameSinkClientRequest client_request)
+    : cc::CompositorFrameSink(std::move(context_provider), nullptr),
+      compositor_frame_sink_info_(std::move(compositor_frame_sink_info)),
+      client_request_(std::move(client_request)) {}
+
+void WindowCompositorFrameSink::DidReceiveCompositorFrameAck() {
+  DCHECK(thread_checker_);
+  DCHECK(thread_checker_->CalledOnValidThread());
+  if (!client_)
+    return;
+  client_->DidReceiveCompositorFrameAck();
+}
+
+void WindowCompositorFrameSink::ReclaimResources(
+    const cc::ReturnedResourceArray& resources) {
+  DCHECK(thread_checker_);
+  DCHECK(thread_checker_->CalledOnValidThread());
+  if (!client_)
+    return;
+  client_->ReclaimResources(resources);
+}
+
+WindowCompositorFrameSinkBinding::~WindowCompositorFrameSinkBinding() {}
+
+WindowCompositorFrameSinkBinding::WindowCompositorFrameSinkBinding(
+    cc::mojom::MojoCompositorFrameSinkRequest compositor_frame_sink_request,
+    mojo::InterfacePtrInfo<cc::mojom::MojoCompositorFrameSinkClient>
+        compositor_frame_sink_client)
+    : compositor_frame_sink_request_(std::move(compositor_frame_sink_request)),
+      compositor_frame_sink_client_(std::move(compositor_frame_sink_client)) {}
+
+}  // namespace ui