1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
|
// Copyright (c) 2013 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.
#ifndef CHROME_BROWSER_MEDIA_GALLERIES_FILEAPI_DEVICE_MEDIA_ASYNC_FILE_UTIL_H_
#define CHROME_BROWSER_MEDIA_GALLERIES_FILEAPI_DEVICE_MEDIA_ASYNC_FILE_UTIL_H_
#include "base/files/file.h"
#include "base/files/file_path.h"
#include "base/memory/ref_counted.h"
#include "base/memory/scoped_ptr.h"
#include "base/memory/weak_ptr.h"
#include "storage/browser/fileapi/async_file_util.h"
#include "storage/common/blob/shareable_file_reference.h"
namespace storage {
class FileSystemOperationContext;
class FileSystemURL;
}
namespace storage {
class FileStreamReader;
}
enum MediaFileValidationType {
NO_MEDIA_FILE_VALIDATION,
APPLY_MEDIA_FILE_VALIDATION,
};
class DeviceMediaAsyncFileUtil : public storage::AsyncFileUtil {
public:
~DeviceMediaAsyncFileUtil() override;
// Returns an instance of DeviceMediaAsyncFileUtil.
static scoped_ptr<DeviceMediaAsyncFileUtil> Create(
const base::FilePath& profile_path,
MediaFileValidationType validation_type);
bool SupportsStreaming(const storage::FileSystemURL& url);
// AsyncFileUtil overrides.
void CreateOrOpen(scoped_ptr<storage::FileSystemOperationContext> context,
const storage::FileSystemURL& url,
int file_flags,
const CreateOrOpenCallback& callback) override;
void EnsureFileExists(scoped_ptr<storage::FileSystemOperationContext> context,
const storage::FileSystemURL& url,
const EnsureFileExistsCallback& callback) override;
void CreateDirectory(scoped_ptr<storage::FileSystemOperationContext> context,
const storage::FileSystemURL& url,
bool exclusive,
bool recursive,
const StatusCallback& callback) override;
void GetFileInfo(scoped_ptr<storage::FileSystemOperationContext> context,
const storage::FileSystemURL& url,
const GetFileInfoCallback& callback) override;
void ReadDirectory(scoped_ptr<storage::FileSystemOperationContext> context,
const storage::FileSystemURL& url,
const ReadDirectoryCallback& callback) override;
void Touch(scoped_ptr<storage::FileSystemOperationContext> context,
const storage::FileSystemURL& url,
const base::Time& last_access_time,
const base::Time& last_modified_time,
const StatusCallback& callback) override;
void Truncate(scoped_ptr<storage::FileSystemOperationContext> context,
const storage::FileSystemURL& url,
int64 length,
const StatusCallback& callback) override;
void CopyFileLocal(scoped_ptr<storage::FileSystemOperationContext> context,
const storage::FileSystemURL& src_url,
const storage::FileSystemURL& dest_url,
CopyOrMoveOption option,
const CopyFileProgressCallback& progress_callback,
const StatusCallback& callback) override;
void MoveFileLocal(scoped_ptr<storage::FileSystemOperationContext> context,
const storage::FileSystemURL& src_url,
const storage::FileSystemURL& dest_url,
CopyOrMoveOption option,
const StatusCallback& callback) override;
void CopyInForeignFile(
scoped_ptr<storage::FileSystemOperationContext> context,
const base::FilePath& src_file_path,
const storage::FileSystemURL& dest_url,
const StatusCallback& callback) override;
void DeleteFile(scoped_ptr<storage::FileSystemOperationContext> context,
const storage::FileSystemURL& url,
const StatusCallback& callback) override;
void DeleteDirectory(scoped_ptr<storage::FileSystemOperationContext> context,
const storage::FileSystemURL& url,
const StatusCallback& callback) override;
void DeleteRecursively(
scoped_ptr<storage::FileSystemOperationContext> context,
const storage::FileSystemURL& url,
const StatusCallback& callback) override;
void CreateSnapshotFile(
scoped_ptr<storage::FileSystemOperationContext> context,
const storage::FileSystemURL& url,
const CreateSnapshotFileCallback& callback) override;
// This method is called when existing Blobs are read.
// |expected_modification_time| indicates the expected snapshot state of the
// underlying storage. The returned FileStreamReader must return an error
// when the state of the underlying storage changes. Any errors associated
// with reading this file are returned by the FileStreamReader itself.
virtual scoped_ptr<storage::FileStreamReader> GetFileStreamReader(
const storage::FileSystemURL& url,
int64 offset,
const base::Time& expected_modification_time,
storage::FileSystemContext* context);
private:
class MediaPathFilterWrapper;
// Use Create() to get an instance of DeviceMediaAsyncFileUtil.
DeviceMediaAsyncFileUtil(const base::FilePath& profile_path,
MediaFileValidationType validation_type);
// Called when GetFileInfo method call succeeds. |file_info| contains the
// file details of the requested url. |callback| is invoked to complete the
// GetFileInfo request.
void OnDidGetFileInfo(
base::SequencedTaskRunner* task_runner,
const base::FilePath& path,
const GetFileInfoCallback& callback,
const base::File::Info& file_info);
// Called when ReadDirectory method call succeeds. |callback| is invoked to
// complete the ReadDirectory request.
//
// If the contents of the given directory are reported in one batch, then
// |file_list| will have the list of all files/directories in the given
// directory and |has_more| will be false.
//
// If the contents of the given directory are reported in multiple chunks,
// |file_list| will have only a subset of all contents (the subsets reported
// in any two calls are disjoint), and |has_more| will be true, except for
// the last chunk.
void OnDidReadDirectory(
base::SequencedTaskRunner* task_runner,
const ReadDirectoryCallback& callback,
const EntryList& file_list,
bool has_more);
bool validate_media_files() const;
// Profile path.
const base::FilePath profile_path_;
scoped_refptr<MediaPathFilterWrapper> media_path_filter_wrapper_;
// For callbacks that may run after destruction.
base::WeakPtrFactory<DeviceMediaAsyncFileUtil> weak_ptr_factory_;
DISALLOW_COPY_AND_ASSIGN(DeviceMediaAsyncFileUtil);
};
#endif // CHROME_BROWSER_MEDIA_GALLERIES_FILEAPI_DEVICE_MEDIA_ASYNC_FILE_UTIL_H_
|
