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
|
// Copyright 2013 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#ifndef CHROME_BROWSER_SYNC_FILE_SYSTEM_LOCAL_SYNCABLE_FILE_SYSTEM_OPERATION_H_
#define CHROME_BROWSER_SYNC_FILE_SYSTEM_LOCAL_SYNCABLE_FILE_SYSTEM_OPERATION_H_
#include <stdint.h>
#include <memory>
#include <vector>
#include "base/functional/callback.h"
#include "base/memory/weak_ptr.h"
#include "base/types/pass_key.h"
#include "storage/browser/file_system/file_system_operation.h"
#include "storage/browser/file_system/file_system_url.h"
namespace storage {
class FileSystemContext;
class FileSystemOperationContext;
} // namespace storage
namespace sync_file_system {
class SyncFileSystemBackend;
class SyncableFileOperationRunner;
// A wrapper class of FileSystemOperation for syncable file system.
class SyncableFileSystemOperation : public storage::FileSystemOperation {
public:
// Exposed for std::make_unique. Instances should be obtained from the factory
// method SyncFileSystemBackend::CreateFileSystemOperation().
SyncableFileSystemOperation(
storage::OperationType type,
const storage::FileSystemURL& url,
storage::FileSystemContext* file_system_context,
std::unique_ptr<storage::FileSystemOperationContext> operation_context,
base::PassKey<SyncFileSystemBackend>);
SyncableFileSystemOperation(const SyncableFileSystemOperation&) = delete;
SyncableFileSystemOperation& operator=(const SyncableFileSystemOperation&) =
delete;
~SyncableFileSystemOperation() override;
// storage::FileSystemOperation overrides.
void CreateFile(const storage::FileSystemURL& url,
bool exclusive,
StatusCallback callback) override;
void CreateDirectory(const storage::FileSystemURL& url,
bool exclusive,
bool recursive,
StatusCallback callback) override;
void Copy(const storage::FileSystemURL& src_url,
const storage::FileSystemURL& dest_url,
CopyOrMoveOptionSet options,
ErrorBehavior error_behavior,
std::unique_ptr<storage::CopyOrMoveHookDelegate>
copy_or_move_hook_delegate,
StatusCallback callback) override;
void Move(const storage::FileSystemURL& src_url,
const storage::FileSystemURL& dest_url,
CopyOrMoveOptionSet options,
ErrorBehavior error_behavior,
std::unique_ptr<storage::CopyOrMoveHookDelegate>
copy_or_move_hook_delegate,
StatusCallback callback) override;
void DirectoryExists(const storage::FileSystemURL& url,
StatusCallback callback) override;
void FileExists(const storage::FileSystemURL& url,
StatusCallback callback) override;
void GetMetadata(const storage::FileSystemURL& url,
GetMetadataFieldSet fields,
GetMetadataCallback callback) override;
void ReadDirectory(const storage::FileSystemURL& url,
const ReadDirectoryCallback& callback) override;
void Remove(const storage::FileSystemURL& url,
bool recursive,
StatusCallback callback) override;
void WriteBlob(const storage::FileSystemURL& url,
std::unique_ptr<storage::FileWriterDelegate> writer_delegate,
std::unique_ptr<storage::BlobReader> blob_reader,
const WriteCallback& callback) override;
void Write(const storage::FileSystemURL& url,
std::unique_ptr<storage::FileWriterDelegate> writer_delegate,
mojo::ScopedDataPipeConsumerHandle data_pipe,
const WriteCallback& callback) override;
void Truncate(const storage::FileSystemURL& url,
int64_t length,
StatusCallback callback) override;
void TouchFile(const storage::FileSystemURL& url,
const base::Time& last_access_time,
const base::Time& last_modified_time,
StatusCallback callback) override;
void OpenFile(const storage::FileSystemURL& url,
uint32_t file_flags,
OpenFileCallback callback) override;
void Cancel(StatusCallback cancel_callback) override;
void CreateSnapshotFile(const storage::FileSystemURL& path,
SnapshotFileCallback callback) override;
void CopyInForeignFile(const base::FilePath& src_local_disk_path,
const storage::FileSystemURL& dest_url,
StatusCallback callback) override;
void RemoveFile(const storage::FileSystemURL& url,
StatusCallback callback) override;
void RemoveDirectory(const storage::FileSystemURL& url,
StatusCallback callback) override;
void CopyFileLocal(const storage::FileSystemURL& src_url,
const storage::FileSystemURL& dest_url,
CopyOrMoveOptionSet options,
const CopyFileProgressCallback& progress_callback,
StatusCallback callback) override;
void MoveFileLocal(const storage::FileSystemURL& src_url,
const storage::FileSystemURL& dest_url,
CopyOrMoveOptionSet options,
StatusCallback callback) override;
base::File::Error SyncGetPlatformPath(const storage::FileSystemURL& url,
base::FilePath* platform_path) override;
private:
typedef SyncableFileSystemOperation self;
class QueueableTask;
// Only SyncFileSystemBackend can create a new operation directly.
friend class SyncFileSystemBackend;
void DidFinish(base::File::Error status);
void DidWrite(const WriteCallback& callback,
base::File::Error result,
int64_t bytes,
bool complete);
void OnCancelled();
const storage::FileSystemURL url_;
std::unique_ptr<storage::FileSystemOperation> impl_;
base::WeakPtr<SyncableFileOperationRunner> operation_runner_;
std::vector<storage::FileSystemURL> target_paths_;
StatusCallback completion_callback_;
base::WeakPtrFactory<SyncableFileSystemOperation> weak_factory_{this};
};
} // namespace sync_file_system
#endif // CHROME_BROWSER_SYNC_FILE_SYSTEM_LOCAL_SYNCABLE_FILE_SYSTEM_OPERATION_H_
|
