| OLD | NEW |
| 1 // Copyright 2016 The Chromium Authors. All rights reserved. | 1 // Copyright 2016 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "chrome/browser/chromeos/arc/fileapi/arc_file_system_instance_util.h" | 5 #include "chrome/browser/chromeos/arc/fileapi/arc_file_system_instance_util.h" |
| 6 | 6 |
| 7 #include <string> |
| 8 |
| 7 #include "components/arc/arc_bridge_service.h" | 9 #include "components/arc/arc_bridge_service.h" |
| 10 #include "components/arc/arc_service_manager.h" |
| 8 #include "content/public/browser/browser_thread.h" | 11 #include "content/public/browser/browser_thread.h" |
| 9 #include "url/gurl.h" | 12 #include "url/gurl.h" |
| 10 | 13 |
| 11 namespace arc { | 14 namespace arc { |
| 12 | 15 |
| 13 namespace file_system_instance_util { | 16 namespace file_system_instance_util { |
| 14 | 17 |
| 15 namespace { | 18 namespace { |
| 16 | 19 |
| 17 constexpr uint32_t kGetFileSizeVersion = 1; | 20 constexpr uint32_t kGetFileSizeVersion = 1; |
| 18 constexpr uint32_t kOpenFileToReadVersion = 1; | 21 constexpr uint32_t kOpenFileToReadVersion = 1; |
| 19 | 22 |
| 23 // Returns FileSystemInstance for the given |min_version|, if found. |
| 24 // Otherwise, nullptr. |
| 25 mojom::FileSystemInstance* GetFileSystemInstance( |
| 26 const std::string& method_name_for_logging, |
| 27 uint32_t min_version) { |
| 28 DCHECK_CURRENTLY_ON(content::BrowserThread::UI); |
| 29 auto* arc_service_manager = arc::ArcServiceManager::Get(); |
| 30 if (!arc_service_manager) { |
| 31 LOG(ERROR) << "Failed to get ArcServiceManager."; |
| 32 return nullptr; |
| 33 } |
| 34 return arc_service_manager->arc_bridge_service() |
| 35 ->file_system() |
| 36 ->GetInstanceForMethod(method_name_for_logging, min_version); |
| 37 } |
| 38 |
| 20 void OnGetFileSize(const GetFileSizeCallback& callback, int64_t size) { | 39 void OnGetFileSize(const GetFileSizeCallback& callback, int64_t size) { |
| 21 DCHECK_CURRENTLY_ON(content::BrowserThread::UI); | 40 DCHECK_CURRENTLY_ON(content::BrowserThread::UI); |
| 22 content::BrowserThread::PostTask(content::BrowserThread::IO, FROM_HERE, | 41 content::BrowserThread::PostTask(content::BrowserThread::IO, FROM_HERE, |
| 23 base::Bind(callback, size)); | 42 base::Bind(callback, size)); |
| 24 } | 43 } |
| 25 | 44 |
| 26 void GetFileSizeOnUIThread(const GURL& arc_url, | 45 void GetFileSizeOnUIThread(const GURL& arc_url, |
| 27 const GetFileSizeCallback& callback) { | 46 const GetFileSizeCallback& callback) { |
| 28 DCHECK_CURRENTLY_ON(content::BrowserThread::UI); | 47 DCHECK_CURRENTLY_ON(content::BrowserThread::UI); |
| 29 auto* arc_bridge_service = arc::ArcBridgeService::Get(); | 48 auto* file_system_instance = |
| 30 if (!arc_bridge_service) { | 49 GetFileSystemInstance("GetFileSize", kGetFileSizeVersion); |
| 31 LOG(ERROR) << "Failed to get ArcBridgeService."; | 50 if (!file_system_instance) { |
| 32 OnGetFileSize(callback, -1); | 51 OnGetFileSize(callback, -1); |
| 33 return; | 52 return; |
| 34 } | 53 } |
| 35 mojom::FileSystemInstance* file_system_instance = | |
| 36 arc_bridge_service->file_system()->GetInstanceForMethod( | |
| 37 "GetFileSize", kGetFileSizeVersion); | |
| 38 if (!file_system_instance) { | |
| 39 LOG(ERROR) << "Failed to get FileSystemInstance."; | |
| 40 OnGetFileSize(callback, -1); | |
| 41 return; | |
| 42 } | |
| 43 file_system_instance->GetFileSize(arc_url.spec(), | 54 file_system_instance->GetFileSize(arc_url.spec(), |
| 44 base::Bind(&OnGetFileSize, callback)); | 55 base::Bind(&OnGetFileSize, callback)); |
| 45 } | 56 } |
| 46 | 57 |
| 47 void OnOpenFileToRead(const OpenFileToReadCallback& callback, | 58 void OnOpenFileToRead(const OpenFileToReadCallback& callback, |
| 48 mojo::ScopedHandle handle) { | 59 mojo::ScopedHandle handle) { |
| 49 DCHECK_CURRENTLY_ON(content::BrowserThread::UI); | 60 DCHECK_CURRENTLY_ON(content::BrowserThread::UI); |
| 50 content::BrowserThread::PostTask(content::BrowserThread::IO, FROM_HERE, | 61 content::BrowserThread::PostTask(content::BrowserThread::IO, FROM_HERE, |
| 51 base::Bind(callback, base::Passed(&handle))); | 62 base::Bind(callback, base::Passed(&handle))); |
| 52 } | 63 } |
| 53 | 64 |
| 54 void OpenFileToReadOnUIThread(const GURL& arc_url, | 65 void OpenFileToReadOnUIThread(const GURL& arc_url, |
| 55 const OpenFileToReadCallback& callback) { | 66 const OpenFileToReadCallback& callback) { |
| 56 DCHECK_CURRENTLY_ON(content::BrowserThread::UI); | 67 DCHECK_CURRENTLY_ON(content::BrowserThread::UI); |
| 57 auto* arc_bridge_service = arc::ArcBridgeService::Get(); | 68 auto* file_system_instance = |
| 58 if (!arc_bridge_service) { | 69 GetFileSystemInstance("OpenFileToRead", kOpenFileToReadVersion); |
| 59 LOG(ERROR) << "Failed to get ArcBridgeService."; | 70 if (!file_system_instance) { |
| 60 OnOpenFileToRead(callback, mojo::ScopedHandle()); | 71 OnOpenFileToRead(callback, mojo::ScopedHandle()); |
| 61 return; | 72 return; |
| 62 } | 73 } |
| 63 mojom::FileSystemInstance* file_system_instance = | |
| 64 arc_bridge_service->file_system()->GetInstanceForMethod( | |
| 65 "OpenFileToRead", kOpenFileToReadVersion); | |
| 66 if (!file_system_instance) { | |
| 67 LOG(ERROR) << "Failed to get FileSystemInstance."; | |
| 68 OnOpenFileToRead(callback, mojo::ScopedHandle()); | |
| 69 return; | |
| 70 } | |
| 71 file_system_instance->OpenFileToRead(arc_url.spec(), | 74 file_system_instance->OpenFileToRead(arc_url.spec(), |
| 72 base::Bind(&OnOpenFileToRead, callback)); | 75 base::Bind(&OnOpenFileToRead, callback)); |
| 73 } | 76 } |
| 74 | 77 |
| 75 } // namespace | 78 } // namespace |
| 76 | 79 |
| 77 void GetFileSizeOnIOThread(const GURL& arc_url, | 80 void GetFileSizeOnIOThread(const GURL& arc_url, |
| 78 const GetFileSizeCallback& callback) { | 81 const GetFileSizeCallback& callback) { |
| 79 DCHECK_CURRENTLY_ON(content::BrowserThread::IO); | 82 DCHECK_CURRENTLY_ON(content::BrowserThread::IO); |
| 80 content::BrowserThread::PostTask( | 83 content::BrowserThread::PostTask( |
| 81 content::BrowserThread::UI, FROM_HERE, | 84 content::BrowserThread::UI, FROM_HERE, |
| 82 base::Bind(&GetFileSizeOnUIThread, arc_url, callback)); | 85 base::Bind(&GetFileSizeOnUIThread, arc_url, callback)); |
| 83 } | 86 } |
| 84 | 87 |
| 85 void OpenFileToReadOnIOThread(const GURL& arc_url, | 88 void OpenFileToReadOnIOThread(const GURL& arc_url, |
| 86 const OpenFileToReadCallback& callback) { | 89 const OpenFileToReadCallback& callback) { |
| 87 DCHECK_CURRENTLY_ON(content::BrowserThread::IO); | 90 DCHECK_CURRENTLY_ON(content::BrowserThread::IO); |
| 88 content::BrowserThread::PostTask( | 91 content::BrowserThread::PostTask( |
| 89 content::BrowserThread::UI, FROM_HERE, | 92 content::BrowserThread::UI, FROM_HERE, |
| 90 base::Bind(&OpenFileToReadOnUIThread, arc_url, callback)); | 93 base::Bind(&OpenFileToReadOnUIThread, arc_url, callback)); |
| 91 } | 94 } |
| 92 | 95 |
| 93 } // namespace file_system_instance_util | 96 } // namespace file_system_instance_util |
| 94 | 97 |
| 95 } // namespace arc | 98 } // namespace arc |
| OLD | NEW |