| OLD | NEW |
| 1 // Copyright (c) 2013 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2013 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/media_galleries/fileapi/device_media_async_file_util.h" | 5 #include "chrome/browser/media_galleries/fileapi/device_media_async_file_util.h" |
| 6 | 6 |
| 7 #include "base/callback.h" | 7 #include "base/callback.h" |
| 8 #include "base/file_util.h" | 8 #include "base/file_util.h" |
| 9 #include "base/single_thread_task_runner.h" | 9 #include "base/single_thread_task_runner.h" |
| 10 #include "chrome/browser/media_galleries/fileapi/filtering_file_enumerator.h" | 10 #include "chrome/browser/media_galleries/fileapi/filtering_file_enumerator.h" |
| 11 #include "chrome/browser/media_galleries/fileapi/media_file_system_mount_point_p
rovider.h" | 11 #include "chrome/browser/media_galleries/fileapi/media_file_system_mount_point_p
rovider.h" |
| 12 #include "chrome/browser/media_galleries/fileapi/media_path_filter.h" | 12 #include "chrome/browser/media_galleries/fileapi/media_path_filter.h" |
| 13 #include "chrome/browser/media_galleries/fileapi/mtp_device_async_delegate.h" | 13 #include "chrome/browser/media_galleries/fileapi/mtp_device_async_delegate.h" |
| 14 #include "chrome/browser/media_galleries/fileapi/mtp_device_map_service.h" | 14 #include "chrome/browser/media_galleries/fileapi/mtp_device_map_service.h" |
| 15 #include "webkit/blob/shareable_file_reference.h" |
| 15 #include "webkit/fileapi/file_system_context.h" | 16 #include "webkit/fileapi/file_system_context.h" |
| 16 #include "webkit/fileapi/file_system_operation_context.h" | 17 #include "webkit/fileapi/file_system_operation_context.h" |
| 17 #include "webkit/fileapi/file_system_task_runners.h" | 18 #include "webkit/fileapi/file_system_task_runners.h" |
| 18 #include "webkit/fileapi/file_system_url.h" | 19 #include "webkit/fileapi/file_system_url.h" |
| 19 #include "webkit/fileapi/isolated_context.h" | 20 #include "webkit/fileapi/isolated_context.h" |
| 20 | 21 |
| 21 using fileapi::FileSystemOperationContext; | 22 using fileapi::FileSystemOperationContext; |
| 22 using fileapi::FileSystemURL; | 23 using fileapi::FileSystemURL; |
| 24 using webkit_blob::ShareableFileReference; |
| 23 | 25 |
| 24 namespace chrome { | 26 namespace chrome { |
| 25 | 27 |
| 26 namespace { | 28 namespace { |
| 27 | 29 |
| 28 const base::FilePath::CharType kDeviceMediaAsyncFileUtilTempDir[] = | 30 const base::FilePath::CharType kDeviceMediaAsyncFileUtilTempDir[] = |
| 29 FILE_PATH_LITERAL("DeviceMediaFileSystem"); | 31 FILE_PATH_LITERAL("DeviceMediaFileSystem"); |
| 30 | 32 |
| 31 // Returns true if the current thread is IO thread. | 33 // Returns true if the current thread is IO thread. |
| 32 bool IsOnIOThread(FileSystemOperationContext* context) { | 34 bool IsOnIOThread(FileSystemOperationContext* context) { |
| (...skipping 269 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 302 | 304 |
| 303 void DeviceMediaAsyncFileUtil::OnReadDirectoryError( | 305 void DeviceMediaAsyncFileUtil::OnReadDirectoryError( |
| 304 const AsyncFileUtil::ReadDirectoryCallback& callback, | 306 const AsyncFileUtil::ReadDirectoryCallback& callback, |
| 305 base::PlatformFileError error) { | 307 base::PlatformFileError error) { |
| 306 if (!callback.is_null()) | 308 if (!callback.is_null()) |
| 307 callback.Run(error, AsyncFileUtil::EntryList(), false /*no more*/); | 309 callback.Run(error, AsyncFileUtil::EntryList(), false /*no more*/); |
| 308 } | 310 } |
| 309 | 311 |
| 310 void DeviceMediaAsyncFileUtil::OnDidCreateSnapshotFile( | 312 void DeviceMediaAsyncFileUtil::OnDidCreateSnapshotFile( |
| 311 const AsyncFileUtil::CreateSnapshotFileCallback& callback, | 313 const AsyncFileUtil::CreateSnapshotFileCallback& callback, |
| 314 base::SequencedTaskRunner* media_task_runner, |
| 312 const base::PlatformFileInfo& file_info, | 315 const base::PlatformFileInfo& file_info, |
| 313 const base::FilePath& platform_path) { | 316 const base::FilePath& platform_path) { |
| 314 if (!callback.is_null()) | 317 if (callback.is_null()) |
| 315 callback.Run(base::PLATFORM_FILE_OK, file_info, platform_path, | 318 return; |
| 316 fileapi::kSnapshotFileTemporary); | 319 callback.Run(base::PLATFORM_FILE_OK, file_info, platform_path, |
| 320 ShareableFileReference::GetOrCreate( |
| 321 platform_path, |
| 322 ShareableFileReference::DELETE_ON_FINAL_RELEASE, |
| 323 media_task_runner)); |
| 317 } | 324 } |
| 318 | 325 |
| 319 void DeviceMediaAsyncFileUtil::OnCreateSnapshotFileError( | 326 void DeviceMediaAsyncFileUtil::OnCreateSnapshotFileError( |
| 320 const AsyncFileUtil::CreateSnapshotFileCallback& callback, | 327 const AsyncFileUtil::CreateSnapshotFileCallback& callback, |
| 321 base::PlatformFileError error) { | 328 base::PlatformFileError error) { |
| 322 if (!callback.is_null()) | 329 if (!callback.is_null()) |
| 323 callback.Run(error, base::PlatformFileInfo(), base::FilePath(), | 330 callback.Run(error, base::PlatformFileInfo(), base::FilePath(), |
| 324 fileapi::kSnapshotFileTemporary); | 331 scoped_refptr<ShareableFileReference>()); |
| 325 } | 332 } |
| 326 | 333 |
| 327 void DeviceMediaAsyncFileUtil::OnSnapshotFileCreatedRunTask( | 334 void DeviceMediaAsyncFileUtil::OnSnapshotFileCreatedRunTask( |
| 328 FileSystemOperationContext* context, | 335 FileSystemOperationContext* context, |
| 329 const AsyncFileUtil::CreateSnapshotFileCallback& callback, | 336 const AsyncFileUtil::CreateSnapshotFileCallback& callback, |
| 330 const base::FilePath& device_file_path, | 337 const base::FilePath& device_file_path, |
| 331 base::FilePath* snapshot_file_path) { | 338 base::FilePath* snapshot_file_path) { |
| 332 DCHECK(IsOnIOThread(context)); | 339 DCHECK(IsOnIOThread(context)); |
| 333 if (!snapshot_file_path || snapshot_file_path->empty()) { | 340 if (!snapshot_file_path || snapshot_file_path->empty()) { |
| 334 OnCreateSnapshotFileError(callback, base::PLATFORM_FILE_ERROR_FAILED); | 341 OnCreateSnapshotFileError(callback, base::PLATFORM_FILE_ERROR_FAILED); |
| 335 return; | 342 return; |
| 336 } | 343 } |
| 337 MTPDeviceAsyncDelegate* delegate = GetMTPDeviceDelegate(context); | 344 MTPDeviceAsyncDelegate* delegate = GetMTPDeviceDelegate(context); |
| 338 if (!delegate) { | 345 if (!delegate) { |
| 339 OnCreateSnapshotFileError(callback, base::PLATFORM_FILE_ERROR_NOT_FOUND); | 346 OnCreateSnapshotFileError(callback, base::PLATFORM_FILE_ERROR_NOT_FOUND); |
| 340 return; | 347 return; |
| 341 } | 348 } |
| 342 delegate->CreateSnapshotFile( | 349 delegate->CreateSnapshotFile( |
| 343 device_file_path, | 350 device_file_path, |
| 344 *snapshot_file_path, | 351 *snapshot_file_path, |
| 345 base::Bind(&DeviceMediaAsyncFileUtil::OnDidCreateSnapshotFile, | 352 base::Bind(&DeviceMediaAsyncFileUtil::OnDidCreateSnapshotFile, |
| 346 weak_ptr_factory_.GetWeakPtr(), | 353 weak_ptr_factory_.GetWeakPtr(), |
| 347 callback), | 354 callback, |
| 355 make_scoped_refptr(context->task_runner())), |
| 348 base::Bind(&DeviceMediaAsyncFileUtil::OnCreateSnapshotFileError, | 356 base::Bind(&DeviceMediaAsyncFileUtil::OnCreateSnapshotFileError, |
| 349 weak_ptr_factory_.GetWeakPtr(), | 357 weak_ptr_factory_.GetWeakPtr(), |
| 350 callback)); | 358 callback)); |
| 351 } | 359 } |
| 352 | 360 |
| 353 } // namespace chrome | 361 } // namespace chrome |
| OLD | NEW |