| Index: chrome/browser/extensions/api/storage/local_value_store_cache.cc
|
| diff --git a/chrome/browser/extensions/api/storage/sync_or_local_value_store_cache.cc b/chrome/browser/extensions/api/storage/local_value_store_cache.cc
|
| similarity index 42%
|
| copy from chrome/browser/extensions/api/storage/sync_or_local_value_store_cache.cc
|
| copy to chrome/browser/extensions/api/storage/local_value_store_cache.cc
|
| index 9ff1175bc728be18c84db4c226feba7720610e0c..d0a0efa2bb7f35bfcef903c4024a73212081b9c6 100644
|
| --- a/chrome/browser/extensions/api/storage/sync_or_local_value_store_cache.cc
|
| +++ b/chrome/browser/extensions/api/storage/local_value_store_cache.cc
|
| @@ -2,18 +2,18 @@
|
| // Use of this source code is governed by a BSD-style license that can be
|
| // found in the LICENSE file.
|
|
|
| -#include "chrome/browser/extensions/api/storage/sync_or_local_value_store_cache.h"
|
| +#include "chrome/browser/extensions/api/storage/local_value_store_cache.h"
|
| +
|
| +#include <limits>
|
|
|
| #include "base/bind.h"
|
| #include "base/callback.h"
|
| #include "base/files/file_path.h"
|
| -#include "base/sequenced_task_runner.h"
|
| #include "chrome/browser/extensions/api/storage/local_storage_backend.h"
|
| -#include "chrome/browser/extensions/api/storage/settings_frontend.h"
|
| +#include "chrome/browser/extensions/api/storage/settings_storage_factory.h"
|
| #include "chrome/browser/extensions/api/storage/settings_storage_quota_enforcer.h"
|
| -#include "chrome/browser/extensions/api/storage/sync_storage_backend.h"
|
| #include "chrome/browser/extensions/api/storage/weak_unlimited_settings_storage.h"
|
| -#include "chrome/browser/sync/glue/sync_start_util.h"
|
| +#include "chrome/common/extensions/api/storage.h"
|
| #include "content/public/browser/browser_thread.h"
|
| #include "extensions/common/constants.h"
|
| #include "extensions/common/extension.h"
|
| @@ -23,47 +23,42 @@ using content::BrowserThread;
|
|
|
| namespace extensions {
|
|
|
| -SyncOrLocalValueStoreCache::SyncOrLocalValueStoreCache(
|
| - settings_namespace::Namespace settings_namespace,
|
| +namespace {
|
| +
|
| +// Returns the quota limit for local storage, taken from the schema in
|
| +// chrome/common/extensions/api/storage.json.
|
| +SettingsStorageQuotaEnforcer::Limits GetLocalQuotaLimits() {
|
| + SettingsStorageQuotaEnforcer::Limits limits = {
|
| + static_cast<size_t>(api::storage::local::QUOTA_BYTES),
|
| + std::numeric_limits<size_t>::max(),
|
| + std::numeric_limits<size_t>::max()
|
| + };
|
| + return limits;
|
| +}
|
| +
|
| +} // namespace
|
| +
|
| +LocalValueStoreCache::LocalValueStoreCache(
|
| const scoped_refptr<SettingsStorageFactory>& factory,
|
| - const SettingsStorageQuotaEnforcer::Limits& quota,
|
| - const scoped_refptr<SettingsObserverList>& observers,
|
| const base::FilePath& profile_path)
|
| - : settings_namespace_(settings_namespace), initialized_(false) {
|
| + : initialized_(false) {
|
| DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
|
| - DCHECK(settings_namespace_ == settings_namespace::LOCAL ||
|
| - settings_namespace_ == settings_namespace::SYNC);
|
|
|
| // This post is safe since the destructor can only be invoked from the
|
| // same message loop, and any potential post of a deletion task must come
|
| // after the constructor returns.
|
| BrowserThread::PostTask(
|
| BrowserThread::FILE, FROM_HERE,
|
| - base::Bind(&SyncOrLocalValueStoreCache::InitOnFileThread,
|
| + base::Bind(&LocalValueStoreCache::InitOnFileThread,
|
| base::Unretained(this),
|
| - factory, quota, observers, profile_path));
|
| + factory, profile_path));
|
| }
|
|
|
| -SyncOrLocalValueStoreCache::~SyncOrLocalValueStoreCache() {
|
| +LocalValueStoreCache::~LocalValueStoreCache() {
|
| DCHECK(BrowserThread::CurrentlyOn(BrowserThread::FILE));
|
| }
|
|
|
| -syncer::SyncableService* SyncOrLocalValueStoreCache::GetSyncableService(
|
| - syncer::ModelType type) const {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::FILE));
|
| - DCHECK(initialized_);
|
| - switch (type) {
|
| - case syncer::APP_SETTINGS:
|
| - return app_backend_->GetAsSyncableService();
|
| - case syncer::EXTENSION_SETTINGS:
|
| - return extension_backend_->GetAsSyncableService();
|
| - default:
|
| - NOTREACHED();
|
| - return NULL;
|
| - }
|
| -}
|
| -
|
| -void SyncOrLocalValueStoreCache::RunWithValueStoreForExtension(
|
| +void LocalValueStoreCache::RunWithValueStoreForExtension(
|
| const StorageCallback& callback,
|
| scoped_refptr<const Extension> extension) {
|
| DCHECK(BrowserThread::CurrentlyOn(BrowserThread::FILE));
|
| @@ -74,15 +69,8 @@ void SyncOrLocalValueStoreCache::RunWithValueStoreForExtension(
|
| ValueStore* storage = backend->GetStorage(extension->id());
|
|
|
| // A neat way to implement unlimited storage; if the extension has the
|
| - // unlimited storage permission, force through all calls to Set() (in the
|
| - // same way that writes from sync ignore quota).
|
| - // But only if it's local storage (bad stuff would happen if sync'ed
|
| - // storage is allowed to be unlimited).
|
| - bool is_unlimited =
|
| - settings_namespace_ == settings_namespace::LOCAL &&
|
| - extension->HasAPIPermission(APIPermission::kUnlimitedStorage);
|
| -
|
| - if (is_unlimited) {
|
| + // unlimited storage permission, force through all calls to Set().
|
| + if (extension->HasAPIPermission(APIPermission::kUnlimitedStorage)) {
|
| WeakUnlimitedSettingsStorage unlimited_storage(storage);
|
| callback.Run(&unlimited_storage);
|
| } else {
|
| @@ -90,52 +78,26 @@ void SyncOrLocalValueStoreCache::RunWithValueStoreForExtension(
|
| }
|
| }
|
|
|
| -void SyncOrLocalValueStoreCache::DeleteStorageSoon(
|
| - const std::string& extension_id) {
|
| +void LocalValueStoreCache::DeleteStorageSoon(const std::string& extension_id) {
|
| DCHECK(BrowserThread::CurrentlyOn(BrowserThread::FILE));
|
| DCHECK(initialized_);
|
| app_backend_->DeleteStorage(extension_id);
|
| extension_backend_->DeleteStorage(extension_id);
|
| }
|
|
|
| -void SyncOrLocalValueStoreCache::InitOnFileThread(
|
| +void LocalValueStoreCache::InitOnFileThread(
|
| const scoped_refptr<SettingsStorageFactory>& factory,
|
| - const SettingsStorageQuotaEnforcer::Limits& quota,
|
| - const scoped_refptr<SettingsObserverList>& observers,
|
| const base::FilePath& profile_path) {
|
| DCHECK(BrowserThread::CurrentlyOn(BrowserThread::FILE));
|
| DCHECK(!initialized_);
|
| - switch (settings_namespace_) {
|
| - case settings_namespace::LOCAL:
|
| - app_backend_.reset(new LocalStorageBackend(
|
| - factory,
|
| - profile_path.AppendASCII(kLocalAppSettingsDirectoryName),
|
| - quota));
|
| - extension_backend_.reset(new LocalStorageBackend(
|
| - factory,
|
| - profile_path.AppendASCII(kLocalExtensionSettingsDirectoryName),
|
| - quota));
|
| - break;
|
| - case settings_namespace::SYNC:
|
| - app_backend_.reset(new SyncStorageBackend(
|
| - factory,
|
| - profile_path.AppendASCII(kSyncAppSettingsDirectoryName),
|
| - quota,
|
| - observers,
|
| - syncer::APP_SETTINGS,
|
| - sync_start_util::GetFlareForSyncableService(profile_path)));
|
| - extension_backend_.reset(new SyncStorageBackend(
|
| - factory,
|
| - profile_path.AppendASCII(kSyncExtensionSettingsDirectoryName),
|
| - quota,
|
| - observers,
|
| - syncer::EXTENSION_SETTINGS,
|
| - sync_start_util::GetFlareForSyncableService(profile_path)));
|
| - break;
|
| - default:
|
| - NOTREACHED();
|
| - }
|
| -
|
| + app_backend_.reset(new LocalStorageBackend(
|
| + factory,
|
| + profile_path.AppendASCII(kLocalAppSettingsDirectoryName),
|
| + GetLocalQuotaLimits()));
|
| + extension_backend_.reset(new LocalStorageBackend(
|
| + factory,
|
| + profile_path.AppendASCII(kLocalExtensionSettingsDirectoryName),
|
| + GetLocalQuotaLimits()));
|
| initialized_ = true;
|
| }
|
|
|
|
|