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

Side by Side Diff: chrome/browser/sync_file_system/local/canned_syncable_file_system.cc

Issue 147843007: [SyncFS] Disable quota management on tests (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: fix Created 6 years, 10 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 2013 The Chromium Authors. All rights reserved. 1 // Copyright 2013 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 "chrome/browser/sync_file_system/local/canned_syncable_file_system.h" 5 #include "chrome/browser/sync_file_system/local/canned_syncable_file_system.h"
6 6
7 #include <algorithm> 7 #include <algorithm>
8 #include <iterator> 8 #include <iterator>
9 9
10 #include "base/bind.h" 10 #include "base/bind.h"
(...skipping 204 matching lines...) Expand 10 before | Expand all | Expand 10 after
215 env_override_(env_override), 215 env_override_(env_override),
216 io_task_runner_(io_task_runner), 216 io_task_runner_(io_task_runner),
217 file_task_runner_(file_task_runner), 217 file_task_runner_(file_task_runner),
218 is_filesystem_set_up_(false), 218 is_filesystem_set_up_(false),
219 is_filesystem_opened_(false), 219 is_filesystem_opened_(false),
220 sync_status_observers_(new ObserverList) { 220 sync_status_observers_(new ObserverList) {
221 } 221 }
222 222
223 CannedSyncableFileSystem::~CannedSyncableFileSystem() {} 223 CannedSyncableFileSystem::~CannedSyncableFileSystem() {}
224 224
225 void CannedSyncableFileSystem::SetUp() { 225 void CannedSyncableFileSystem::SetUp(QuotaMode quota_mode) {
226 ASSERT_FALSE(is_filesystem_set_up_); 226 ASSERT_FALSE(is_filesystem_set_up_);
227 ASSERT_TRUE(data_dir_.CreateUniqueTempDir()); 227 ASSERT_TRUE(data_dir_.CreateUniqueTempDir());
228 228
229 scoped_refptr<quota::SpecialStoragePolicy> storage_policy = 229 scoped_refptr<quota::SpecialStoragePolicy> storage_policy =
230 new quota::MockSpecialStoragePolicy(); 230 new quota::MockSpecialStoragePolicy();
231 231
232 quota_manager_ = new QuotaManager(false /* is_incognito */, 232 if (quota_mode == QUOTA_ENABLED) {
233 data_dir_.path(), 233 quota_manager_ = new QuotaManager(false /* is_incognito */,
234 io_task_runner_.get(), 234 data_dir_.path(),
235 base::MessageLoopProxy::current().get(), 235 io_task_runner_.get(),
236 storage_policy.get()); 236 base::MessageLoopProxy::current().get(),
237 storage_policy.get());
238 }
237 239
238 std::vector<std::string> additional_allowed_schemes; 240 std::vector<std::string> additional_allowed_schemes;
239 additional_allowed_schemes.push_back(origin_.scheme()); 241 additional_allowed_schemes.push_back(origin_.scheme());
240 fileapi::FileSystemOptions options( 242 fileapi::FileSystemOptions options(
241 fileapi::FileSystemOptions::PROFILE_MODE_NORMAL, 243 fileapi::FileSystemOptions::PROFILE_MODE_NORMAL,
242 additional_allowed_schemes, 244 additional_allowed_schemes,
243 env_override_); 245 env_override_);
244 246
245 ScopedVector<fileapi::FileSystemBackend> additional_backends; 247 ScopedVector<fileapi::FileSystemBackend> additional_backends;
246 additional_backends.push_back(SyncFileSystemBackend::CreateForTesting()); 248 additional_backends.push_back(SyncFileSystemBackend::CreateForTesting());
247 249
248 file_system_context_ = new FileSystemContext( 250 file_system_context_ = new FileSystemContext(
249 io_task_runner_.get(), 251 io_task_runner_.get(),
250 file_task_runner_.get(), 252 file_task_runner_.get(),
251 fileapi::ExternalMountPoints::CreateRefCounted().get(), 253 fileapi::ExternalMountPoints::CreateRefCounted().get(),
252 storage_policy.get(), 254 storage_policy.get(),
253 quota_manager_->proxy(), 255 quota_manager_ ? quota_manager_->proxy() : NULL,
254 additional_backends.Pass(), 256 additional_backends.Pass(),
255 data_dir_.path(), options); 257 data_dir_.path(), options);
256 258
257 is_filesystem_set_up_ = true; 259 is_filesystem_set_up_ = true;
258 } 260 }
259 261
260 void CannedSyncableFileSystem::TearDown() { 262 void CannedSyncableFileSystem::TearDown() {
261 quota_manager_ = NULL; 263 quota_manager_ = NULL;
262 file_system_context_ = NULL; 264 file_system_context_ = NULL;
263 265
(...skipping 437 matching lines...) Expand 10 before | Expand all | Expand 10 after
701 base::Bind(&WriteHelper::DidWrite, 703 base::Bind(&WriteHelper::DidWrite,
702 base::Owned(helper), callback)); 704 base::Owned(helper), callback));
703 } 705 }
704 706
705 void CannedSyncableFileSystem::DoGetUsageAndQuota( 707 void CannedSyncableFileSystem::DoGetUsageAndQuota(
706 int64* usage, 708 int64* usage,
707 int64* quota, 709 int64* quota,
708 const quota::StatusCallback& callback) { 710 const quota::StatusCallback& callback) {
709 EXPECT_TRUE(io_task_runner_->RunsTasksOnCurrentThread()); 711 EXPECT_TRUE(io_task_runner_->RunsTasksOnCurrentThread());
710 EXPECT_TRUE(is_filesystem_opened_); 712 EXPECT_TRUE(is_filesystem_opened_);
713 DCHECK(quota_manager_);
711 quota_manager_->GetUsageAndQuota( 714 quota_manager_->GetUsageAndQuota(
712 origin_, storage_type(), 715 origin_, storage_type(),
713 base::Bind(&DidGetUsageAndQuota, callback, usage, quota)); 716 base::Bind(&DidGetUsageAndQuota, callback, usage, quota));
714 } 717 }
715 718
716 void CannedSyncableFileSystem::DidOpenFileSystem( 719 void CannedSyncableFileSystem::DidOpenFileSystem(
717 base::SingleThreadTaskRunner* original_task_runner, 720 base::SingleThreadTaskRunner* original_task_runner,
718 const GURL& root, 721 const GURL& root,
719 const std::string& name, 722 const std::string& name,
720 File::Error result) { 723 File::Error result) {
(...skipping 21 matching lines...) Expand all
742 sync_status_ = status; 745 sync_status_ = status;
743 base::MessageLoop::current()->Quit(); 746 base::MessageLoop::current()->Quit();
744 } 747 }
745 748
746 void CannedSyncableFileSystem::InitializeSyncStatusObserver() { 749 void CannedSyncableFileSystem::InitializeSyncStatusObserver() {
747 ASSERT_TRUE(io_task_runner_->RunsTasksOnCurrentThread()); 750 ASSERT_TRUE(io_task_runner_->RunsTasksOnCurrentThread());
748 backend()->sync_context()->sync_status()->AddObserver(this); 751 backend()->sync_context()->sync_status()->AddObserver(this);
749 } 752 }
750 753
751 } // namespace sync_file_system 754 } // namespace sync_file_system
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698