Move mus to //services/ui

components/mus/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 "components/mus/gles2/command_buffer_impl.h"
-
-#include "base/bind.h"
-#include "base/macros.h"
-#include "base/message_loop/message_loop.h"
-#include "components/mus/common/gpu_type_converters.h"
-#include "components/mus/gles2/command_buffer_driver.h"
-#include "components/mus/gles2/gpu_state.h"
-#include "gpu/command_buffer/service/sync_point_manager.h"
-
-namespace mus {
-
-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<mus::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(
-    mus::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<mus::mojom::CommandBuffer> request) {
-  binding_.reset(
-      new mojo::Binding<mus::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 mus