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; |