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

Side by Side Diff: webkit/fileapi/syncable/canned_syncable_file_system.cc

Issue 11266031: Add Quota related method to CannedSyncableFileSystem for testing (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Created 8 years, 1 month 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 (c) 2012 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2012 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 "webkit/fileapi/syncable/canned_syncable_file_system.h" 5 #include "webkit/fileapi/syncable/canned_syncable_file_system.h"
6 6
7 #include "base/bind.h" 7 #include "base/bind.h"
8 #include "base/file_util.h" 8 #include "base/file_util.h"
9 #include "base/message_loop_proxy.h" 9 #include "base/message_loop_proxy.h"
10 #include "base/single_thread_task_runner.h" 10 #include "base/single_thread_task_runner.h"
(...skipping 71 matching lines...) Expand 10 before | Expand all | Expand 10 after
82 return; 82 return;
83 } 83 }
84 completion_callback.Run(error == base::PLATFORM_FILE_OK 84 completion_callback.Run(error == base::PLATFORM_FILE_OK
85 ? bytes_written_ : static_cast<int64>(error)); 85 ? bytes_written_ : static_cast<int64>(error));
86 } 86 }
87 87
88 private: 88 private:
89 int64 bytes_written_; 89 int64 bytes_written_;
90 }; 90 };
91 91
92 void DidGetUsageAndQuota(const quota::StatusCallback& callback,
93 int64* usage_out, int64* quota_out,
94 quota::QuotaStatusCode status,
95 int64 usage, int64 quota) {
96 *usage_out = usage;
97 *quota_out = quota;
98 callback.Run(status);
99 }
100
92 } // namespace 101 } // namespace
93 102
94 CannedSyncableFileSystem::CannedSyncableFileSystem( 103 CannedSyncableFileSystem::CannedSyncableFileSystem(
95 const GURL& origin, const std::string& service, 104 const GURL& origin, const std::string& service,
96 base::SingleThreadTaskRunner* io_task_runner) 105 base::SingleThreadTaskRunner* io_task_runner)
97 : service_name_(service), 106 : service_name_(service),
98 test_helper_(origin, kFileSystemTypeSyncable), 107 test_helper_(origin, kFileSystemTypeSyncable),
99 result_(base::PLATFORM_FILE_OK), 108 result_(base::PLATFORM_FILE_OK),
100 sync_status_(SYNC_STATUS_OK), 109 sync_status_(SYNC_STATUS_OK),
101 io_task_runner_(io_task_runner), 110 io_task_runner_(io_task_runner),
(...skipping 156 matching lines...) Expand 10 before | Expand all | Expand 10 after
258 EXPECT_TRUE(is_filesystem_set_up_); 267 EXPECT_TRUE(is_filesystem_set_up_);
259 return RunOnThread<PlatformFileError>( 268 return RunOnThread<PlatformFileError>(
260 io_task_runner_, 269 io_task_runner_,
261 FROM_HERE, 270 FROM_HERE,
262 base::Bind(&FileSystemContext::DeleteFileSystem, 271 base::Bind(&FileSystemContext::DeleteFileSystem,
263 file_system_context_, 272 file_system_context_,
264 test_helper_.origin(), 273 test_helper_.origin(),
265 test_helper_.type())); 274 test_helper_.type()));
266 } 275 }
267 276
277 quota::QuotaStatusCode CannedSyncableFileSystem::GetUsageAndQuota(
278 int64* usage, int64* quota) {
279 return RunOnThread<quota::QuotaStatusCode>(
280 io_task_runner_,
281 FROM_HERE,
282 base::Bind(&CannedSyncableFileSystem::DoGetUsageAndQuota,
283 base::Unretained(this), usage, quota));
284 }
285
268 FileSystemOperation* CannedSyncableFileSystem::NewOperation() { 286 FileSystemOperation* CannedSyncableFileSystem::NewOperation() {
269 return file_system_context_->CreateFileSystemOperation(URL(""), NULL); 287 return file_system_context_->CreateFileSystemOperation(URL(""), NULL);
270 } 288 }
271 289
272 void CannedSyncableFileSystem::DoCreateDirectory( 290 void CannedSyncableFileSystem::DoCreateDirectory(
273 const FileSystemURL& url, 291 const FileSystemURL& url,
274 const StatusCallback& callback) { 292 const StatusCallback& callback) {
275 EXPECT_TRUE(is_filesystem_opened_); 293 EXPECT_TRUE(is_filesystem_opened_);
276 NewOperation()->CreateDirectory( 294 NewOperation()->CreateDirectory(
277 url, false /* exclusive */, false /* recursive */, callback); 295 url, false /* exclusive */, false /* recursive */, callback);
(...skipping 52 matching lines...) Expand 10 before | Expand all | Expand 10 after
330 net::URLRequestContext* url_request_context, 348 net::URLRequestContext* url_request_context,
331 const FileSystemURL& url, const GURL& blob_url, 349 const FileSystemURL& url, const GURL& blob_url,
332 const WriteCallback& callback) { 350 const WriteCallback& callback) {
333 EXPECT_TRUE(is_filesystem_opened_); 351 EXPECT_TRUE(is_filesystem_opened_);
334 WriteHelper* helper = new WriteHelper; 352 WriteHelper* helper = new WriteHelper;
335 NewOperation()->Write(url_request_context, url, blob_url, 0, 353 NewOperation()->Write(url_request_context, url, blob_url, 0,
336 base::Bind(&WriteHelper::DidWrite, 354 base::Bind(&WriteHelper::DidWrite,
337 base::Owned(helper), callback)); 355 base::Owned(helper), callback));
338 } 356 }
339 357
358 void CannedSyncableFileSystem::DoGetUsageAndQuota(
359 int64* usage,
360 int64* quota,
361 const quota::StatusCallback& callback) {
362 quota_manager_->GetUsageAndQuota(
363 test_helper_.origin(),
364 test_helper_.storage_type(),
365 base::Bind(&DidGetUsageAndQuota, callback, usage, quota));
366 }
367
340 void CannedSyncableFileSystem::DidOpenFileSystem( 368 void CannedSyncableFileSystem::DidOpenFileSystem(
341 PlatformFileError result, const std::string& name, const GURL& root) { 369 PlatformFileError result, const std::string& name, const GURL& root) {
342 result_ = result; 370 result_ = result;
343 root_url_ = root; 371 root_url_ = root;
344 is_filesystem_opened_ = true; 372 is_filesystem_opened_ = true;
345 } 373 }
346 374
347 void CannedSyncableFileSystem::DidInitializeFileSystemContext( 375 void CannedSyncableFileSystem::DidInitializeFileSystemContext(
348 SyncStatusCode status) { 376 SyncStatusCode status) {
349 sync_status_ = status; 377 sync_status_ = status;
350 MessageLoop::current()->Quit(); 378 MessageLoop::current()->Quit();
351 } 379 }
352 380
353 } // namespace fileapi 381 } // namespace fileapi
OLDNEW
« no previous file with comments | « webkit/fileapi/syncable/canned_syncable_file_system.h ('k') | webkit/fileapi/syncable/syncable_file_system_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698