Write out CacheStorageCache size to index file.

content/browser/cache_storage/cache_storage.h

Index: content/browser/cache_storage/cache_storage.h
diff --git a/content/browser/cache_storage/cache_storage.h b/content/browser/cache_storage/cache_storage.h
index e0569f19716d5327e43801801ee5a948e56a51d7..19e9b57c9b3d76131690d978e37bc7a8e88b7604 100644
--- a/content/browser/cache_storage/cache_storage.h
+++ b/content/browser/cache_storage/cache_storage.h
@@ -18,6 +18,7 @@
 #include "base/memory/ref_counted.h"
 #include "base/memory/weak_ptr.h"
 #include "content/browser/cache_storage/cache_storage_cache.h"
+#include "content/browser/cache_storage/cache_storage_cache_observer.h"
 
 namespace base {
 class SequencedTaskRunner;
@@ -33,6 +34,7 @@ class BlobStorageContext;
 
 namespace content {
 class CacheStorageCacheHandle;
+class CacheStorageIndex;
 class CacheStorageScheduler;
 
 // TODO(jkarlin): Constrain the total bytes used per origin.
@@ -40,14 +42,15 @@ class CacheStorageScheduler;
 // CacheStorage holds the set of caches for a given origin. It is
 // owned by the CacheStorageManager. This class expects to be run
 // on the IO thread. The asynchronous methods are executed serially.
-class CONTENT_EXPORT CacheStorage {
+class CONTENT_EXPORT CacheStorage : public CacheStorageCacheObserver {
  public:
-  typedef std::vector<std::string> StringVector;
+  constexpr static int64_t kSizeUnknown = -1;
+
   typedef base::Callback<void(bool, CacheStorageError)> BoolAndErrorCallback;
   typedef base::Callback<void(std::unique_ptr<CacheStorageCacheHandle>,
                               CacheStorageError)>
       CacheAndErrorCallback;
-  using StringsCallback = base::Callback<void(const StringVector&)>;
+  using IndexCallback = base::Callback<void(const CacheStorageIndex&)>;
   using SizeCallback = base::Callback<void(int64_t)>;
 
   static const char kIndexFileName[];
@@ -86,8 +89,8 @@ class CONTENT_EXPORT CacheStorage {
   void DeleteCache(const std::string& cache_name,
                    const BoolAndErrorCallback& callback);
 
-  // Calls the callback with a vector of cache names (keys) available.
-  void EnumerateCaches(const StringsCallback& callback);
+  // Calls the callback with the cache index.
+  void EnumerateCaches(const IndexCallback& callback);
 
   // Calls match on the cache with the given |cache_name|.
   void MatchCache(const std::string& cache_name,
@@ -116,9 +119,13 @@ class CONTENT_EXPORT CacheStorage {
   void StartAsyncOperationForTesting();
   void CompleteAsyncOperationForTesting();
 
+  // CacheStorageCacheObserver:
+  void CacheSizeUpdated(const CacheStorageCache* cache, int64_t size) override;
+
  private:
   friend class CacheStorageCacheHandle;
   friend class CacheStorageCache;
+  friend class CacheStorageManagerTest;
   class CacheLoader;
   class MemoryLoader;
   class SimpleCacheLoader;
@@ -140,8 +147,7 @@ class CONTENT_EXPORT CacheStorage {
   // Initializer and its callback are below.
   void LazyInit();
   void LazyInitImpl();
-  void LazyInitDidLoadIndex(
-      std::unique_ptr<std::vector<std::string>> indexed_cache_names);
+  void LazyInitDidLoadIndex(std::unique_ptr<CacheStorageIndex> index);
 
   // The Open and CreateCache callbacks are below.
   void OpenCacheImpl(const std::string& cache_name,
@@ -163,7 +169,7 @@ class CONTENT_EXPORT CacheStorage {
                        const BoolAndErrorCallback& callback);
   void DeleteCacheDidWriteIndex(
       const std::string& cache_name,
-      const StringVector& original_ordered_cache_names,
+      std::unique_ptr<CacheStorageIndex> index_before_delete,
       const BoolAndErrorCallback& callback,
       bool success);
   void DeleteCacheFinalize(std::unique_ptr<CacheStorageCache> doomed_cache);
@@ -172,7 +178,7 @@ class CONTENT_EXPORT CacheStorage {
   void DeleteCacheDidCleanUp(bool success);
 
   // The EnumerateCache callbacks are below.
-  void EnumerateCachesImpl(const StringsCallback& callback);
+  void EnumerateCachesImpl(const IndexCallback& callback);
 
   // The MatchCache callbacks are below.
   void MatchCacheImpl(const std::string& cache_name,
@@ -203,6 +209,18 @@ class CONTENT_EXPORT CacheStorage {
   void GetSizeThenCloseAllCachesImpl(const SizeCallback& callback);
 
   void SizeImpl(const SizeCallback& callback);
+  void SizeRetrievedFromCache(
+      std::unique_ptr<CacheStorageCacheHandle> cache_handle,
+      const base::Closure& closure,
+      int64_t* accumulator,
+      int64_t size);
+
+  void ScheduleWriteIndex();
+  void WriteIndex();
+  void WriteIndexImpl();
+  // Start a scheduled index write immediately. Returns true if a write was
+  // scheduled, or false if not.
+  bool InitiateScheduledIndexWriteForTest();
 
   // Whether or not we've loaded the list of cache names into memory.
   bool initialized_;
@@ -225,8 +243,8 @@ class CONTENT_EXPORT CacheStorage {
   // CacheStorageCacheHandle reference counts
   std::map<CacheStorageCache*, size_t> cache_handle_counts_;
 
-  // The names of caches in the order that they were created.
-  StringVector ordered_cache_names_;
+  // The cache index data.
+  std::unique_ptr<CacheStorageIndex> cache_index_;
 
   // The file path for this CacheStorage.
   base::FilePath origin_path_;
@@ -243,6 +261,9 @@ class CONTENT_EXPORT CacheStorage {
   // The origin that this CacheStorage is associated with.
   GURL origin_;
 
+  base::CancelableClosure index_write_task_;
+  bool index_write_pending_;

[jkarlin, 2016/12/09 19:49:19]

This bool shouldn't be necessary, can't you infer this from
index_write_task_->IsCancelled()?

[cmumford, 2016/12/15 22:29:14]

Done.

+
   base::WeakPtrFactory<CacheStorage> weak_factory_;
 
   DISALLOW_COPY_AND_ASSIGN(CacheStorage);