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/network_time/network_time_tracker.h" | 5 #include "components/network_time/network_time_tracker.h" |
6 | 6 |
7 #include <map> | 7 #include <map> |
8 #include <memory> | 8 #include <memory> |
9 #include <string> | 9 #include <string> |
10 #include <utility> | 10 #include <utility> |
(...skipping 214 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
225 TestingPrefServiceSimple pref_service_; | 225 TestingPrefServiceSimple pref_service_; |
226 std::unique_ptr<base::FieldTrialList> field_trial_list_; | 226 std::unique_ptr<base::FieldTrialList> field_trial_list_; |
227 std::unique_ptr<NetworkTimeTracker> tracker_; | 227 std::unique_ptr<NetworkTimeTracker> tracker_; |
228 std::unique_ptr<net::EmbeddedTestServer> test_server_; | 228 std::unique_ptr<net::EmbeddedTestServer> test_server_; |
229 std::unique_ptr<base::test::ScopedFeatureList> scoped_feature_list_; | 229 std::unique_ptr<base::test::ScopedFeatureList> scoped_feature_list_; |
230 }; | 230 }; |
231 | 231 |
232 TEST_F(NetworkTimeTrackerTest, Uninitialized) { | 232 TEST_F(NetworkTimeTrackerTest, Uninitialized) { |
233 base::Time network_time; | 233 base::Time network_time; |
234 base::TimeDelta uncertainty; | 234 base::TimeDelta uncertainty; |
235 EXPECT_FALSE(tracker_->GetNetworkTime(&network_time, &uncertainty)); | 235 EXPECT_EQ(NetworkTimeTracker::NETWORK_TIME_NO_SYNC, |
| 236 tracker_->GetNetworkTime(&network_time, &uncertainty)); |
236 } | 237 } |
237 | 238 |
238 TEST_F(NetworkTimeTrackerTest, LongPostingDelay) { | 239 TEST_F(NetworkTimeTrackerTest, LongPostingDelay) { |
239 // The request arrives at the server, which records the time. Advance the | 240 // The request arrives at the server, which records the time. Advance the |
240 // clock to simulate the latency of sending the reply, which we'll say for | 241 // clock to simulate the latency of sending the reply, which we'll say for |
241 // convenience is half the total latency. | 242 // convenience is half the total latency. |
242 base::Time in_network_time = clock_->Now(); | 243 base::Time in_network_time = clock_->Now(); |
243 AdvanceBoth(latency_ / 2); | 244 AdvanceBoth(latency_ / 2); |
244 | 245 |
245 // Record the tick counter at the time the reply is received. At this point, | 246 // Record the tick counter at the time the reply is received. At this point, |
246 // we would post UpdateNetworkTime to be run on the browser thread. | 247 // we would post UpdateNetworkTime to be run on the browser thread. |
247 base::TimeTicks posting_time = tick_clock_->NowTicks(); | 248 base::TimeTicks posting_time = tick_clock_->NowTicks(); |
248 | 249 |
249 // Simulate that it look a long time (1888us) for the browser thread to get | 250 // Simulate that it look a long time (1888us) for the browser thread to get |
250 // around to executing the update. | 251 // around to executing the update. |
251 AdvanceBoth(base::TimeDelta::FromMicroseconds(1888)); | 252 AdvanceBoth(base::TimeDelta::FromMicroseconds(1888)); |
252 UpdateNetworkTime(in_network_time, resolution_, latency_, posting_time); | 253 UpdateNetworkTime(in_network_time, resolution_, latency_, posting_time); |
253 | 254 |
254 base::Time out_network_time; | 255 base::Time out_network_time; |
255 base::TimeDelta uncertainty; | 256 base::TimeDelta uncertainty; |
256 EXPECT_TRUE(tracker_->GetNetworkTime(&out_network_time, &uncertainty)); | 257 EXPECT_EQ(NetworkTimeTracker::NETWORK_TIME_AVAILABLE, |
| 258 tracker_->GetNetworkTime(&out_network_time, &uncertainty)); |
257 EXPECT_EQ(resolution_ + latency_ + adjustment_, uncertainty); | 259 EXPECT_EQ(resolution_ + latency_ + adjustment_, uncertainty); |
258 EXPECT_EQ(clock_->Now(), out_network_time); | 260 EXPECT_EQ(clock_->Now(), out_network_time); |
259 } | 261 } |
260 | 262 |
261 TEST_F(NetworkTimeTrackerTest, LopsidedLatency) { | 263 TEST_F(NetworkTimeTrackerTest, LopsidedLatency) { |
262 // Simulate that the server received the request instantaneously, and that all | 264 // Simulate that the server received the request instantaneously, and that all |
263 // of the latency was in sending the reply. (This contradicts the assumption | 265 // of the latency was in sending the reply. (This contradicts the assumption |
264 // in the code.) | 266 // in the code.) |
265 base::Time in_network_time = clock_->Now(); | 267 base::Time in_network_time = clock_->Now(); |
266 AdvanceBoth(latency_); | 268 AdvanceBoth(latency_); |
267 UpdateNetworkTime(in_network_time, resolution_, latency_, | 269 UpdateNetworkTime(in_network_time, resolution_, latency_, |
268 tick_clock_->NowTicks()); | 270 tick_clock_->NowTicks()); |
269 | 271 |
270 // But, the answer is still within the uncertainty bounds! | 272 // But, the answer is still within the uncertainty bounds! |
271 base::Time out_network_time; | 273 base::Time out_network_time; |
272 base::TimeDelta uncertainty; | 274 base::TimeDelta uncertainty; |
273 EXPECT_TRUE(tracker_->GetNetworkTime(&out_network_time, &uncertainty)); | 275 EXPECT_EQ(NetworkTimeTracker::NETWORK_TIME_AVAILABLE, |
| 276 tracker_->GetNetworkTime(&out_network_time, &uncertainty)); |
274 EXPECT_LT(out_network_time - uncertainty / 2, clock_->Now()); | 277 EXPECT_LT(out_network_time - uncertainty / 2, clock_->Now()); |
275 EXPECT_GT(out_network_time + uncertainty / 2, clock_->Now()); | 278 EXPECT_GT(out_network_time + uncertainty / 2, clock_->Now()); |
276 } | 279 } |
277 | 280 |
278 TEST_F(NetworkTimeTrackerTest, ClockIsWack) { | 281 TEST_F(NetworkTimeTrackerTest, ClockIsWack) { |
279 // Now let's assume the system clock is completely wrong. | 282 // Now let's assume the system clock is completely wrong. |
280 base::Time in_network_time = clock_->Now() - base::TimeDelta::FromDays(90); | 283 base::Time in_network_time = clock_->Now() - base::TimeDelta::FromDays(90); |
281 UpdateNetworkTime(in_network_time - latency_ / 2, resolution_, latency_, | 284 UpdateNetworkTime(in_network_time - latency_ / 2, resolution_, latency_, |
282 tick_clock_->NowTicks()); | 285 tick_clock_->NowTicks()); |
283 | 286 |
284 base::Time out_network_time; | 287 base::Time out_network_time; |
285 EXPECT_TRUE(tracker_->GetNetworkTime(&out_network_time, nullptr)); | 288 EXPECT_EQ(NetworkTimeTracker::NETWORK_TIME_AVAILABLE, |
| 289 tracker_->GetNetworkTime(&out_network_time, nullptr)); |
286 EXPECT_EQ(in_network_time, out_network_time); | 290 EXPECT_EQ(in_network_time, out_network_time); |
287 } | 291 } |
288 | 292 |
289 TEST_F(NetworkTimeTrackerTest, ClocksDivergeSlightly) { | 293 TEST_F(NetworkTimeTrackerTest, ClocksDivergeSlightly) { |
290 // The two clocks are allowed to diverge a little bit. | 294 // The two clocks are allowed to diverge a little bit. |
291 base::Time in_network_time = clock_->Now(); | 295 base::Time in_network_time = clock_->Now(); |
292 UpdateNetworkTime(in_network_time - latency_ / 2, resolution_, latency_, | 296 UpdateNetworkTime(in_network_time - latency_ / 2, resolution_, latency_, |
293 tick_clock_->NowTicks()); | 297 tick_clock_->NowTicks()); |
294 | 298 |
295 base::TimeDelta small = base::TimeDelta::FromSeconds(30); | 299 base::TimeDelta small = base::TimeDelta::FromSeconds(30); |
296 tick_clock_->Advance(small); | 300 tick_clock_->Advance(small); |
297 base::Time out_network_time; | 301 base::Time out_network_time; |
298 base::TimeDelta out_uncertainty; | 302 base::TimeDelta out_uncertainty; |
299 EXPECT_TRUE(tracker_->GetNetworkTime(&out_network_time, &out_uncertainty)); | 303 EXPECT_EQ(NetworkTimeTracker::NETWORK_TIME_AVAILABLE, |
| 304 tracker_->GetNetworkTime(&out_network_time, &out_uncertainty)); |
300 EXPECT_EQ(in_network_time + small, out_network_time); | 305 EXPECT_EQ(in_network_time + small, out_network_time); |
301 // The clock divergence should show up in the uncertainty. | 306 // The clock divergence should show up in the uncertainty. |
302 EXPECT_EQ(resolution_ + latency_ + adjustment_ + small, out_uncertainty); | 307 EXPECT_EQ(resolution_ + latency_ + adjustment_ + small, out_uncertainty); |
303 } | 308 } |
304 | 309 |
305 TEST_F(NetworkTimeTrackerTest, NetworkTimeUpdates) { | 310 TEST_F(NetworkTimeTrackerTest, NetworkTimeUpdates) { |
306 // Verify that the the tracker receives and properly handles updates to the | 311 // Verify that the the tracker receives and properly handles updates to the |
307 // network time. | 312 // network time. |
308 base::Time out_network_time; | 313 base::Time out_network_time; |
309 base::TimeDelta uncertainty; | 314 base::TimeDelta uncertainty; |
310 | 315 |
311 UpdateNetworkTime(clock_->Now() - latency_ / 2, resolution_, latency_, | 316 UpdateNetworkTime(clock_->Now() - latency_ / 2, resolution_, latency_, |
312 tick_clock_->NowTicks()); | 317 tick_clock_->NowTicks()); |
313 EXPECT_TRUE(tracker_->GetNetworkTime(&out_network_time, &uncertainty)); | 318 EXPECT_EQ(NetworkTimeTracker::NETWORK_TIME_AVAILABLE, |
| 319 tracker_->GetNetworkTime(&out_network_time, &uncertainty)); |
314 EXPECT_EQ(clock_->Now(), out_network_time); | 320 EXPECT_EQ(clock_->Now(), out_network_time); |
315 EXPECT_EQ(resolution_ + latency_ + adjustment_, uncertainty); | 321 EXPECT_EQ(resolution_ + latency_ + adjustment_, uncertainty); |
316 | 322 |
317 // Fake a wait to make sure we keep tracking. | 323 // Fake a wait to make sure we keep tracking. |
318 AdvanceBoth(base::TimeDelta::FromSeconds(1)); | 324 AdvanceBoth(base::TimeDelta::FromSeconds(1)); |
319 EXPECT_TRUE(tracker_->GetNetworkTime(&out_network_time, &uncertainty)); | 325 EXPECT_EQ(NetworkTimeTracker::NETWORK_TIME_AVAILABLE, |
| 326 tracker_->GetNetworkTime(&out_network_time, &uncertainty)); |
320 EXPECT_EQ(clock_->Now(), out_network_time); | 327 EXPECT_EQ(clock_->Now(), out_network_time); |
321 EXPECT_EQ(resolution_ + latency_ + adjustment_, uncertainty); | 328 EXPECT_EQ(resolution_ + latency_ + adjustment_, uncertainty); |
322 | 329 |
323 // And one more time. | 330 // And one more time. |
324 UpdateNetworkTime(clock_->Now() - latency_ / 2, resolution_, latency_, | 331 UpdateNetworkTime(clock_->Now() - latency_ / 2, resolution_, latency_, |
325 tick_clock_->NowTicks()); | 332 tick_clock_->NowTicks()); |
326 AdvanceBoth(base::TimeDelta::FromSeconds(1)); | 333 AdvanceBoth(base::TimeDelta::FromSeconds(1)); |
327 EXPECT_TRUE(tracker_->GetNetworkTime(&out_network_time, &uncertainty)); | 334 EXPECT_EQ(NetworkTimeTracker::NETWORK_TIME_AVAILABLE, |
| 335 tracker_->GetNetworkTime(&out_network_time, &uncertainty)); |
328 EXPECT_EQ(clock_->Now(), out_network_time); | 336 EXPECT_EQ(clock_->Now(), out_network_time); |
329 EXPECT_EQ(resolution_ + latency_ + adjustment_, uncertainty); | 337 EXPECT_EQ(resolution_ + latency_ + adjustment_, uncertainty); |
330 } | 338 } |
331 | 339 |
332 TEST_F(NetworkTimeTrackerTest, SpringForward) { | 340 TEST_F(NetworkTimeTrackerTest, SpringForward) { |
333 // Simulate the wall clock advancing faster than the tick clock. | 341 // Simulate the wall clock advancing faster than the tick clock. |
334 UpdateNetworkTime(clock_->Now(), resolution_, latency_, | 342 UpdateNetworkTime(clock_->Now(), resolution_, latency_, |
335 tick_clock_->NowTicks()); | 343 tick_clock_->NowTicks()); |
336 tick_clock_->Advance(base::TimeDelta::FromSeconds(1)); | 344 tick_clock_->Advance(base::TimeDelta::FromSeconds(1)); |
337 clock_->Advance(base::TimeDelta::FromDays(1)); | 345 clock_->Advance(base::TimeDelta::FromDays(1)); |
338 base::Time out_network_time; | 346 base::Time out_network_time; |
339 EXPECT_FALSE(tracker_->GetNetworkTime(&out_network_time, nullptr)); | 347 EXPECT_EQ(NetworkTimeTracker::NETWORK_TIME_SYNC_LOST, |
| 348 tracker_->GetNetworkTime(&out_network_time, nullptr)); |
340 } | 349 } |
341 | 350 |
342 TEST_F(NetworkTimeTrackerTest, FallBack) { | 351 TEST_F(NetworkTimeTrackerTest, FallBack) { |
343 // Simulate the wall clock running backward. | 352 // Simulate the wall clock running backward. |
344 UpdateNetworkTime(clock_->Now(), resolution_, latency_, | 353 UpdateNetworkTime(clock_->Now(), resolution_, latency_, |
345 tick_clock_->NowTicks()); | 354 tick_clock_->NowTicks()); |
346 tick_clock_->Advance(base::TimeDelta::FromSeconds(1)); | 355 tick_clock_->Advance(base::TimeDelta::FromSeconds(1)); |
347 clock_->Advance(base::TimeDelta::FromDays(-1)); | 356 clock_->Advance(base::TimeDelta::FromDays(-1)); |
348 base::Time out_network_time; | 357 base::Time out_network_time; |
349 EXPECT_FALSE(tracker_->GetNetworkTime(&out_network_time, nullptr)); | 358 EXPECT_EQ(NetworkTimeTracker::NETWORK_TIME_SYNC_LOST, |
| 359 tracker_->GetNetworkTime(&out_network_time, nullptr)); |
350 } | 360 } |
351 | 361 |
352 TEST_F(NetworkTimeTrackerTest, SuspendAndResume) { | 362 TEST_F(NetworkTimeTrackerTest, SuspendAndResume) { |
353 // Simulate the wall clock advancing while the tick clock stands still, as | 363 // Simulate the wall clock advancing while the tick clock stands still, as |
354 // would happen in a suspend+resume cycle. | 364 // would happen in a suspend+resume cycle. |
355 UpdateNetworkTime(clock_->Now(), resolution_, latency_, | 365 UpdateNetworkTime(clock_->Now(), resolution_, latency_, |
356 tick_clock_->NowTicks()); | 366 tick_clock_->NowTicks()); |
357 clock_->Advance(base::TimeDelta::FromHours(1)); | 367 clock_->Advance(base::TimeDelta::FromHours(1)); |
358 base::Time out_network_time; | 368 base::Time out_network_time; |
359 EXPECT_FALSE(tracker_->GetNetworkTime(&out_network_time, nullptr)); | 369 EXPECT_EQ(NetworkTimeTracker::NETWORK_TIME_SYNC_LOST, |
| 370 tracker_->GetNetworkTime(&out_network_time, nullptr)); |
360 } | 371 } |
361 | 372 |
362 TEST_F(NetworkTimeTrackerTest, Serialize) { | 373 TEST_F(NetworkTimeTrackerTest, Serialize) { |
363 // Test that we can serialize and deserialize state and get consistent | 374 // Test that we can serialize and deserialize state and get consistent |
364 // results. | 375 // results. |
365 base::Time in_network_time = clock_->Now() - base::TimeDelta::FromDays(90); | 376 base::Time in_network_time = clock_->Now() - base::TimeDelta::FromDays(90); |
366 UpdateNetworkTime(in_network_time - latency_ / 2, resolution_, latency_, | 377 UpdateNetworkTime(in_network_time - latency_ / 2, resolution_, latency_, |
367 tick_clock_->NowTicks()); | 378 tick_clock_->NowTicks()); |
368 base::Time out_network_time; | 379 base::Time out_network_time; |
369 base::TimeDelta out_uncertainty; | 380 base::TimeDelta out_uncertainty; |
370 EXPECT_TRUE(tracker_->GetNetworkTime(&out_network_time, &out_uncertainty)); | 381 EXPECT_EQ(NetworkTimeTracker::NETWORK_TIME_AVAILABLE, |
| 382 tracker_->GetNetworkTime(&out_network_time, &out_uncertainty)); |
371 EXPECT_EQ(in_network_time, out_network_time); | 383 EXPECT_EQ(in_network_time, out_network_time); |
372 EXPECT_EQ(resolution_ + latency_ + adjustment_, out_uncertainty); | 384 EXPECT_EQ(resolution_ + latency_ + adjustment_, out_uncertainty); |
373 | 385 |
374 // 6 days is just under the threshold for discarding data. | 386 // 6 days is just under the threshold for discarding data. |
375 base::TimeDelta delta = base::TimeDelta::FromDays(6); | 387 base::TimeDelta delta = base::TimeDelta::FromDays(6); |
376 AdvanceBoth(delta); | 388 AdvanceBoth(delta); |
377 Reset(); | 389 Reset(); |
378 EXPECT_TRUE(tracker_->GetNetworkTime(&out_network_time, &out_uncertainty)); | 390 EXPECT_EQ(NetworkTimeTracker::NETWORK_TIME_AVAILABLE, |
| 391 tracker_->GetNetworkTime(&out_network_time, &out_uncertainty)); |
379 EXPECT_EQ(in_network_time + delta, out_network_time); | 392 EXPECT_EQ(in_network_time + delta, out_network_time); |
380 EXPECT_EQ(resolution_ + latency_ + adjustment_, out_uncertainty); | 393 EXPECT_EQ(resolution_ + latency_ + adjustment_, out_uncertainty); |
381 } | 394 } |
382 | 395 |
383 TEST_F(NetworkTimeTrackerTest, DeserializeOldFormat) { | 396 TEST_F(NetworkTimeTrackerTest, DeserializeOldFormat) { |
384 // Test that deserializing old data (which do not record the uncertainty and | 397 // Test that deserializing old data (which do not record the uncertainty and |
385 // tick clock) causes the serialized data to be ignored. | 398 // tick clock) causes the serialized data to be ignored. |
386 base::Time in_network_time = clock_->Now() - base::TimeDelta::FromDays(90); | 399 base::Time in_network_time = clock_->Now() - base::TimeDelta::FromDays(90); |
387 UpdateNetworkTime(in_network_time - latency_ / 2, resolution_, latency_, | 400 UpdateNetworkTime(in_network_time - latency_ / 2, resolution_, latency_, |
388 tick_clock_->NowTicks()); | 401 tick_clock_->NowTicks()); |
389 | 402 |
390 base::Time out_network_time; | 403 base::Time out_network_time; |
391 EXPECT_TRUE(tracker_->GetNetworkTime(&out_network_time, nullptr)); | 404 EXPECT_EQ(NetworkTimeTracker::NETWORK_TIME_AVAILABLE, |
| 405 tracker_->GetNetworkTime(&out_network_time, nullptr)); |
392 double local, network; | 406 double local, network; |
393 const base::DictionaryValue* saved_prefs = | 407 const base::DictionaryValue* saved_prefs = |
394 pref_service_.GetDictionary(prefs::kNetworkTimeMapping); | 408 pref_service_.GetDictionary(prefs::kNetworkTimeMapping); |
395 saved_prefs->GetDouble("local", &local); | 409 saved_prefs->GetDouble("local", &local); |
396 saved_prefs->GetDouble("network", &network); | 410 saved_prefs->GetDouble("network", &network); |
397 base::DictionaryValue prefs; | 411 base::DictionaryValue prefs; |
398 prefs.SetDouble("local", local); | 412 prefs.SetDouble("local", local); |
399 prefs.SetDouble("network", network); | 413 prefs.SetDouble("network", network); |
400 pref_service_.Set(prefs::kNetworkTimeMapping, prefs); | 414 pref_service_.Set(prefs::kNetworkTimeMapping, prefs); |
401 Reset(); | 415 Reset(); |
402 EXPECT_FALSE(tracker_->GetNetworkTime(&out_network_time, nullptr)); | 416 EXPECT_EQ(NetworkTimeTracker::NETWORK_TIME_NO_SYNC, |
| 417 tracker_->GetNetworkTime(&out_network_time, nullptr)); |
403 } | 418 } |
404 | 419 |
405 TEST_F(NetworkTimeTrackerTest, SerializeWithLongDelay) { | 420 TEST_F(NetworkTimeTrackerTest, SerializeWithLongDelay) { |
406 // Test that if the serialized data are more than a week old, they are | 421 // Test that if the serialized data are more than a week old, they are |
407 // discarded. | 422 // discarded. |
408 base::Time in_network_time = clock_->Now() - base::TimeDelta::FromDays(90); | 423 base::Time in_network_time = clock_->Now() - base::TimeDelta::FromDays(90); |
409 UpdateNetworkTime(in_network_time - latency_ / 2, resolution_, latency_, | 424 UpdateNetworkTime(in_network_time - latency_ / 2, resolution_, latency_, |
410 tick_clock_->NowTicks()); | 425 tick_clock_->NowTicks()); |
411 base::Time out_network_time; | 426 base::Time out_network_time; |
412 EXPECT_TRUE(tracker_->GetNetworkTime(&out_network_time, nullptr)); | 427 EXPECT_EQ(NetworkTimeTracker::NETWORK_TIME_AVAILABLE, |
| 428 tracker_->GetNetworkTime(&out_network_time, nullptr)); |
413 AdvanceBoth(base::TimeDelta::FromDays(8)); | 429 AdvanceBoth(base::TimeDelta::FromDays(8)); |
414 Reset(); | 430 Reset(); |
415 EXPECT_FALSE(tracker_->GetNetworkTime(&out_network_time, nullptr)); | 431 EXPECT_EQ(NetworkTimeTracker::NETWORK_TIME_NO_SYNC, |
| 432 tracker_->GetNetworkTime(&out_network_time, nullptr)); |
416 } | 433 } |
417 | 434 |
418 TEST_F(NetworkTimeTrackerTest, SerializeWithTickClockAdvance) { | 435 TEST_F(NetworkTimeTrackerTest, SerializeWithTickClockAdvance) { |
419 // Test that serialized data are discarded if the wall clock and tick clock | 436 // Test that serialized data are discarded if the wall clock and tick clock |
420 // have not advanced consistently since data were serialized. | 437 // have not advanced consistently since data were serialized. |
421 base::Time in_network_time = clock_->Now() - base::TimeDelta::FromDays(90); | 438 base::Time in_network_time = clock_->Now() - base::TimeDelta::FromDays(90); |
422 UpdateNetworkTime(in_network_time - latency_ / 2, resolution_, latency_, | 439 UpdateNetworkTime(in_network_time - latency_ / 2, resolution_, latency_, |
423 tick_clock_->NowTicks()); | 440 tick_clock_->NowTicks()); |
424 base::Time out_network_time; | 441 base::Time out_network_time; |
425 EXPECT_TRUE(tracker_->GetNetworkTime(&out_network_time, nullptr)); | 442 EXPECT_EQ(NetworkTimeTracker::NETWORK_TIME_AVAILABLE, |
| 443 tracker_->GetNetworkTime(&out_network_time, nullptr)); |
426 tick_clock_->Advance(base::TimeDelta::FromDays(1)); | 444 tick_clock_->Advance(base::TimeDelta::FromDays(1)); |
427 Reset(); | 445 Reset(); |
428 EXPECT_FALSE(tracker_->GetNetworkTime(&out_network_time, nullptr)); | 446 EXPECT_EQ(NetworkTimeTracker::NETWORK_TIME_SYNC_LOST, |
| 447 tracker_->GetNetworkTime(&out_network_time, nullptr)); |
429 } | 448 } |
430 | 449 |
431 TEST_F(NetworkTimeTrackerTest, SerializeWithWallClockAdvance) { | 450 TEST_F(NetworkTimeTrackerTest, SerializeWithWallClockAdvance) { |
432 // Test that serialized data are discarded if the wall clock and tick clock | 451 // Test that serialized data are discarded if the wall clock and tick clock |
433 // have not advanced consistently since data were serialized. | 452 // have not advanced consistently since data were serialized. |
434 base::Time in_network_time = clock_->Now() - base::TimeDelta::FromDays(90); | 453 base::Time in_network_time = clock_->Now() - base::TimeDelta::FromDays(90); |
435 UpdateNetworkTime(in_network_time - latency_ / 2, resolution_, latency_, | 454 UpdateNetworkTime(in_network_time - latency_ / 2, resolution_, latency_, |
436 tick_clock_->NowTicks()); | 455 tick_clock_->NowTicks()); |
437 | 456 |
438 base::Time out_network_time; | 457 base::Time out_network_time; |
439 EXPECT_TRUE(tracker_->GetNetworkTime(&out_network_time, nullptr)); | 458 EXPECT_EQ(NetworkTimeTracker::NETWORK_TIME_AVAILABLE, |
| 459 tracker_->GetNetworkTime(&out_network_time, nullptr)); |
440 clock_->Advance(base::TimeDelta::FromDays(1)); | 460 clock_->Advance(base::TimeDelta::FromDays(1)); |
441 Reset(); | 461 Reset(); |
442 EXPECT_FALSE(tracker_->GetNetworkTime(&out_network_time, nullptr)); | 462 EXPECT_EQ(NetworkTimeTracker::NETWORK_TIME_SYNC_LOST, |
| 463 tracker_->GetNetworkTime(&out_network_time, nullptr)); |
443 } | 464 } |
444 | 465 |
445 TEST_F(NetworkTimeTrackerTest, UpdateFromNetwork) { | 466 TEST_F(NetworkTimeTrackerTest, UpdateFromNetwork) { |
446 base::HistogramTester histograms; | 467 base::HistogramTester histograms; |
447 histograms.ExpectTotalCount(kFetchFailedHistogram, 0); | 468 histograms.ExpectTotalCount(kFetchFailedHistogram, 0); |
448 histograms.ExpectTotalCount(kFetchValidHistogram, 0); | 469 histograms.ExpectTotalCount(kFetchValidHistogram, 0); |
449 | 470 |
450 base::Time out_network_time; | 471 base::Time out_network_time; |
451 EXPECT_FALSE(tracker_->GetNetworkTime(&out_network_time, nullptr)); | 472 EXPECT_EQ(NetworkTimeTracker::NETWORK_TIME_NO_SYNC, |
| 473 tracker_->GetNetworkTime(&out_network_time, nullptr)); |
452 // First query should happen soon. | 474 // First query should happen soon. |
453 EXPECT_EQ(base::TimeDelta::FromMinutes(0), | 475 EXPECT_EQ(base::TimeDelta::FromMinutes(0), |
454 tracker_->GetTimerDelayForTesting()); | 476 tracker_->GetTimerDelayForTesting()); |
455 | 477 |
456 test_server_->RegisterRequestHandler( | 478 test_server_->RegisterRequestHandler( |
457 base::Bind(&NetworkTimeTrackerTest::GoodTimeResponseHandler)); | 479 base::Bind(&NetworkTimeTrackerTest::GoodTimeResponseHandler)); |
458 EXPECT_TRUE(test_server_->Start()); | 480 EXPECT_TRUE(test_server_->Start()); |
459 tracker_->SetTimeServerURLForTesting(test_server_->GetURL("/")); | 481 tracker_->SetTimeServerURLForTesting(test_server_->GetURL("/")); |
460 EXPECT_TRUE(tracker_->QueryTimeServiceForTesting()); | 482 EXPECT_TRUE(tracker_->QueryTimeServiceForTesting()); |
461 tracker_->WaitForFetchForTesting(123123123); | 483 tracker_->WaitForFetchForTesting(123123123); |
462 | 484 |
463 EXPECT_TRUE(tracker_->GetNetworkTime(&out_network_time, nullptr)); | 485 EXPECT_EQ(NetworkTimeTracker::NETWORK_TIME_AVAILABLE, |
| 486 tracker_->GetNetworkTime(&out_network_time, nullptr)); |
464 EXPECT_EQ(base::Time::UnixEpoch() + | 487 EXPECT_EQ(base::Time::UnixEpoch() + |
465 base::TimeDelta::FromMilliseconds(1461621971825), | 488 base::TimeDelta::FromMilliseconds(1461621971825), |
466 out_network_time); | 489 out_network_time); |
467 // Should see no backoff in the success case. | 490 // Should see no backoff in the success case. |
468 EXPECT_EQ(base::TimeDelta::FromMinutes(60), | 491 EXPECT_EQ(base::TimeDelta::FromMinutes(60), |
469 tracker_->GetTimerDelayForTesting()); | 492 tracker_->GetTimerDelayForTesting()); |
470 | 493 |
471 histograms.ExpectTotalCount(kFetchFailedHistogram, 0); | 494 histograms.ExpectTotalCount(kFetchFailedHistogram, 0); |
472 histograms.ExpectTotalCount(kFetchValidHistogram, 1); | 495 histograms.ExpectTotalCount(kFetchValidHistogram, 1); |
473 histograms.ExpectBucketCount(kFetchValidHistogram, true, 1); | 496 histograms.ExpectBucketCount(kFetchValidHistogram, true, 1); |
(...skipping 42 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
516 histograms.ExpectTotalCount(kFetchValidHistogram, 0); | 539 histograms.ExpectTotalCount(kFetchValidHistogram, 0); |
517 | 540 |
518 test_server_->RegisterRequestHandler( | 541 test_server_->RegisterRequestHandler( |
519 base::Bind(&NetworkTimeTrackerTest::BadSignatureResponseHandler)); | 542 base::Bind(&NetworkTimeTrackerTest::BadSignatureResponseHandler)); |
520 EXPECT_TRUE(test_server_->Start()); | 543 EXPECT_TRUE(test_server_->Start()); |
521 tracker_->SetTimeServerURLForTesting(test_server_->GetURL("/")); | 544 tracker_->SetTimeServerURLForTesting(test_server_->GetURL("/")); |
522 EXPECT_TRUE(tracker_->QueryTimeServiceForTesting()); | 545 EXPECT_TRUE(tracker_->QueryTimeServiceForTesting()); |
523 tracker_->WaitForFetchForTesting(123123123); | 546 tracker_->WaitForFetchForTesting(123123123); |
524 | 547 |
525 base::Time out_network_time; | 548 base::Time out_network_time; |
526 EXPECT_FALSE(tracker_->GetNetworkTime(&out_network_time, nullptr)); | 549 EXPECT_EQ(NetworkTimeTracker::NETWORK_TIME_NO_SYNC, |
| 550 tracker_->GetNetworkTime(&out_network_time, nullptr)); |
527 EXPECT_EQ(base::TimeDelta::FromMinutes(120), | 551 EXPECT_EQ(base::TimeDelta::FromMinutes(120), |
528 tracker_->GetTimerDelayForTesting()); | 552 tracker_->GetTimerDelayForTesting()); |
529 | 553 |
530 histograms.ExpectTotalCount(kFetchFailedHistogram, 0); | 554 histograms.ExpectTotalCount(kFetchFailedHistogram, 0); |
531 histograms.ExpectTotalCount(kFetchValidHistogram, 1); | 555 histograms.ExpectTotalCount(kFetchValidHistogram, 1); |
532 histograms.ExpectBucketCount(kFetchValidHistogram, false, 1); | 556 histograms.ExpectBucketCount(kFetchValidHistogram, false, 1); |
533 } | 557 } |
534 | 558 |
535 static const uint8_t kDevKeyPubBytes[] = { | 559 static const uint8_t kDevKeyPubBytes[] = { |
536 0x30, 0x59, 0x30, 0x13, 0x06, 0x07, 0x2a, 0x86, 0x48, 0xce, 0x3d, 0x02, | 560 0x30, 0x59, 0x30, 0x13, 0x06, 0x07, 0x2a, 0x86, 0x48, 0xce, 0x3d, 0x02, |
(...skipping 13 matching lines...) Expand all Loading... |
550 test_server_->RegisterRequestHandler( | 574 test_server_->RegisterRequestHandler( |
551 base::Bind(&NetworkTimeTrackerTest::BadDataResponseHandler)); | 575 base::Bind(&NetworkTimeTrackerTest::BadDataResponseHandler)); |
552 EXPECT_TRUE(test_server_->Start()); | 576 EXPECT_TRUE(test_server_->Start()); |
553 base::StringPiece key = {reinterpret_cast<const char*>(kDevKeyPubBytes), | 577 base::StringPiece key = {reinterpret_cast<const char*>(kDevKeyPubBytes), |
554 sizeof(kDevKeyPubBytes)}; | 578 sizeof(kDevKeyPubBytes)}; |
555 tracker_->SetPublicKeyForTesting(key); | 579 tracker_->SetPublicKeyForTesting(key); |
556 tracker_->SetTimeServerURLForTesting(test_server_->GetURL("/")); | 580 tracker_->SetTimeServerURLForTesting(test_server_->GetURL("/")); |
557 EXPECT_TRUE(tracker_->QueryTimeServiceForTesting()); | 581 EXPECT_TRUE(tracker_->QueryTimeServiceForTesting()); |
558 tracker_->WaitForFetchForTesting(123123123); | 582 tracker_->WaitForFetchForTesting(123123123); |
559 base::Time out_network_time; | 583 base::Time out_network_time; |
560 EXPECT_FALSE(tracker_->GetNetworkTime(&out_network_time, nullptr)); | 584 EXPECT_EQ(NetworkTimeTracker::NETWORK_TIME_NO_SYNC, |
| 585 tracker_->GetNetworkTime(&out_network_time, nullptr)); |
561 EXPECT_EQ(base::TimeDelta::FromMinutes(120), | 586 EXPECT_EQ(base::TimeDelta::FromMinutes(120), |
562 tracker_->GetTimerDelayForTesting()); | 587 tracker_->GetTimerDelayForTesting()); |
563 | 588 |
564 histograms.ExpectTotalCount(kFetchFailedHistogram, 0); | 589 histograms.ExpectTotalCount(kFetchFailedHistogram, 0); |
565 histograms.ExpectTotalCount(kFetchValidHistogram, 1); | 590 histograms.ExpectTotalCount(kFetchValidHistogram, 1); |
566 histograms.ExpectBucketCount(kFetchValidHistogram, false, 1); | 591 histograms.ExpectBucketCount(kFetchValidHistogram, false, 1); |
567 } | 592 } |
568 | 593 |
569 TEST_F(NetworkTimeTrackerTest, UpdateFromNetworkServerError) { | 594 TEST_F(NetworkTimeTrackerTest, UpdateFromNetworkServerError) { |
570 base::HistogramTester histograms; | 595 base::HistogramTester histograms; |
571 histograms.ExpectTotalCount(kFetchFailedHistogram, 0); | 596 histograms.ExpectTotalCount(kFetchFailedHistogram, 0); |
572 histograms.ExpectTotalCount(kFetchValidHistogram, 0); | 597 histograms.ExpectTotalCount(kFetchValidHistogram, 0); |
573 | 598 |
574 test_server_->RegisterRequestHandler( | 599 test_server_->RegisterRequestHandler( |
575 base::Bind(&NetworkTimeTrackerTest::ServerErrorResponseHandler)); | 600 base::Bind(&NetworkTimeTrackerTest::ServerErrorResponseHandler)); |
576 EXPECT_TRUE(test_server_->Start()); | 601 EXPECT_TRUE(test_server_->Start()); |
577 tracker_->SetTimeServerURLForTesting(test_server_->GetURL("/")); | 602 tracker_->SetTimeServerURLForTesting(test_server_->GetURL("/")); |
578 EXPECT_TRUE(tracker_->QueryTimeServiceForTesting()); | 603 EXPECT_TRUE(tracker_->QueryTimeServiceForTesting()); |
579 tracker_->WaitForFetchForTesting(123123123); | 604 tracker_->WaitForFetchForTesting(123123123); |
580 | 605 |
581 base::Time out_network_time; | 606 base::Time out_network_time; |
582 EXPECT_FALSE(tracker_->GetNetworkTime(&out_network_time, nullptr)); | 607 EXPECT_EQ(NetworkTimeTracker::NETWORK_TIME_NO_SYNC, |
| 608 tracker_->GetNetworkTime(&out_network_time, nullptr)); |
583 // Should see backoff in the error case. | 609 // Should see backoff in the error case. |
584 EXPECT_EQ(base::TimeDelta::FromMinutes(120), | 610 EXPECT_EQ(base::TimeDelta::FromMinutes(120), |
585 tracker_->GetTimerDelayForTesting()); | 611 tracker_->GetTimerDelayForTesting()); |
586 | 612 |
587 histograms.ExpectTotalCount(kFetchFailedHistogram, 1); | 613 histograms.ExpectTotalCount(kFetchFailedHistogram, 1); |
588 // There was no network error, so the histogram is recorded as | 614 // There was no network error, so the histogram is recorded as |
589 // net::OK, indicating that the connection succeeded but there was a | 615 // net::OK, indicating that the connection succeeded but there was a |
590 // non-200 HTTP status code. | 616 // non-200 HTTP status code. |
591 histograms.ExpectBucketCount(kFetchFailedHistogram, net::OK, 1); | 617 histograms.ExpectBucketCount(kFetchFailedHistogram, net::OK, 1); |
592 histograms.ExpectTotalCount(kFetchValidHistogram, 0); | 618 histograms.ExpectTotalCount(kFetchValidHistogram, 0); |
593 } | 619 } |
594 | 620 |
595 TEST_F(NetworkTimeTrackerTest, UpdateFromNetworkNetworkError) { | 621 TEST_F(NetworkTimeTrackerTest, UpdateFromNetworkNetworkError) { |
596 base::HistogramTester histograms; | 622 base::HistogramTester histograms; |
597 histograms.ExpectTotalCount(kFetchFailedHistogram, 0); | 623 histograms.ExpectTotalCount(kFetchFailedHistogram, 0); |
598 histograms.ExpectTotalCount(kFetchValidHistogram, 0); | 624 histograms.ExpectTotalCount(kFetchValidHistogram, 0); |
599 | 625 |
600 test_server_->RegisterRequestHandler( | 626 test_server_->RegisterRequestHandler( |
601 base::Bind(&NetworkTimeTrackerTest::NetworkErrorResponseHandler)); | 627 base::Bind(&NetworkTimeTrackerTest::NetworkErrorResponseHandler)); |
602 EXPECT_TRUE(test_server_->Start()); | 628 EXPECT_TRUE(test_server_->Start()); |
603 tracker_->SetTimeServerURLForTesting(test_server_->GetURL("/")); | 629 tracker_->SetTimeServerURLForTesting(test_server_->GetURL("/")); |
604 EXPECT_TRUE(tracker_->QueryTimeServiceForTesting()); | 630 EXPECT_TRUE(tracker_->QueryTimeServiceForTesting()); |
605 tracker_->WaitForFetchForTesting(123123123); | 631 tracker_->WaitForFetchForTesting(123123123); |
606 | 632 |
607 base::Time out_network_time; | 633 base::Time out_network_time; |
608 EXPECT_FALSE(tracker_->GetNetworkTime(&out_network_time, nullptr)); | 634 EXPECT_EQ(NetworkTimeTracker::NETWORK_TIME_NO_SYNC, |
| 635 tracker_->GetNetworkTime(&out_network_time, nullptr)); |
609 // Should see backoff in the error case. | 636 // Should see backoff in the error case. |
610 EXPECT_EQ(base::TimeDelta::FromMinutes(120), | 637 EXPECT_EQ(base::TimeDelta::FromMinutes(120), |
611 tracker_->GetTimerDelayForTesting()); | 638 tracker_->GetTimerDelayForTesting()); |
612 | 639 |
613 histograms.ExpectTotalCount(kFetchFailedHistogram, 1); | 640 histograms.ExpectTotalCount(kFetchFailedHistogram, 1); |
614 histograms.ExpectBucketCount(kFetchFailedHistogram, -net::ERR_EMPTY_RESPONSE, | 641 histograms.ExpectBucketCount(kFetchFailedHistogram, -net::ERR_EMPTY_RESPONSE, |
615 1); | 642 1); |
616 histograms.ExpectTotalCount(kFetchValidHistogram, 0); | 643 histograms.ExpectTotalCount(kFetchValidHistogram, 0); |
617 } | 644 } |
618 | 645 |
619 TEST_F(NetworkTimeTrackerTest, UpdateFromNetworkLargeResponse) { | 646 TEST_F(NetworkTimeTrackerTest, UpdateFromNetworkLargeResponse) { |
620 base::HistogramTester histograms; | 647 base::HistogramTester histograms; |
621 histograms.ExpectTotalCount(kFetchFailedHistogram, 0); | 648 histograms.ExpectTotalCount(kFetchFailedHistogram, 0); |
622 histograms.ExpectTotalCount(kFetchValidHistogram, 0); | 649 histograms.ExpectTotalCount(kFetchValidHistogram, 0); |
623 | 650 |
624 test_server_->RegisterRequestHandler( | 651 test_server_->RegisterRequestHandler( |
625 base::Bind(&NetworkTimeTrackerTest::GoodTimeResponseHandler)); | 652 base::Bind(&NetworkTimeTrackerTest::GoodTimeResponseHandler)); |
626 EXPECT_TRUE(test_server_->Start()); | 653 EXPECT_TRUE(test_server_->Start()); |
627 tracker_->SetTimeServerURLForTesting(test_server_->GetURL("/")); | 654 tracker_->SetTimeServerURLForTesting(test_server_->GetURL("/")); |
628 | 655 |
629 base::Time out_network_time; | 656 base::Time out_network_time; |
630 | 657 |
631 tracker_->SetMaxResponseSizeForTesting(3); | 658 tracker_->SetMaxResponseSizeForTesting(3); |
632 EXPECT_TRUE(tracker_->QueryTimeServiceForTesting()); | 659 EXPECT_TRUE(tracker_->QueryTimeServiceForTesting()); |
633 tracker_->WaitForFetchForTesting(123123123); | 660 tracker_->WaitForFetchForTesting(123123123); |
634 EXPECT_FALSE(tracker_->GetNetworkTime(&out_network_time, nullptr)); | 661 EXPECT_EQ(NetworkTimeTracker::NETWORK_TIME_NO_SYNC, |
| 662 tracker_->GetNetworkTime(&out_network_time, nullptr)); |
635 | 663 |
636 histograms.ExpectTotalCount(kFetchFailedHistogram, 1); | 664 histograms.ExpectTotalCount(kFetchFailedHistogram, 1); |
637 histograms.ExpectTotalCount(kFetchValidHistogram, 0); | 665 histograms.ExpectTotalCount(kFetchValidHistogram, 0); |
638 | 666 |
639 tracker_->SetMaxResponseSizeForTesting(1024); | 667 tracker_->SetMaxResponseSizeForTesting(1024); |
640 EXPECT_TRUE(tracker_->QueryTimeServiceForTesting()); | 668 EXPECT_TRUE(tracker_->QueryTimeServiceForTesting()); |
641 tracker_->WaitForFetchForTesting(123123123); | 669 tracker_->WaitForFetchForTesting(123123123); |
642 EXPECT_TRUE(tracker_->GetNetworkTime(&out_network_time, nullptr)); | 670 EXPECT_EQ(NetworkTimeTracker::NETWORK_TIME_AVAILABLE, |
| 671 tracker_->GetNetworkTime(&out_network_time, nullptr)); |
643 | 672 |
644 histograms.ExpectTotalCount(kFetchFailedHistogram, 1); | 673 histograms.ExpectTotalCount(kFetchFailedHistogram, 1); |
645 histograms.ExpectTotalCount(kFetchValidHistogram, 1); | 674 histograms.ExpectTotalCount(kFetchValidHistogram, 1); |
646 histograms.ExpectBucketCount(kFetchValidHistogram, true, 1); | 675 histograms.ExpectBucketCount(kFetchValidHistogram, true, 1); |
647 } | 676 } |
648 | 677 |
649 } // namespace network_time | 678 } // namespace network_time |
OLD | NEW |