Implement GpuArcVideoService for arc video accelerator

components/arc/arc_bridge_service_impl.cc

 // Copyright 2015 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/arc/arc_bridge_service_impl.h"
 
 #include <string>
 #include <utility>
 
 #include "base/command_line.h"
 #include "base/prefs/pref_registry_simple.h"
 #include "base/prefs/pref_service.h"
 #include "base/sequenced_task_runner.h"
 #include "base/task_runner_util.h"
 #include "base/thread_task_runner_handle.h"
 #include "chromeos/chromeos_switches.h"
 #include "chromeos/dbus/dbus_method_call_status.h"
 #include "chromeos/dbus/dbus_thread_manager.h"
 #include "chromeos/dbus/session_manager_client.h"
+#include "ipc/ipc_channel_handle.h"
 #include "mojo/public/cpp/bindings/array.h"
 #include "third_party/mojo/src/mojo/edk/embedder/embedder.h"
 
 namespace mojo {
 
 template <>
 struct TypeConverter<arc::AppInfo, arc::AppInfoPtr> {
   static arc::AppInfo Convert(const arc::AppInfoPtr& app_info_ptr) {
     return *app_info_ptr;
   }
@@ skipping 142 matching lines @@
 bool ArcBridgeServiceImpl::RequestProcessList() {
   DCHECK(CalledOnValidThread());
   if (state() != State::READY) {
     LOG(ERROR) << "Called RequestProcessList when the service is not ready";
     return false;
   }
   instance_ptr_->RequestProcessList();
   return true;
 }
 
+void ArcBridgeServiceImpl::NotifyVideoAcceleratorChannelCreated(
+    const IPC::ChannelHandle& handle) {
+  DCHECK(CalledOnValidThread());
+  if (state() != State::READY) {
+    LOG(ERROR) << "Called NotifyVideoAcceleratorChannelCreated when the "
+                  "service is not ready";
+    return;
+  }
+  // TODO revisit before commit:
+  // can mojo create wrapper for invalid handle?
+  MojoHandle wrapped_handle;
+  MojoResult wrap_result = mojo::embedder::CreatePlatformHandleWrapper(
+      mojo::embedder::ScopedPlatformHandle(
+          mojo::embedder::PlatformHandle(handle.socket.fd)),
+      &wrapped_handle);
+  if (wrap_result != MOJO_RESULT_OK) {
+    LOG(WARNING) << "Pipe failed to wrap handles. Closing: " << wrap_result;
+    return;
+  }
+  instance_ptr_->NotifyVideoAcceleratorChannelCreated(
+      mojo::ScopedHandle(mojo::Handle(wrapped_handle)));
+}
+
 void ArcBridgeServiceImpl::OnInstanceBootPhase(InstanceBootPhase phase) {
   DCHECK(CalledOnValidThread());
   // The state can be CONNECTED the first time this is called, and will then
   // transition to READY after BRIDGE_READY has been passed.
   if (state() != State::CONNECTED && state() != State::READY) {
     VLOG(1) << "StopInstance() called while connecting";
     return;
   }
   if (phase == INSTANCE_BOOT_PHASE_BRIDGE_READY) {
     SetState(State::READY);
@@ skipping 46 matching lines @@
   // TODO(ejcaruso): Implement.
   VLOG(1) << "OnAcquireDisplayWakeLock";
 }
 
 void ArcBridgeServiceImpl::OnReleaseDisplayWakeLock(DisplayWakeLockType type) {
   DCHECK(CalledOnValidThread());
   // TODO(ejcaruso): Implement.
   VLOG(1) << "OnReleaseDisplayWakeLock";
 }
 
+void ArcBridgeServiceImpl::OnRequestArcVideoAcceleratorChannel() {
+  DCHECK(CalledOnValidThread());
+  if (!video_service()) {
+    LOG(ERROR) << "Got OnRequestArcVideoAcceleratorChannel"
+                  " but video service is not registered";
+    return;
+  }
+  video_service()->OnRequestArcVideoAcceleratorChannel();
+}
+
 void ArcBridgeServiceImpl::OnArcAvailable(bool arc_available) {
   DCHECK(CalledOnValidThread());
   if (available() == arc_available)
     return;
   SetAvailable(arc_available);
   PrerequisitesChanged();
 }
 
 void ArcBridgeServiceImpl::OnConnectionEstablished(
     ArcBridgeInstancePtr instance) {
@@ skipping 11 matching lines @@
 
   SetState(State::CONNECTED);
 }
 
 void ArcBridgeServiceImpl::OnStopped() {
   DCHECK(CalledOnValidThread());
   SetState(State::STOPPED);
 }
 
 }  // namespace arc