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

Side by Side Diff: chrome/browser/chromeos/policy/status_uploader_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 "base/prefs/testing_pref_service.h" 5 #include "base/prefs/testing_pref_service.h"
6 #include "base/test/test_simple_task_runner.h" 6 #include "base/test/test_simple_task_runner.h"
7 #include "base/time/time.h" 7 #include "base/time/time.h"
8 #include "chrome/browser/chromeos/policy/device_status_collector.h" 8 #include "chrome/browser/chromeos/policy/device_status_collector.h"
9 #include "chrome/browser/chromeos/policy/status_uploader.h" 9 #include "chrome/browser/chromeos/policy/status_uploader.h"
10 #include "chrome/browser/chromeos/settings/device_settings_service.h" 10 #include "chrome/browser/chromeos/settings/settings_provider_test_base.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 120 and others.
12 #include "chromeos/settings/cros_settings_names.h" 11 #include "chromeos/settings/cros_settings_names.h"
13 #include "components/policy/core/common/cloud/cloud_policy_client.h" 12 #include "components/policy/core/common/cloud/cloud_policy_client.h"
14 #include "components/policy/core/common/cloud/mock_cloud_policy_client.h" 13 #include "components/policy/core/common/cloud/mock_cloud_policy_client.h"
15 #include "components/policy/core/common/cloud/mock_device_management_service.h" 14 #include "components/policy/core/common/cloud/mock_device_management_service.h"
16 #include "content/public/test/test_utils.h" 15 #include "content/public/test/test_utils.h"
17 #include "net/url_request/url_request_context_getter.h" 16 #include "net/url_request/url_request_context_getter.h"
18 #include "testing/gmock/include/gmock/gmock.h" 17 #include "testing/gmock/include/gmock/gmock.h"
19 #include "testing/gtest/include/gtest/gtest.h" 18 #include "testing/gtest/include/gtest/gtest.h"
20 19
21 using ::testing::_; 20 using ::testing::_;
(...skipping 15 matching lines...) Expand all
37 policy::DeviceStatusCollector::VolumeInfoFetcher()) { 36 policy::DeviceStatusCollector::VolumeInfoFetcher()) {
38 } 37 }
39 38
40 MOCK_METHOD1(GetDeviceStatus, bool(em::DeviceStatusReportRequest*)); 39 MOCK_METHOD1(GetDeviceStatus, bool(em::DeviceStatusReportRequest*));
41 MOCK_METHOD1(GetDeviceSessionStatus, bool(em::SessionStatusReportRequest*)); 40 MOCK_METHOD1(GetDeviceSessionStatus, bool(em::SessionStatusReportRequest*));
42 }; 41 };
43 42
44 } // namespace 43 } // namespace
45 44
46 namespace policy { 45 namespace policy {
47 class StatusUploaderTest : public testing::Test { 46 class StatusUploaderTest : public testing::Test,
47 public chromeos::SettingsProviderTestBase {
48 public: 48 public:
49 StatusUploaderTest() 49 StatusUploaderTest() : task_runner_(new base::TestSimpleTaskRunner()) {
50 : task_runner_(new base::TestSimpleTaskRunner()),
51 device_settings_provider_(nullptr) {
52 DeviceStatusCollector::RegisterPrefs(prefs_.registry()); 50 DeviceStatusCollector::RegisterPrefs(prefs_.registry());
53 } 51 }
54 52
55 void SetUp() override { 53 void SetUp() override {
56 client_.SetDMToken("dm_token"); 54 client_.SetDMToken("dm_token");
57 collector_.reset(new MockDeviceStatusCollector(&prefs_)); 55 collector_.reset(new MockDeviceStatusCollector(&prefs_));
58 56 ReplaceProvider(chromeos::kReportUploadFrequency);
59 // Swap out the DeviceSettingsProvider with our stub settings provider
60 // so we can set values for the upload frequency.
61 chromeos::CrosSettings* cros_settings = chromeos::CrosSettings::Get();
62 device_settings_provider_ =
63 cros_settings->GetProvider(chromeos::kReportDeviceVersionInfo);
64 EXPECT_TRUE(device_settings_provider_);
65 EXPECT_TRUE(
66 cros_settings->RemoveSettingsProvider(device_settings_provider_));
67 cros_settings->AddSettingsProvider(&stub_settings_provider_);
68
69 } 57 }
70 58
71 void TearDown() override { 59 void TearDown() override {
72 content::RunAllBlockingPoolTasksUntilIdle(); 60 content::RunAllBlockingPoolTasksUntilIdle();
73 // Restore the real DeviceSettingsProvider. 61 RestoreProvider();
74 chromeos::CrosSettings* cros_settings = chromeos::CrosSettings::Get();
75 EXPECT_TRUE(cros_settings->RemoveSettingsProvider(
76 &stub_settings_provider_));
77 cros_settings->AddSettingsProvider(device_settings_provider_);
78 } 62 }
79 63
80 // Given a pending task to upload status, mocks out a server response. 64 // Given a pending task to upload status, mocks out a server response.
81 void RunPendingUploadTaskAndCheckNext(const StatusUploader& uploader, 65 void RunPendingUploadTaskAndCheckNext(const StatusUploader& uploader,
82 base::TimeDelta expected_delay) { 66 base::TimeDelta expected_delay) {
83 EXPECT_FALSE(task_runner_->GetPendingTasks().empty()); 67 EXPECT_FALSE(task_runner_->GetPendingTasks().empty());
84 CloudPolicyClient::StatusCallback callback; 68 CloudPolicyClient::StatusCallback callback;
85 EXPECT_CALL(client_, UploadDeviceStatus(_, _, _)) 69 EXPECT_CALL(client_, UploadDeviceStatus(_, _, _))
86 .WillOnce(SaveArg<2>(&callback)); 70 .WillOnce(SaveArg<2>(&callback));
87 task_runner_->RunPendingTasks(); 71 task_runner_->RunPendingTasks();
(...skipping 19 matching lines...) Expand all
107 // |expected_delay| and |now| + |expected_delay|. 91 // |expected_delay| and |now| + |expected_delay|.
108 base::Time now = base::Time::NowFromSystemTime(); 92 base::Time now = base::Time::NowFromSystemTime();
109 base::Time next_task = now + task_runner_->NextPendingTaskDelay(); 93 base::Time next_task = now + task_runner_->NextPendingTaskDelay();
110 94
111 EXPECT_LE(next_task, now + expected_delay); 95 EXPECT_LE(next_task, now + expected_delay);
112 EXPECT_GE(next_task, uploader.last_upload() + expected_delay); 96 EXPECT_GE(next_task, uploader.last_upload() + expected_delay);
113 } 97 }
114 98
115 base::MessageLoop loop_; 99 base::MessageLoop loop_;
116 scoped_refptr<base::TestSimpleTaskRunner> task_runner_; 100 scoped_refptr<base::TestSimpleTaskRunner> task_runner_;
117 chromeos::ScopedTestDeviceSettingsService test_device_settings_service_;
118 chromeos::ScopedTestCrosSettings test_cros_settings_;
119 scoped_ptr<MockDeviceStatusCollector> collector_; 101 scoped_ptr<MockDeviceStatusCollector> collector_;
120 chromeos::CrosSettingsProvider* device_settings_provider_;
121 chromeos::StubCrosSettingsProvider stub_settings_provider_;
122 MockCloudPolicyClient client_; 102 MockCloudPolicyClient client_;
123 MockDeviceManagementService device_management_service_; 103 MockDeviceManagementService device_management_service_;
124 TestingPrefServiceSimple prefs_; 104 TestingPrefServiceSimple prefs_;
125 }; 105 };
126 106
127 TEST_F(StatusUploaderTest, BasicTest) { 107 TEST_F(StatusUploaderTest, BasicTest) {
128 EXPECT_TRUE(task_runner_->GetPendingTasks().empty()); 108 EXPECT_TRUE(task_runner_->GetPendingTasks().empty());
129 StatusUploader uploader(&client_, collector_.Pass(), task_runner_); 109 StatusUploader uploader(&client_, collector_.Pass(), task_runner_);
130 EXPECT_EQ(1U, task_runner_->GetPendingTasks().size()); 110 EXPECT_EQ(1U, task_runner_->GetPendingTasks().size());
131 // On startup, first update should happen immediately. 111 // On startup, first update should happen immediately.
132 EXPECT_EQ(base::TimeDelta(), task_runner_->NextPendingTaskDelay()); 112 EXPECT_EQ(base::TimeDelta(), task_runner_->NextPendingTaskDelay());
133 } 113 }
134 114
135 TEST_F(StatusUploaderTest, DifferentFrequencyAtStart) { 115 TEST_F(StatusUploaderTest, DifferentFrequencyAtStart) {
136 // Keep a pointer to the mock collector because collector_ gets cleared 116 // Keep a pointer to the mock collector because collector_ gets cleared
137 // when it is passed to the StatusUploader constructor below. 117 // when it is passed to the StatusUploader constructor below.
138 MockDeviceStatusCollector* const mock_collector = collector_.get(); 118 MockDeviceStatusCollector* const mock_collector = collector_.get();
139 const int new_delay = StatusUploader::kDefaultUploadDelayMs * 2; 119 const int new_delay = StatusUploader::kDefaultUploadDelayMs * 2;
140 chromeos::CrosSettings::Get()->SetInteger(chromeos::kReportUploadFrequency, 120 stub_settings_provider_.SetInteger(chromeos::kReportUploadFrequency,
141 new_delay); 121 new_delay);
142 const base::TimeDelta expected_delay = base::TimeDelta::FromMilliseconds( 122 const base::TimeDelta expected_delay = base::TimeDelta::FromMilliseconds(
143 new_delay); 123 new_delay);
144 EXPECT_TRUE(task_runner_->GetPendingTasks().empty()); 124 EXPECT_TRUE(task_runner_->GetPendingTasks().empty());
145 StatusUploader uploader(&client_, collector_.Pass(), task_runner_); 125 StatusUploader uploader(&client_, collector_.Pass(), task_runner_);
146 ASSERT_EQ(1U, task_runner_->GetPendingTasks().size()); 126 ASSERT_EQ(1U, task_runner_->GetPendingTasks().size());
147 // On startup, first update should happen immediately. 127 // On startup, first update should happen immediately.
148 EXPECT_EQ(base::TimeDelta(), task_runner_->NextPendingTaskDelay()); 128 EXPECT_EQ(base::TimeDelta(), task_runner_->NextPendingTaskDelay());
149 129
150 EXPECT_CALL(*mock_collector, GetDeviceStatus(_)).WillRepeatedly(Return(true)); 130 EXPECT_CALL(*mock_collector, GetDeviceStatus(_)).WillRepeatedly(Return(true));
151 EXPECT_CALL(*mock_collector, GetDeviceSessionStatus(_)).WillRepeatedly( 131 EXPECT_CALL(*mock_collector, GetDeviceSessionStatus(_)).WillRepeatedly(
(...skipping 43 matching lines...) Expand 10 before | Expand all | Expand 10 after
195 // Keep a pointer to the mock collector because collector_ gets cleared 175 // Keep a pointer to the mock collector because collector_ gets cleared
196 // when it is passed to the StatusUploader constructor below. 176 // when it is passed to the StatusUploader constructor below.
197 MockDeviceStatusCollector* const mock_collector = collector_.get(); 177 MockDeviceStatusCollector* const mock_collector = collector_.get();
198 StatusUploader uploader(&client_, collector_.Pass(), task_runner_); 178 StatusUploader uploader(&client_, collector_.Pass(), task_runner_);
199 EXPECT_CALL(*mock_collector, GetDeviceStatus(_)).WillRepeatedly(Return(true)); 179 EXPECT_CALL(*mock_collector, GetDeviceStatus(_)).WillRepeatedly(Return(true));
200 EXPECT_CALL(*mock_collector, GetDeviceSessionStatus(_)).WillRepeatedly( 180 EXPECT_CALL(*mock_collector, GetDeviceSessionStatus(_)).WillRepeatedly(
201 Return(true)); 181 Return(true));
202 // Change the frequency. The new frequency should be reflected in the timing 182 // Change the frequency. The new frequency should be reflected in the timing
203 // used for the next callback. 183 // used for the next callback.
204 const int new_delay = StatusUploader::kDefaultUploadDelayMs * 2; 184 const int new_delay = StatusUploader::kDefaultUploadDelayMs * 2;
205 chromeos::CrosSettings::Get()->SetInteger(chromeos::kReportUploadFrequency, 185 stub_settings_provider_.SetInteger(chromeos::kReportUploadFrequency,
206 new_delay); 186 new_delay);
207 const base::TimeDelta expected_delay = base::TimeDelta::FromMilliseconds( 187 const base::TimeDelta expected_delay = base::TimeDelta::FromMilliseconds(
208 new_delay); 188 new_delay);
209 RunPendingUploadTaskAndCheckNext(uploader, expected_delay); 189 RunPendingUploadTaskAndCheckNext(uploader, expected_delay);
210 } 190 }
211 191
212 } // namespace policy 192 } // namespace policy
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698