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

Side by Side Diff: chrome/browser/chromeos/policy/heartbeat_scheduler_unittest.cc

Issue 1019283004: Switch to direct use of OwnerSettingsServiceChromeOS::Set() in tests. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Nits. Created 5 years, 8 months 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 (c) 2015 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2015 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 "chrome/browser/chromeos/policy/heartbeat_scheduler.h" 5 #include "chrome/browser/chromeos/policy/heartbeat_scheduler.h"
6 6
7 #include "base/strings/string_number_conversions.h" 7 #include "base/strings/string_number_conversions.h"
8 #include "base/test/test_simple_task_runner.h" 8 #include "base/test/test_simple_task_runner.h"
9 #include "chrome/browser/chromeos/settings/cros_settings.h" 9 #include "chrome/browser/chromeos/settings/settings_provider_test_base.h"
10 #include "chrome/browser/chromeos/settings/device_settings_service.h"
11 #include "chrome/browser/chromeos/settings/stub_cros_settings_provider.h"
bartfab (slow) 2015/03/31 14:12:40 Nit: Still used in line 106 and others.
12 #include "chromeos/settings/cros_settings_names.h" 10 #include "chromeos/settings/cros_settings_names.h"
13 #include "components/gcm_driver/fake_gcm_driver.h" 11 #include "components/gcm_driver/fake_gcm_driver.h"
14 #include "content/public/test/test_utils.h" 12 #include "content/public/test/test_utils.h"
15 #include "testing/gmock/include/gmock/gmock.h" 13 #include "testing/gmock/include/gmock/gmock.h"
16 #include "testing/gtest/include/gtest/gtest.h" 14 #include "testing/gtest/include/gtest/gtest.h"
17 15
18 using ::testing::_; 16 using ::testing::_;
19 using ::testing::SaveArg; 17 using ::testing::SaveArg;
20 18
21 namespace { 19 namespace {
(...skipping 25 matching lines...) Expand all
47 45
48 // Helper function to complete a send operation previously started by 46 // Helper function to complete a send operation previously started by
49 // Send(). 47 // Send().
50 void CompleteSend(const std::string& app_id, 48 void CompleteSend(const std::string& app_id,
51 const std::string& message_id, 49 const std::string& message_id,
52 gcm::GCMClient::Result result) { 50 gcm::GCMClient::Result result) {
53 SendFinished(app_id, message_id, result); 51 SendFinished(app_id, message_id, result);
54 } 52 }
55 }; 53 };
56 54
57 class HeartbeatSchedulerTest : public testing::Test { 55 class HeartbeatSchedulerTest : public testing::Test,
56 public chromeos::SettingsProviderTestBase {
58 public: 57 public:
59 HeartbeatSchedulerTest() 58 HeartbeatSchedulerTest()
60 : task_runner_(new base::TestSimpleTaskRunner()), 59 : task_runner_(new base::TestSimpleTaskRunner()),
61 scheduler_( 60 scheduler_(
62 &gcm_driver_, kFakeEnrollmentDomain, kFakeDeviceId, task_runner_) { 61 &gcm_driver_, kFakeEnrollmentDomain, kFakeDeviceId, task_runner_) {
63 } 62 }
64 63
65 void SetUp() override { 64 void SetUp() override { ReplaceProvider(chromeos::kHeartbeatEnabled); }
bartfab (slow) 2015/03/31 14:12:40 Nit: Per style guide, this must be broken into thr
66 // Swap out the DeviceSettingsProvider with our stub settings provider
67 // so we can set values for the heartbeat frequency.
68 chromeos::CrosSettings* cros_settings = chromeos::CrosSettings::Get();
69 device_settings_provider_ =
70 cros_settings->GetProvider(chromeos::kReportDeviceVersionInfo);
71 EXPECT_TRUE(device_settings_provider_);
72 EXPECT_TRUE(
73 cros_settings->RemoveSettingsProvider(device_settings_provider_));
74 cros_settings->AddSettingsProvider(&stub_settings_provider_);
75 }
76 65
77 void TearDown() override { 66 void TearDown() override {
67 RestoreProvider();
78 content::RunAllBlockingPoolTasksUntilIdle(); 68 content::RunAllBlockingPoolTasksUntilIdle();
79 // Restore the real DeviceSettingsProvider.
80 chromeos::CrosSettings* cros_settings = chromeos::CrosSettings::Get();
81 EXPECT_TRUE(cros_settings->RemoveSettingsProvider(
82 &stub_settings_provider_));
83 cros_settings->AddSettingsProvider(device_settings_provider_);
84 } 69 }
85 70
86 void CheckPendingTaskDelay(base::Time last_heartbeat, 71 void CheckPendingTaskDelay(base::Time last_heartbeat,
87 base::TimeDelta expected_delay) { 72 base::TimeDelta expected_delay) {
88 EXPECT_FALSE(last_heartbeat.is_null()); 73 EXPECT_FALSE(last_heartbeat.is_null());
89 base::Time now = base::Time::NowFromSystemTime(); 74 base::Time now = base::Time::NowFromSystemTime();
90 EXPECT_GE(now, last_heartbeat); 75 EXPECT_GE(now, last_heartbeat);
91 base::TimeDelta actual_delay = task_runner_->NextPendingTaskDelay(); 76 base::TimeDelta actual_delay = task_runner_->NextPendingTaskDelay();
92 77
93 // NextPendingTaskDelay() returns the exact original delay value the task 78 // NextPendingTaskDelay() returns the exact original delay value the task
94 // was posted with. The heartbeat task would have been calculated to fire at 79 // was posted with. The heartbeat task would have been calculated to fire at
95 // |last_heartbeat| + |expected_delay|, but we don't know the exact time 80 // |last_heartbeat| + |expected_delay|, but we don't know the exact time
96 // when the task was posted (if it was a couple of milliseconds after 81 // when the task was posted (if it was a couple of milliseconds after
97 // |last_heartbeat|, then |actual_delay| would be a couple of milliseconds 82 // |last_heartbeat|, then |actual_delay| would be a couple of milliseconds
98 // smaller than |expected_delay|. 83 // smaller than |expected_delay|.
99 // 84 //
100 // We do know that the task was posted sometime between |last_heartbeat| 85 // We do know that the task was posted sometime between |last_heartbeat|
101 // and |now|, so we know that 0 <= |expected_delay| - |actual_delay| <= 86 // and |now|, so we know that 0 <= |expected_delay| - |actual_delay| <=
102 // |now| - |last_heartbeat|. 87 // |now| - |last_heartbeat|.
103 base::TimeDelta delta = expected_delay - actual_delay; 88 base::TimeDelta delta = expected_delay - actual_delay;
104 EXPECT_LE(base::TimeDelta(), delta); 89 EXPECT_LE(base::TimeDelta(), delta);
105 EXPECT_GE(now - last_heartbeat, delta); 90 EXPECT_GE(now - last_heartbeat, delta);
106 } 91 }
107 92
108 base::MessageLoop loop_; 93 base::MessageLoop loop_;
109
110 // Helpers used to mock out cros settings.
111 chromeos::ScopedTestDeviceSettingsService test_device_settings_service_;
112 chromeos::ScopedTestCrosSettings test_cros_settings_;
113 chromeos::CrosSettingsProvider* device_settings_provider_;
114 chromeos::StubCrosSettingsProvider stub_settings_provider_;
115
116 MockGCMDriver gcm_driver_; 94 MockGCMDriver gcm_driver_;
117 95
118 // TaskRunner used to run individual tests. 96 // TaskRunner used to run individual tests.
119 scoped_refptr<base::TestSimpleTaskRunner> task_runner_; 97 scoped_refptr<base::TestSimpleTaskRunner> task_runner_;
120 98
121 // The HeartbeatScheduler instance under test. 99 // The HeartbeatScheduler instance under test.
122 policy::HeartbeatScheduler scheduler_; 100 policy::HeartbeatScheduler scheduler_;
123 }; 101 };
124 102
125 TEST_F(HeartbeatSchedulerTest, Basic) { 103 TEST_F(HeartbeatSchedulerTest, Basic) {
126 // Just makes sure we can spin up and shutdown the scheduler with 104 // Just makes sure we can spin up and shutdown the scheduler with
127 // heartbeats disabled. 105 // heartbeats disabled.
128 chromeos::CrosSettings::Get()->SetBoolean( 106 stub_settings_provider_.SetBoolean(chromeos::kHeartbeatEnabled, false);
129 chromeos::kHeartbeatEnabled, false);
130 ASSERT_TRUE(task_runner_->GetPendingTasks().empty()); 107 ASSERT_TRUE(task_runner_->GetPendingTasks().empty());
131 } 108 }
132 109
133 TEST_F(HeartbeatSchedulerTest, PermanentlyFailedGCMRegistration) { 110 TEST_F(HeartbeatSchedulerTest, PermanentlyFailedGCMRegistration) {
134 // If heartbeats are enabled, we should register with GCMDriver. 111 // If heartbeats are enabled, we should register with GCMDriver.
135 EXPECT_CALL(gcm_driver_, RegisterImpl(kHeartbeatGCMAppID, _)); 112 EXPECT_CALL(gcm_driver_, RegisterImpl(kHeartbeatGCMAppID, _));
136 chromeos::CrosSettings::Get()->SetBoolean( 113 stub_settings_provider_.SetBoolean(chromeos::kHeartbeatEnabled, true);
137 chromeos::kHeartbeatEnabled, true);
138 gcm_driver_.CompleteRegistration( 114 gcm_driver_.CompleteRegistration(
139 kHeartbeatGCMAppID, gcm::GCMClient::GCM_DISABLED); 115 kHeartbeatGCMAppID, gcm::GCMClient::GCM_DISABLED);
140 116
141 // There should be no heartbeat tasks pending, because registration failed. 117 // There should be no heartbeat tasks pending, because registration failed.
142 ASSERT_TRUE(task_runner_->GetPendingTasks().empty()); 118 ASSERT_TRUE(task_runner_->GetPendingTasks().empty());
143 } 119 }
144 120
145 TEST_F(HeartbeatSchedulerTest, TemporarilyFailedGCMRegistration) { 121 TEST_F(HeartbeatSchedulerTest, TemporarilyFailedGCMRegistration) {
146 EXPECT_CALL(gcm_driver_, RegisterImpl(kHeartbeatGCMAppID, _)); 122 EXPECT_CALL(gcm_driver_, RegisterImpl(kHeartbeatGCMAppID, _));
147 chromeos::CrosSettings::Get()->SetBoolean( 123 stub_settings_provider_.SetBoolean(chromeos::kHeartbeatEnabled, true);
148 chromeos::kHeartbeatEnabled, true);
149 gcm_driver_.CompleteRegistration( 124 gcm_driver_.CompleteRegistration(
150 kHeartbeatGCMAppID, gcm::GCMClient::SERVER_ERROR); 125 kHeartbeatGCMAppID, gcm::GCMClient::SERVER_ERROR);
151 testing::Mock::VerifyAndClearExpectations(&gcm_driver_); 126 testing::Mock::VerifyAndClearExpectations(&gcm_driver_);
152 127
153 // Should have a pending task to try registering again. 128 // Should have a pending task to try registering again.
154 ASSERT_FALSE(task_runner_->GetPendingTasks().empty()); 129 ASSERT_FALSE(task_runner_->GetPendingTasks().empty());
155 EXPECT_CALL(gcm_driver_, RegisterImpl(kHeartbeatGCMAppID, _)); 130 EXPECT_CALL(gcm_driver_, RegisterImpl(kHeartbeatGCMAppID, _));
156 task_runner_->RunPendingTasks(); 131 task_runner_->RunPendingTasks();
157 testing::Mock::VerifyAndClearExpectations(&gcm_driver_); 132 testing::Mock::VerifyAndClearExpectations(&gcm_driver_);
158 133
159 // Once we have successfully registered, we should send a heartbeat. 134 // Once we have successfully registered, we should send a heartbeat.
160 EXPECT_CALL(gcm_driver_, SendImpl(kHeartbeatGCMAppID, _, _)); 135 EXPECT_CALL(gcm_driver_, SendImpl(kHeartbeatGCMAppID, _, _));
161 gcm_driver_.CompleteRegistration( 136 gcm_driver_.CompleteRegistration(
162 kHeartbeatGCMAppID, gcm::GCMClient::SUCCESS); 137 kHeartbeatGCMAppID, gcm::GCMClient::SUCCESS);
163 task_runner_->RunPendingTasks(); 138 task_runner_->RunPendingTasks();
164 } 139 }
165 140
166 TEST_F(HeartbeatSchedulerTest, ChangeHeartbeatFrequency) { 141 TEST_F(HeartbeatSchedulerTest, ChangeHeartbeatFrequency) {
167 EXPECT_CALL(gcm_driver_, RegisterImpl(kHeartbeatGCMAppID, _)); 142 EXPECT_CALL(gcm_driver_, RegisterImpl(kHeartbeatGCMAppID, _));
168 chromeos::CrosSettings::Get()->SetBoolean( 143 stub_settings_provider_.SetBoolean(chromeos::kHeartbeatEnabled, true);
169 chromeos::kHeartbeatEnabled, true);
170 gcm_driver_.CompleteRegistration( 144 gcm_driver_.CompleteRegistration(
171 kHeartbeatGCMAppID, gcm::GCMClient::SUCCESS); 145 kHeartbeatGCMAppID, gcm::GCMClient::SUCCESS);
172 146
173 EXPECT_EQ(1U, task_runner_->GetPendingTasks().size()); 147 EXPECT_EQ(1U, task_runner_->GetPendingTasks().size());
174 // Should have a heartbeat task posted with zero delay on startup. 148 // Should have a heartbeat task posted with zero delay on startup.
175 EXPECT_EQ(base::TimeDelta(), task_runner_->NextPendingTaskDelay()); 149 EXPECT_EQ(base::TimeDelta(), task_runner_->NextPendingTaskDelay());
176 testing::Mock::VerifyAndClearExpectations(&gcm_driver_); 150 testing::Mock::VerifyAndClearExpectations(&gcm_driver_);
177 151
178 const int new_delay = 1234*1000; // 1234 seconds. 152 const int new_delay = 1234*1000; // 1234 seconds.
179 chromeos::CrosSettings::Get()->SetInteger(chromeos::kHeartbeatFrequency, 153 stub_settings_provider_.SetInteger(chromeos::kHeartbeatFrequency, new_delay);
180 new_delay);
181 // Now run pending heartbeat task, should send a heartbeat. 154 // Now run pending heartbeat task, should send a heartbeat.
182 gcm::GCMClient::OutgoingMessage message; 155 gcm::GCMClient::OutgoingMessage message;
183 EXPECT_CALL(gcm_driver_, SendImpl(kHeartbeatGCMAppID, _, _)) 156 EXPECT_CALL(gcm_driver_, SendImpl(kHeartbeatGCMAppID, _, _))
184 .WillOnce(SaveArg<2>(&message)); 157 .WillOnce(SaveArg<2>(&message));
185 task_runner_->RunPendingTasks(); 158 task_runner_->RunPendingTasks();
186 EXPECT_TRUE(task_runner_->GetPendingTasks().empty()); 159 EXPECT_TRUE(task_runner_->GetPendingTasks().empty());
187 160
188 // Complete sending a message - we should queue up the next heartbeat 161 // Complete sending a message - we should queue up the next heartbeat
189 // even if the previous attempt failed. 162 // even if the previous attempt failed.
190 gcm_driver_.CompleteSend( 163 gcm_driver_.CompleteSend(
191 kHeartbeatGCMAppID, message.id, gcm::GCMClient::SERVER_ERROR); 164 kHeartbeatGCMAppID, message.id, gcm::GCMClient::SERVER_ERROR);
192 EXPECT_EQ(1U, task_runner_->GetPendingTasks().size()); 165 EXPECT_EQ(1U, task_runner_->GetPendingTasks().size());
193 CheckPendingTaskDelay(scheduler_.last_heartbeat(), 166 CheckPendingTaskDelay(scheduler_.last_heartbeat(),
194 base::TimeDelta::FromMilliseconds(new_delay)); 167 base::TimeDelta::FromMilliseconds(new_delay));
195 } 168 }
196 169
197 TEST_F(HeartbeatSchedulerTest, DisableHeartbeats) { 170 TEST_F(HeartbeatSchedulerTest, DisableHeartbeats) {
198 // Makes sure that we can disable heartbeats on the fly. 171 // Makes sure that we can disable heartbeats on the fly.
199 EXPECT_CALL(gcm_driver_, RegisterImpl(kHeartbeatGCMAppID, _)); 172 EXPECT_CALL(gcm_driver_, RegisterImpl(kHeartbeatGCMAppID, _));
200 chromeos::CrosSettings::Get()->SetBoolean( 173 stub_settings_provider_.SetBoolean(chromeos::kHeartbeatEnabled, true);
201 chromeos::kHeartbeatEnabled, true);
202 gcm::GCMClient::OutgoingMessage message; 174 gcm::GCMClient::OutgoingMessage message;
203 EXPECT_CALL(gcm_driver_, SendImpl(kHeartbeatGCMAppID, _, _)) 175 EXPECT_CALL(gcm_driver_, SendImpl(kHeartbeatGCMAppID, _, _))
204 .WillOnce(SaveArg<2>(&message)); 176 .WillOnce(SaveArg<2>(&message));
205 gcm_driver_.CompleteRegistration( 177 gcm_driver_.CompleteRegistration(
206 kHeartbeatGCMAppID, gcm::GCMClient::SUCCESS); 178 kHeartbeatGCMAppID, gcm::GCMClient::SUCCESS);
207 // Should have a heartbeat task posted. 179 // Should have a heartbeat task posted.
208 EXPECT_EQ(1U, task_runner_->GetPendingTasks().size()); 180 EXPECT_EQ(1U, task_runner_->GetPendingTasks().size());
209 task_runner_->RunPendingTasks(); 181 task_runner_->RunPendingTasks();
210 182
211 // Complete sending a message - we should queue up the next heartbeat. 183 // Complete sending a message - we should queue up the next heartbeat.
212 gcm_driver_.CompleteSend( 184 gcm_driver_.CompleteSend(
213 kHeartbeatGCMAppID, message.id, gcm::GCMClient::SUCCESS); 185 kHeartbeatGCMAppID, message.id, gcm::GCMClient::SUCCESS);
214 186
215 // Should have a new heartbeat task posted. 187 // Should have a new heartbeat task posted.
216 ASSERT_EQ(1U, task_runner_->GetPendingTasks().size()); 188 ASSERT_EQ(1U, task_runner_->GetPendingTasks().size());
217 CheckPendingTaskDelay( 189 CheckPendingTaskDelay(
218 scheduler_.last_heartbeat(), 190 scheduler_.last_heartbeat(),
219 base::TimeDelta::FromMilliseconds( 191 base::TimeDelta::FromMilliseconds(
220 policy::HeartbeatScheduler::kDefaultHeartbeatIntervalMs)); 192 policy::HeartbeatScheduler::kDefaultHeartbeatIntervalMs));
221 testing::Mock::VerifyAndClearExpectations(&gcm_driver_); 193 testing::Mock::VerifyAndClearExpectations(&gcm_driver_);
222 194
223 // Now disable heartbeats. Should get no more heartbeats sent. 195 // Now disable heartbeats. Should get no more heartbeats sent.
224 chromeos::CrosSettings::Get()->SetBoolean( 196 stub_settings_provider_.SetBoolean(chromeos::kHeartbeatEnabled, false);
225 chromeos::kHeartbeatEnabled, false);
226 task_runner_->RunPendingTasks(); 197 task_runner_->RunPendingTasks();
227 EXPECT_TRUE(task_runner_->GetPendingTasks().empty()); 198 EXPECT_TRUE(task_runner_->GetPendingTasks().empty());
228 } 199 }
229 200
230 TEST_F(HeartbeatSchedulerTest, CheckMessageContents) { 201 TEST_F(HeartbeatSchedulerTest, CheckMessageContents) {
231 gcm::GCMClient::OutgoingMessage message; 202 gcm::GCMClient::OutgoingMessage message;
232 EXPECT_CALL(gcm_driver_, RegisterImpl(kHeartbeatGCMAppID, _)); 203 EXPECT_CALL(gcm_driver_, RegisterImpl(kHeartbeatGCMAppID, _));
233 EXPECT_CALL(gcm_driver_, SendImpl(kHeartbeatGCMAppID, _, _)) 204 EXPECT_CALL(gcm_driver_, SendImpl(kHeartbeatGCMAppID, _, _))
234 .WillOnce(SaveArg<2>(&message)); 205 .WillOnce(SaveArg<2>(&message));
235 chromeos::CrosSettings::Get()->SetBoolean( 206 stub_settings_provider_.SetBoolean(chromeos::kHeartbeatEnabled, true);
236 chromeos::kHeartbeatEnabled, true);
237 gcm_driver_.CompleteRegistration( 207 gcm_driver_.CompleteRegistration(
238 kHeartbeatGCMAppID, gcm::GCMClient::SUCCESS); 208 kHeartbeatGCMAppID, gcm::GCMClient::SUCCESS);
239 task_runner_->RunPendingTasks(); 209 task_runner_->RunPendingTasks();
240 210
241 // Heartbeats should have a time-to-live equivalent to the heartbeat frequency 211 // Heartbeats should have a time-to-live equivalent to the heartbeat frequency
242 // so we don't have more than one heartbeat queued at a time. 212 // so we don't have more than one heartbeat queued at a time.
243 EXPECT_EQ(policy::HeartbeatScheduler::kDefaultHeartbeatIntervalMs/1000, 213 EXPECT_EQ(policy::HeartbeatScheduler::kDefaultHeartbeatIntervalMs/1000,
244 message.time_to_live); 214 message.time_to_live);
245 215
246 // Check the values in the message payload. 216 // Check the values in the message payload.
247 EXPECT_EQ("hb", message.data["type"]); 217 EXPECT_EQ("hb", message.data["type"]);
248 int64 timestamp; 218 int64 timestamp;
249 EXPECT_TRUE(base::StringToInt64(message.data["timestamp"], &timestamp)); 219 EXPECT_TRUE(base::StringToInt64(message.data["timestamp"], &timestamp));
250 EXPECT_EQ(kFakeEnrollmentDomain, message.data["domain_name"]); 220 EXPECT_EQ(kFakeEnrollmentDomain, message.data["domain_name"]);
251 EXPECT_EQ(kFakeDeviceId, message.data["device_id"]); 221 EXPECT_EQ(kFakeDeviceId, message.data["device_id"]);
252 } 222 }
253 223
254 } // namespace 224 } // namespace
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698