OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #ifndef COMPONENTS_DATA_REDUCTION_PROXY_CORE_BROWSER_DATA_REDUCTION_PROXY_STATIS
TICS_PREFS_H_ | 5 #ifndef COMPONENTS_DATA_REDUCTION_PROXY_CORE_BROWSER_DATA_REDUCTION_PROXY_COMPRE
SSION_STATS_H_ |
6 #define COMPONENTS_DATA_REDUCTION_PROXY_CORE_BROWSER_DATA_REDUCTION_PROXY_STATIS
TICS_PREFS_H_ | 6 #define COMPONENTS_DATA_REDUCTION_PROXY_CORE_BROWSER_DATA_REDUCTION_PROXY_COMPRE
SSION_STATS_H_ |
7 | 7 |
8 #include <map> | 8 #include <map> |
9 | 9 |
10 #include "base/containers/scoped_ptr_hash_map.h" | 10 #include "base/containers/scoped_ptr_hash_map.h" |
11 #include "base/macros.h" | 11 #include "base/macros.h" |
12 #include "base/memory/ref_counted.h" | 12 #include "base/memory/ref_counted.h" |
13 #include "base/memory/weak_ptr.h" | 13 #include "base/memory/weak_ptr.h" |
14 #include "base/threading/thread_checker.h" | 14 #include "base/threading/thread_checker.h" |
15 #include "base/time/time.h" | 15 #include "base/time/time.h" |
16 #include "components/data_reduction_proxy/core/common/data_reduction_proxy_pref_
names.h" | 16 #include "components/data_reduction_proxy/core/common/data_reduction_proxy_pref_
names.h" |
17 | 17 |
18 class PrefChangeRegistrar; | 18 class PrefChangeRegistrar; |
19 class PrefService; | 19 class PrefService; |
20 | 20 |
21 namespace base { | 21 namespace base { |
22 class ListValue; | 22 class ListValue; |
23 class SequencedTaskRunner; | 23 class SequencedTaskRunner; |
24 class Value; | 24 class Value; |
25 } | 25 } |
26 | 26 |
27 namespace data_reduction_proxy { | 27 namespace data_reduction_proxy { |
28 | 28 |
29 // Data reduction proxy delayed pref service reduces the number calls to pref | 29 // Data reduction proxy delayed pref service reduces the number calls to pref |
30 // service by storing prefs in memory and writing to the given PrefService after | 30 // service by storing prefs in memory and writing to the given PrefService after |
31 // |delay| amount of time. If |delay| is zero, the delayed pref service writes | 31 // |delay| amount of time. If |delay| is zero, the delayed pref service writes |
32 // directly to the PrefService and does not store the prefs in memory. All | 32 // directly to the PrefService and does not store the prefs in memory. All |
33 // prefs must be stored and read on the UI thread. | 33 // prefs must be stored and read on the UI thread. |
34 // TODO(bengr): Rename as DataReductionProxyCompressionStats. | 34 class DataReductionProxyCompressionStats { |
35 class DataReductionProxyStatisticsPrefs { | 35 public: |
36 public: | |
37 // Constructs a data reduction proxy delayed pref service object using | 36 // Constructs a data reduction proxy delayed pref service object using |
38 // |pref_service|. Writes prefs to |pref_service| after |delay| | 37 // |pref_service|. Writes prefs to |pref_service| after |delay| |
39 // and stores them in |pref_map_| and |list_pref_map| between writes. | 38 // and stores them in |pref_map_| and |list_pref_map| between writes. |
40 // If |delay| is zero, writes directly to the PrefService and does not store | 39 // If |delay| is zero, writes directly to the PrefService and does not store |
41 // in the maps. | 40 // in the maps. |
42 DataReductionProxyStatisticsPrefs( | 41 DataReductionProxyCompressionStats( |
43 PrefService* pref_service, | 42 PrefService* pref_service, |
44 scoped_refptr<base::SequencedTaskRunner> task_runner, | 43 scoped_refptr<base::SequencedTaskRunner> task_runner, |
45 const base::TimeDelta& delay); | 44 const base::TimeDelta& delay); |
46 ~DataReductionProxyStatisticsPrefs(); | 45 ~DataReductionProxyCompressionStats(); |
47 | 46 |
48 // Loads all data_reduction_proxy::prefs into the |pref_map_| and | 47 // Loads all data_reduction_proxy::prefs into the |pref_map_| and |
49 // |list_pref_map_|. | 48 // |list_pref_map_|. |
50 void Init(); | 49 void Init(); |
51 | 50 |
52 void OnUpdateContentLengths(); | 51 void OnUpdateContentLengths(); |
53 | 52 |
54 // Gets the int64 pref at |pref_path| from the |DataReductionProxyPrefMap|. | 53 // Gets the int64 pref at |pref_path| from the |DataReductionProxyPrefMap|. |
55 int64 GetInt64(const char* pref_path); | 54 int64 GetInt64(const char* pref_path); |
56 | 55 |
57 // Updates the pref value in the |DataReductionProxyPrefMap| map. | 56 // Updates the pref value in the |DataReductionProxyPrefMap| map. |
58 // The pref is later written to |pref service_|. | 57 // The pref is later written to |pref service_|. |
59 void SetInt64(const char* pref_path, int64 pref_value); | 58 void SetInt64(const char* pref_path, int64 pref_value); |
60 | 59 |
61 // Gets the pref list at |pref_path| from the |DataReductionProxyPrefMap|. | 60 // Gets the pref list at |pref_path| from the |DataReductionProxyPrefMap|. |
62 base::ListValue* GetList(const char* pref_path); | 61 base::ListValue* GetList(const char* pref_path); |
63 | 62 |
64 // Writes the prefs stored in |DataReductionProxyPrefMap| and | 63 // Writes the prefs stored in |DataReductionProxyPrefMap| and |
65 // |DataReductionProxyListPrefMap| to |pref_service|. | 64 // |DataReductionProxyListPrefMap| to |pref_service|. |
66 void WritePrefs(); | 65 void WritePrefs(); |
67 | 66 |
68 // Creates a |Value| summary of the persistent state of the network session. | 67 // Creates a |Value| summary of the persistent state of the network session. |
69 // The caller is responsible for deleting the returned value. | 68 // The caller is responsible for deleting the returned value. |
70 // Must be called on the UI thread. | 69 // Must be called on the UI thread. |
71 base::Value* HistoricNetworkStatsInfoToValue(); | 70 base::Value* HistoricNetworkStatsInfoToValue(); |
72 | 71 |
73 base::WeakPtr<DataReductionProxyStatisticsPrefs> GetWeakPtr(); | 72 base::WeakPtr<DataReductionProxyCompressionStats> GetWeakPtr(); |
74 | 73 |
75 private: | 74 private: |
76 typedef std::map<const char*, int64> DataReductionProxyPrefMap; | 75 typedef std::map<const char*, int64> DataReductionProxyPrefMap; |
77 typedef base::ScopedPtrHashMap<const char*, base::ListValue> | 76 typedef base::ScopedPtrHashMap<const char*, base::ListValue> |
78 DataReductionProxyListPrefMap; | 77 DataReductionProxyListPrefMap; |
79 | 78 |
80 // Gets the value of |pref| from the pref service and adds it to the | 79 // Gets the value of |pref| from the pref service and adds it to the |
81 // |pref_map|. | 80 // |pref_map|. |
82 void InitInt64Pref(const char* pref); | 81 void InitInt64Pref(const char* pref); |
83 | 82 |
84 // Gets the value of |pref| from the pref service and adds it to the | 83 // Gets the value of |pref| from the pref service and adds it to the |
85 // |list_pref_map|. | 84 // |list_pref_map|. |
(...skipping 17 matching lines...) Expand all Loading... |
103 | 102 |
104 PrefService* pref_service_; | 103 PrefService* pref_service_; |
105 scoped_refptr<base::SequencedTaskRunner> task_runner_; | 104 scoped_refptr<base::SequencedTaskRunner> task_runner_; |
106 const base::TimeDelta delay_; | 105 const base::TimeDelta delay_; |
107 bool delayed_task_posted_; | 106 bool delayed_task_posted_; |
108 DataReductionProxyPrefMap pref_map_; | 107 DataReductionProxyPrefMap pref_map_; |
109 DataReductionProxyListPrefMap list_pref_map_; | 108 DataReductionProxyListPrefMap list_pref_map_; |
110 scoped_ptr<PrefChangeRegistrar> pref_change_registrar_; | 109 scoped_ptr<PrefChangeRegistrar> pref_change_registrar_; |
111 base::ThreadChecker thread_checker_; | 110 base::ThreadChecker thread_checker_; |
112 | 111 |
113 base::WeakPtrFactory<DataReductionProxyStatisticsPrefs> weak_factory_; | 112 base::WeakPtrFactory<DataReductionProxyCompressionStats> weak_factory_; |
114 | 113 |
115 DISALLOW_COPY_AND_ASSIGN(DataReductionProxyStatisticsPrefs); | 114 DISALLOW_COPY_AND_ASSIGN(DataReductionProxyCompressionStats); |
116 }; | 115 }; |
117 | 116 |
118 } // namespace data_reduction_proxy | 117 } // namespace data_reduction_proxy |
119 | 118 |
120 #endif // COMPONENTS_DATA_REDUCTION_PROXY_CORE_BROWSER_DATA_REDUCTION_PROXY_STA
TISTICS_PREFS_H_ | 119 #endif // COMPONENTS_DATA_REDUCTION_PROXY_CORE_BROWSER_DATA_REDUCTION_PROXY_COM
PRESSION_STATS_H_ |
OLD | NEW |