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_BROWSER_DATA_REDUCTION_PROXY_USAGE_STATS
_H_ | 5 #ifndef COMPONENTS_DATA_REDUCTION_PROXY_BROWSER_DATA_REDUCTION_PROXY_USAGE_STATS
_H_ |
6 #define COMPONENTS_DATA_REDUCTION_PROXY_BROWSER_DATA_REDUCTION_PROXY_USAGE_STATS
_H_ | 6 #define COMPONENTS_DATA_REDUCTION_PROXY_BROWSER_DATA_REDUCTION_PROXY_USAGE_STATS
_H_ |
7 | 7 |
8 #include "base/message_loop/message_loop_proxy.h" | 8 #include "base/message_loop/message_loop_proxy.h" |
| 9 #include "base/prefs/pref_member.h" |
9 #include "base/threading/thread_checker.h" | 10 #include "base/threading/thread_checker.h" |
10 #include "components/data_reduction_proxy/browser/data_reduction_proxy_params.h" | 11 #include "components/data_reduction_proxy/browser/data_reduction_proxy_params.h" |
11 #include "net/base/host_port_pair.h" | 12 #include "net/base/host_port_pair.h" |
12 #include "net/base/network_change_notifier.h" | 13 #include "net/base/network_change_notifier.h" |
| 14 #include "net/proxy/proxy_service.h" |
13 | 15 |
14 namespace data_reduction_proxy { | 16 namespace data_reduction_proxy { |
15 | 17 |
16 class DataReductionProxyUsageStats | 18 class DataReductionProxyUsageStats |
17 : public net::NetworkChangeNotifier::NetworkChangeObserver { | 19 : public net::NetworkChangeNotifier::NetworkChangeObserver { |
18 public: | 20 public: |
19 // MessageLoopProxy instances are owned by io_thread. |params| outlives | 21 // MessageLoopProxy instances are owned by io_thread. |params| outlives |
20 // this class instance. | 22 // this class instance. |
21 DataReductionProxyUsageStats(DataReductionProxyParams* params, | 23 DataReductionProxyUsageStats(DataReductionProxyParams* params, |
22 base::MessageLoopProxy* ui_thread_proxy, | 24 base::MessageLoopProxy* ui_thread_proxy, |
23 base::MessageLoopProxy* io_thread_proxy); | 25 base::MessageLoopProxy* io_thread_proxy); |
24 virtual ~DataReductionProxyUsageStats(); | 26 virtual ~DataReductionProxyUsageStats(); |
25 | 27 |
26 /** | 28 // Callback intended to be called from |ChromeNetworkDelegate| when a |
27 * Callback intended to be called from |ChromeNetworkDelegate| when a | 29 // request completes. This method is used to gather usage stats. |
28 * request completes. This method is used to gather usage stats. | |
29 */ | |
30 void OnUrlRequestCompleted(const net::URLRequest* request, bool started); | 30 void OnUrlRequestCompleted(const net::URLRequest* request, bool started); |
31 | 31 |
32 /** | 32 // Determines whether the data reduction proxy is unreachable. |
33 * Determines whether the data reduction proxy is unreachable. | 33 // Returns true if data reduction proxy is unreachable. |
34 * Returns true if data reduction proxy is unreachable. | |
35 */ | |
36 bool isDataReductionProxyUnreachable(); | 34 bool isDataReductionProxyUnreachable(); |
37 | 35 |
| 36 // Records the last bypass reason to |bypass_type_| and sets |
| 37 // |triggering_request_| to true. |
| 38 void SetBypassType(net::ProxyService::DataReductionProxyBypassType type); |
| 39 |
| 40 // Records the number of bypassed bytes for various bypass reasons into their |
| 41 // respective UMAs. |
| 42 void RecordBypassedBytesHistograms(const int64 content_length, |
| 43 const net::URLRequest* request); |
| 44 |
38 private: | 45 private: |
39 DataReductionProxyParams* data_reduction_proxy_params_; | 46 DataReductionProxyParams* data_reduction_proxy_params_; |
| 47 net::ProxyService::DataReductionProxyBypassType bypass_type_; |
| 48 bool triggering_request_; |
40 base::MessageLoopProxy* ui_thread_proxy_; | 49 base::MessageLoopProxy* ui_thread_proxy_; |
41 base::MessageLoopProxy* io_thread_proxy_; | 50 base::MessageLoopProxy* io_thread_proxy_; |
42 | 51 |
43 // The following 2 fields are used to determine if data reduction proxy is | 52 // The following 2 fields are used to determine if data reduction proxy is |
44 // unreachable. We keep a count of requests which should go through | 53 // unreachable. We keep a count of requests which should go through |
45 // data request proxy, as well as those which actually do. The proxy is | 54 // data request proxy, as well as those which actually do. The proxy is |
46 // unreachable if no successful requests are made through it despite a | 55 // unreachable if no successful requests are made through it despite a |
47 // non-zero number of requests being eligible. | 56 // non-zero number of requests being eligible. |
48 | 57 |
49 // Count of requests which will be tried to be sent through data reduction | 58 // Count of requests which will be tried to be sent through data reduction |
50 // proxy. The count is only based on the config and not the bad proxy list. | 59 // proxy. The count is only based on the config and not the bad proxy list. |
51 // Explicit bypasses are not part of this count. This is the desired behavior | 60 // Explicit bypasses are not part of this count. This is the desired behavior |
52 // since otherwise both counts would be identical. | 61 // since otherwise both counts would be identical. |
53 unsigned long eligible_num_requests_through_proxy_; | 62 unsigned long eligible_num_requests_through_proxy_; |
54 // Count of successfull requests through data reduction proxy. | 63 // Count of successfull requests through data reduction proxy. |
55 unsigned long actual_num_requests_through_proxy_; | 64 unsigned long actual_num_requests_through_proxy_; |
56 | 65 |
57 // NetworkChangeNotifier::NetworkChangeObserver: | 66 // NetworkChangeNotifier::NetworkChangeObserver: |
58 virtual void OnNetworkChanged( | 67 virtual void OnNetworkChanged( |
59 net::NetworkChangeNotifier::ConnectionType type) OVERRIDE; | 68 net::NetworkChangeNotifier::ConnectionType type) OVERRIDE; |
60 | 69 |
61 void IncRequestCountsOnUiThread(bool actual); | 70 void IncRequestCountsOnUiThread(bool actual); |
62 void ClearRequestCountsOnUiThread(); | 71 void ClearRequestCountsOnUiThread(); |
63 | 72 |
64 base::ThreadChecker thread_checker_; | 73 base::ThreadChecker thread_checker_; |
65 | 74 |
| 75 void RecordTriggeringRequestBypassedBytes( |
| 76 net::ProxyService::DataReductionProxyBypassType bypass_type, |
| 77 int64 content_length); |
| 78 void RecordNetworkErrorBypassedBytes(const net::URLRequest* request, |
| 79 int64 content_length); |
| 80 void RecordBypassedBytes( |
| 81 net::ProxyService::DataReductionProxyBypassType bypass_type, |
| 82 int64 content_length); |
| 83 |
66 DISALLOW_COPY_AND_ASSIGN(DataReductionProxyUsageStats); | 84 DISALLOW_COPY_AND_ASSIGN(DataReductionProxyUsageStats); |
67 }; | 85 }; |
68 | 86 |
69 } // namespace data_reduction_proxy | 87 } // namespace data_reduction_proxy |
70 | 88 |
71 #endif // COMPONENTS_DATA_REDUCTION_PROXY_BROWSER_DATA_REDUCTION_PROXY_USAGE_ST
ATS_H_ | 89 #endif // COMPONENTS_DATA_REDUCTION_PROXY_BROWSER_DATA_REDUCTION_PROXY_USAGE_ST
ATS_H_ |
OLD | NEW |