OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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/file_system_provider/service.h" | 5 #include "chrome/browser/chromeos/file_system_provider/service.h" |
6 | 6 |
7 #include "base/files/file_path.h" | 7 #include "base/files/file_path.h" |
8 #include "base/stl_util.h" | 8 #include "base/stl_util.h" |
9 #include "chrome/browser/chromeos/file_system_provider/mount_path_util.h" | 9 #include "chrome/browser/chromeos/file_system_provider/mount_path_util.h" |
10 #include "chrome/browser/chromeos/file_system_provider/observer.h" | 10 #include "chrome/browser/chromeos/file_system_provider/observer.h" |
11 #include "chrome/browser/chromeos/file_system_provider/provided_file_system.h" | 11 #include "chrome/browser/chromeos/file_system_provider/provided_file_system.h" |
12 #include "chrome/browser/chromeos/file_system_provider/provided_file_system_info
.h" | 12 #include "chrome/browser/chromeos/file_system_provider/provided_file_system_info
.h" |
13 #include "chrome/browser/chromeos/file_system_provider/provided_file_system_inte
rface.h" | 13 #include "chrome/browser/chromeos/file_system_provider/provided_file_system_inte
rface.h" |
14 #include "chrome/browser/chromeos/file_system_provider/service_factory.h" | 14 #include "chrome/browser/chromeos/file_system_provider/service_factory.h" |
15 #include "content/public/browser/browser_thread.h" | 15 #include "content/public/browser/browser_thread.h" |
16 #include "extensions/browser/event_router.h" | 16 #include "extensions/browser/event_router.h" |
17 #include "extensions/browser/extension_registry.h" | 17 #include "extensions/browser/extension_registry.h" |
18 #include "extensions/browser/extension_system.h" | 18 #include "extensions/browser/extension_system.h" |
19 #include "webkit/browser/fileapi/external_mount_points.h" | 19 #include "webkit/browser/fileapi/external_mount_points.h" |
20 | 20 |
| 21 using content::BrowserThread; |
| 22 |
21 namespace chromeos { | 23 namespace chromeos { |
22 namespace file_system_provider { | 24 namespace file_system_provider { |
23 namespace { | 25 namespace { |
24 | 26 |
25 // Maximum number of file systems to be mounted in the same time, per profile. | 27 // Maximum number of file systems to be mounted in the same time, per profile. |
26 const size_t kMaxFileSystems = 16; | 28 const size_t kMaxFileSystems = 16; |
27 | 29 |
28 // Default factory for provided file systems. The |event_router| must not be | 30 // Default factory for provided file systems. The |event_router| must not be |
29 // NULL. | 31 // NULL. |
30 ProvidedFileSystemInterface* CreateProvidedFileSystem( | 32 ProvidedFileSystemInterface* CreateProvidedFileSystem( |
(...skipping 47 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
78 } | 80 } |
79 | 81 |
80 void Service::SetFileSystemFactoryForTests( | 82 void Service::SetFileSystemFactoryForTests( |
81 const FileSystemFactoryCallback& factory_callback) { | 83 const FileSystemFactoryCallback& factory_callback) { |
82 DCHECK(!factory_callback.is_null()); | 84 DCHECK(!factory_callback.is_null()); |
83 file_system_factory_ = factory_callback; | 85 file_system_factory_ = factory_callback; |
84 } | 86 } |
85 | 87 |
86 int Service::MountFileSystem(const std::string& extension_id, | 88 int Service::MountFileSystem(const std::string& extension_id, |
87 const std::string& file_system_name) { | 89 const std::string& file_system_name) { |
88 DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI)); | 90 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
89 | 91 |
90 // Restrict number of file systems to prevent system abusing. | 92 // Restrict number of file systems to prevent system abusing. |
91 if (file_system_map_.size() + 1 > kMaxFileSystems) { | 93 if (file_system_map_.size() + 1 > kMaxFileSystems) { |
92 FOR_EACH_OBSERVER( | 94 FOR_EACH_OBSERVER( |
93 Observer, | 95 Observer, |
94 observers_, | 96 observers_, |
95 OnProvidedFileSystemMount(ProvidedFileSystemInfo(), | 97 OnProvidedFileSystemMount(ProvidedFileSystemInfo(), |
96 base::File::FILE_ERROR_TOO_MANY_OPENED)); | 98 base::File::FILE_ERROR_TOO_MANY_OPENED)); |
97 return 0; | 99 return 0; |
98 } | 100 } |
(...skipping 45 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
144 Observer, | 146 Observer, |
145 observers_, | 147 observers_, |
146 OnProvidedFileSystemMount(file_system_info, base::File::FILE_OK)); | 148 OnProvidedFileSystemMount(file_system_info, base::File::FILE_OK)); |
147 | 149 |
148 next_id_++; | 150 next_id_++; |
149 return file_system_id; | 151 return file_system_id; |
150 } | 152 } |
151 | 153 |
152 bool Service::UnmountFileSystem(const std::string& extension_id, | 154 bool Service::UnmountFileSystem(const std::string& extension_id, |
153 int file_system_id) { | 155 int file_system_id) { |
154 DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI)); | 156 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
155 | 157 |
156 const ProvidedFileSystemMap::iterator file_system_it = | 158 const ProvidedFileSystemMap::iterator file_system_it = |
157 file_system_map_.find(file_system_id); | 159 file_system_map_.find(file_system_id); |
158 if (file_system_it == file_system_map_.end() || | 160 if (file_system_it == file_system_map_.end() || |
159 file_system_it->second->GetFileSystemInfo().extension_id() != | 161 file_system_it->second->GetFileSystemInfo().extension_id() != |
160 extension_id) { | 162 extension_id) { |
161 const ProvidedFileSystemInfo empty_file_system_info; | 163 const ProvidedFileSystemInfo empty_file_system_info; |
162 FOR_EACH_OBSERVER( | 164 FOR_EACH_OBSERVER( |
163 Observer, | 165 Observer, |
164 observers_, | 166 observers_, |
(...skipping 27 matching lines...) Expand all Loading... |
192 | 194 |
193 mount_point_name_to_id_map_.erase(mount_point_name); | 195 mount_point_name_to_id_map_.erase(mount_point_name); |
194 | 196 |
195 delete file_system_it->second; | 197 delete file_system_it->second; |
196 file_system_map_.erase(file_system_it); | 198 file_system_map_.erase(file_system_it); |
197 | 199 |
198 return true; | 200 return true; |
199 } | 201 } |
200 | 202 |
201 bool Service::RequestUnmount(int file_system_id) { | 203 bool Service::RequestUnmount(int file_system_id) { |
202 DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI)); | 204 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
203 | 205 |
204 ProvidedFileSystemMap::iterator file_system_it = | 206 ProvidedFileSystemMap::iterator file_system_it = |
205 file_system_map_.find(file_system_id); | 207 file_system_map_.find(file_system_id); |
206 if (file_system_it == file_system_map_.end()) | 208 if (file_system_it == file_system_map_.end()) |
207 return false; | 209 return false; |
208 | 210 |
209 file_system_it->second->RequestUnmount( | 211 file_system_it->second->RequestUnmount( |
210 base::Bind(&Service::OnRequestUnmountStatus, | 212 base::Bind(&Service::OnRequestUnmountStatus, |
211 weak_ptr_factory_.GetWeakPtr(), | 213 weak_ptr_factory_.GetWeakPtr(), |
212 file_system_it->second->GetFileSystemInfo())); | 214 file_system_it->second->GetFileSystemInfo())); |
213 return true; | 215 return true; |
214 } | 216 } |
215 | 217 |
216 std::vector<ProvidedFileSystemInfo> Service::GetProvidedFileSystemInfoList() { | 218 std::vector<ProvidedFileSystemInfo> Service::GetProvidedFileSystemInfoList() { |
217 DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI)); | 219 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
218 | 220 |
219 std::vector<ProvidedFileSystemInfo> result; | 221 std::vector<ProvidedFileSystemInfo> result; |
220 for (ProvidedFileSystemMap::const_iterator it = file_system_map_.begin(); | 222 for (ProvidedFileSystemMap::const_iterator it = file_system_map_.begin(); |
221 it != file_system_map_.end(); | 223 it != file_system_map_.end(); |
222 ++it) { | 224 ++it) { |
223 result.push_back(it->second->GetFileSystemInfo()); | 225 result.push_back(it->second->GetFileSystemInfo()); |
224 } | 226 } |
225 return result; | 227 return result; |
226 } | 228 } |
227 | 229 |
228 ProvidedFileSystemInterface* Service::GetProvidedFileSystem( | 230 ProvidedFileSystemInterface* Service::GetProvidedFileSystem( |
229 const std::string& extension_id, | 231 const std::string& extension_id, |
230 int file_system_id) { | 232 int file_system_id) { |
231 DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI)); | 233 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
232 | 234 |
233 const ProvidedFileSystemMap::const_iterator file_system_it = | 235 const ProvidedFileSystemMap::const_iterator file_system_it = |
234 file_system_map_.find(file_system_id); | 236 file_system_map_.find(file_system_id); |
235 if (file_system_it == file_system_map_.end() || | 237 if (file_system_it == file_system_map_.end() || |
236 file_system_it->second->GetFileSystemInfo().extension_id() != | 238 file_system_it->second->GetFileSystemInfo().extension_id() != |
237 extension_id) { | 239 extension_id) { |
238 return NULL; | 240 return NULL; |
239 } | 241 } |
240 | 242 |
241 return file_system_it->second; | 243 return file_system_it->second; |
(...skipping 14 matching lines...) Expand all Loading... |
256 if (file_system_info.extension_id() == extension->id()) { | 258 if (file_system_info.extension_id() == extension->id()) { |
257 bool result = UnmountFileSystem(file_system_info.extension_id(), | 259 bool result = UnmountFileSystem(file_system_info.extension_id(), |
258 file_system_info.file_system_id()); | 260 file_system_info.file_system_id()); |
259 DCHECK(result); | 261 DCHECK(result); |
260 } | 262 } |
261 } | 263 } |
262 } | 264 } |
263 | 265 |
264 ProvidedFileSystemInterface* Service::GetProvidedFileSystem( | 266 ProvidedFileSystemInterface* Service::GetProvidedFileSystem( |
265 const std::string& mount_point_name) { | 267 const std::string& mount_point_name) { |
266 DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI)); | 268 DCHECK_CURRENTLY_ON(BrowserThread::UI); |
267 | 269 |
268 const MountPointNameToIdMap::const_iterator mapping_it = | 270 const MountPointNameToIdMap::const_iterator mapping_it = |
269 mount_point_name_to_id_map_.find(mount_point_name); | 271 mount_point_name_to_id_map_.find(mount_point_name); |
270 if (mapping_it == mount_point_name_to_id_map_.end()) | 272 if (mapping_it == mount_point_name_to_id_map_.end()) |
271 return NULL; | 273 return NULL; |
272 | 274 |
273 const ProvidedFileSystemMap::const_iterator file_system_it = | 275 const ProvidedFileSystemMap::const_iterator file_system_it = |
274 file_system_map_.find(mapping_it->second); | 276 file_system_map_.find(mapping_it->second); |
275 if (file_system_it == file_system_map_.end()) | 277 if (file_system_it == file_system_map_.end()) |
276 return NULL; | 278 return NULL; |
277 | 279 |
278 return file_system_it->second; | 280 return file_system_it->second; |
279 } | 281 } |
280 | 282 |
281 void Service::OnRequestUnmountStatus( | 283 void Service::OnRequestUnmountStatus( |
282 const ProvidedFileSystemInfo& file_system_info, | 284 const ProvidedFileSystemInfo& file_system_info, |
283 base::File::Error error) { | 285 base::File::Error error) { |
284 // Notify observers about failure in unmounting, since mount() will not be | 286 // Notify observers about failure in unmounting, since mount() will not be |
285 // called by the provided file system. In case of success mount() will be | 287 // called by the provided file system. In case of success mount() will be |
286 // invoked, and observers notified, so there is no need to call them now. | 288 // invoked, and observers notified, so there is no need to call them now. |
287 if (error != base::File::FILE_OK) { | 289 if (error != base::File::FILE_OK) { |
288 FOR_EACH_OBSERVER(Observer, | 290 FOR_EACH_OBSERVER(Observer, |
289 observers_, | 291 observers_, |
290 OnProvidedFileSystemUnmount(file_system_info, error)); | 292 OnProvidedFileSystemUnmount(file_system_info, error)); |
291 } | 293 } |
292 } | 294 } |
293 | 295 |
294 } // namespace file_system_provider | 296 } // namespace file_system_provider |
295 } // namespace chromeos | 297 } // namespace chromeos |
OLD | NEW |