media_file_system_backend.cc revision bb1529ce867d8845a77ec7cdf3e3003ef1771a40 
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
3// found in the LICENSE file.
4
5#include "chrome/browser/media_galleries/fileapi/media_file_system_backend.h"
6
7#include <string>
8
9#include "base/bind.h"
10#include "base/files/file_path.h"
11#include "base/logging.h"
12#include "base/message_loop/message_loop_proxy.h"
13#include "base/platform_file.h"
14#include "base/sequenced_task_runner.h"
15#include "base/threading/sequenced_worker_pool.h"
16#include "chrome/browser/media_galleries/fileapi/device_media_async_file_util.h"
17#include "chrome/browser/media_galleries/fileapi/media_file_validator_factory.h"
18#include "chrome/browser/media_galleries/fileapi/media_path_filter.h"
19#include "chrome/browser/media_galleries/fileapi/native_media_file_util.h"
20#include "content/public/browser/browser_thread.h"
21#include "webkit/browser/blob/local_file_stream_reader.h"
22#include "webkit/browser/fileapi/async_file_util_adapter.h"
23#include "webkit/browser/fileapi/copy_or_move_file_validator.h"
24#include "webkit/browser/fileapi/file_system_context.h"
25#include "webkit/browser/fileapi/file_system_file_stream_reader.h"
26#include "webkit/browser/fileapi/file_system_operation_context.h"
27#include "webkit/browser/fileapi/file_system_operation_impl.h"
28#include "webkit/browser/fileapi/isolated_context.h"
29#include "webkit/browser/fileapi/isolated_file_util.h"
30#include "webkit/browser/fileapi/local_file_stream_writer.h"
31#include "webkit/browser/fileapi/native_file_util.h"
32#include "webkit/common/fileapi/file_system_types.h"
33#include "webkit/common/fileapi/file_system_util.h"
34
35#if defined(OS_WIN) || defined(OS_MACOSX)
36#include "chrome/browser/media_galleries/fileapi/itunes_file_util.h"
37#include "chrome/browser/media_galleries/fileapi/picasa/picasa_file_util.h"
38#endif  // defined(OS_WIN) || defined(OS_MACOSX)
39
40using fileapi::FileSystemContext;
41using fileapi::FileSystemURL;
42
43namespace chrome {
44
45const char MediaFileSystemBackend::kMediaTaskRunnerName[] =
46    "media-task-runner";
47
48MediaFileSystemBackend::MediaFileSystemBackend(
49    const base::FilePath& profile_path,
50    base::SequencedTaskRunner* media_task_runner)
51    : profile_path_(profile_path),
52      media_task_runner_(media_task_runner),
53      media_path_filter_(new MediaPathFilter),
54      media_copy_or_move_file_validator_factory_(new MediaFileValidatorFactory),
55      native_media_file_util_(
56          new NativeMediaFileUtil(media_path_filter_.get())),
57      device_media_async_file_util_(
58          DeviceMediaAsyncFileUtil::Create(profile_path_))
59#if defined(OS_WIN) || defined(OS_MACOSX)
60      ,
61      picasa_file_util_(new picasa::PicasaFileUtil(media_path_filter_.get())),
62      itunes_file_util_(new itunes::ItunesFileUtil(media_path_filter_.get()))
63#endif  // defined(OS_WIN) || defined(OS_MACOSX)
64{
65}
66
67MediaFileSystemBackend::~MediaFileSystemBackend() {
68}
69
70// static
71bool MediaFileSystemBackend::CurrentlyOnMediaTaskRunnerThread() {
72  base::SequencedWorkerPool* pool = content::BrowserThread::GetBlockingPool();
73  base::SequencedWorkerPool::SequenceToken media_sequence_token =
74      pool->GetNamedSequenceToken(kMediaTaskRunnerName);
75  return pool->IsRunningSequenceOnCurrentThread(media_sequence_token);
76}
77
78// static
79scoped_refptr<base::SequencedTaskRunner>
80MediaFileSystemBackend::MediaTaskRunner() {
81  base::SequencedWorkerPool* pool = content::BrowserThread::GetBlockingPool();
82  base::SequencedWorkerPool::SequenceToken media_sequence_token =
83      pool->GetNamedSequenceToken(kMediaTaskRunnerName);
84  return pool->GetSequencedTaskRunner(media_sequence_token);
85}
86
87bool MediaFileSystemBackend::CanHandleType(
88    fileapi::FileSystemType type) const {
89  switch (type) {
90    case fileapi::kFileSystemTypeNativeMedia:
91    case fileapi::kFileSystemTypeDeviceMedia:
92#if defined(OS_WIN) || defined(OS_MACOSX)
93    case fileapi::kFileSystemTypePicasa:
94    case fileapi::kFileSystemTypeItunes:
95#endif  // defined(OS_WIN) || defined(OS_MACOSX)
96      return true;
97    default:
98      return false;
99  }
100}
101
102void MediaFileSystemBackend::Initialize(fileapi::FileSystemContext* context) {
103}
104
105void MediaFileSystemBackend::OpenFileSystem(
106    const GURL& origin_url,
107    fileapi::FileSystemType type,
108    fileapi::OpenFileSystemMode mode,
109    const OpenFileSystemCallback& callback) {
110  // We never allow opening a new isolated FileSystem via usual OpenFileSystem.
111  base::MessageLoopProxy::current()->PostTask(
112      FROM_HERE,
113      base::Bind(callback,
114                 GetFileSystemRootURI(origin_url, type),
115                 GetFileSystemName(origin_url, type),
116                 base::PLATFORM_FILE_ERROR_SECURITY));
117}
118
119fileapi::FileSystemFileUtil* MediaFileSystemBackend::GetFileUtil(
120    fileapi::FileSystemType type) {
121  NOTREACHED();
122  return NULL;
123}
124
125fileapi::AsyncFileUtil* MediaFileSystemBackend::GetAsyncFileUtil(
126    fileapi::FileSystemType type) {
127  switch (type) {
128    case fileapi::kFileSystemTypeNativeMedia:
129      return native_media_file_util_.get();
130    case fileapi::kFileSystemTypeDeviceMedia:
131      return device_media_async_file_util_.get();
132#if defined(OS_WIN) || defined(OS_MACOSX)
133    case fileapi::kFileSystemTypeItunes:
134      return itunes_file_util_.get();
135    case fileapi::kFileSystemTypePicasa:
136      return picasa_file_util_.get();
137#endif  // defined(OS_WIN) || defined(OS_MACOSX)
138    default:
139      NOTREACHED();
140  }
141  return NULL;
142}
143
144fileapi::CopyOrMoveFileValidatorFactory*
145MediaFileSystemBackend::GetCopyOrMoveFileValidatorFactory(
146    fileapi::FileSystemType type, base::PlatformFileError* error_code) {
147  DCHECK(error_code);
148  *error_code = base::PLATFORM_FILE_OK;
149  switch (type) {
150    case fileapi::kFileSystemTypeNativeMedia:
151    case fileapi::kFileSystemTypeDeviceMedia:
152    case fileapi::kFileSystemTypeItunes:
153      if (!media_copy_or_move_file_validator_factory_) {
154        *error_code = base::PLATFORM_FILE_ERROR_SECURITY;
155        return NULL;
156      }
157      return media_copy_or_move_file_validator_factory_.get();
158    default:
159      NOTREACHED();
160  }
161  return NULL;
162}
163
164fileapi::FileSystemOperation*
165MediaFileSystemBackend::CreateFileSystemOperation(
166    const FileSystemURL& url,
167    FileSystemContext* context,
168    base::PlatformFileError* error_code) const {
169  scoped_ptr<fileapi::FileSystemOperationContext> operation_context(
170      new fileapi::FileSystemOperationContext(
171          context, media_task_runner_.get()));
172  return new fileapi::FileSystemOperationImpl(url, context,
173                                              operation_context.Pass());
174}
175
176scoped_ptr<webkit_blob::FileStreamReader>
177MediaFileSystemBackend::CreateFileStreamReader(
178    const FileSystemURL& url,
179    int64 offset,
180    const base::Time& expected_modification_time,
181    FileSystemContext* context) const {
182  return scoped_ptr<webkit_blob::FileStreamReader>(
183      new webkit_blob::LocalFileStreamReader(
184          context->default_file_task_runner(),
185          url.path(), offset, expected_modification_time));
186}
187
188scoped_ptr<fileapi::FileStreamWriter>
189MediaFileSystemBackend::CreateFileStreamWriter(
190    const FileSystemURL& url,
191    int64 offset,
192    FileSystemContext* context) const {
193  return scoped_ptr<fileapi::FileStreamWriter>(
194      new fileapi::LocalFileStreamWriter(
195          context->default_file_task_runner(),
196          url.path(), offset));
197}
198
199fileapi::FileSystemQuotaUtil*
200MediaFileSystemBackend::GetQuotaUtil() {
201  // No quota support.
202  return NULL;
203}
204
205}  // namespace chrome
206