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

Unified Diff: storage/browser/quota/quota_manager.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 side-by-side diff with in-line comments
Download patch
« no previous file with comments | « storage/browser/quota/quota_manager.h ('k') | storage/browser/quota/quota_manager_proxy.h » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: storage/browser/quota/quota_manager.cc
diff --git a/webkit/browser/quota/quota_manager.cc b/storage/browser/quota/quota_manager.cc
similarity index 82%
rename from webkit/browser/quota/quota_manager.cc
rename to storage/browser/quota/quota_manager.cc
index e468822054847f50cc41385e7642f96062116b30..e4b962912ec210080719d25ab615e856e3dfbc03 100644
--- a/webkit/browser/quota/quota_manager.cc
+++ b/storage/browser/quota/quota_manager.cc
@@ -2,7 +2,7 @@
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
-#include "webkit/browser/quota/quota_manager.h"
+#include "storage/browser/quota/quota_manager.h"
#include <algorithm>
#include <deque>
@@ -23,17 +23,19 @@
#include "base/task_runner_util.h"
#include "base/time/time.h"
#include "net/base/net_util.h"
-#include "webkit/browser/quota/quota_database.h"
-#include "webkit/browser/quota/quota_manager_proxy.h"
-#include "webkit/browser/quota/quota_temporary_storage_evictor.h"
-#include "webkit/browser/quota/storage_monitor.h"
-#include "webkit/browser/quota/usage_tracker.h"
-#include "webkit/common/quota/quota_types.h"
-
-#define UMA_HISTOGRAM_MBYTES(name, sample) \
- UMA_HISTOGRAM_CUSTOM_COUNTS( \
- (name), static_cast<int>((sample) / kMBytes), \
- 1, 10 * 1024 * 1024 /* 10TB */, 100)
+#include "storage/browser/quota/quota_database.h"
+#include "storage/browser/quota/quota_manager_proxy.h"
+#include "storage/browser/quota/quota_temporary_storage_evictor.h"
+#include "storage/browser/quota/storage_monitor.h"
+#include "storage/browser/quota/usage_tracker.h"
+#include "storage/common/quota/quota_types.h"
+
+#define UMA_HISTOGRAM_MBYTES(name, sample) \
+ UMA_HISTOGRAM_CUSTOM_COUNTS((name), \
+ static_cast<int>((sample) / kMBytes), \
+ 1, \
+ 10 * 1024 * 1024 /* 10TB */, \
+ 100)
namespace quota {
@@ -43,7 +45,7 @@ const int64 kMBytes = 1024 * 1024;
const int kMinutesInMilliSeconds = 60 * 1000;
const int64 kReportHistogramInterval = 60 * 60 * 1000; // 1 hour
-const double kTemporaryQuotaRatioToAvail = 1.0 / 3.0; // 33%
+const double kTemporaryQuotaRatioToAvail = 1.0 / 3.0; // 33%
} // namespace
@@ -106,8 +108,8 @@ void CountOriginType(const std::set<GURL>& origins,
bool SetTemporaryGlobalOverrideQuotaOnDBThread(int64* new_quota,
QuotaDatabase* database) {
DCHECK(database);
- if (!database->SetQuotaConfigValue(
- QuotaDatabase::kTemporaryQuotaOverrideKey, *new_quota)) {
+ if (!database->SetQuotaConfigValue(QuotaDatabase::kTemporaryQuotaOverrideKey,
+ *new_quota)) {
*new_quota = -1;
return false;
}
@@ -221,13 +223,15 @@ void DispatchTemporaryGlobalQuotaCallback(
return;
}
- callback.Run(status, CalculateTemporaryGlobalQuota(
- usage_and_quota.global_limited_usage,
- usage_and_quota.available_disk_space));
+ callback.Run(
+ status,
+ CalculateTemporaryGlobalQuota(usage_and_quota.global_limited_usage,
+ usage_and_quota.available_disk_space));
}
-int64 CalculateQuotaWithDiskSpace(
- int64 available_disk_space, int64 usage, int64 quota) {
+int64 CalculateQuotaWithDiskSpace(int64 available_disk_space,
+ int64 usage,
+ int64 quota) {
if (available_disk_space < QuotaManager::kMinimumPreserveForSystem) {
LOG(WARNING)
<< "Running out of disk space for profile."
@@ -289,11 +293,10 @@ void DispatchUsageAndQuotaForWebApps(
// We assume we can expose the actual disk size for them and cap the quota by
// the available disk space.
if (is_unlimited || can_query_disk_size) {
- callback.Run(
- status, usage,
- CalculateQuotaWithDiskSpace(
- usage_and_quota.available_disk_space,
- usage, quota));
+ callback.Run(status,
+ usage,
+ CalculateQuotaWithDiskSpace(
+ usage_and_quota.available_disk_space, usage, quota));
return;
}
@@ -303,17 +306,13 @@ void DispatchUsageAndQuotaForWebApps(
} // namespace
UsageAndQuota::UsageAndQuota()
- : usage(0),
- global_limited_usage(0),
- quota(0),
- available_disk_space(0) {
+ : usage(0), global_limited_usage(0), quota(0), available_disk_space(0) {
}
-UsageAndQuota::UsageAndQuota(
- int64 usage,
- int64 global_limited_usage,
- int64 quota,
- int64 available_disk_space)
+UsageAndQuota::UsageAndQuota(int64 usage,
+ int64 global_limited_usage,
+ int64 quota,
+ int64 available_disk_space)
: usage(usage),
global_limited_usage(global_limited_usage),
quota(quota),
@@ -465,13 +464,8 @@ class UsageAndQuotaCallbackDispatcher
class QuotaManager::GetUsageInfoTask : public QuotaTask {
public:
- GetUsageInfoTask(
- QuotaManager* manager,
- const GetUsageInfoCallback& callback)
- : QuotaTask(manager),
- callback_(callback),
- weak_factory_(this) {
- }
+ GetUsageInfoTask(QuotaManager* manager, const GetUsageInfoCallback& callback)
+ : QuotaTask(manager), callback_(callback), weak_factory_(this) {}
protected:
virtual void Run() OVERRIDE {
@@ -553,10 +547,12 @@ class QuotaManager::OriginDataDeleter : public QuotaTask {
error_count_ = 0;
remaining_clients_ = manager()->clients_.size();
for (QuotaClientList::iterator iter = manager()->clients_.begin();
- iter != manager()->clients_.end(); ++iter) {
+ iter != manager()->clients_.end();
+ ++iter) {
if (quota_client_mask_ & (*iter)->id()) {
(*iter)->DeleteOriginData(
- origin_, type_,
+ origin_,
+ type_,
base::Bind(&OriginDataDeleter::DidDeleteOriginData,
weak_factory_.GetWeakPtr()));
} else {
@@ -633,11 +629,13 @@ class QuotaManager::HostDataDeleter : public QuotaTask {
error_count_ = 0;
remaining_clients_ = manager()->clients_.size();
for (QuotaClientList::iterator iter = manager()->clients_.begin();
- iter != manager()->clients_.end(); ++iter) {
- (*iter)->GetOriginsForHost(
- type_, host_,
- base::Bind(&HostDataDeleter::DidGetOriginsForHost,
- weak_factory_.GetWeakPtr()));
+ iter != manager()->clients_.end();
+ ++iter) {
+ (*iter)
+ ->GetOriginsForHost(type_,
+ host_,
+ base::Bind(&HostDataDeleter::DidGetOriginsForHost,
+ weak_factory_.GetWeakPtr()));
}
}
@@ -674,11 +672,13 @@ class QuotaManager::HostDataDeleter : public QuotaTask {
for (std::set<GURL>::const_iterator p = origins_.begin();
p != origins_.end();
++p) {
- OriginDataDeleter* deleter =
- new OriginDataDeleter(
- manager(), *p, type_, quota_client_mask_,
- base::Bind(&HostDataDeleter::DidDeleteOriginData,
- weak_factory_.GetWeakPtr()));
+ OriginDataDeleter* deleter = new OriginDataDeleter(
+ manager(),
+ *p,
+ type_,
+ quota_client_mask_,
+ base::Bind(&HostDataDeleter::DidDeleteOriginData,
+ weak_factory_.GetWeakPtr()));
deleter->Start();
}
}
@@ -769,9 +769,8 @@ class QuotaManager::DumpOriginInfoTableHelper {
public:
bool DumpOriginInfoTableOnDBThread(QuotaDatabase* database) {
DCHECK(database);
- return database->DumpOriginInfoTable(
- base::Bind(&DumpOriginInfoTableHelper::AppendEntry,
- base::Unretained(this)));
+ return database->DumpOriginInfoTable(base::Bind(
+ &DumpOriginInfoTableHelper::AppendEntry, base::Unretained(this)));
}
void DidDumpOriginInfoTable(const base::WeakPtr<QuotaManager>& manager,
@@ -802,21 +801,20 @@ QuotaManager::QuotaManager(bool is_incognito,
base::SingleThreadTaskRunner* io_thread,
base::SequencedTaskRunner* db_thread,
SpecialStoragePolicy* special_storage_policy)
- : is_incognito_(is_incognito),
- profile_path_(profile_path),
- proxy_(new QuotaManagerProxy(
- this, io_thread)),
- db_disabled_(false),
- eviction_disabled_(false),
- io_thread_(io_thread),
- db_thread_(db_thread),
- temporary_quota_initialized_(false),
- temporary_quota_override_(-1),
- desired_available_space_(-1),
- special_storage_policy_(special_storage_policy),
- get_disk_space_fn_(&CallSystemGetAmountOfFreeDiskSpace),
- storage_monitor_(new StorageMonitor(this)),
- weak_factory_(this) {
+ : is_incognito_(is_incognito),
+ profile_path_(profile_path),
+ proxy_(new QuotaManagerProxy(this, io_thread)),
+ db_disabled_(false),
+ eviction_disabled_(false),
+ io_thread_(io_thread),
+ db_thread_(db_thread),
+ temporary_quota_initialized_(false),
+ temporary_quota_override_(-1),
+ desired_available_space_(-1),
+ special_storage_policy_(special_storage_policy),
+ get_disk_space_fn_(&CallSystemGetAmountOfFreeDiskSpace),
+ storage_monitor_(new StorageMonitor(this)),
+ weak_factory_(this) {
}
void QuotaManager::GetUsageInfo(const GetUsageInfoCallback& callback) {
@@ -829,8 +827,7 @@ void QuotaManager::GetUsageAndQuotaForWebApps(
const GURL& origin,
StorageType type,
const GetUsageAndQuotaCallback& callback) {
- if (type != kStorageTypeTemporary &&
- type != kStorageTypePersistent &&
+ if (type != kStorageTypeTemporary && type != kStorageTypePersistent &&
type != kStorageTypeSyncable) {
callback.Run(kQuotaErrorNotSupported, 0, 0);
return;
@@ -850,8 +847,8 @@ void QuotaManager::GetUsageAndQuotaForWebApps(
dispatcher->set_quota(kNoLimit);
} else {
if (type == kStorageTypeTemporary) {
- GetUsageTracker(type)->GetGlobalLimitedUsage(
- dispatcher->GetGlobalLimitedUsageCallback());
+ GetUsageTracker(type)
+ ->GetGlobalLimitedUsage(dispatcher->GetGlobalLimitedUsageCallback());
GetTemporaryGlobalQuota(dispatcher->GetQuotaCallback());
} else if (type == kStorageTypePersistent) {
GetPersistentHostQuota(net::GetHostOrSpecFromURL(origin),
@@ -868,15 +865,17 @@ void QuotaManager::GetUsageAndQuotaForWebApps(
if (!is_incognito_ && (unlimited || can_query_disk_size))
GetAvailableSpace(dispatcher->GetAvailableSpaceCallback());
- dispatcher->WaitForResults(base::Bind(
- &DispatchUsageAndQuotaForWebApps,
- type, is_incognito_, unlimited, can_query_disk_size,
- callback));
+ dispatcher->WaitForResults(base::Bind(&DispatchUsageAndQuotaForWebApps,
+ type,
+ is_incognito_,
+ unlimited,
+ can_query_disk_size,
+ callback));
}
-void QuotaManager::GetUsageAndQuota(
- const GURL& origin, StorageType type,
- const GetUsageAndQuotaCallback& callback) {
+void QuotaManager::GetUsageAndQuota(const GURL& origin,
+ StorageType type,
+ const GetUsageAndQuotaCallback& callback) {
DCHECK(origin == origin.GetOrigin());
if (IsStorageUnlimited(origin, type)) {
@@ -887,19 +886,20 @@ void QuotaManager::GetUsageAndQuota(
GetUsageAndQuotaForWebApps(origin, type, callback);
}
-void QuotaManager::NotifyStorageAccessed(
- QuotaClient::ID client_id,
- const GURL& origin, StorageType type) {
+void QuotaManager::NotifyStorageAccessed(QuotaClient::ID client_id,
+ const GURL& origin,
+ StorageType type) {
DCHECK(origin == origin.GetOrigin());
NotifyStorageAccessedInternal(client_id, origin, type, base::Time::Now());
}
-void QuotaManager::NotifyStorageModified(
- QuotaClient::ID client_id,
- const GURL& origin, StorageType type, int64 delta) {
+void QuotaManager::NotifyStorageModified(QuotaClient::ID client_id,
+ const GURL& origin,
+ StorageType type,
+ int64 delta) {
DCHECK(origin == origin.GetOrigin());
- NotifyStorageModifiedInternal(client_id, origin, type, delta,
- base::Time::Now());
+ NotifyStorageModifiedInternal(
+ client_id, origin, type, delta, base::Time::Now());
}
void QuotaManager::NotifyOriginInUse(const GURL& origin) {
@@ -924,9 +924,10 @@ void QuotaManager::SetUsageCacheEnabled(QuotaClient::ID client_id,
GetUsageTracker(type)->SetUsageCacheEnabled(client_id, origin, enabled);
}
-void QuotaManager::DeleteOriginData(
- const GURL& origin, StorageType type, int quota_client_mask,
- const StatusCallback& callback) {
+void QuotaManager::DeleteOriginData(const GURL& origin,
+ StorageType type,
+ int quota_client_mask,
+ const StatusCallback& callback) {
LazyInitialize();
if (origin.is_empty() || clients_.empty()) {
@@ -970,9 +971,10 @@ void QuotaManager::GetAvailableSpace(const AvailableSpaceCallback& callback) {
void QuotaManager::GetTemporaryGlobalQuota(const QuotaCallback& callback) {
LazyInitialize();
if (!temporary_quota_initialized_) {
- db_initialization_callbacks_.Add(base::Bind(
- &QuotaManager::GetTemporaryGlobalQuota,
- weak_factory_.GetWeakPtr(), callback));
+ db_initialization_callbacks_.Add(
+ base::Bind(&QuotaManager::GetTemporaryGlobalQuota,
+ weak_factory_.GetWeakPtr(),
+ callback));
return;
}
@@ -983,15 +985,16 @@ void QuotaManager::GetTemporaryGlobalQuota(const QuotaCallback& callback) {
UsageAndQuotaCallbackDispatcher* dispatcher =
new UsageAndQuotaCallbackDispatcher(this);
- GetUsageTracker(kStorageTypeTemporary)->
- GetGlobalLimitedUsage(dispatcher->GetGlobalLimitedUsageCallback());
+ GetUsageTracker(kStorageTypeTemporary)
+ ->GetGlobalLimitedUsage(dispatcher->GetGlobalLimitedUsageCallback());
GetAvailableSpace(dispatcher->GetAvailableSpaceCallback());
dispatcher->WaitForResults(
base::Bind(&DispatchTemporaryGlobalQuotaCallback, callback));
}
void QuotaManager::SetTemporaryGlobalOverrideQuota(
- int64 new_quota, const QuotaCallback& callback) {
+ int64 new_quota,
+ const QuotaCallback& callback) {
LazyInitialize();
if (new_quota < 0) {
@@ -1034,9 +1037,8 @@ void QuotaManager::GetPersistentHostQuota(const std::string& host,
int64* quota_ptr = new int64(0);
PostTaskAndReplyWithResultForDBThread(
FROM_HERE,
- base::Bind(&GetPersistentHostQuotaOnDBThread,
- host,
- base::Unretained(quota_ptr)),
+ base::Bind(
+ &GetPersistentHostQuotaOnDBThread, host, base::Unretained(quota_ptr)),
base::Bind(&QuotaManager::DidGetPersistentHostQuota,
weak_factory_.GetWeakPtr(),
host,
@@ -1166,19 +1168,25 @@ bool QuotaManager::ResetUsageTracker(StorageType type) {
return false;
switch (type) {
case kStorageTypeTemporary:
- temporary_usage_tracker_.reset(new UsageTracker(
- clients_, kStorageTypeTemporary, special_storage_policy_.get(),
- storage_monitor_.get()));
+ temporary_usage_tracker_.reset(
+ new UsageTracker(clients_,
+ kStorageTypeTemporary,
+ special_storage_policy_.get(),
+ storage_monitor_.get()));
return true;
case kStorageTypePersistent:
- persistent_usage_tracker_.reset(new UsageTracker(
- clients_, kStorageTypePersistent, special_storage_policy_.get(),
- storage_monitor_.get()));
+ persistent_usage_tracker_.reset(
+ new UsageTracker(clients_,
+ kStorageTypePersistent,
+ special_storage_policy_.get(),
+ storage_monitor_.get()));
return true;
case kStorageTypeSyncable:
- syncable_usage_tracker_.reset(new UsageTracker(
- clients_, kStorageTypeSyncable, special_storage_policy_.get(),
- storage_monitor_.get()));
+ syncable_usage_tracker_.reset(
+ new UsageTracker(clients_,
+ kStorageTypeSyncable,
+ special_storage_policy_.get(),
+ storage_monitor_.get()));
return true;
default:
NOTREACHED();
@@ -1187,7 +1195,8 @@ bool QuotaManager::ResetUsageTracker(StorageType type) {
}
void QuotaManager::AddStorageObserver(
- StorageObserver* observer, const StorageObserver::MonitorParams& params) {
+ StorageObserver* observer,
+ const StorageObserver::MonitorParams& params) {
DCHECK(observer);
storage_monitor_->AddObserver(observer, params);
}
@@ -1198,14 +1207,16 @@ void QuotaManager::RemoveStorageObserver(StorageObserver* observer) {
}
void QuotaManager::RemoveStorageObserverForFilter(
- StorageObserver* observer, const StorageObserver::Filter& filter) {
+ StorageObserver* observer,
+ const StorageObserver::Filter& filter) {
DCHECK(observer);
storage_monitor_->RemoveObserverForFilter(observer, filter);
}
QuotaManager::~QuotaManager() {
proxy_->manager_ = NULL;
- std::for_each(clients_.begin(), clients_.end(),
+ std::for_each(clients_.begin(),
+ clients_.end(),
std::mem_fun(&QuotaClient::OnQuotaManagerDestroyed));
if (database_)
db_thread_->DeleteSoon(FROM_HERE, database_.release());
@@ -1226,18 +1237,23 @@ void QuotaManager::LazyInitialize() {
}
// Use an empty path to open an in-memory only databse for incognito.
- database_.reset(new QuotaDatabase(is_incognito_ ? base::FilePath() :
- profile_path_.AppendASCII(kDatabaseName)));
-
- temporary_usage_tracker_.reset(new UsageTracker(
- clients_, kStorageTypeTemporary, special_storage_policy_.get(),
- storage_monitor_.get()));
- persistent_usage_tracker_.reset(new UsageTracker(
- clients_, kStorageTypePersistent, special_storage_policy_.get(),
- storage_monitor_.get()));
- syncable_usage_tracker_.reset(new UsageTracker(
- clients_, kStorageTypeSyncable, special_storage_policy_.get(),
- storage_monitor_.get()));
+ database_.reset(new QuotaDatabase(
+ is_incognito_ ? base::FilePath()
+ : profile_path_.AppendASCII(kDatabaseName)));
+
+ temporary_usage_tracker_.reset(new UsageTracker(clients_,
+ kStorageTypeTemporary,
+ special_storage_policy_.get(),
+ storage_monitor_.get()));
+ persistent_usage_tracker_.reset(
+ new UsageTracker(clients_,
+ kStorageTypePersistent,
+ special_storage_policy_.get(),
+ storage_monitor_.get()));
+ syncable_usage_tracker_.reset(new UsageTracker(clients_,
+ kStorageTypeSyncable,
+ special_storage_policy_.get(),
+ storage_monitor_.get()));
int64* temporary_quota_override = new int64(-1);
int64* desired_available_space = new int64(-1);
@@ -1273,18 +1289,17 @@ UsageTracker* QuotaManager::GetUsageTracker(StorageType type) const {
return NULL;
}
-void QuotaManager::GetCachedOrigins(
- StorageType type, std::set<GURL>* origins) {
+void QuotaManager::GetCachedOrigins(StorageType type, std::set<GURL>* origins) {
DCHECK(origins);
LazyInitialize();
DCHECK(GetUsageTracker(type));
GetUsageTracker(type)->GetCachedOrigins(origins);
}
-void QuotaManager::NotifyStorageAccessedInternal(
- QuotaClient::ID client_id,
- const GURL& origin, StorageType type,
- base::Time accessed_time) {
+void QuotaManager::NotifyStorageAccessedInternal(QuotaClient::ID client_id,
+ const GURL& origin,
+ StorageType type,
+ base::Time accessed_time) {
LazyInitialize();
if (type == kStorageTypeTemporary && !lru_origin_callback_.is_null()) {
// Record the accessed origins while GetLRUOrigin task is runing
@@ -1297,16 +1312,14 @@ void QuotaManager::NotifyStorageAccessedInternal(
PostTaskAndReplyWithResultForDBThread(
FROM_HERE,
base::Bind(&UpdateAccessTimeOnDBThread, origin, type, accessed_time),
- base::Bind(&QuotaManager::DidDatabaseWork,
- weak_factory_.GetWeakPtr()));
+ base::Bind(&QuotaManager::DidDatabaseWork, weak_factory_.GetWeakPtr()));
}
-void QuotaManager::NotifyStorageModifiedInternal(
- QuotaClient::ID client_id,
- const GURL& origin,
- StorageType type,
- int64 delta,
- base::Time modified_time) {
+void QuotaManager::NotifyStorageModifiedInternal(QuotaClient::ID client_id,
+ const GURL& origin,
+ StorageType type,
+ int64 delta,
+ base::Time modified_time) {
LazyInitialize();
DCHECK(GetUsageTracker(type));
GetUsageTracker(type)->UpdateUsageCache(client_id, origin, delta);
@@ -1314,8 +1327,7 @@ void QuotaManager::NotifyStorageModifiedInternal(
PostTaskAndReplyWithResultForDBThread(
FROM_HERE,
base::Bind(&UpdateModifiedTimeOnDBThread, origin, type, modified_time),
- base::Bind(&QuotaManager::DidDatabaseWork,
- weak_factory_.GetWeakPtr()));
+ base::Bind(&QuotaManager::DidDatabaseWork, weak_factory_.GetWeakPtr()));
}
void QuotaManager::DumpQuotaTable(const DumpQuotaTableCallback& callback) {
@@ -1345,16 +1357,16 @@ void QuotaManager::DumpOriginInfoTable(
void QuotaManager::StartEviction() {
DCHECK(!temporary_storage_evictor_.get());
- temporary_storage_evictor_.reset(new QuotaTemporaryStorageEvictor(
- this, kEvictionIntervalInMilliSeconds));
+ temporary_storage_evictor_.reset(
+ new QuotaTemporaryStorageEvictor(this, kEvictionIntervalInMilliSeconds));
if (desired_available_space_ >= 0)
temporary_storage_evictor_->set_min_available_disk_space_to_start_eviction(
desired_available_space_);
temporary_storage_evictor_->Start();
}
-void QuotaManager::DeleteOriginFromDatabase(
- const GURL& origin, StorageType type) {
+void QuotaManager::DeleteOriginFromDatabase(const GURL& origin,
+ StorageType type) {
LazyInitialize();
if (db_disabled_)
return;
@@ -1362,8 +1374,7 @@ void QuotaManager::DeleteOriginFromDatabase(
PostTaskAndReplyWithResultForDBThread(
FROM_HERE,
base::Bind(&DeleteOriginInfoOnDBThread, origin, type),
- base::Bind(&QuotaManager::DidDatabaseWork,
- weak_factory_.GetWeakPtr()));
+ base::Bind(&QuotaManager::DidDatabaseWork, weak_factory_.GetWeakPtr()));
}
void QuotaManager::DidOriginDataEvicted(QuotaStatusCode status) {
@@ -1381,14 +1392,14 @@ void QuotaManager::DidOriginDataEvicted(QuotaStatusCode status) {
}
void QuotaManager::ReportHistogram() {
- GetGlobalUsage(kStorageTypeTemporary,
- base::Bind(
- &QuotaManager::DidGetTemporaryGlobalUsageForHistogram,
- weak_factory_.GetWeakPtr()));
- GetGlobalUsage(kStorageTypePersistent,
- base::Bind(
- &QuotaManager::DidGetPersistentGlobalUsageForHistogram,
- weak_factory_.GetWeakPtr()));
+ GetGlobalUsage(
+ kStorageTypeTemporary,
+ base::Bind(&QuotaManager::DidGetTemporaryGlobalUsageForHistogram,
+ weak_factory_.GetWeakPtr()));
+ GetGlobalUsage(
+ kStorageTypePersistent,
+ base::Bind(&QuotaManager::DidGetPersistentGlobalUsageForHistogram,
+ weak_factory_.GetWeakPtr()));
}
void QuotaManager::DidGetTemporaryGlobalUsageForHistogram(
@@ -1407,8 +1418,7 @@ void QuotaManager::DidGetTemporaryGlobalUsageForHistogram(
&protected_origins,
&unlimited_origins);
- UMA_HISTOGRAM_COUNTS("Quota.NumberOfTemporaryStorageOrigins",
- num_origins);
+ UMA_HISTOGRAM_COUNTS("Quota.NumberOfTemporaryStorageOrigins", num_origins);
UMA_HISTOGRAM_COUNTS("Quota.NumberOfProtectedTemporaryStorageOrigins",
protected_origins);
UMA_HISTOGRAM_COUNTS("Quota.NumberOfUnlimitedTemporaryStorageOrigins",
@@ -1431,17 +1441,15 @@ void QuotaManager::DidGetPersistentGlobalUsageForHistogram(
&protected_origins,
&unlimited_origins);
- UMA_HISTOGRAM_COUNTS("Quota.NumberOfPersistentStorageOrigins",
- num_origins);
+ UMA_HISTOGRAM_COUNTS("Quota.NumberOfPersistentStorageOrigins", num_origins);
UMA_HISTOGRAM_COUNTS("Quota.NumberOfProtectedPersistentStorageOrigins",
protected_origins);
UMA_HISTOGRAM_COUNTS("Quota.NumberOfUnlimitedPersistentStorageOrigins",
unlimited_origins);
}
-void QuotaManager::GetLRUOrigin(
- StorageType type,
- const GetLRUOriginCallback& callback) {
+void QuotaManager::GetLRUOrigin(StorageType type,
+ const GetLRUOriginCallback& callback) {
LazyInitialize();
// This must not be called while there's an in-flight task.
DCHECK(lru_origin_callback_.is_null());
@@ -1479,10 +1487,9 @@ void QuotaManager::GetLRUOrigin(
base::Owned(url)));
}
-void QuotaManager::EvictOriginData(
- const GURL& origin,
- StorageType type,
- const EvictOriginDataCallback& callback) {
+void QuotaManager::EvictOriginData(const GURL& origin,
+ StorageType type,
+ const EvictOriginDataCallback& callback) {
DCHECK(io_thread_->BelongsToCurrentThread());
DCHECK_EQ(type, kStorageTypeTemporary);
@@ -1490,9 +1497,11 @@ void QuotaManager::EvictOriginData(
eviction_context_.evicted_type = type;
eviction_context_.evict_origin_data_callback = callback;
- DeleteOriginData(origin, type, QuotaClient::kAllClientsMask,
- base::Bind(&QuotaManager::DidOriginDataEvicted,
- weak_factory_.GetWeakPtr()));
+ DeleteOriginData(origin,
+ type,
+ QuotaClient::kAllClientsMask,
+ base::Bind(&QuotaManager::DidOriginDataEvicted,
+ weak_factory_.GetWeakPtr()));
}
void QuotaManager::GetUsageAndQuotaForEviction(
@@ -1502,8 +1511,8 @@ void QuotaManager::GetUsageAndQuotaForEviction(
UsageAndQuotaCallbackDispatcher* dispatcher =
new UsageAndQuotaCallbackDispatcher(this);
- GetUsageTracker(kStorageTypeTemporary)->
- GetGlobalLimitedUsage(dispatcher->GetGlobalLimitedUsageCallback());
+ GetUsageTracker(kStorageTypeTemporary)
+ ->GetGlobalLimitedUsage(dispatcher->GetGlobalLimitedUsageCallback());
GetTemporaryGlobalQuota(dispatcher->GetQuotaCallback());
GetAvailableSpace(dispatcher->GetAvailableSpaceCallback());
dispatcher->WaitForResults(callback);
@@ -1530,8 +1539,7 @@ void QuotaManager::DidGetPersistentHostQuota(const std::string& host,
const int64* quota,
bool success) {
DidDatabaseWork(success);
- persistent_host_quota_callbacks_.Run(
- host, MakeTuple(kQuotaStatusOk, *quota));
+ persistent_host_quota_callbacks_.Run(host, MakeTuple(kQuotaStatusOk, *quota));
}
void QuotaManager::DidSetPersistentHostQuota(const std::string& host,
@@ -1550,10 +1558,11 @@ void QuotaManager::DidInitialize(int64* temporary_quota_override,
temporary_quota_initialized_ = true;
DidDatabaseWork(success);
- histogram_timer_.Start(FROM_HERE,
- base::TimeDelta::FromMilliseconds(
- kReportHistogramInterval),
- this, &QuotaManager::ReportHistogram);
+ histogram_timer_.Start(
+ FROM_HERE,
+ base::TimeDelta::FromMilliseconds(kReportHistogramInterval),
+ this,
+ &QuotaManager::ReportHistogram);
db_initialization_callbacks_.Run(MakeTuple());
GetTemporaryGlobalQuota(
@@ -1561,8 +1570,7 @@ void QuotaManager::DidInitialize(int64* temporary_quota_override,
weak_factory_.GetWeakPtr()));
}
-void QuotaManager::DidGetLRUOrigin(const GURL* origin,
- bool success) {
+void QuotaManager::DidGetLRUOrigin(const GURL* origin, bool success) {
DidDatabaseWork(success);
// Make sure the returned origin is (still) not in the origin_in_use_ set
// and has not been accessed since we posted the task.
@@ -1575,8 +1583,8 @@ void QuotaManager::DidGetLRUOrigin(const GURL* origin,
lru_origin_callback_.Reset();
}
-void QuotaManager::DidGetInitialTemporaryGlobalQuota(
- QuotaStatusCode status, int64 quota_unused) {
+void QuotaManager::DidGetInitialTemporaryGlobalQuota(QuotaStatusCode status,
+ int64 quota_unused) {
if (eviction_disabled_)
return;
« no previous file with comments | « storage/browser/quota/quota_manager.h ('k') | storage/browser/quota/quota_manager_proxy.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698