system_time_change_notifier_unittest.cc 7.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213
  1. // Copyright 2015 The Chromium Authors. All rights reserved.
  2. // Use of this source code is governed by a BSD-style license that can be
  3. // found in the LICENSE file.
  4. #include "chromecast/base/system_time_change_notifier.h"
  5. #include <memory>
  6. #include <utility>
  7. #include "base/bind.h"
  8. #include "base/location.h"
  9. #include "base/run_loop.h"
  10. #include "base/task/sequenced_task_runner.h"
  11. #include "base/task/single_thread_task_runner.h"
  12. #include "base/test/task_environment.h"
  13. #include "base/threading/thread_task_runner_handle.h"
  14. #include "base/time/time.h"
  15. #include "testing/gtest/include/gtest/gtest.h"
  16. namespace chromecast {
  17. namespace {
  18. class SequencedTaskRunnerNoDelay : public base::SequencedTaskRunner {
  19. public:
  20. SequencedTaskRunnerNoDelay() {}
  21. SequencedTaskRunnerNoDelay(const SequencedTaskRunnerNoDelay&) = delete;
  22. SequencedTaskRunnerNoDelay& operator=(const SequencedTaskRunnerNoDelay&) =
  23. delete;
  24. // base::SequencedTaskRunner implementation:
  25. bool PostDelayedTask(const base::Location& from_here,
  26. base::OnceClosure task,
  27. base::TimeDelta delay) override {
  28. base::ThreadTaskRunnerHandle::Get()->PostTask(from_here, std::move(task));
  29. return true;
  30. }
  31. bool PostNonNestableDelayedTask(const base::Location& from_here,
  32. base::OnceClosure task,
  33. base::TimeDelta delay) override {
  34. return true;
  35. }
  36. bool RunsTasksInCurrentSequence() const override { return true; }
  37. private:
  38. ~SequencedTaskRunnerNoDelay() override {}
  39. };
  40. class TimeChangeObserver : public SystemTimeChangeNotifier::Observer {
  41. public:
  42. TimeChangeObserver() : num_time_changed_(0) {}
  43. TimeChangeObserver(const TimeChangeObserver&) = delete;
  44. TimeChangeObserver& operator=(const TimeChangeObserver&) = delete;
  45. ~TimeChangeObserver() override {}
  46. // SystemTimeChangeNotifier::Observer implementation:
  47. void OnSystemTimeChanged() override { ++num_time_changed_; }
  48. int num_time_changed() const { return num_time_changed_; }
  49. private:
  50. int num_time_changed_;
  51. };
  52. } // namespace
  53. class SystemTimeChangeNotifierTest : public testing::Test {
  54. protected:
  55. void SetUp() override {
  56. notifier_.reset(new SystemTimeChangeNotifierPeriodicMonitor(
  57. new SequencedTaskRunnerNoDelay()));
  58. observer_.reset(new TimeChangeObserver);
  59. notifier_->AddObserver(observer_.get());
  60. }
  61. // Runs pending tasks. It doesn't run tasks schedule after this call.
  62. void RunPendingTasks() {
  63. base::RunLoop run_loop;
  64. base::ThreadTaskRunnerHandle::Get()->PostTask(FROM_HERE,
  65. run_loop.QuitClosure());
  66. run_loop.Run();
  67. }
  68. base::test::SingleThreadTaskEnvironment task_environment_;
  69. std::unique_ptr<SystemTimeChangeNotifierPeriodicMonitor> notifier_;
  70. std::unique_ptr<TimeChangeObserver> observer_;
  71. };
  72. TEST_F(SystemTimeChangeNotifierTest, NotChanged) {
  73. EXPECT_EQ(0, observer_->num_time_changed());
  74. // Not changed.
  75. RunPendingTasks();
  76. EXPECT_EQ(0, observer_->num_time_changed());
  77. }
  78. TEST_F(SystemTimeChangeNotifierTest, TimeChangedForwardLessThan10Seconds) {
  79. base::Time now = base::Time::Now();
  80. EXPECT_EQ(0, observer_->num_time_changed());
  81. // Time change NOT detected.
  82. notifier_->set_fake_now_for_testing(now + base::Seconds(4));
  83. RunPendingTasks();
  84. EXPECT_EQ(0, observer_->num_time_changed());
  85. RunPendingTasks();
  86. EXPECT_EQ(0, observer_->num_time_changed());
  87. }
  88. TEST_F(SystemTimeChangeNotifierTest, TimeChangedBackwardLessThan10Seconds) {
  89. base::Time now = base::Time::Now();
  90. EXPECT_EQ(0, observer_->num_time_changed());
  91. // Time change NOT detected.
  92. notifier_->set_fake_now_for_testing(now - base::Seconds(4));
  93. RunPendingTasks();
  94. EXPECT_EQ(0, observer_->num_time_changed());
  95. RunPendingTasks();
  96. EXPECT_EQ(0, observer_->num_time_changed());
  97. }
  98. TEST_F(SystemTimeChangeNotifierTest, TimeChangedForwardMoreThan10Seconds) {
  99. base::Time now = base::Time::Now();
  100. EXPECT_EQ(0, observer_->num_time_changed());
  101. notifier_->set_fake_now_for_testing(now + base::Seconds(40));
  102. RunPendingTasks();
  103. // Still 0 since observe callback is running in next run loop.
  104. EXPECT_EQ(0, observer_->num_time_changed());
  105. RunPendingTasks();
  106. // Time change detected.
  107. EXPECT_EQ(1, observer_->num_time_changed());
  108. }
  109. TEST_F(SystemTimeChangeNotifierTest, TimeChangedBackwardMoreThan10Seconds) {
  110. base::Time now = base::Time::Now();
  111. EXPECT_EQ(0, observer_->num_time_changed());
  112. notifier_->set_fake_now_for_testing(now - base::Seconds(40));
  113. RunPendingTasks();
  114. // Still 0 since observe callback is running in next run loop.
  115. EXPECT_EQ(0, observer_->num_time_changed());
  116. RunPendingTasks();
  117. // Time change detected.
  118. EXPECT_EQ(1, observer_->num_time_changed());
  119. }
  120. TEST_F(SystemTimeChangeNotifierTest, CannotDetectTimeDriftForward) {
  121. base::Time now = base::Time::Now();
  122. EXPECT_EQ(0, observer_->num_time_changed());
  123. // Time change NOT detected. Expected = now + 1, actual = now + 4.
  124. notifier_->set_fake_now_for_testing(now + base::Seconds(4));
  125. RunPendingTasks();
  126. EXPECT_EQ(0, observer_->num_time_changed());
  127. // Time change NOT detected. Expected = now + 4 + 1, actual = now + 8.
  128. notifier_->set_fake_now_for_testing(now + base::Seconds(8));
  129. RunPendingTasks();
  130. EXPECT_EQ(0, observer_->num_time_changed());
  131. // Time change NOT detected. Expected = now + 8 + 1, actual = now + 12.
  132. notifier_->set_fake_now_for_testing(now + base::Seconds(12));
  133. RunPendingTasks();
  134. EXPECT_EQ(0, observer_->num_time_changed());
  135. // Time change detected. Expected = now + 12 + 1, actual = now + 16.
  136. notifier_->set_fake_now_for_testing(now + base::Seconds(16));
  137. RunPendingTasks();
  138. EXPECT_EQ(0, observer_->num_time_changed());
  139. // Time change detected. Expected = now + 16 + 1, actual = now + 20.
  140. notifier_->set_fake_now_for_testing(now + base::Seconds(20));
  141. RunPendingTasks();
  142. EXPECT_EQ(0, observer_->num_time_changed());
  143. }
  144. TEST_F(SystemTimeChangeNotifierTest, CannotDetectTTimeDriftBackward) {
  145. base::Time now = base::Time::Now();
  146. EXPECT_EQ(0, observer_->num_time_changed());
  147. // Time change NOT detected. Expected = now + 1, actual = now - 4.
  148. notifier_->set_fake_now_for_testing(now - base::Seconds(4));
  149. RunPendingTasks();
  150. EXPECT_EQ(0, observer_->num_time_changed());
  151. // Time change NOT detected. Expected = now - 4 + 1, actual = now - 8.
  152. notifier_->set_fake_now_for_testing(now - base::Seconds(8));
  153. RunPendingTasks();
  154. EXPECT_EQ(0, observer_->num_time_changed());
  155. // Time change detected. Expected = now - 8 + 1, actual = now - 12.
  156. notifier_->set_fake_now_for_testing(now - base::Seconds(12));
  157. RunPendingTasks();
  158. EXPECT_EQ(0, observer_->num_time_changed());
  159. // Time change detected. Expected = now - 12 + 1, actual = now - 16.
  160. notifier_->set_fake_now_for_testing(now - base::Seconds(16));
  161. RunPendingTasks();
  162. EXPECT_EQ(0, observer_->num_time_changed());
  163. // Time change detected. Expected = now - 20 + 1, actual = now - 20.
  164. notifier_->set_fake_now_for_testing(now - base::Seconds(20));
  165. RunPendingTasks();
  166. EXPECT_EQ(0, observer_->num_time_changed());
  167. }
  168. } // namespace chromecast