services/ui: Revert CLs that broke Windows.

services/ui/gles2/command_buffer_impl.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/gles2/command_buffer_impl.h"
+
+#include "base/bind.h"
+#include "base/macros.h"
+#include "base/message_loop/message_loop.h"
+#include "gpu/command_buffer/service/sync_point_manager.h"
+#include "services/ui/common/gpu_type_converters.h"
+#include "services/ui/gles2/command_buffer_driver.h"
+#include "services/ui/gles2/gpu_state.h"
+
+namespace ui {
+
+namespace {
+
+uint64_t g_next_command_buffer_id = 0;
+
+void RunInitializeCallback(
+    const mojom::CommandBuffer::InitializeCallback& callback,
+    mojom::CommandBufferInitializeResultPtr result) {
+  callback.Run(std::move(result));
+}
+
+void RunMakeProgressCallback(
+    const mojom::CommandBuffer::MakeProgressCallback& callback,
+    const gpu::CommandBuffer::State& state) {
+  callback.Run(state);
+}
+
+}  // namespace
+
+CommandBufferImpl::CommandBufferImpl(
+    mojo::InterfaceRequest<ui::mojom::CommandBuffer> request,
+    scoped_refptr<GpuState> gpu_state)
+    : gpu_state_(gpu_state) {
+  // Bind |CommandBufferImpl| to the |request| in the GPU control thread.
+  gpu_state_->control_task_runner()->PostTask(
+      FROM_HERE,
+      base::Bind(&CommandBufferImpl::BindToRequest,
+                 base::Unretained(this), base::Passed(&request)));
+}
+
+void CommandBufferImpl::DidLoseContext(uint32_t reason) {
+  driver_->set_client(nullptr);
+  client_->Destroyed(reason, gpu::error::kLostContext);
+}
+
+void CommandBufferImpl::UpdateVSyncParameters(const base::TimeTicks& timebase,
+                                              const base::TimeDelta& interval) {
+}
+
+void CommandBufferImpl::OnGpuCompletedSwapBuffers(gfx::SwapResult result) {}
+
+CommandBufferImpl::~CommandBufferImpl() {
+}
+
+void CommandBufferImpl::Initialize(
+    ui::mojom::CommandBufferClientPtr client,
+    mojo::ScopedSharedBufferHandle shared_state,
+    mojo::Array<int32_t> attribs,
+    const mojom::CommandBuffer::InitializeCallback& callback) {
+  gpu_state_->command_buffer_task_runner()->task_runner()->PostTask(
+      FROM_HERE,
+      base::Bind(&CommandBufferImpl::InitializeOnGpuThread,
+                 base::Unretained(this), base::Passed(&client),
+                 base::Passed(&shared_state), base::Passed(&attribs),
+                 base::Bind(&RunInitializeCallback, callback)));
+}
+
+void CommandBufferImpl::SetGetBuffer(int32_t buffer) {
+  gpu_state_->command_buffer_task_runner()->PostTask(
+      driver_.get(), base::Bind(&CommandBufferImpl::SetGetBufferOnGpuThread,
+                                base::Unretained(this), buffer));
+}
+
+void CommandBufferImpl::Flush(int32_t put_offset) {
+  gpu::SyncPointManager* sync_point_manager = gpu_state_->sync_point_manager();
+  const uint32_t order_num = driver_->sync_point_order_data()
+      ->GenerateUnprocessedOrderNumber(sync_point_manager);
+  gpu_state_->command_buffer_task_runner()->PostTask(
+      driver_.get(), base::Bind(&CommandBufferImpl::FlushOnGpuThread,
+                                base::Unretained(this), put_offset, order_num));
+}
+
+void CommandBufferImpl::MakeProgress(
+    int32_t last_get_offset,
+    const mojom::CommandBuffer::MakeProgressCallback& callback) {
+  gpu_state_->command_buffer_task_runner()->PostTask(
+      driver_.get(), base::Bind(&CommandBufferImpl::MakeProgressOnGpuThread,
+                                base::Unretained(this), last_get_offset,
+                                base::Bind(&RunMakeProgressCallback,
+                                           callback)));
+}
+
+void CommandBufferImpl::RegisterTransferBuffer(
+    int32_t id,
+    mojo::ScopedSharedBufferHandle transfer_buffer,
+    uint32_t size) {
+  gpu_state_->command_buffer_task_runner()->PostTask(
+      driver_.get(),
+      base::Bind(&CommandBufferImpl::RegisterTransferBufferOnGpuThread,
+                 base::Unretained(this), id, base::Passed(&transfer_buffer),
+                 size));
+}
+
+void CommandBufferImpl::DestroyTransferBuffer(int32_t id) {
+  gpu_state_->command_buffer_task_runner()->PostTask(
+      driver_.get(),
+      base::Bind(&CommandBufferImpl::DestroyTransferBufferOnGpuThread,
+                 base::Unretained(this), id));
+}
+
+void CommandBufferImpl::CreateImage(int32_t id,
+                                    mojo::ScopedHandle memory_handle,
+                                    int32_t type,
+                                    const gfx::Size& size,
+                                    int32_t format,
+                                    int32_t internal_format) {
+  gpu_state_->command_buffer_task_runner()->PostTask(
+      driver_.get(),
+      base::Bind(&CommandBufferImpl::CreateImageOnGpuThread,
+                 base::Unretained(this), id, base::Passed(&memory_handle), type,
+                 size, format, internal_format));
+}
+
+void CommandBufferImpl::DestroyImage(int32_t id) {
+  gpu_state_->command_buffer_task_runner()->PostTask(
+      driver_.get(), base::Bind(&CommandBufferImpl::DestroyImageOnGpuThread,
+                                base::Unretained(this), id));
+}
+
+void CommandBufferImpl::CreateStreamTexture(
+    uint32_t client_texture_id,
+    const mojom::CommandBuffer::CreateStreamTextureCallback& callback) {
+  NOTIMPLEMENTED();
+}
+
+void CommandBufferImpl::TakeFrontBuffer(const gpu::Mailbox& mailbox) {
+  NOTIMPLEMENTED();
+}
+
+void CommandBufferImpl::ReturnFrontBuffer(const gpu::Mailbox& mailbox,
+                                          bool is_lost) {
+  NOTIMPLEMENTED();
+}
+
+void CommandBufferImpl::SignalQuery(uint32_t query, uint32_t signal_id) {
+  NOTIMPLEMENTED();
+}
+
+void CommandBufferImpl::SignalSyncToken(const gpu::SyncToken& sync_token,
+                                        uint32_t signal_id) {
+  NOTIMPLEMENTED();
+}
+
+void CommandBufferImpl::WaitForGetOffsetInRange(
+    int32_t start, int32_t end,
+    const mojom::CommandBuffer::WaitForGetOffsetInRangeCallback& callback) {
+  NOTIMPLEMENTED();
+}
+
+void CommandBufferImpl::WaitForTokenInRange(
+    int32_t start, int32_t end,
+    const mojom::CommandBuffer::WaitForGetOffsetInRangeCallback& callback) {
+  NOTIMPLEMENTED();
+}
+
+void CommandBufferImpl::BindToRequest(
+    mojo::InterfaceRequest<ui::mojom::CommandBuffer> request) {
+  binding_.reset(
+      new mojo::Binding<ui::mojom::CommandBuffer>(this, std::move(request)));
+  binding_->set_connection_error_handler(
+      base::Bind(&CommandBufferImpl::OnConnectionError,
+                 base::Unretained(this)));
+}
+
+void CommandBufferImpl::InitializeOnGpuThread(
+    mojom::CommandBufferClientPtr client,
+    mojo::ScopedSharedBufferHandle shared_state,
+    mojo::Array<int32_t> attribs,
+    const base::Callback<
+        void(mojom::CommandBufferInitializeResultPtr)>& callback) {
+  DCHECK(!driver_);
+  driver_.reset(new CommandBufferDriver(
+      gpu::CommandBufferNamespace::MOJO,
+      gpu::CommandBufferId::FromUnsafeValue(++g_next_command_buffer_id),
+      gfx::kNullAcceleratedWidget, gpu_state_));
+  driver_->set_client(this);
+  client_ = mojo::MakeProxy(client.PassInterface());
+  bool result =
+      driver_->Initialize(std::move(shared_state), std::move(attribs));
+  mojom::CommandBufferInitializeResultPtr initialize_result;
+  if (result) {
+    initialize_result = mojom::CommandBufferInitializeResult::New();
+    initialize_result->command_buffer_namespace = driver_->GetNamespaceID();
+    initialize_result->command_buffer_id =
+        driver_->GetCommandBufferID().GetUnsafeValue();
+    initialize_result->capabilities = driver_->GetCapabilities();
+  }
+  gpu_state_->control_task_runner()->PostTask(
+      FROM_HERE, base::Bind(callback, base::Passed(&initialize_result)));
+}
+
+bool CommandBufferImpl::SetGetBufferOnGpuThread(int32_t buffer) {
+  DCHECK(driver_->IsScheduled());
+  driver_->SetGetBuffer(buffer);
+  return true;
+}
+
+bool CommandBufferImpl::FlushOnGpuThread(int32_t put_offset,
+                                         uint32_t order_num) {
+  DCHECK(driver_->IsScheduled());
+  driver_->sync_point_order_data()->BeginProcessingOrderNumber(order_num);
+  driver_->Flush(put_offset);
+
+  // Return false if the Flush is not finished, so the CommandBufferTaskRunner
+  // will not remove this task from the task queue.
+  const bool complete = !driver_->HasUnprocessedCommands();
+  if (!complete)
+    driver_->sync_point_order_data()->PauseProcessingOrderNumber(order_num);
+  else
+    driver_->sync_point_order_data()->FinishProcessingOrderNumber(order_num);
+  return complete;
+}
+
+bool CommandBufferImpl::MakeProgressOnGpuThread(
+    int32_t last_get_offset,
+    const base::Callback<void(const gpu::CommandBuffer::State&)>& callback) {
+  DCHECK(driver_->IsScheduled());
+  gpu_state_->control_task_runner()->PostTask(
+      FROM_HERE, base::Bind(callback, driver_->GetLastState()));
+  return true;
+}
+
+bool CommandBufferImpl::RegisterTransferBufferOnGpuThread(
+    int32_t id,
+    mojo::ScopedSharedBufferHandle transfer_buffer,
+    uint32_t size) {
+  DCHECK(driver_->IsScheduled());
+  driver_->RegisterTransferBuffer(id, std::move(transfer_buffer), size);
+  return true;
+}
+
+bool CommandBufferImpl::DestroyTransferBufferOnGpuThread(int32_t id) {
+  DCHECK(driver_->IsScheduled());
+  driver_->DestroyTransferBuffer(id);
+  return true;
+}
+
+bool CommandBufferImpl::CreateImageOnGpuThread(int32_t id,
+                                               mojo::ScopedHandle memory_handle,
+                                               int32_t type,
+                                               const gfx::Size& size,
+                                               int32_t format,
+                                               int32_t internal_format) {
+  DCHECK(driver_->IsScheduled());
+  driver_->CreateImage(id, std::move(memory_handle), type, std::move(size),
+                       format, internal_format);
+  return true;
+}
+
+bool CommandBufferImpl::DestroyImageOnGpuThread(int32_t id) {
+  DCHECK(driver_->IsScheduled());
+  driver_->DestroyImage(id);
+  return true;
+}
+
+void CommandBufferImpl::OnConnectionError() {
+  // OnConnectionError() is called on the control thread |control_task_runner|.
+
+  // Before deleting, we need to delete |binding_| because it is bound to the
+  // current thread (|control_task_runner|).
+  binding_.reset();
+
+  // Objects we own (such as CommandBufferDriver) need to be destroyed on the
+  // thread we were created on. It's entirely possible we haven't or are in the
+  // process of creating |driver_|.
+  if (driver_) {
+    gpu_state_->command_buffer_task_runner()->PostTask(
+        driver_.get(), base::Bind(&CommandBufferImpl::DeleteOnGpuThread,
+                                  base::Unretained(this)));
+  } else {
+    gpu_state_->command_buffer_task_runner()->task_runner()->PostTask(
+        FROM_HERE, base::Bind(&CommandBufferImpl::DeleteOnGpuThread2,
+                              base::Unretained(this)));
+  }
+}
+
+bool CommandBufferImpl::DeleteOnGpuThread() {
+  delete this;
+  return true;
+}
+
+void CommandBufferImpl::DeleteOnGpuThread2() {
+  delete this;
+}
+
+}  // namespace ui