Add OBB mounter Mojo interface

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 70 matching lines @@
   if (policy_instance())
     observer->OnPolicyInstanceReady();
   if (power_instance())
     observer->OnPowerInstanceReady();
   if (process_instance())
     observer->OnProcessInstanceReady();
   if (video_instance())
     observer->OnVideoInstanceReady();
   if (window_manager_instance())
     observer->OnWindowManagerInstanceReady();
+  if (obb_mounter_instance())
+    observer->OnObbMounterInstanceReady();
 }
 
 void ArcBridgeService::RemoveObserver(Observer* observer) {
   DCHECK(CalledOnValidThread());
   observer_list_.RemoveObserver(observer);
 }
 
 void ArcBridgeService::OnAppInstanceReady(mojom::AppInstancePtr app_ptr) {
   DCHECK(CalledOnValidThread());
   temporary_app_ptr_ = std::move(app_ptr);
@@ skipping 386 matching lines @@
 }
 
 void ArcBridgeService::CloseWindowManagerChannel() {
   if (!window_manager_ptr_)
     return;
 
   window_manager_ptr_.reset();
   FOR_EACH_OBSERVER(Observer, observer_list(), OnWindowManagerInstanceClosed());
 }
 
+void ArcBridgeService::OnObbMounterInstanceReady(
+    mojom::ObbMounterInstancePtr obb_mounter_ptr) {
+  DCHECK(CalledOnValidThread());
+  temporary_obb_mounter_ptr_ = std::move(obb_mounter_ptr);
+  temporary_obb_mounter_ptr_.QueryVersion(base::Bind(
+      &ArcBridgeService::OnObbMounterVersionReady,
+      weak_factory_.GetWeakPtr()));
+}
+
+void ArcBridgeService::OnObbMounterVersionReady(int32_t version) {
+  DCHECK(CalledOnValidThread());
+  obb_mounter_ptr_ = std::move(temporary_obb_mounter_ptr_);
+  obb_mounter_ptr_.set_connection_error_handler(base::Bind(
+      &ArcBridgeService::CloseObbMounterChannel,
+      weak_factory_.GetWeakPtr()));
+  FOR_EACH_OBSERVER(Observer, observer_list(), OnObbMounterInstanceReady());
+}
+
+void ArcBridgeService::CloseObbMounterChannel() {
+  if (!obb_mounter_ptr_)
+    return;
+
+  obb_mounter_ptr_.reset();
+  FOR_EACH_OBSERVER(Observer, observer_list(), OnObbMounterInstanceClosed());
+}
+
 void ArcBridgeService::SetState(State state) {
   DCHECK(CalledOnValidThread());
   // DCHECK on enum classes not supported.
   DCHECK(state_ != state);
   state_ = state;
   VLOG(2) << "State: " << static_cast<uint32_t>(state_);
   FOR_EACH_OBSERVER(Observer, observer_list(), OnStateChanged(state_));
 }
 
 void ArcBridgeService::SetAvailable(bool available) {
@@ skipping 19 matching lines @@
   CloseImeChannel();
   CloseIntentHelperChannel();
   CloseMetricsChannel();
   CloseNetChannel();
   CloseNotificationsChannel();
   ClosePolicyChannel();
   ClosePowerChannel();
   CloseProcessChannel();
   CloseVideoChannel();
   CloseWindowManagerChannel();
+  CloseObbMounterChannel();
 }
 
 }  // namespace arc