Implement GpuArcVideoService for arc video accelerator

components/arc/arc_bridge_service.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.h"
 
 #include <utility>
 
 #include "base/command_line.h"
 #include "base/sequenced_task_runner.h"
@@ skipping 185 matching lines @@
 
 void ArcBridgeService::CloseSettingsChannel() {
   DCHECK(CalledOnValidThread());
   if (!settings_ptr_)
     return;
 
   settings_ptr_.reset();
   FOR_EACH_OBSERVER(Observer, observer_list(), OnSettingsInstanceClosed());
 }
 
+void ArcBridgeService::OnVideoInstanceReady(VideoInstancePtr video_ptr) {
+  DCHECK(CalledOnValidThread());
+  temporary_video_ptr_ = std::move(video_ptr);
+  temporary_video_ptr_.QueryVersion(base::Bind(
+      &ArcBridgeService::OnVideoVersionReady, weak_factory_.GetWeakPtr()));
+}
+
+void ArcBridgeService::OnVideoVersionReady(int32_t version) {
+  video_ptr_ = std::move(temporary_video_ptr_);
+  FOR_EACH_OBSERVER(Observer, observer_list(), OnVideoInstanceReady());
+  video_ptr_.set_connection_error_handler(base::Bind(
+      &ArcBridgeService::CloseVideoChannel, weak_factory_.GetWeakPtr()));
+}
+
+void ArcBridgeService::CloseVideoChannel() {
+  DCHECK(CalledOnValidThread());
+  if (!video_ptr_)
+    return;
+
+  video_ptr_.reset();
+  FOR_EACH_OBSERVER(Observer, observer_list(), OnVideoInstanceClosed());
+}
+
 void ArcBridgeService::SetState(State state) {
   DCHECK(CalledOnValidThread());
   // DCHECK on enum classes not supported.
   DCHECK(state_ != state);
   state_ = state;
   FOR_EACH_OBSERVER(Observer, observer_list(), OnStateChanged(state_));
 }
 
 void ArcBridgeService::SetAvailable(bool available) {
   DCHECK(CalledOnValidThread());
   DCHECK(available_ != available);
   available_ = available;
   FOR_EACH_OBSERVER(Observer, observer_list(), OnAvailableChanged(available_));
 }
 
 bool ArcBridgeService::CalledOnValidThread() {
   return thread_checker_.CalledOnValidThread();
 }
 
 void ArcBridgeService::CloseAllChannels() {
   // Call all the error handlers of all the channels to both close the channel
   // and notify any observers that the channel is closed.
   CloseAppChannel();
   CloseInputChannel();
   CloseNotificationsChannel();
   ClosePowerChannel();
   CloseProcessChannel();
   CloseSettingsChannel();
+  CloseVideoChannel();
 }
 
 }  // namespace arc