Expose API to store and load data usage stats from UI task runner.

components/data_reduction_proxy/core/browser/data_reduction_proxy_service.h

Index: components/data_reduction_proxy/core/browser/data_reduction_proxy_service.h
diff --git a/components/data_reduction_proxy/core/browser/data_reduction_proxy_service.h b/components/data_reduction_proxy/core/browser/data_reduction_proxy_service.h
index 16b24bc6c3ef116b7da720e55aa0c53df4488bee..d60b548df9f96c91e7b6cb0923da2019dba2a365 100644
--- a/components/data_reduction_proxy/core/browser/data_reduction_proxy_service.h
+++ b/components/data_reduction_proxy/core/browser/data_reduction_proxy_service.h
@@ -14,9 +14,10 @@
 #include "base/memory/scoped_ptr.h"
 #include "base/memory/weak_ptr.h"
 #include "base/observer_list.h"
-#include "base/single_thread_task_runner.h"
+#include "base/sequenced_task_runner.h"
 #include "base/threading/non_thread_safe.h"
 #include "components/data_reduction_proxy/core/browser/data_reduction_proxy_metrics.h"
+#include "components/data_reduction_proxy/core/browser/db_data_owner.h"
 #include "components/data_reduction_proxy/core/common/data_reduction_proxy_event_storage_delegate.h"
 
 class GURL;
@@ -57,7 +58,9 @@ class DataReductionProxyService
       DataReductionProxySettings* settings,
       PrefService* prefs,
       net::URLRequestContextGetter* request_context_getter,
-      scoped_refptr<base::SingleThreadTaskRunner> io_task_runner);
+      scoped_ptr<DataStore> store,
+      const scoped_refptr<base::SingleThreadTaskRunner>& io_task_runner,
+      const scoped_refptr<base::SequencedTaskRunner>& db_task_runner);
 
   virtual ~DataReductionProxyService();
 
@@ -70,11 +73,13 @@ class DataReductionProxyService
   // final step in initialization.
   bool Initialized() const;
 
-  // Constructs compression stats. This should not be called if a valid
-  // compression stats is passed into the constructor.
+  // Constructs compression stats with a noop |DataReductionProxyStore|; load
+  // and store calls do nothing. This should not be called
+  // if a valid compression stats is passed into the constructor.
   void EnableCompressionStatisticsLogging(
       PrefService* prefs,
       scoped_refptr<base::SequencedTaskRunner> ui_task_runner,
+      scoped_refptr<base::SequencedTaskRunner> db_task_runner,

[jeremyim, 2015/07/13 20:19:41]

nit: make these const &

[Not at Google. Contact bengr, 2015/07/14 16:41:31]

Done.

       const base::TimeDelta& commit_delay);
 
   // Records daily data savings statistics in |compression_stats_|.
@@ -115,6 +120,10 @@ class DataReductionProxyService
   virtual void SetProxyPrefs(bool enabled, bool at_startup);
   void RetrieveConfig();
 
+  void LoadCurrentDataUsageBucket(
+      const OnLoadDataUsageBucketCallback& onLoadDataUsageBucket);
+  void StoreCurrentDataUsageBucket(scoped_ptr<DataUsageBucket> current);
+
   // Methods for adding/removing observers on |this|.
   void AddObserver(DataReductionProxyServiceObserver* observer);
   void RemoveObserver(DataReductionProxyServiceObserver* observer);
@@ -163,9 +172,14 @@ class DataReductionProxyService
   // A prefs service for storing data.
   PrefService* prefs_;
 
+  scoped_ptr<DBDataOwner> db_data_owner_;
+
   // Used to post tasks to |io_data_|.
   scoped_refptr<base::SingleThreadTaskRunner> io_task_runner_;
 
+  // Used to post tasks to |db_data_owner_|.
+  scoped_refptr<base::SequencedTaskRunner> db_task_runner_;
+
   // A weak pointer to DataReductionProxyIOData so that UI based objects can
   // make calls to IO based objects.
   base::WeakPtr<DataReductionProxyIOData> io_data_;