Host-side implementation of ARC audio bridge.

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 42 matching lines @@
 
 void ArcBridgeService::AddObserver(Observer* observer) {
   DCHECK(CalledOnValidThread());
   observer_list_.AddObserver(observer);
 
   // If any of the instances were ready before the call to AddObserver(), the
   // |observer| won't get any readiness events. For such cases, we have to call
   // them explicitly now to avoid a race.
   if (app_instance())
     observer->OnAppInstanceReady();
+  if (audio_instance())
+    observer->OnAudioInstanceReady();
   if (auth_instance())
     observer->OnAuthInstanceReady();
   if (clipboard_instance())
     observer->OnClipboardInstanceReady();
   if (crash_collector_instance())
     observer->OnCrashCollectorInstanceReady();
   if (ime_instance())
     observer->OnImeInstanceReady();
   if (input_instance())
     observer->OnInputInstanceReady();
@@ skipping 33 matching lines @@
 
 void ArcBridgeService::CloseAppChannel() {
   DCHECK(CalledOnValidThread());
   if (!app_ptr_)
     return;
 
   app_ptr_.reset();
   FOR_EACH_OBSERVER(Observer, observer_list(), OnAppInstanceClosed());
 }
 
+void ArcBridgeService::OnAudioInstanceReady(AudioInstancePtr audio_ptr) {
+  DCHECK(CalledOnValidThread());
+  temporary_audio_ptr_ = std::move(audio_ptr);
+  temporary_audio_ptr_.QueryVersion(base::Bind(
+      &ArcBridgeService::OnAudioVersionReady, weak_factory_.GetWeakPtr()));
+}
+
+void ArcBridgeService::OnAudioVersionReady(int32_t version) {
+  DCHECK(CalledOnValidThread());
+  audio_ptr_ = std::move(temporary_audio_ptr_);
+  audio_ptr_.set_connection_error_handler(base::Bind(
+      &ArcBridgeService::CloseAudioChannel, weak_factory_.GetWeakPtr()));
+  FOR_EACH_OBSERVER(Observer, observer_list(), OnAudioInstanceReady());
+}
+
+void ArcBridgeService::CloseAudioChannel() {
+  if (!audio_ptr_)
+    return;
+
+  audio_ptr_.reset();
+  FOR_EACH_OBSERVER(Observer, observer_list(), OnAudioInstanceClosed());
+}
+
 void ArcBridgeService::OnAuthInstanceReady(AuthInstancePtr auth_ptr) {
   DCHECK(CalledOnValidThread());
   temporary_auth_ptr_ = std::move(auth_ptr);
   temporary_auth_ptr_.QueryVersion(base::Bind(
       &ArcBridgeService::OnAuthVersionReady, weak_factory_.GetWeakPtr()));
 }
 
 void ArcBridgeService::OnAuthVersionReady(int32_t version) {
   DCHECK(CalledOnValidThread());
   auth_ptr_ = std::move(temporary_auth_ptr_);
@@ skipping 301 matching lines @@
 }
 
 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();
+  CloseAudioChannel();
   CloseAuthChannel();
   CloseClipboardChannel();
   CloseCrashCollectorChannel();
   CloseImeChannel();
   CloseInputChannel();
   CloseIntentHelperChannel();
   CloseNetChannel();
   CloseNotificationsChannel();
   ClosePolicyChannel();
   ClosePowerChannel();
   CloseProcessChannel();
   CloseVideoChannel();
 }
 
 }  // namespace arc