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 #include "components/domain_reliability/monitor.h" | 5 #include "components/domain_reliability/monitor.h" |
6 | 6 |
7 #include "base/command_line.h" | 7 #include "base/command_line.h" |
8 #include "base/logging.h" | 8 #include "base/logging.h" |
9 #include "base/profiler/scoped_tracker.h" | 9 #include "base/profiler/scoped_tracker.h" |
10 #include "base/single_thread_task_runner.h" | 10 #include "base/single_thread_task_runner.h" |
11 #include "base/task_runner.h" | 11 #include "base/task_runner.h" |
12 #include "base/time/time.h" | 12 #include "base/time/time.h" |
13 #include "components/domain_reliability/baked_in_configs.h" | 13 #include "components/domain_reliability/baked_in_configs.h" |
14 #include "net/base/load_flags.h" | 14 #include "net/base/load_flags.h" |
15 #include "net/http/http_response_headers.h" | 15 #include "net/http/http_response_headers.h" |
16 #include "net/url_request/url_request.h" | 16 #include "net/url_request/url_request.h" |
17 #include "net/url_request/url_request_context.h" | 17 #include "net/url_request/url_request_context.h" |
18 #include "net/url_request/url_request_context_getter.h" | 18 #include "net/url_request/url_request_context_getter.h" |
19 | 19 |
20 namespace domain_reliability { | 20 namespace domain_reliability { |
21 | 21 |
22 DomainReliabilityMonitor::DomainReliabilityMonitor( | 22 DomainReliabilityMonitor::DomainReliabilityMonitor( |
23 const std::string& upload_reporter_string, | 23 const std::string& upload_reporter_string, |
24 scoped_refptr<base::SingleThreadTaskRunner> pref_thread, | 24 const scoped_refptr<base::SingleThreadTaskRunner>& pref_thread, |
25 scoped_refptr<base::SingleThreadTaskRunner> network_thread) | 25 const scoped_refptr<base::SingleThreadTaskRunner>& network_thread) |
26 : time_(new ActualTime()), | 26 : time_(new ActualTime()), |
27 upload_reporter_string_(upload_reporter_string), | 27 upload_reporter_string_(upload_reporter_string), |
28 scheduler_params_( | 28 scheduler_params_( |
29 DomainReliabilityScheduler::Params::GetFromFieldTrialsOrDefaults()), | 29 DomainReliabilityScheduler::Params::GetFromFieldTrialsOrDefaults()), |
30 dispatcher_(time_.get()), | 30 dispatcher_(time_.get()), |
31 pref_task_runner_(pref_thread), | 31 pref_task_runner_(pref_thread), |
32 network_task_runner_(network_thread), | 32 network_task_runner_(network_thread), |
33 moved_to_network_thread_(false), | 33 moved_to_network_thread_(false), |
34 discard_uploads_set_(false), | 34 discard_uploads_set_(false), |
35 weak_factory_(this) { | 35 weak_factory_(this) { |
36 DCHECK(OnPrefThread()); | 36 DCHECK(OnPrefThread()); |
37 net::NetworkChangeNotifier::AddNetworkChangeObserver(this); | 37 net::NetworkChangeNotifier::AddNetworkChangeObserver(this); |
38 } | 38 } |
39 | 39 |
40 DomainReliabilityMonitor::DomainReliabilityMonitor( | 40 DomainReliabilityMonitor::DomainReliabilityMonitor( |
41 const std::string& upload_reporter_string, | 41 const std::string& upload_reporter_string, |
42 scoped_refptr<base::SingleThreadTaskRunner> pref_thread, | 42 const scoped_refptr<base::SingleThreadTaskRunner>& pref_thread, |
43 scoped_refptr<base::SingleThreadTaskRunner> network_thread, | 43 const scoped_refptr<base::SingleThreadTaskRunner>& network_thread, |
44 scoped_ptr<MockableTime> time) | 44 scoped_ptr<MockableTime> time) |
45 : time_(time.Pass()), | 45 : time_(time.Pass()), |
46 upload_reporter_string_(upload_reporter_string), | 46 upload_reporter_string_(upload_reporter_string), |
47 scheduler_params_( | 47 scheduler_params_( |
48 DomainReliabilityScheduler::Params::GetFromFieldTrialsOrDefaults()), | 48 DomainReliabilityScheduler::Params::GetFromFieldTrialsOrDefaults()), |
49 dispatcher_(time_.get()), | 49 dispatcher_(time_.get()), |
50 pref_task_runner_(pref_thread), | 50 pref_task_runner_(pref_thread), |
51 network_task_runner_(network_thread), | 51 network_task_runner_(network_thread), |
52 moved_to_network_thread_(false), | 52 moved_to_network_thread_(false), |
53 discard_uploads_set_(false), | 53 discard_uploads_set_(false), |
(...skipping 29 matching lines...) Expand all Loading... |
83 DCHECK(OnNetworkThread()); | 83 DCHECK(OnNetworkThread()); |
84 DCHECK(moved_to_network_thread_); | 84 DCHECK(moved_to_network_thread_); |
85 | 85 |
86 scoped_refptr<net::URLRequestContextGetter> url_request_context_getter = | 86 scoped_refptr<net::URLRequestContextGetter> url_request_context_getter = |
87 new net::TrivialURLRequestContextGetter(url_request_context, | 87 new net::TrivialURLRequestContextGetter(url_request_context, |
88 network_task_runner_); | 88 network_task_runner_); |
89 InitURLRequestContext(url_request_context_getter); | 89 InitURLRequestContext(url_request_context_getter); |
90 } | 90 } |
91 | 91 |
92 void DomainReliabilityMonitor::InitURLRequestContext( | 92 void DomainReliabilityMonitor::InitURLRequestContext( |
93 scoped_refptr<net::URLRequestContextGetter> url_request_context_getter) { | 93 const scoped_refptr<net::URLRequestContextGetter>& |
| 94 url_request_context_getter) { |
94 DCHECK(OnNetworkThread()); | 95 DCHECK(OnNetworkThread()); |
95 DCHECK(moved_to_network_thread_); | 96 DCHECK(moved_to_network_thread_); |
96 | 97 |
97 // Make sure the URLRequestContext actually lives on what was declared to be | 98 // Make sure the URLRequestContext actually lives on what was declared to be |
98 // the network thread. | 99 // the network thread. |
99 DCHECK(url_request_context_getter->GetNetworkTaskRunner()-> | 100 DCHECK(url_request_context_getter->GetNetworkTaskRunner()-> |
100 RunsTasksOnCurrentThread()); | 101 RunsTasksOnCurrentThread()); |
101 | 102 |
102 uploader_ = DomainReliabilityUploader::Create(time_.get(), | 103 uploader_ = DomainReliabilityUploader::Create(time_.get(), |
103 url_request_context_getter); | 104 url_request_context_getter); |
104 } | 105 } |
105 | 106 |
106 void DomainReliabilityMonitor::AddBakedInConfigs() { | 107 void DomainReliabilityMonitor::AddBakedInConfigs() { |
107 // TODO(vadimt): Remove ScopedTracker below once crbug.com/436671 is fixed. | 108 // TODO(vadimt): Remove ScopedTracker below once crbug.com/436671 is fixed. |
108 tracked_objects::ScopedTracker tracking_profile( | 109 tracked_objects::ScopedTracker tracking_profile( |
109 FROM_HERE_WITH_EXPLICIT_FUNCTION( | 110 FROM_HERE_WITH_EXPLICIT_FUNCTION( |
110 "436671 DomainReliabilityMonitor::AddBakedInConfigs")); | 111 "436671 DomainReliabilityMonitor::AddBakedInConfigs")); |
111 | 112 |
112 DCHECK(OnNetworkThread()); | 113 DCHECK(OnNetworkThread()); |
113 DCHECK(moved_to_network_thread_); | 114 DCHECK(moved_to_network_thread_); |
114 | 115 |
115 base::Time now = base::Time::Now(); | 116 base::Time now = base::Time::Now(); |
116 for (size_t i = 0; kBakedInJsonConfigs[i]; ++i) { | 117 for (size_t i = 0; kBakedInJsonConfigs[i]; ++i) { |
117 std::string json(kBakedInJsonConfigs[i]); | 118 base::StringPiece json(kBakedInJsonConfigs[i]); |
118 scoped_ptr<const DomainReliabilityConfig> config = | 119 scoped_ptr<const DomainReliabilityConfig> config = |
119 DomainReliabilityConfig::FromJSON(json); | 120 DomainReliabilityConfig::FromJSON(json); |
120 if (config && config->IsExpired(now)) { | 121 if (!config) { |
| 122 continue; |
| 123 } else if (config->IsExpired(now)) { |
121 LOG(WARNING) << "Baked-in Domain Reliability config for " | 124 LOG(WARNING) << "Baked-in Domain Reliability config for " |
122 << config->domain << " is expired."; | 125 << config->domain << " is expired."; |
123 continue; | 126 continue; |
124 } | 127 } |
125 AddContext(config.Pass()); | 128 AddContext(config.Pass()); |
126 } | 129 } |
127 } | 130 } |
128 | 131 |
129 void DomainReliabilityMonitor::SetDiscardUploads(bool discard_uploads) { | 132 void DomainReliabilityMonitor::SetDiscardUploads(bool discard_uploads) { |
130 DCHECK(OnNetworkThread()); | 133 DCHECK(OnNetworkThread()); |
(...skipping 214 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
345 | 348 |
346 return NULL; | 349 return NULL; |
347 } | 350 } |
348 | 351 |
349 base::WeakPtr<DomainReliabilityMonitor> | 352 base::WeakPtr<DomainReliabilityMonitor> |
350 DomainReliabilityMonitor::MakeWeakPtr() { | 353 DomainReliabilityMonitor::MakeWeakPtr() { |
351 return weak_factory_.GetWeakPtr(); | 354 return weak_factory_.GetWeakPtr(); |
352 } | 355 } |
353 | 356 |
354 } // namespace domain_reliability | 357 } // namespace domain_reliability |
OLD | NEW |