Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(157)

Side by Side Diff: components/network_time/network_time_tracker.h

Issue 2453523002: Add NetworkTimeTracker::StartTimeFetch() for on-demand time queries (Closed)
Patch Set: Created 4 years, 1 month ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
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_NETWORK_TIME_NETWORK_TIME_TRACKER_H_ 5 #ifndef COMPONENTS_NETWORK_TIME_NETWORK_TIME_TRACKER_H_
6 #define COMPONENTS_NETWORK_TIME_NETWORK_TIME_TRACKER_H_ 6 #define COMPONENTS_NETWORK_TIME_NETWORK_TIME_TRACKER_H_
7 7
8 #include <stdint.h> 8 #include <stdint.h>
9 #include <memory> 9 #include <memory>
10 10
11 #include "base/feature_list.h" 11 #include "base/feature_list.h"
12 #include "base/gtest_prod_util.h" 12 #include "base/gtest_prod_util.h"
13 #include "base/macros.h" 13 #include "base/macros.h"
14 #include "base/memory/ref_counted.h" 14 #include "base/memory/ref_counted.h"
15 #include "base/threading/thread_checker.h" 15 #include "base/threading/thread_checker.h"
16 #include "base/time/clock.h" 16 #include "base/time/clock.h"
17 #include "base/time/time.h" 17 #include "base/time/time.h"
18 #include "base/timer/timer.h" 18 #include "base/timer/timer.h"
19 #include "net/url_request/url_fetcher_delegate.h" 19 #include "net/url_request/url_fetcher_delegate.h"
20 #include "url/gurl.h" 20 #include "url/gurl.h"
21 21
22 class PrefRegistrySimple; 22 class PrefRegistrySimple;
23 class PrefService; 23 class PrefService;
24 24
25 namespace base { 25 namespace base {
26 class RunLoop;
27 class TickClock; 26 class TickClock;
28 } // namespace base 27 } // namespace base
29 28
30 namespace client_update_protocol { 29 namespace client_update_protocol {
31 class Ecdsa; 30 class Ecdsa;
32 } // namespace client_update_protocol 31 } // namespace client_update_protocol
33 32
34 namespace net { 33 namespace net {
35 class URLFetcher; 34 class URLFetcher;
36 class URLRequestContextGetter; 35 class URLRequestContextGetter;
(...skipping 62 matching lines...) Expand 10 before | Expand all | Expand 10 after
99 // 98 //
100 // Network time may be available on startup if deserialized from a pref. 99 // Network time may be available on startup if deserialized from a pref.
101 // Failing that, a call to |UpdateNetworkTime| is required to make time 100 // Failing that, a call to |UpdateNetworkTime| is required to make time
102 // available to callers of |GetNetworkTime|. Subsequently, network time may 101 // available to callers of |GetNetworkTime|. Subsequently, network time may
103 // become unavailable if |NetworkTimeTracker| has reason to believe it is no 102 // become unavailable if |NetworkTimeTracker| has reason to believe it is no
104 // longer accurate. Consumers should even be prepared to handle the case 103 // longer accurate. Consumers should even be prepared to handle the case
105 // where calls to |GetNetworkTime| never once succeeds. 104 // where calls to |GetNetworkTime| never once succeeds.
106 NetworkTimeResult GetNetworkTime(base::Time* network_time, 105 NetworkTimeResult GetNetworkTime(base::Time* network_time,
107 base::TimeDelta* uncertainty) const; 106 base::TimeDelta* uncertainty) const;
108 107
108 // Starts a network time query if network time isn't already available
109 // and if there isn't already a time query in progress. If a new query
110 // is started or if there is one already in progress, |callback| will
111 // run when the query completes.
112 //
113 // Returns true if a time query is started or was already in progress,
114 // and false otherwise. For example, this method may return false if
115 // time queries are disabled or if network time is already available.
116 bool StartTimeFetch(const base::Closure& callback);
117
109 // Calculates corresponding time ticks according to the given parameters. 118 // Calculates corresponding time ticks according to the given parameters.
110 // The provided |network_time| is precise at the given |resolution| and 119 // The provided |network_time| is precise at the given |resolution| and
111 // represent the time between now and up to |latency| + (now - |post_time|) 120 // represent the time between now and up to |latency| + (now - |post_time|)
112 // ago. 121 // ago.
113 void UpdateNetworkTime(base::Time network_time, 122 void UpdateNetworkTime(base::Time network_time,
114 base::TimeDelta resolution, 123 base::TimeDelta resolution,
115 base::TimeDelta latency, 124 base::TimeDelta latency,
116 base::TimeTicks post_time); 125 base::TimeTicks post_time);
117 126
118 void SetMaxResponseSizeForTesting(size_t limit); 127 void SetMaxResponseSizeForTesting(size_t limit);
(...skipping 35 matching lines...) Expand 10 before | Expand all | Expand 10 after
154 base::TimeDelta backoff_; 163 base::TimeDelta backoff_;
155 // Timer that runs CheckTime(). All backoff and delay is implemented by 164 // Timer that runs CheckTime(). All backoff and delay is implemented by
156 // changing the delay of this timer, with the result that CheckTime() may 165 // changing the delay of this timer, with the result that CheckTime() may
157 // assume that if it runs, it is eligible to issue a time query. 166 // assume that if it runs, it is eligible to issue a time query.
158 base::RepeatingTimer timer_; 167 base::RepeatingTimer timer_;
159 scoped_refptr<net::URLRequestContextGetter> getter_; 168 scoped_refptr<net::URLRequestContextGetter> getter_;
160 std::unique_ptr<net::URLFetcher> time_fetcher_; 169 std::unique_ptr<net::URLFetcher> time_fetcher_;
161 base::TimeTicks fetch_started_; 170 base::TimeTicks fetch_started_;
162 std::unique_ptr<client_update_protocol::Ecdsa> query_signer_; 171 std::unique_ptr<client_update_protocol::Ecdsa> query_signer_;
163 172
164 // Run by WaitForFetchForTesting() and quit by OnURLFetchComplete().
165 base::RunLoop* run_loop_for_testing_ = nullptr;
166
167 // The |Clock| and |TickClock| are used to sanity-check one another, allowing 173 // The |Clock| and |TickClock| are used to sanity-check one another, allowing
168 // the NetworkTimeTracker to notice e.g. suspend/resume events and clock 174 // the NetworkTimeTracker to notice e.g. suspend/resume events and clock
169 // resets. 175 // resets.
170 std::unique_ptr<base::Clock> clock_; 176 std::unique_ptr<base::Clock> clock_;
171 std::unique_ptr<base::TickClock> tick_clock_; 177 std::unique_ptr<base::TickClock> tick_clock_;
172 178
173 PrefService* pref_service_; 179 PrefService* pref_service_;
174 180
175 // Network time based on last call to UpdateNetworkTime(). 181 // Network time based on last call to UpdateNetworkTime().
176 mutable base::Time network_time_at_last_measurement_; 182 mutable base::Time network_time_at_last_measurement_;
177 183
178 // The estimated local times that correspond with |network_time_|. Assumes 184 // The estimated local times that correspond with |network_time_|. Assumes
179 // the actual network time measurement was performed midway through the 185 // the actual network time measurement was performed midway through the
180 // latency time. See UpdateNetworkTime(...) implementation for details. The 186 // latency time. See UpdateNetworkTime(...) implementation for details. The
181 // tick clock is the one actually used to return values to callers, but both 187 // tick clock is the one actually used to return values to callers, but both
182 // clocks must agree to within some tolerance. 188 // clocks must agree to within some tolerance.
183 base::Time time_at_last_measurement_; 189 base::Time time_at_last_measurement_;
184 base::TimeTicks ticks_at_last_measurement_; 190 base::TimeTicks ticks_at_last_measurement_;
185 191
186 // Uncertainty of |network_time_| based on added inaccuracies/resolution. See 192 // Uncertainty of |network_time_| based on added inaccuracies/resolution. See
187 // UpdateNetworkTime(...) implementation for details. 193 // UpdateNetworkTime(...) implementation for details.
188 base::TimeDelta network_time_uncertainty_; 194 base::TimeDelta network_time_uncertainty_;
189 195
190 // True if any time query has completed (but not necessarily succeeded) in 196 // True if any time query has completed (but not necessarily succeeded) in
191 // this NetworkTimeTracker's lifetime. 197 // this NetworkTimeTracker's lifetime.
192 bool time_query_completed_; 198 bool time_query_completed_;
193 199
200 // Callbacks to run when the in-progress time fetch completes.
201 std::vector<base::Closure> fetch_completion_callbacks_;
202
194 base::ThreadChecker thread_checker_; 203 base::ThreadChecker thread_checker_;
195 204
196 DISALLOW_COPY_AND_ASSIGN(NetworkTimeTracker); 205 DISALLOW_COPY_AND_ASSIGN(NetworkTimeTracker);
197 }; 206 };
198 207
199 } // namespace network_time 208 } // namespace network_time
200 209
201 #endif // COMPONENTS_NETWORK_TIME_NETWORK_TIME_TRACKER_H_ 210 #endif // COMPONENTS_NETWORK_TIME_NETWORK_TIME_TRACKER_H_
OLDNEW
« no previous file with comments | « no previous file | components/network_time/network_time_tracker.cc » ('j') | components/network_time/network_time_tracker.cc » ('J')

Powered by Google App Engine
This is Rietveld 408576698