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

Unified Diff: storage/browser/quota/quota_temporary_storage_evictor.cc

Issue 1782053004: Change how the quota system computes the total poolsize for temporary storage (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: rebase Created 4 years, 2 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
Index: storage/browser/quota/quota_temporary_storage_evictor.cc
diff --git a/storage/browser/quota/quota_temporary_storage_evictor.cc b/storage/browser/quota/quota_temporary_storage_evictor.cc
index 9174377c8facbd82530eda1773f80bb64e2c5085..f8e8db70114ed1019d38b351116486529819d7f1 100644
--- a/storage/browser/quota/quota_temporary_storage_evictor.cc
+++ b/storage/browser/quota/quota_temporary_storage_evictor.cc
@@ -8,6 +8,7 @@
#include <algorithm>
+#include "base/auto_reset.h"
#include "base/bind.h"
#include "base/metrics/histogram.h"
#include "storage/browser/quota/quota_manager.h"
@@ -36,9 +37,6 @@ const double kDiskSpaceShortageAllowanceRatio = 0.5;
namespace storage {
-const int QuotaTemporaryStorageEvictor::
- kMinAvailableToStartEvictionNotSpecified = -1;
-
QuotaTemporaryStorageEvictor::EvictionRoundStatistics::EvictionRoundStatistics()
: in_round(false),
is_initialized(false),
@@ -52,11 +50,9 @@ QuotaTemporaryStorageEvictor::EvictionRoundStatistics::EvictionRoundStatistics()
QuotaTemporaryStorageEvictor::QuotaTemporaryStorageEvictor(
QuotaEvictionHandler* quota_eviction_handler,
int64_t interval_ms)
- : min_available_to_start_eviction_(
- kMinAvailableToStartEvictionNotSpecified),
- quota_eviction_handler_(quota_eviction_handler),
+ : quota_eviction_handler_(quota_eviction_handler),
interval_ms_(interval_ms),
- repeated_eviction_(true),
+ timer_disabled_for_testing_(false),
weak_factory_(this) {
DCHECK(quota_eviction_handler);
}
@@ -142,6 +138,8 @@ void QuotaTemporaryStorageEvictor::OnEvictionRoundFinished() {
void QuotaTemporaryStorageEvictor::Start() {
DCHECK(CalledOnValidThread());
+
+ base::AutoReset<bool> auto_reset(&timer_disabled_for_testing_, false);
StartEvictionTimerWithDelay(0);
if (histogram_timer_.IsRunning())
@@ -153,7 +151,7 @@ void QuotaTemporaryStorageEvictor::Start() {
}
void QuotaTemporaryStorageEvictor::StartEvictionTimerWithDelay(int delay_ms) {
- if (eviction_timer_.IsRunning())
+ if (eviction_timer_.IsRunning() || timer_disabled_for_testing_)
return;
eviction_timer_.Start(FROM_HERE, base::TimeDelta::FromMilliseconds(delay_ms),
this, &QuotaTemporaryStorageEvictor::ConsiderEviction);
@@ -161,66 +159,46 @@ void QuotaTemporaryStorageEvictor::StartEvictionTimerWithDelay(int delay_ms) {
void QuotaTemporaryStorageEvictor::ConsiderEviction() {
OnEvictionRoundStarted();
-
- if (min_available_to_start_eviction_ ==
- kMinAvailableToStartEvictionNotSpecified) {
- quota_eviction_handler_->AsyncGetVolumeInfo(
- base::Bind(&QuotaTemporaryStorageEvictor::OnGotVolumeInfo,
- weak_factory_.GetWeakPtr()));
- } else {
- quota_eviction_handler_->GetUsageAndQuotaForEviction(
- base::Bind(&QuotaTemporaryStorageEvictor::OnGotUsageAndQuotaForEviction,
- weak_factory_.GetWeakPtr(),
- min_available_to_start_eviction_));
- }
+ quota_eviction_handler_->GetEvictionRoundInfo(
+ base::Bind(&QuotaTemporaryStorageEvictor::OnGotEvictionRoundInfo,
+ weak_factory_.GetWeakPtr()));
}
-void QuotaTemporaryStorageEvictor::OnGotVolumeInfo(
- bool success, uint64_t available_space, uint64_t total_size) {
- // Compute how much to keep free as a function of total disk size.
- int64_t must_remain_available_space = success ?
- static_cast<int64_t>(total_size * kMustRemainAvailableRatio) :
- kDefaultMustRemainAvailableSpace;
-
- quota_eviction_handler_->GetUsageAndQuotaForEviction(
- base::Bind(&QuotaTemporaryStorageEvictor::OnGotUsageAndQuotaForEviction,
- weak_factory_.GetWeakPtr(), must_remain_available_space));
-}
-
-void QuotaTemporaryStorageEvictor::OnGotUsageAndQuotaForEviction(
- int64_t must_remain_available_space,
+void QuotaTemporaryStorageEvictor::OnGotEvictionRoundInfo(
QuotaStatusCode status,
- const UsageAndQuota& qau) {
- DCHECK(CalledOnValidThread());
+ const TemporaryStorageConfiguration& config,
+ int64_t available_space, int64_t total_space,
+ int64_t current_usage, bool current_usage_is_complete) {
+ DCHECK_GE(current_usage, 0);
- int64_t usage = qau.global_limited_usage;
- DCHECK_GE(usage, 0);
+ // Note: if there is no storage pressure, current_usage will
+ // may not be fully calculated and may be 0.
if (status != kQuotaStatusOk)
++statistics_.num_errors_on_getting_usage_and_quota;
int64_t usage_overage = std::max(
static_cast<int64_t>(0),
- usage - static_cast<int64_t>(qau.quota * kUsageRatioToStartEviction));
-
+ current_usage - static_cast<int64_t>(
+ config.pool_size * kUsageRatioToStartEviction));
int64_t diskspace_shortage = std::max(
static_cast<int64_t>(0),
- must_remain_available_space - qau.available_disk_space);
+ config.must_remain_available - available_space);
// If we're using so little that freeing all of it wouldn't help,
// don't let the low space condition cause us to delete it all.
- if (usage < static_cast<int64_t>(diskspace_shortage *
- kDiskSpaceShortageAllowanceRatio)) {
+ if (current_usage < static_cast<int64_t>(diskspace_shortage *
+ kDiskSpaceShortageAllowanceRatio)) {
diskspace_shortage = 0;
}
if (!round_statistics_.is_initialized) {
round_statistics_.usage_overage_at_round = usage_overage;
round_statistics_.diskspace_shortage_at_round = diskspace_shortage;
- round_statistics_.usage_on_beginning_of_round = usage;
+ round_statistics_.usage_on_beginning_of_round = current_usage;
round_statistics_.is_initialized = true;
}
- round_statistics_.usage_on_end_of_round = usage;
+ round_statistics_.usage_on_end_of_round = current_usage;
int64_t amount_to_evict = std::max(usage_overage, diskspace_shortage);
if (status == kQuotaStatusOk && amount_to_evict > 0) {
@@ -228,33 +206,30 @@ void QuotaTemporaryStorageEvictor::OnGotUsageAndQuotaForEviction(
// TODO(michaeln): if the reason for eviction is low physical disk space,
// make 'unlimited' origins subject to eviction too.
quota_eviction_handler_->GetEvictionOrigin(
- kStorageTypeTemporary, in_progress_eviction_origins_, qau.quota,
+ kStorageTypeTemporary, in_progress_eviction_origins_, config.pool_size,
base::Bind(&QuotaTemporaryStorageEvictor::OnGotEvictionOrigin,
weak_factory_.GetWeakPtr()));
+ return;
+ }
+
+ // No action required, sleep for a while and check again later.
+ if (statistics_.num_errors_on_getting_usage_and_quota <
+ kThresholdOfErrorsToStopEviction) {
+ StartEvictionTimerWithDelay(interval_ms_);
} else {
- if (repeated_eviction_) {
- // No action required, sleep for a while and check again later.
- if (statistics_.num_errors_on_getting_usage_and_quota <
- kThresholdOfErrorsToStopEviction) {
- StartEvictionTimerWithDelay(interval_ms_);
- } else {
- // TODO(dmikurube): Try restarting eviction after a while.
- LOG(WARNING) << "Stopped eviction of temporary storage due to errors "
- "in GetUsageAndQuotaForEviction.";
- }
- }
- OnEvictionRoundFinished();
+ // TODO(dmikurube): Add error handling for the case status is not OK.
+ // TODO(dmikurube): Try restarting eviction after a while.
+ LOG(WARNING) << "Stopped eviction of temporary storage due to errors";
}
- // TODO(dmikurube): Add error handling for the case status != kQuotaStatusOk.
+ OnEvictionRoundFinished();
}
void QuotaTemporaryStorageEvictor::OnGotEvictionOrigin(const GURL& origin) {
DCHECK(CalledOnValidThread());
if (origin.is_empty()) {
- if (repeated_eviction_)
- StartEvictionTimerWithDelay(interval_ms_);
+ StartEvictionTimerWithDelay(interval_ms_);
OnEvictionRoundFinished();
return;
}
@@ -284,10 +259,8 @@ void QuotaTemporaryStorageEvictor::OnEvictionComplete(
ConsiderEviction();
} else {
++statistics_.num_errors_on_evicting_origin;
- if (repeated_eviction_) {
- // Sleep for a while and retry again until we see too many errors.
- StartEvictionTimerWithDelay(interval_ms_);
- }
+ // Sleep for a while and retry again until we see too many errors.
+ StartEvictionTimerWithDelay(interval_ms_);
OnEvictionRoundFinished();
}
}

Powered by Google App Engine
This is Rietveld 408576698