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

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: Rebase 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/scoped_cros_settings_test_helper.h"
11 #include "chrome/browser/chromeos/settings/stub_cros_settings_provider.h"
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 17 matching lines...) Expand all
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 {
48 public: 47 public:
49 StatusUploaderTest() 48 StatusUploaderTest() : task_runner_(new base::TestSimpleTaskRunner()) {
50 : task_runner_(new base::TestSimpleTaskRunner()),
51 device_settings_provider_(nullptr) {
52 DeviceStatusCollector::RegisterPrefs(prefs_.registry()); 49 DeviceStatusCollector::RegisterPrefs(prefs_.registry());
53 } 50 }
54 51
55 void SetUp() override { 52 void SetUp() override {
56 client_.SetDMToken("dm_token"); 53 client_.SetDMToken("dm_token");
57 collector_.reset(new MockDeviceStatusCollector(&prefs_)); 54 collector_.reset(new MockDeviceStatusCollector(&prefs_));
58 55 settings_helper_.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 } 56 }
70 57
71 void TearDown() override { 58 void TearDown() override {
72 content::RunAllBlockingPoolTasksUntilIdle(); 59 content::RunAllBlockingPoolTasksUntilIdle();
73 // Restore the real DeviceSettingsProvider.
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 } 60 }
79 61
80 // Given a pending task to upload status, mocks out a server response. 62 // Given a pending task to upload status, mocks out a server response.
81 void RunPendingUploadTaskAndCheckNext(const StatusUploader& uploader, 63 void RunPendingUploadTaskAndCheckNext(const StatusUploader& uploader,
82 base::TimeDelta expected_delay) { 64 base::TimeDelta expected_delay) {
83 EXPECT_FALSE(task_runner_->GetPendingTasks().empty()); 65 EXPECT_FALSE(task_runner_->GetPendingTasks().empty());
84 CloudPolicyClient::StatusCallback callback; 66 CloudPolicyClient::StatusCallback callback;
85 EXPECT_CALL(client_, UploadDeviceStatus(_, _, _)) 67 EXPECT_CALL(client_, UploadDeviceStatus(_, _, _))
86 .WillOnce(SaveArg<2>(&callback)); 68 .WillOnce(SaveArg<2>(&callback));
87 task_runner_->RunPendingTasks(); 69 task_runner_->RunPendingTasks();
(...skipping 19 matching lines...) Expand all
107 // |expected_delay| and |now| + |expected_delay|. 89 // |expected_delay| and |now| + |expected_delay|.
108 base::Time now = base::Time::NowFromSystemTime(); 90 base::Time now = base::Time::NowFromSystemTime();
109 base::Time next_task = now + task_runner_->NextPendingTaskDelay(); 91 base::Time next_task = now + task_runner_->NextPendingTaskDelay();
110 92
111 EXPECT_LE(next_task, now + expected_delay); 93 EXPECT_LE(next_task, now + expected_delay);
112 EXPECT_GE(next_task, uploader.last_upload() + expected_delay); 94 EXPECT_GE(next_task, uploader.last_upload() + expected_delay);
113 } 95 }
114 96
115 base::MessageLoop loop_; 97 base::MessageLoop loop_;
116 scoped_refptr<base::TestSimpleTaskRunner> task_runner_; 98 scoped_refptr<base::TestSimpleTaskRunner> task_runner_;
117 chromeos::ScopedTestDeviceSettingsService test_device_settings_service_; 99 chromeos::ScopedCrosSettingsTestHelper settings_helper_;
118 chromeos::ScopedTestCrosSettings test_cros_settings_;
119 scoped_ptr<MockDeviceStatusCollector> collector_; 100 scoped_ptr<MockDeviceStatusCollector> collector_;
120 chromeos::CrosSettingsProvider* device_settings_provider_;
121 chromeos::StubCrosSettingsProvider stub_settings_provider_;
122 MockCloudPolicyClient client_; 101 MockCloudPolicyClient client_;
123 MockDeviceManagementService device_management_service_; 102 MockDeviceManagementService device_management_service_;
124 TestingPrefServiceSimple prefs_; 103 TestingPrefServiceSimple prefs_;
125 }; 104 };
126 105
127 TEST_F(StatusUploaderTest, BasicTest) { 106 TEST_F(StatusUploaderTest, BasicTest) {
128 EXPECT_TRUE(task_runner_->GetPendingTasks().empty()); 107 EXPECT_TRUE(task_runner_->GetPendingTasks().empty());
129 StatusUploader uploader(&client_, collector_.Pass(), task_runner_); 108 StatusUploader uploader(&client_, collector_.Pass(), task_runner_);
130 EXPECT_EQ(1U, task_runner_->GetPendingTasks().size()); 109 EXPECT_EQ(1U, task_runner_->GetPendingTasks().size());
131 // On startup, first update should happen immediately. 110 // On startup, first update should happen immediately.
132 EXPECT_EQ(base::TimeDelta(), task_runner_->NextPendingTaskDelay()); 111 EXPECT_EQ(base::TimeDelta(), task_runner_->NextPendingTaskDelay());
133 } 112 }
134 113
135 TEST_F(StatusUploaderTest, DifferentFrequencyAtStart) { 114 TEST_F(StatusUploaderTest, DifferentFrequencyAtStart) {
136 // Keep a pointer to the mock collector because collector_ gets cleared 115 // Keep a pointer to the mock collector because collector_ gets cleared
137 // when it is passed to the StatusUploader constructor below. 116 // when it is passed to the StatusUploader constructor below.
138 MockDeviceStatusCollector* const mock_collector = collector_.get(); 117 MockDeviceStatusCollector* const mock_collector = collector_.get();
139 const int new_delay = StatusUploader::kDefaultUploadDelayMs * 2; 118 const int new_delay = StatusUploader::kDefaultUploadDelayMs * 2;
140 chromeos::CrosSettings::Get()->SetInteger(chromeos::kReportUploadFrequency, 119 settings_helper_.SetInteger(chromeos::kReportUploadFrequency, new_delay);
141 new_delay);
142 const base::TimeDelta expected_delay = base::TimeDelta::FromMilliseconds( 120 const base::TimeDelta expected_delay = base::TimeDelta::FromMilliseconds(
143 new_delay); 121 new_delay);
144 EXPECT_TRUE(task_runner_->GetPendingTasks().empty()); 122 EXPECT_TRUE(task_runner_->GetPendingTasks().empty());
145 StatusUploader uploader(&client_, collector_.Pass(), task_runner_); 123 StatusUploader uploader(&client_, collector_.Pass(), task_runner_);
146 ASSERT_EQ(1U, task_runner_->GetPendingTasks().size()); 124 ASSERT_EQ(1U, task_runner_->GetPendingTasks().size());
147 // On startup, first update should happen immediately. 125 // On startup, first update should happen immediately.
148 EXPECT_EQ(base::TimeDelta(), task_runner_->NextPendingTaskDelay()); 126 EXPECT_EQ(base::TimeDelta(), task_runner_->NextPendingTaskDelay());
149 127
150 EXPECT_CALL(*mock_collector, GetDeviceStatus(_)).WillRepeatedly(Return(true)); 128 EXPECT_CALL(*mock_collector, GetDeviceStatus(_)).WillRepeatedly(Return(true));
151 EXPECT_CALL(*mock_collector, GetDeviceSessionStatus(_)).WillRepeatedly( 129 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 173 // Keep a pointer to the mock collector because collector_ gets cleared
196 // when it is passed to the StatusUploader constructor below. 174 // when it is passed to the StatusUploader constructor below.
197 MockDeviceStatusCollector* const mock_collector = collector_.get(); 175 MockDeviceStatusCollector* const mock_collector = collector_.get();
198 StatusUploader uploader(&client_, collector_.Pass(), task_runner_); 176 StatusUploader uploader(&client_, collector_.Pass(), task_runner_);
199 EXPECT_CALL(*mock_collector, GetDeviceStatus(_)).WillRepeatedly(Return(true)); 177 EXPECT_CALL(*mock_collector, GetDeviceStatus(_)).WillRepeatedly(Return(true));
200 EXPECT_CALL(*mock_collector, GetDeviceSessionStatus(_)).WillRepeatedly( 178 EXPECT_CALL(*mock_collector, GetDeviceSessionStatus(_)).WillRepeatedly(
201 Return(true)); 179 Return(true));
202 // Change the frequency. The new frequency should be reflected in the timing 180 // Change the frequency. The new frequency should be reflected in the timing
203 // used for the next callback. 181 // used for the next callback.
204 const int new_delay = StatusUploader::kDefaultUploadDelayMs * 2; 182 const int new_delay = StatusUploader::kDefaultUploadDelayMs * 2;
205 chromeos::CrosSettings::Get()->SetInteger(chromeos::kReportUploadFrequency, 183 settings_helper_.SetInteger(chromeos::kReportUploadFrequency, new_delay);
206 new_delay);
207 const base::TimeDelta expected_delay = base::TimeDelta::FromMilliseconds( 184 const base::TimeDelta expected_delay = base::TimeDelta::FromMilliseconds(
208 new_delay); 185 new_delay);
209 RunPendingUploadTaskAndCheckNext(uploader, expected_delay); 186 RunPendingUploadTaskAndCheckNext(uploader, expected_delay);
210 } 187 }
211 188
212 } // namespace policy 189 } // namespace policy
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698