Update data reduction proxy statistics prefs less often on desktop

components/data_reduction_proxy/browser/data_reduction_proxy_statistics_prefs.cc

Index: components/data_reduction_proxy/browser/data_reduction_proxy_statistics_prefs.cc
diff --git a/components/data_reduction_proxy/browser/data_reduction_proxy_statistics_prefs.cc b/components/data_reduction_proxy/browser/data_reduction_proxy_statistics_prefs.cc
new file mode 100644
index 0000000000000000000000000000000000000000..6561415ff76ab1c9ff7b727ecfc8cea4ee9ec612
--- /dev/null
+++ b/components/data_reduction_proxy/browser/data_reduction_proxy_statistics_prefs.cc
@@ -0,0 +1,159 @@
+// Copyright 2014 The Chromium Authors. All rights reserved.
+// Use of this source code is governed by a BSD-style license that can be
+// found in the LICENSE file.
+
+#include "components/data_reduction_proxy/browser/data_reduction_proxy_statistics_prefs.h"
+
+#include "base/bind.h"
+#include "base/location.h"
+#include "base/prefs/pref_service.h"
+#include "base/prefs/scoped_user_pref_update.h"
+#include "base/sequenced_task_runner.h"
+#include "base/strings/string_number_conversions.h"
+#include "base/time/time.h"
+#include "base/values.h"
+
+namespace data_reduction_proxy {
+
+DataReductionProxyStatisticsPrefs::DataReductionProxyStatisticsPrefs(
+    PrefService* prefs,
+    scoped_refptr<base::SequencedTaskRunner> task_runner,
+    const base::TimeDelta& delay)
+    : pref_service_(prefs),
+      task_runner_(task_runner),
+      weak_factory_(this),
+      delay_(delay),
+      delayed_task_posted_(false){
+  DCHECK(prefs);
+  DCHECK_GE(delay.InMilliseconds(), 0);
+  Init();
+}
+
+DataReductionProxyStatisticsPrefs::~DataReductionProxyStatisticsPrefs() {
+  WritePrefs();
+}
+
+void DataReductionProxyStatisticsPrefs::Init() {
+  if (delay_ != base::TimeDelta()) {

[bengr, 2014/09/09 02:09:39]

change to:

if (delay == base::TimeDelta()
  return;

[megjablon, 2014/09/09 18:52:23]

Done.

+    //Init all int64 prefs
+    InitInt64Pref(data_reduction_proxy::prefs::
+                  kDailyHttpContentLengthLastUpdateDate);
+    InitInt64Pref(data_reduction_proxy::prefs::kHttpReceivedContentLength);
+    InitInt64Pref(data_reduction_proxy::prefs::kHttpOriginalContentLength);
+
+    //Init all list prefs
+    InitListPref(data_reduction_proxy::prefs::
+                 kDailyContentLengthHttpsWithDataReductionProxyEnabled);
+    InitListPref(data_reduction_proxy::prefs::
+                 kDailyContentLengthLongBypassWithDataReductionProxyEnabled);
+    InitListPref(data_reduction_proxy::prefs::
+                 kDailyContentLengthShortBypassWithDataReductionProxyEnabled);
+    InitListPref(data_reduction_proxy::prefs::
+                 kDailyContentLengthUnknownWithDataReductionProxyEnabled);
+    InitListPref(data_reduction_proxy::prefs::
+                 kDailyContentLengthViaDataReductionProxy);
+    InitListPref(data_reduction_proxy::prefs::
+                 kDailyContentLengthWithDataReductionProxyEnabled);
+    InitListPref(data_reduction_proxy::prefs::kDailyHttpOriginalContentLength);
+    InitListPref(data_reduction_proxy::prefs::kDailyHttpReceivedContentLength);
+    InitListPref(data_reduction_proxy::prefs::
+                 kDailyOriginalContentLengthViaDataReductionProxy);
+    InitListPref(data_reduction_proxy::prefs::
+                 kDailyOriginalContentLengthWithDataReductionProxyEnabled);
+  }
+}
+
+void DataReductionProxyStatisticsPrefs::InitInt64Pref(const char* pref) {
+  int64 pref_value = pref_service_->GetInt64(pref);
+  pref_map_[pref] = pref_value;
+}
+
+void DataReductionProxyStatisticsPrefs::InitListPref(const char* pref) {
+  scoped_ptr<base::ListValue> pref_value = scoped_ptr<base::ListValue>(
+      pref_service_->GetList(pref)->DeepCopy());
+  list_pref_map_.add(pref, pref_value.Pass());
+}
+
+int64 DataReductionProxyStatisticsPrefs::GetInt64(const char* pref_path) {
+  if (delay_ == base::TimeDelta())
+    return pref_service_->GetInt64(pref_path);
+
+  DataReductionProxyPrefMap::iterator iter = pref_map_.find(pref_path);
+  return iter->second;
+}
+
+void DataReductionProxyStatisticsPrefs::SetInt64(const char* pref_path,
+                                                 int64 pref_value) {

[bengr, 2014/09/09 02:09:40]

Use int64_t here and everywhere

[megjablon, 2014/09/09 18:52:23]

Done.

+  if (delay_ == base::TimeDelta()) {
+    pref_service_->SetInt64(pref_path, pref_value);
+    return;
+  }
+
+  if (!delayed_task_posted_)
+    WritePrefsAndPost();
+  pref_map_[pref_path] = pref_value;
+}
+
+base::ListValue* DataReductionProxyStatisticsPrefs::GetList(
+    const char* pref_path) {
+  if (delay_ == base::TimeDelta())
+    return ListPrefUpdate(pref_service_, pref_path).Get();
+
+  if (!delayed_task_posted_)
+    WritePrefsAndPost();
+  return list_pref_map_.get(pref_path);
+}
+
+void DataReductionProxyStatisticsPrefs::WritePrefs() {
+  for (DataReductionProxyPrefMap::iterator iter = pref_map_.begin();
+       iter != pref_map_.end(); ++iter) {
+    pref_service_->SetInt64(iter->first, iter->second);
+  }
+
+  for (DataReductionProxyListPrefMap::iterator iter = list_pref_map_.begin();
+       iter != list_pref_map_.end(); ++iter) {
+    TransferList(*(iter->second),
+                 ListPrefUpdate(pref_service_, iter->first).Get());
+  }
+}
+
+void DataReductionProxyStatisticsPrefs::WritePrefsAndPost() {
+  // Only write after the first time posting the task.
+  if (!delayed_task_posted_)
+    delayed_task_posted_ = true;
+  else
+    WritePrefs();
+
+  task_runner_->PostDelayedTask(
+      FROM_HERE,
+      base::Bind(&DataReductionProxyStatisticsPrefs::WritePrefsAndPost,
+                 weak_factory_.GetWeakPtr()),
+                 delay_);
+}
+
+void DataReductionProxyStatisticsPrefs::TransferList(
+    const base::ListValue& from_list,
+    base::ListValue* to_list) {
+  to_list->Clear();
+  for (size_t i = 0; i < from_list.GetSize(); ++i) {
+    to_list->Set(i, new base::StringValue(base::Int64ToString(
+        GetListPrefInt64Value(from_list, i))));
+  }
+}
+
+int64 DataReductionProxyStatisticsPrefs::GetListPrefInt64Value(
+    const base::ListValue& list,
+    size_t index) {
+  std::string string_value;
+  if (!list.GetString(index, &string_value)) {
+    NOTREACHED();
+    return 0;
+  }
+
+  int64 value = 0;
+  bool rv = base::StringToInt64(string_value, &value);
+  DCHECK(rv);
+  return value;
+}
+
+} // namespace data_reduction_proxy