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

Unified Diff: net/disk_cache/simple/simple_index.cc

Issue 14362009: Receive app notifications in SimpleCache, so we save our index file (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 7 years, 8 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: net/disk_cache/simple/simple_index.cc
diff --git a/net/disk_cache/simple/simple_index.cc b/net/disk_cache/simple/simple_index.cc
index b475c16584919be9f19434f1220a88d0661f476a..706e44645b412521a114044bd12873a9ad0844a9 100644
--- a/net/disk_cache/simple/simple_index.cc
+++ b/net/disk_cache/simple/simple_index.cc
@@ -27,10 +27,8 @@ namespace {
// How many seconds we delay writing the index to disk since the last cache
// operation has happened.
-const int kWriteToDiskDelaySecs = 20;
-
-// WriteToDisk at lest every 5 minutes.
-const int kMaxWriteToDiskDelaySecs = 300;
+const int kWriteToDiskDelayMSecs = 20000;
+const int kWriteToDiskOnBackgroundDelayMSecs = 100;
// Cache size when all other size heuristics failed.
const uint64 kDefaultCacheSize = 80 * 1024 * 1024;
@@ -126,7 +124,12 @@ SimpleIndex::SimpleIndex(
initialized_(false),
index_filename_(path.AppendASCII("simple-index")),
cache_thread_(cache_thread),
- io_thread_(io_thread) {
+ io_thread_(io_thread),
+#if defined(OS_ANDROID)
+ activity_status_notifier_(
+ base::Bind(&SimpleIndex::ActivityStatusChanged, AsWeakPtr())),
+#endif
+ app_on_background_(false) {
}
SimpleIndex::~SimpleIndex() {
@@ -335,19 +338,17 @@ void SimpleIndex::InsertInEntrySet(
void SimpleIndex::PostponeWritingToDisk() {
if (!initialized_)
return;
- const base::TimeDelta file_age = base::Time::Now() - last_write_to_disk_;
- if (file_age > base::TimeDelta::FromSeconds(kMaxWriteToDiskDelaySecs) &&
- write_to_disk_timer_.IsRunning()) {
- // If the index file is too old and there is a timer programmed to run a
- // WriteToDisk soon, we don't postpone it, so we always WriteToDisk
- // approximately every kMaxWriteToDiskDelaySecs.
- return;
+ int delay = kWriteToDiskDelayMSecs;
+ if (app_on_background_) {
+ // When the app is in the background we can write the index much more
+ // frequently. We could even write it to disk on every operation if we
+ // wanted to.
+ delay = kWriteToDiskOnBackgroundDelayMSecs;
}
-
// If the timer is already active, Start() will just Reset it, postponing it.
write_to_disk_timer_.Start(
FROM_HERE,
- base::TimeDelta::FromSeconds(kWriteToDiskDelaySecs),
+ base::TimeDelta::FromMilliseconds(delay),
base::Bind(&SimpleIndex::WriteToDisk, AsWeakPtr()));
}
@@ -398,8 +399,6 @@ scoped_ptr<SimpleIndex::EntrySet> SimpleIndex::RestoreFromDisk(
const base::FilePath& index_filename) {
using file_util::FileEnumerator;
LOG(INFO) << "Simple Cache Index is being restored from disk.";
-
- file_util::Delete(index_filename, /* recursive = */ false);
scoped_ptr<EntrySet> index_file_entries(new EntrySet());
// TODO(felipeg,gavinp): Fix this once we have a one-file per entry format.
@@ -425,7 +424,6 @@ scoped_ptr<SimpleIndex::EntrySet> SimpleIndex::RestoreFromDisk(
hash_key_string, &hash_key)) {
LOG(WARNING) << "Invalid Entry Hash Key filename while restoring "
<< "Simple Index from disk: " << hash_name;
- // TODO(felipeg): Should we delete the invalid file here ?
continue;
}
@@ -488,7 +486,6 @@ void SimpleIndex::MergeInitializingSet(scoped_ptr<EntrySet> index_file_entries,
cache_size_ += it->second.GetEntrySize();
}
}
- last_write_to_disk_ = base::Time::Now();
initialized_ = true;
removed_entries_.clear();
@@ -505,11 +502,27 @@ void SimpleIndex::MergeInitializingSet(scoped_ptr<EntrySet> index_file_entries,
to_run_when_initialized_.clear();
}
+#if defined(OS_ANDROID)
+void SimpleIndex::ActivityStatusChanged(
+ net::SimpleCacheActivityStatusNotifier::ActivityStatus activity_status) {
+ DCHECK(io_thread_checker_.CalledOnValidThread());
+ // For more info about android activities, see:
+ // developer.android.com/training/basics/activity-lifecycle/pausing.html
+ // These values are defined in the file ActivityStatus.java
+ if (activity_status == net::SimpleCacheActivityStatusNotifier::RESUMED) {
+ app_on_background_ = false;
+ } else if (activity_status ==
+ net::SimpleCacheActivityStatusNotifier::STOPPED) {
+ app_on_background_ = true;
+ WriteToDisk();
+ }
+}
+#endif
+
void SimpleIndex::WriteToDisk() {
DCHECK(io_thread_checker_.CalledOnValidThread());
if (!initialized_)
return;
- last_write_to_disk_ = base::Time::Now();
SimpleIndexFile::IndexMetadata index_metadata(entries_set_.size(),
cache_size_);
scoped_ptr<Pickle> pickle = SimpleIndexFile::Serialize(index_metadata,

Powered by Google App Engine
This is Rietveld 408576698