arc: IPC definition of file system interfaces.

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 52 matching lines @@
   if (audio_instance())
     observer->OnAudioInstanceReady();
   if (auth_instance())
     observer->OnAuthInstanceReady();
   if (bluetooth_instance())
     observer->OnBluetoothInstanceReady();
   if (clipboard_instance())
     observer->OnClipboardInstanceReady();
   if (crash_collector_instance())
     observer->OnCrashCollectorInstanceReady();
+  if (file_system_instance())
+    observer->OnFileSystemInstanceReady();
   if (ime_instance())
     observer->OnImeInstanceReady();
   if (metrics_instance())
     observer->OnMetricsInstanceReady();
   if (net_instance())
     observer->OnNetInstanceReady();
   if (notifications_instance())
     observer->OnNotificationsInstanceReady();
   if (policy_instance())
     observer->OnPolicyInstanceReady();
@@ skipping 156 matching lines @@
 void ArcBridgeService::CloseCrashCollectorChannel() {
   DCHECK(CalledOnValidThread());
   if (!crash_collector_ptr_)
     return;
 
   crash_collector_ptr_.reset();
   FOR_EACH_OBSERVER(Observer, observer_list(),
                     OnCrashCollectorInstanceClosed());
 }
 
+void ArcBridgeService::OnFileSystemInstanceReady(
+    mojom::FileSystemInstancePtr file_system_ptr) {
+  DCHECK(CalledOnValidThread());
+  temporary_file_system_ptr_ = std::move(file_system_ptr);
+  temporary_file_system_ptr_.QueryVersion(
+      base::Bind(&ArcBridgeService::OnFileSystemVersionReady,
+                 weak_factory_.GetWeakPtr()));
+}
+
+void ArcBridgeService::OnFileSystemVersionReady(int32_t version) {
+  DCHECK(CalledOnValidThread());
+  file_system_ptr_ = std::move(temporary_file_system_ptr_);
+  file_system_ptr_.set_connection_error_handler(
+      base::Bind(&ArcBridgeService::CloseFileSystemChannel,
+                 weak_factory_.GetWeakPtr()));
+  FOR_EACH_OBSERVER(Observer, observer_list(), OnFileSystemInstanceReady());
+}
+
+void ArcBridgeService::CloseFileSystemChannel() {
+  DCHECK(CalledOnValidThread());
+  if (!file_system_ptr_)
+    return;
+
+  file_system_ptr_.reset();
+  FOR_EACH_OBSERVER(Observer, observer_list(),
+                    OnFileSystemInstanceClosed());
+}
+
 void ArcBridgeService::OnImeInstanceReady(mojom::ImeInstancePtr ime_ptr) {
   DCHECK(CalledOnValidThread());
   temporary_ime_ptr_ = std::move(ime_ptr);
   temporary_ime_ptr_.QueryVersion(base::Bind(
       &ArcBridgeService::OnImeVersionReady, weak_factory_.GetWeakPtr()));
 }
 
 void ArcBridgeService::OnImeVersionReady(int32_t version) {
   DCHECK(CalledOnValidThread());
   ime_ptr_ = std::move(temporary_ime_ptr_);
@@ skipping 288 matching lines @@
 
 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();
   CloseBluetoothChannel();
   CloseClipboardChannel();
   CloseCrashCollectorChannel();
+  CloseFileSystemChannel();
   CloseImeChannel();
   CloseIntentHelperChannel();
   CloseMetricsChannel();
   CloseNetChannel();
   CloseNotificationsChannel();
   ClosePolicyChannel();
   ClosePowerChannel();
   CloseProcessChannel();
   CloseStorageManagerChannel();
   CloseVideoChannel();
   CloseWindowManagerChannel();
 }
 
 }  // namespace arc