| OLD | NEW |
| 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 "storage/browser/fileapi/quota/quota_backend_impl.h" | 5 #include "storage/browser/fileapi/quota/quota_backend_impl.h" |
| 6 | 6 |
| 7 #include <stdint.h> | 7 #include <stdint.h> |
| 8 | 8 |
| 9 #include <memory> | 9 #include <memory> |
| 10 #include <string> | 10 #include <string> |
| (...skipping 30 matching lines...) Expand all Loading... |
| 41 *error_out = error; | 41 *error_out = error; |
| 42 *delta_out = delta; | 42 *delta_out = delta; |
| 43 return accepted; | 43 return accepted; |
| 44 } | 44 } |
| 45 | 45 |
| 46 class MockQuotaManagerProxy : public storage::QuotaManagerProxy { | 46 class MockQuotaManagerProxy : public storage::QuotaManagerProxy { |
| 47 public: | 47 public: |
| 48 MockQuotaManagerProxy() | 48 MockQuotaManagerProxy() |
| 49 : QuotaManagerProxy(NULL, NULL), | 49 : QuotaManagerProxy(NULL, NULL), |
| 50 storage_modified_count_(0), | 50 storage_modified_count_(0), |
| 51 usage_(0), quota_(0) {} | 51 usage_(0), |
| 52 quota_(0) {} |
| 52 | 53 |
| 53 // We don't mock them. | 54 // We don't mock them. |
| 54 void NotifyOriginInUse(const GURL& origin) override {} | 55 void NotifyOriginInUse(const GURL& origin) override {} |
| 55 void NotifyOriginNoLongerInUse(const GURL& origin) override {} | 56 void NotifyOriginNoLongerInUse(const GURL& origin) override {} |
| 56 void SetUsageCacheEnabled(storage::QuotaClient::ID client_id, | 57 void SetUsageCacheEnabled(storage::QuotaClient::ID client_id, |
| 57 const GURL& origin, | 58 const GURL& origin, |
| 58 storage::StorageType type, | 59 storage::StorageType type, |
| 59 bool enabled) override {} | 60 bool enabled) override {} |
| 60 | 61 |
| 61 void NotifyStorageModified(storage::QuotaClient::ID client_id, | 62 void NotifyStorageModified(storage::QuotaClient::ID client_id, |
| (...skipping 34 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 96 public: | 97 public: |
| 97 QuotaBackendImplTest() | 98 QuotaBackendImplTest() |
| 98 : file_system_usage_cache_(file_task_runner()), | 99 : file_system_usage_cache_(file_task_runner()), |
| 99 quota_manager_proxy_(new MockQuotaManagerProxy) {} | 100 quota_manager_proxy_(new MockQuotaManagerProxy) {} |
| 100 | 101 |
| 101 void SetUp() override { | 102 void SetUp() override { |
| 102 ASSERT_TRUE(data_dir_.CreateUniqueTempDir()); | 103 ASSERT_TRUE(data_dir_.CreateUniqueTempDir()); |
| 103 in_memory_env_.reset(leveldb::NewMemEnv(leveldb::Env::Default())); | 104 in_memory_env_.reset(leveldb::NewMemEnv(leveldb::Env::Default())); |
| 104 file_util_.reset(ObfuscatedFileUtil::CreateForTesting( | 105 file_util_.reset(ObfuscatedFileUtil::CreateForTesting( |
| 105 NULL, data_dir_.GetPath(), in_memory_env_.get(), file_task_runner())); | 106 NULL, data_dir_.GetPath(), in_memory_env_.get(), file_task_runner())); |
| 106 backend_.reset(new QuotaBackendImpl(file_task_runner(), | 107 backend_.reset(new QuotaBackendImpl(file_task_runner(), file_util_.get(), |
| 107 file_util_.get(), | |
| 108 &file_system_usage_cache_, | 108 &file_system_usage_cache_, |
| 109 quota_manager_proxy_.get())); | 109 quota_manager_proxy_.get())); |
| 110 } | 110 } |
| 111 | 111 |
| 112 void TearDown() override { | 112 void TearDown() override { |
| 113 backend_.reset(); | 113 backend_.reset(); |
| 114 quota_manager_proxy_ = NULL; | 114 quota_manager_proxy_ = NULL; |
| 115 file_util_.reset(); | 115 file_util_.reset(); |
| 116 base::RunLoop().RunUntilIdle(); | 116 base::RunLoop().RunUntilIdle(); |
| 117 } | 117 } |
| (...skipping 15 matching lines...) Expand all Loading... |
| 133 GetUsageCachePath(origin, type), 0)); | 133 GetUsageCachePath(origin, type), 0)); |
| 134 } | 134 } |
| 135 | 135 |
| 136 base::SequencedTaskRunner* file_task_runner() { | 136 base::SequencedTaskRunner* file_task_runner() { |
| 137 return base::ThreadTaskRunnerHandle::Get().get(); | 137 return base::ThreadTaskRunnerHandle::Get().get(); |
| 138 } | 138 } |
| 139 | 139 |
| 140 base::FilePath GetUsageCachePath(const GURL& origin, | 140 base::FilePath GetUsageCachePath(const GURL& origin, |
| 141 storage::FileSystemType type) { | 141 storage::FileSystemType type) { |
| 142 base::FilePath path; | 142 base::FilePath path; |
| 143 base::File::Error error = | 143 base::File::Error error = backend_->GetUsageCachePath(origin, type, &path); |
| 144 backend_->GetUsageCachePath(origin, type, &path); | |
| 145 EXPECT_EQ(base::File::FILE_OK, error); | 144 EXPECT_EQ(base::File::FILE_OK, error); |
| 146 EXPECT_FALSE(path.empty()); | 145 EXPECT_FALSE(path.empty()); |
| 147 return path; | 146 return path; |
| 148 } | 147 } |
| 149 | 148 |
| 150 base::MessageLoop message_loop_; | 149 base::MessageLoop message_loop_; |
| 151 base::ScopedTempDir data_dir_; | 150 base::ScopedTempDir data_dir_; |
| 152 std::unique_ptr<leveldb::Env> in_memory_env_; | 151 std::unique_ptr<leveldb::Env> in_memory_env_; |
| 153 std::unique_ptr<ObfuscatedFileUtil> file_util_; | 152 std::unique_ptr<ObfuscatedFileUtil> file_util_; |
| 154 FileSystemUsageCache file_system_usage_cache_; | 153 FileSystemUsageCache file_system_usage_cache_; |
| (...skipping 112 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 267 uint32_t dirty = 0; | 266 uint32_t dirty = 0; |
| 268 ASSERT_TRUE(file_system_usage_cache_.GetDirty(path, &dirty)); | 267 ASSERT_TRUE(file_system_usage_cache_.GetDirty(path, &dirty)); |
| 269 EXPECT_EQ(1u, dirty); | 268 EXPECT_EQ(1u, dirty); |
| 270 | 269 |
| 271 backend_->DecrementDirtyCount(GURL(kOrigin), type); | 270 backend_->DecrementDirtyCount(GURL(kOrigin), type); |
| 272 ASSERT_TRUE(file_system_usage_cache_.GetDirty(path, &dirty)); | 271 ASSERT_TRUE(file_system_usage_cache_.GetDirty(path, &dirty)); |
| 273 EXPECT_EQ(0u, dirty); | 272 EXPECT_EQ(0u, dirty); |
| 274 } | 273 } |
| 275 | 274 |
| 276 } // namespace content | 275 } // namespace content |
| OLD | NEW |