Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(79)

Side by Side Diff: content/public/test/async_file_test_helper.cc

Issue 442383002: Move storage-related files from webkit/ to new top-level directory storage/ (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: . Created 6 years, 4 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
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 "base/bind.h" 5 #include "base/bind.h"
6 #include "base/file_util.h" 6 #include "base/file_util.h"
7 #include "base/files/scoped_temp_dir.h" 7 #include "base/files/scoped_temp_dir.h"
8 #include "base/run_loop.h" 8 #include "base/run_loop.h"
9 #include "content/public/test/async_file_test_helper.h" 9 #include "content/public/test/async_file_test_helper.h"
10 #include "testing/gtest/include/gtest/gtest.h" 10 #include "testing/gtest/include/gtest/gtest.h"
11 #include "webkit/browser/fileapi/file_system_backend.h" 11 #include "storage/browser/fileapi/file_system_backend.h"
12 #include "webkit/browser/fileapi/file_system_context.h" 12 #include "storage/browser/fileapi/file_system_context.h"
13 #include "webkit/browser/fileapi/file_system_operation_runner.h" 13 #include "storage/browser/fileapi/file_system_operation_runner.h"
14 #include "webkit/browser/fileapi/file_system_url.h" 14 #include "storage/browser/fileapi/file_system_url.h"
15 #include "webkit/browser/quota/quota_manager.h" 15 #include "storage/browser/quota/quota_manager.h"
16 #include "webkit/common/fileapi/file_system_util.h" 16 #include "storage/common/fileapi/file_system_util.h"
17 17
18 namespace content { 18 namespace content {
19 19
20 typedef fileapi::FileSystemOperation::FileEntryList FileEntryList; 20 typedef storage::FileSystemOperation::FileEntryList FileEntryList;
21 21
22 namespace { 22 namespace {
23 23
24 void AssignAndQuit(base::RunLoop* run_loop, 24 void AssignAndQuit(base::RunLoop* run_loop,
25 base::File::Error* result_out, 25 base::File::Error* result_out,
26 base::File::Error result) { 26 base::File::Error result) {
27 *result_out = result; 27 *result_out = result;
28 run_loop->Quit(); 28 run_loop->Quit();
29 } 29 }
30 30
(...skipping 14 matching lines...) Expand all
45 run_loop->Quit(); 45 run_loop->Quit();
46 } 46 }
47 47
48 void CreateSnapshotFileCallback( 48 void CreateSnapshotFileCallback(
49 base::RunLoop* run_loop, 49 base::RunLoop* run_loop,
50 base::File::Error* result_out, 50 base::File::Error* result_out,
51 base::FilePath* platform_path_out, 51 base::FilePath* platform_path_out,
52 base::File::Error result, 52 base::File::Error result,
53 const base::File::Info& file_info, 53 const base::File::Info& file_info,
54 const base::FilePath& platform_path, 54 const base::FilePath& platform_path,
55 const scoped_refptr<webkit_blob::ShareableFileReference>& file_ref) { 55 const scoped_refptr<storage::ShareableFileReference>& file_ref) {
56 DCHECK(!file_ref.get()); 56 DCHECK(!file_ref.get());
57 *result_out = result; 57 *result_out = result;
58 if (platform_path_out) 58 if (platform_path_out)
59 *platform_path_out = platform_path; 59 *platform_path_out = platform_path;
60 run_loop->Quit(); 60 run_loop->Quit();
61 } 61 }
62 62
63 void ReadDirectoryCallback(base::RunLoop* run_loop, 63 void ReadDirectoryCallback(base::RunLoop* run_loop,
64 base::File::Error* result_out, 64 base::File::Error* result_out,
65 FileEntryList* entries_out, 65 FileEntryList* entries_out,
(...skipping 18 matching lines...) Expand all
84 *usage_out = usage; 84 *usage_out = usage;
85 if (quota_out) 85 if (quota_out)
86 *quota_out = quota; 86 *quota_out = quota;
87 } 87 }
88 88
89 } // namespace 89 } // namespace
90 90
91 const int64 AsyncFileTestHelper::kDontCheckSize = -1; 91 const int64 AsyncFileTestHelper::kDontCheckSize = -1;
92 92
93 base::File::Error AsyncFileTestHelper::Copy( 93 base::File::Error AsyncFileTestHelper::Copy(
94 fileapi::FileSystemContext* context, 94 storage::FileSystemContext* context,
95 const fileapi::FileSystemURL& src, 95 const storage::FileSystemURL& src,
96 const fileapi::FileSystemURL& dest) { 96 const storage::FileSystemURL& dest) {
97 return CopyWithProgress(context, src, dest, CopyProgressCallback()); 97 return CopyWithProgress(context, src, dest, CopyProgressCallback());
98 } 98 }
99 99
100 base::File::Error AsyncFileTestHelper::CopyWithProgress( 100 base::File::Error AsyncFileTestHelper::CopyWithProgress(
101 fileapi::FileSystemContext* context, 101 storage::FileSystemContext* context,
102 const fileapi::FileSystemURL& src, 102 const storage::FileSystemURL& src,
103 const fileapi::FileSystemURL& dest, 103 const storage::FileSystemURL& dest,
104 const CopyProgressCallback& progress_callback) { 104 const CopyProgressCallback& progress_callback) {
105 base::File::Error result = base::File::FILE_ERROR_FAILED; 105 base::File::Error result = base::File::FILE_ERROR_FAILED;
106 base::RunLoop run_loop; 106 base::RunLoop run_loop;
107 context->operation_runner()->Copy( 107 context->operation_runner()->Copy(src,
108 src, dest, fileapi::FileSystemOperation::OPTION_NONE, progress_callback, 108 dest,
109 AssignAndQuitCallback(&run_loop, &result)); 109 storage::FileSystemOperation::OPTION_NONE,
110 progress_callback,
111 AssignAndQuitCallback(&run_loop, &result));
110 run_loop.Run(); 112 run_loop.Run();
111 return result; 113 return result;
112 } 114 }
113 115
114 base::File::Error AsyncFileTestHelper::Move( 116 base::File::Error AsyncFileTestHelper::Move(
115 fileapi::FileSystemContext* context, 117 storage::FileSystemContext* context,
116 const fileapi::FileSystemURL& src, 118 const storage::FileSystemURL& src,
117 const fileapi::FileSystemURL& dest) { 119 const storage::FileSystemURL& dest) {
118 base::File::Error result = base::File::FILE_ERROR_FAILED; 120 base::File::Error result = base::File::FILE_ERROR_FAILED;
119 base::RunLoop run_loop; 121 base::RunLoop run_loop;
120 context->operation_runner()->Move( 122 context->operation_runner()->Move(src,
121 src, dest, fileapi::FileSystemOperation::OPTION_NONE, 123 dest,
122 AssignAndQuitCallback(&run_loop, &result)); 124 storage::FileSystemOperation::OPTION_NONE,
125 AssignAndQuitCallback(&run_loop, &result));
123 run_loop.Run(); 126 run_loop.Run();
124 return result; 127 return result;
125 } 128 }
126 129
127 base::File::Error AsyncFileTestHelper::Remove( 130 base::File::Error AsyncFileTestHelper::Remove(
128 fileapi::FileSystemContext* context, 131 storage::FileSystemContext* context,
129 const fileapi::FileSystemURL& url, 132 const storage::FileSystemURL& url,
130 bool recursive) { 133 bool recursive) {
131 base::File::Error result = base::File::FILE_ERROR_FAILED; 134 base::File::Error result = base::File::FILE_ERROR_FAILED;
132 base::RunLoop run_loop; 135 base::RunLoop run_loop;
133 context->operation_runner()->Remove( 136 context->operation_runner()->Remove(
134 url, recursive, AssignAndQuitCallback(&run_loop, &result)); 137 url, recursive, AssignAndQuitCallback(&run_loop, &result));
135 run_loop.Run(); 138 run_loop.Run();
136 return result; 139 return result;
137 } 140 }
138 141
139 base::File::Error AsyncFileTestHelper::ReadDirectory( 142 base::File::Error AsyncFileTestHelper::ReadDirectory(
140 fileapi::FileSystemContext* context, 143 storage::FileSystemContext* context,
141 const fileapi::FileSystemURL& url, 144 const storage::FileSystemURL& url,
142 FileEntryList* entries) { 145 FileEntryList* entries) {
143 base::File::Error result = base::File::FILE_ERROR_FAILED; 146 base::File::Error result = base::File::FILE_ERROR_FAILED;
144 DCHECK(entries); 147 DCHECK(entries);
145 entries->clear(); 148 entries->clear();
146 base::RunLoop run_loop; 149 base::RunLoop run_loop;
147 context->operation_runner()->ReadDirectory( 150 context->operation_runner()->ReadDirectory(
148 url, base::Bind(&ReadDirectoryCallback, &run_loop, &result, entries)); 151 url, base::Bind(&ReadDirectoryCallback, &run_loop, &result, entries));
149 run_loop.Run(); 152 run_loop.Run();
150 return result; 153 return result;
151 } 154 }
152 155
153 base::File::Error AsyncFileTestHelper::CreateDirectory( 156 base::File::Error AsyncFileTestHelper::CreateDirectory(
154 fileapi::FileSystemContext* context, 157 storage::FileSystemContext* context,
155 const fileapi::FileSystemURL& url) { 158 const storage::FileSystemURL& url) {
156 base::File::Error result = base::File::FILE_ERROR_FAILED; 159 base::File::Error result = base::File::FILE_ERROR_FAILED;
157 base::RunLoop run_loop; 160 base::RunLoop run_loop;
158 context->operation_runner()->CreateDirectory( 161 context->operation_runner()->CreateDirectory(
159 url, 162 url,
160 false /* exclusive */, 163 false /* exclusive */,
161 false /* recursive */, 164 false /* recursive */,
162 AssignAndQuitCallback(&run_loop, &result)); 165 AssignAndQuitCallback(&run_loop, &result));
163 run_loop.Run(); 166 run_loop.Run();
164 return result; 167 return result;
165 } 168 }
166 169
167 base::File::Error AsyncFileTestHelper::CreateFile( 170 base::File::Error AsyncFileTestHelper::CreateFile(
168 fileapi::FileSystemContext* context, 171 storage::FileSystemContext* context,
169 const fileapi::FileSystemURL& url) { 172 const storage::FileSystemURL& url) {
170 base::File::Error result = base::File::FILE_ERROR_FAILED; 173 base::File::Error result = base::File::FILE_ERROR_FAILED;
171 base::RunLoop run_loop; 174 base::RunLoop run_loop;
172 context->operation_runner()->CreateFile( 175 context->operation_runner()->CreateFile(
173 url, false /* exclusive */, 176 url, false /* exclusive */,
174 AssignAndQuitCallback(&run_loop, &result)); 177 AssignAndQuitCallback(&run_loop, &result));
175 run_loop.Run(); 178 run_loop.Run();
176 return result; 179 return result;
177 } 180 }
178 181
179 base::File::Error AsyncFileTestHelper::CreateFileWithData( 182 base::File::Error AsyncFileTestHelper::CreateFileWithData(
180 fileapi::FileSystemContext* context, 183 storage::FileSystemContext* context,
181 const fileapi::FileSystemURL& url, 184 const storage::FileSystemURL& url,
182 const char* buf, 185 const char* buf,
183 int buf_size) { 186 int buf_size) {
184 base::ScopedTempDir dir; 187 base::ScopedTempDir dir;
185 if (!dir.CreateUniqueTempDir()) 188 if (!dir.CreateUniqueTempDir())
186 return base::File::FILE_ERROR_FAILED; 189 return base::File::FILE_ERROR_FAILED;
187 base::FilePath local_path = dir.path().AppendASCII("tmp"); 190 base::FilePath local_path = dir.path().AppendASCII("tmp");
188 if (buf_size != base::WriteFile(local_path, buf, buf_size)) 191 if (buf_size != base::WriteFile(local_path, buf, buf_size))
189 return base::File::FILE_ERROR_FAILED; 192 return base::File::FILE_ERROR_FAILED;
190 base::File::Error result = base::File::FILE_ERROR_FAILED; 193 base::File::Error result = base::File::FILE_ERROR_FAILED;
191 base::RunLoop run_loop; 194 base::RunLoop run_loop;
192 context->operation_runner()->CopyInForeignFile( 195 context->operation_runner()->CopyInForeignFile(
193 local_path, url, AssignAndQuitCallback(&run_loop, &result)); 196 local_path, url, AssignAndQuitCallback(&run_loop, &result));
194 run_loop.Run(); 197 run_loop.Run();
195 return result; 198 return result;
196 } 199 }
197 200
198 base::File::Error AsyncFileTestHelper::TruncateFile( 201 base::File::Error AsyncFileTestHelper::TruncateFile(
199 fileapi::FileSystemContext* context, 202 storage::FileSystemContext* context,
200 const fileapi::FileSystemURL& url, 203 const storage::FileSystemURL& url,
201 size_t size) { 204 size_t size) {
202 base::RunLoop run_loop; 205 base::RunLoop run_loop;
203 base::File::Error result = base::File::FILE_ERROR_FAILED; 206 base::File::Error result = base::File::FILE_ERROR_FAILED;
204 context->operation_runner()->Truncate( 207 context->operation_runner()->Truncate(
205 url, size, AssignAndQuitCallback(&run_loop, &result)); 208 url, size, AssignAndQuitCallback(&run_loop, &result));
206 run_loop.Run(); 209 run_loop.Run();
207 return result; 210 return result;
208 } 211 }
209 212
210 base::File::Error AsyncFileTestHelper::GetMetadata( 213 base::File::Error AsyncFileTestHelper::GetMetadata(
211 fileapi::FileSystemContext* context, 214 storage::FileSystemContext* context,
212 const fileapi::FileSystemURL& url, 215 const storage::FileSystemURL& url,
213 base::File::Info* file_info) { 216 base::File::Info* file_info) {
214 base::File::Error result = base::File::FILE_ERROR_FAILED; 217 base::File::Error result = base::File::FILE_ERROR_FAILED;
215 base::RunLoop run_loop; 218 base::RunLoop run_loop;
216 context->operation_runner()->GetMetadata( 219 context->operation_runner()->GetMetadata(
217 url, base::Bind(&GetMetadataCallback, &run_loop, &result, 220 url, base::Bind(&GetMetadataCallback, &run_loop, &result,
218 file_info)); 221 file_info));
219 run_loop.Run(); 222 run_loop.Run();
220 return result; 223 return result;
221 } 224 }
222 225
223 base::File::Error AsyncFileTestHelper::GetPlatformPath( 226 base::File::Error AsyncFileTestHelper::GetPlatformPath(
224 fileapi::FileSystemContext* context, 227 storage::FileSystemContext* context,
225 const fileapi::FileSystemURL& url, 228 const storage::FileSystemURL& url,
226 base::FilePath* platform_path) { 229 base::FilePath* platform_path) {
227 base::File::Error result = base::File::FILE_ERROR_FAILED; 230 base::File::Error result = base::File::FILE_ERROR_FAILED;
228 base::RunLoop run_loop; 231 base::RunLoop run_loop;
229 context->operation_runner()->CreateSnapshotFile( 232 context->operation_runner()->CreateSnapshotFile(
230 url, base::Bind(&CreateSnapshotFileCallback, &run_loop, &result, 233 url, base::Bind(&CreateSnapshotFileCallback, &run_loop, &result,
231 platform_path)); 234 platform_path));
232 run_loop.Run(); 235 run_loop.Run();
233 return result; 236 return result;
234 } 237 }
235 238
236 bool AsyncFileTestHelper::FileExists( 239 bool AsyncFileTestHelper::FileExists(storage::FileSystemContext* context,
237 fileapi::FileSystemContext* context, 240 const storage::FileSystemURL& url,
238 const fileapi::FileSystemURL& url, 241 int64 expected_size) {
239 int64 expected_size) {
240 base::File::Info file_info; 242 base::File::Info file_info;
241 base::File::Error result = GetMetadata(context, url, &file_info); 243 base::File::Error result = GetMetadata(context, url, &file_info);
242 if (result != base::File::FILE_OK || file_info.is_directory) 244 if (result != base::File::FILE_OK || file_info.is_directory)
243 return false; 245 return false;
244 return expected_size == kDontCheckSize || file_info.size == expected_size; 246 return expected_size == kDontCheckSize || file_info.size == expected_size;
245 } 247 }
246 248
247 bool AsyncFileTestHelper::DirectoryExists( 249 bool AsyncFileTestHelper::DirectoryExists(storage::FileSystemContext* context,
248 fileapi::FileSystemContext* context, 250 const storage::FileSystemURL& url) {
249 const fileapi::FileSystemURL& url) {
250 base::File::Info file_info; 251 base::File::Info file_info;
251 base::File::Error result = GetMetadata(context, url, &file_info); 252 base::File::Error result = GetMetadata(context, url, &file_info);
252 return (result == base::File::FILE_OK) && file_info.is_directory; 253 return (result == base::File::FILE_OK) && file_info.is_directory;
253 } 254 }
254 255
255 quota::QuotaStatusCode AsyncFileTestHelper::GetUsageAndQuota( 256 quota::QuotaStatusCode AsyncFileTestHelper::GetUsageAndQuota(
256 quota::QuotaManager* quota_manager, 257 quota::QuotaManager* quota_manager,
257 const GURL& origin, 258 const GURL& origin,
258 fileapi::FileSystemType type, 259 storage::FileSystemType type,
259 int64* usage, 260 int64* usage,
260 int64* quota) { 261 int64* quota) {
261 quota::QuotaStatusCode status = quota::kQuotaStatusUnknown; 262 quota::QuotaStatusCode status = quota::kQuotaStatusUnknown;
262 quota_manager->GetUsageAndQuota( 263 quota_manager->GetUsageAndQuota(
263 origin, 264 origin,
264 FileSystemTypeToQuotaStorageType(type), 265 FileSystemTypeToQuotaStorageType(type),
265 base::Bind(&DidGetUsageAndQuota, &status, usage, quota)); 266 base::Bind(&DidGetUsageAndQuota, &status, usage, quota));
266 base::RunLoop().RunUntilIdle(); 267 base::RunLoop().RunUntilIdle();
267 return status; 268 return status;
268 } 269 }
269 270
270 } // namespace fileapi 271 } // namespace storage
OLDNEW
« no previous file with comments | « content/public/test/async_file_test_helper.h ('k') | content/public/test/mock_blob_url_request_context.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698