OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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 "chromeos/network/shill_property_handler.h" | 5 #include "chromeos/network/shill_property_handler.h" |
6 | 6 |
7 #include <map> | 7 #include <map> |
8 #include <set> | 8 #include <set> |
9 #include <string> | 9 #include <string> |
10 | 10 |
11 #include "base/bind.h" | 11 #include "base/bind.h" |
12 #include "base/memory/scoped_ptr.h" | 12 #include "base/memory/scoped_ptr.h" |
13 #include "base/message_loop.h" | 13 #include "base/message_loop.h" |
14 #include "base/values.h" | 14 #include "base/values.h" |
15 #include "chromeos/dbus/dbus_thread_manager.h" | 15 #include "chromeos/dbus/dbus_thread_manager.h" |
16 #include "chromeos/dbus/shill_device_client.h" | 16 #include "chromeos/dbus/shill_device_client.h" |
| 17 #include "chromeos/dbus/shill_ipconfig_client.h" |
17 #include "chromeos/dbus/shill_manager_client.h" | 18 #include "chromeos/dbus/shill_manager_client.h" |
18 #include "chromeos/dbus/shill_service_client.h" | 19 #include "chromeos/dbus/shill_service_client.h" |
19 #include "dbus/object_path.h" | 20 #include "dbus/object_path.h" |
20 #include "testing/gtest/include/gtest/gtest.h" | 21 #include "testing/gtest/include/gtest/gtest.h" |
21 #include "third_party/cros_system_api/dbus/service_constants.h" | 22 #include "third_party/cros_system_api/dbus/service_constants.h" |
22 | 23 |
23 namespace chromeos { | 24 namespace chromeos { |
24 | 25 |
25 namespace { | 26 namespace { |
26 | 27 |
| 28 void DoNothingWithCallStatus(DBusMethodCallStatus call_status) { |
| 29 } |
| 30 |
27 void ErrorCallbackFunction(const std::string& error_name, | 31 void ErrorCallbackFunction(const std::string& error_name, |
28 const std::string& error_message) { | 32 const std::string& error_message) { |
29 LOG(ERROR) << "Shill Error: " << error_name << " : " << error_message; | 33 LOG(ERROR) << "Shill Error: " << error_name << " : " << error_message; |
30 } | 34 } |
31 | 35 |
32 class TestListener : public internal::ShillPropertyHandler::Listener { | 36 class TestListener : public internal::ShillPropertyHandler::Listener { |
33 public: | 37 public: |
34 TestListener() : manager_updates_(0), errors_(0) { | 38 TestListener() : manager_updates_(0), errors_(0) { |
35 } | 39 } |
36 | 40 |
(...skipping 20 matching lines...) Expand all Loading... |
57 const std::string& device_path, | 61 const std::string& device_path, |
58 const std::string& key, | 62 const std::string& key, |
59 const base::Value& value) OVERRIDE { | 63 const base::Value& value) OVERRIDE { |
60 AddPropertyUpdate(flimflam::kDevicesProperty, device_path); | 64 AddPropertyUpdate(flimflam::kDevicesProperty, device_path); |
61 } | 65 } |
62 | 66 |
63 virtual void ManagerPropertyChanged() OVERRIDE { | 67 virtual void ManagerPropertyChanged() OVERRIDE { |
64 ++manager_updates_; | 68 ++manager_updates_; |
65 } | 69 } |
66 | 70 |
67 virtual void UpdateNetworkServiceIPAddress( | |
68 const std::string& service_path, | |
69 const std::string& ip_address) OVERRIDE { | |
70 AddPropertyUpdate(flimflam::kServicesProperty, service_path); | |
71 } | |
72 | |
73 virtual void ManagedStateListChanged( | 71 virtual void ManagedStateListChanged( |
74 ManagedState::ManagedType type) OVERRIDE { | 72 ManagedState::ManagedType type) OVERRIDE { |
75 AddStateListUpdate(GetTypeString(type)); | 73 AddStateListUpdate(GetTypeString(type)); |
76 } | 74 } |
77 | 75 |
78 std::vector<std::string>& entries(const std::string& type) { | 76 std::vector<std::string>& entries(const std::string& type) { |
79 return entries_[type]; | 77 return entries_[type]; |
80 } | 78 } |
81 std::map<std::string, int>& property_updates(const std::string& type) { | 79 std::map<std::string, int>& property_updates(const std::string& type) { |
82 return property_updates_[type]; | 80 return property_updates_[type]; |
(...skipping 67 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
150 // default stub properties. | 148 // default stub properties. |
151 manager_test_ = | 149 manager_test_ = |
152 DBusThreadManager::Get()->GetShillManagerClient()->GetTestInterface(); | 150 DBusThreadManager::Get()->GetShillManagerClient()->GetTestInterface(); |
153 ASSERT_TRUE(manager_test_); | 151 ASSERT_TRUE(manager_test_); |
154 device_test_ = | 152 device_test_ = |
155 DBusThreadManager::Get()->GetShillDeviceClient()->GetTestInterface(); | 153 DBusThreadManager::Get()->GetShillDeviceClient()->GetTestInterface(); |
156 ASSERT_TRUE(device_test_); | 154 ASSERT_TRUE(device_test_); |
157 service_test_ = | 155 service_test_ = |
158 DBusThreadManager::Get()->GetShillServiceClient()->GetTestInterface(); | 156 DBusThreadManager::Get()->GetShillServiceClient()->GetTestInterface(); |
159 ASSERT_TRUE(service_test_); | 157 ASSERT_TRUE(service_test_); |
| 158 SetupShillPropertyHandler(); |
| 159 message_loop_.RunUntilIdle(); |
160 } | 160 } |
161 | 161 |
162 virtual void TearDown() OVERRIDE { | 162 virtual void TearDown() OVERRIDE { |
163 shill_property_handler_.reset(); | 163 shill_property_handler_.reset(); |
164 listener_.reset(); | 164 listener_.reset(); |
165 DBusThreadManager::Shutdown(); | 165 DBusThreadManager::Shutdown(); |
166 } | 166 } |
167 | 167 |
168 void AddDevice(const std::string& type, const std::string& id) { | 168 void AddDevice(const std::string& type, const std::string& id) { |
169 ASSERT_TRUE(IsValidType(type)); | 169 ASSERT_TRUE(IsValidType(type)); |
170 device_test_->AddDevice(id, type, std::string("/device/" + id)); | 170 device_test_->AddDevice(id, type, std::string("/device/" + id)); |
171 } | 171 } |
172 | 172 |
173 void RemoveDevice(const std::string& id) { | 173 void RemoveDevice(const std::string& id) { |
174 device_test_->RemoveDevice(id); | 174 device_test_->RemoveDevice(id); |
175 } | 175 } |
176 | 176 |
177 void AddService(const std::string& type, | 177 void AddService(const std::string& type, |
178 const std::string& id, | 178 const std::string& id, |
179 const std::string& state, | 179 const std::string& state, |
180 bool add_to_watch_list) { | 180 bool add_to_watch_list) { |
181 ASSERT_TRUE(IsValidType(type)); | 181 ASSERT_TRUE(IsValidType(type)); |
182 service_test_->AddService(id, id, type, state, add_to_watch_list); | 182 service_test_->AddService(id, id, type, state, |
| 183 add_to_watch_list); |
| 184 } |
| 185 |
| 186 void AddServiceWithIPConfig(const std::string& type, |
| 187 const std::string& id, |
| 188 const std::string& state, |
| 189 const std::string& ipconfig_path, |
| 190 bool add_to_watch_list) { |
| 191 ASSERT_TRUE(IsValidType(type)); |
| 192 service_test_->AddServiceWithIPConfig(id, id, type, state, |
| 193 ipconfig_path, add_to_watch_list); |
183 } | 194 } |
184 | 195 |
185 void RemoveService(const std::string& id) { | 196 void RemoveService(const std::string& id) { |
186 service_test_->RemoveService(id); | 197 service_test_->RemoveService(id); |
187 } | 198 } |
188 | 199 |
189 // Call this after any initial Shill client setup | 200 // Call this after any initial Shill client setup |
190 void SetupShillPropertyHandler() { | 201 void SetupShillPropertyHandler() { |
191 SetupDefaultShillState(); | 202 SetupDefaultShillState(); |
192 listener_.reset(new TestListener); | 203 listener_.reset(new TestListener); |
(...skipping 34 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
227 scoped_ptr<internal::ShillPropertyHandler> shill_property_handler_; | 238 scoped_ptr<internal::ShillPropertyHandler> shill_property_handler_; |
228 ShillManagerClient::TestInterface* manager_test_; | 239 ShillManagerClient::TestInterface* manager_test_; |
229 ShillDeviceClient::TestInterface* device_test_; | 240 ShillDeviceClient::TestInterface* device_test_; |
230 ShillServiceClient::TestInterface* service_test_; | 241 ShillServiceClient::TestInterface* service_test_; |
231 | 242 |
232 private: | 243 private: |
233 DISALLOW_COPY_AND_ASSIGN(ShillPropertyHandlerTest); | 244 DISALLOW_COPY_AND_ASSIGN(ShillPropertyHandlerTest); |
234 }; | 245 }; |
235 | 246 |
236 TEST_F(ShillPropertyHandlerTest, ShillPropertyHandlerStub) { | 247 TEST_F(ShillPropertyHandlerTest, ShillPropertyHandlerStub) { |
237 SetupShillPropertyHandler(); | |
238 message_loop_.RunUntilIdle(); | |
239 EXPECT_EQ(1, listener_->manager_updates()); | 248 EXPECT_EQ(1, listener_->manager_updates()); |
240 EXPECT_TRUE(shill_property_handler_->TechnologyAvailable( | 249 EXPECT_TRUE(shill_property_handler_->TechnologyAvailable( |
241 flimflam::kTypeWifi)); | 250 flimflam::kTypeWifi)); |
242 EXPECT_TRUE(shill_property_handler_->TechnologyEnabled( | 251 EXPECT_TRUE(shill_property_handler_->TechnologyEnabled( |
243 flimflam::kTypeWifi)); | 252 flimflam::kTypeWifi)); |
244 const size_t kNumShillManagerClientStubImplDevices = 2; | 253 const size_t kNumShillManagerClientStubImplDevices = 2; |
245 EXPECT_EQ(kNumShillManagerClientStubImplDevices, | 254 EXPECT_EQ(kNumShillManagerClientStubImplDevices, |
246 listener_->entries(flimflam::kDevicesProperty).size()); | 255 listener_->entries(flimflam::kDevicesProperty).size()); |
247 const size_t kNumShillManagerClientStubImplServices = 4; | 256 const size_t kNumShillManagerClientStubImplServices = 4; |
248 EXPECT_EQ(kNumShillManagerClientStubImplServices, | 257 EXPECT_EQ(kNumShillManagerClientStubImplServices, |
249 listener_->entries(flimflam::kServicesProperty).size()); | 258 listener_->entries(flimflam::kServicesProperty).size()); |
250 | 259 |
251 EXPECT_EQ(0, listener_->errors()); | 260 EXPECT_EQ(0, listener_->errors()); |
252 } | 261 } |
253 | 262 |
254 TEST_F(ShillPropertyHandlerTest, ShillPropertyHandlerTechnologyChanged) { | 263 TEST_F(ShillPropertyHandlerTest, ShillPropertyHandlerTechnologyChanged) { |
255 SetupShillPropertyHandler(); | |
256 message_loop_.RunUntilIdle(); | |
257 EXPECT_EQ(1, listener_->manager_updates()); | 264 EXPECT_EQ(1, listener_->manager_updates()); |
258 // Add a disabled technology. | 265 // Add a disabled technology. |
259 manager_test_->AddTechnology(flimflam::kTypeWimax, false); | 266 manager_test_->AddTechnology(flimflam::kTypeWimax, false); |
260 message_loop_.RunUntilIdle(); | 267 message_loop_.RunUntilIdle(); |
261 EXPECT_EQ(2, listener_->manager_updates()); | 268 EXPECT_EQ(2, listener_->manager_updates()); |
262 EXPECT_TRUE(shill_property_handler_->TechnologyAvailable( | 269 EXPECT_TRUE(shill_property_handler_->TechnologyAvailable( |
263 flimflam::kTypeWimax)); | 270 flimflam::kTypeWimax)); |
264 EXPECT_FALSE(shill_property_handler_->TechnologyEnabled( | 271 EXPECT_FALSE(shill_property_handler_->TechnologyEnabled( |
265 flimflam::kTypeWimax)); | 272 flimflam::kTypeWimax)); |
266 | 273 |
267 // Enable the technology. | 274 // Enable the technology. |
268 DBusThreadManager::Get()->GetShillManagerClient()->EnableTechnology( | 275 DBusThreadManager::Get()->GetShillManagerClient()->EnableTechnology( |
269 flimflam::kTypeWimax, | 276 flimflam::kTypeWimax, |
270 base::Bind(&base::DoNothing), base::Bind(&ErrorCallbackFunction)); | 277 base::Bind(&base::DoNothing), base::Bind(&ErrorCallbackFunction)); |
271 message_loop_.RunUntilIdle(); | 278 message_loop_.RunUntilIdle(); |
272 EXPECT_EQ(3, listener_->manager_updates()); | 279 EXPECT_EQ(3, listener_->manager_updates()); |
273 EXPECT_TRUE(shill_property_handler_->TechnologyEnabled( | 280 EXPECT_TRUE(shill_property_handler_->TechnologyEnabled( |
274 flimflam::kTypeWimax)); | 281 flimflam::kTypeWimax)); |
275 | 282 |
276 EXPECT_EQ(0, listener_->errors()); | 283 EXPECT_EQ(0, listener_->errors()); |
277 } | 284 } |
278 | 285 |
279 TEST_F(ShillPropertyHandlerTest, ShillPropertyHandlerDevicePropertyChanged) { | 286 TEST_F(ShillPropertyHandlerTest, ShillPropertyHandlerDevicePropertyChanged) { |
280 SetupShillPropertyHandler(); | |
281 message_loop_.RunUntilIdle(); | |
282 EXPECT_EQ(1, listener_->manager_updates()); | 287 EXPECT_EQ(1, listener_->manager_updates()); |
283 EXPECT_EQ(1, listener_->list_updates(flimflam::kDevicesProperty)); | 288 EXPECT_EQ(1, listener_->list_updates(flimflam::kDevicesProperty)); |
284 const size_t kNumShillManagerClientStubImplDevices = 2; | 289 const size_t kNumShillManagerClientStubImplDevices = 2; |
285 EXPECT_EQ(kNumShillManagerClientStubImplDevices, | 290 EXPECT_EQ(kNumShillManagerClientStubImplDevices, |
286 listener_->entries(flimflam::kDevicesProperty).size()); | 291 listener_->entries(flimflam::kDevicesProperty).size()); |
287 // Add a device. | 292 // Add a device. |
288 const std::string kTestDevicePath("test_wifi_device1"); | 293 const std::string kTestDevicePath("test_wifi_device1"); |
289 AddDevice(flimflam::kTypeWifi, kTestDevicePath); | 294 AddDevice(flimflam::kTypeWifi, kTestDevicePath); |
290 message_loop_.RunUntilIdle(); | 295 message_loop_.RunUntilIdle(); |
291 EXPECT_EQ(1, listener_->manager_updates()); // No new manager updates. | 296 EXPECT_EQ(1, listener_->manager_updates()); // No new manager updates. |
292 EXPECT_EQ(2, listener_->list_updates(flimflam::kDevicesProperty)); | 297 EXPECT_EQ(2, listener_->list_updates(flimflam::kDevicesProperty)); |
293 EXPECT_EQ(kNumShillManagerClientStubImplDevices + 1, | 298 EXPECT_EQ(kNumShillManagerClientStubImplDevices + 1, |
294 listener_->entries(flimflam::kDevicesProperty).size()); | 299 listener_->entries(flimflam::kDevicesProperty).size()); |
295 // Device changes are not observed. | 300 // Device changes are not observed. |
296 // Remove a device | 301 // Remove a device |
297 RemoveDevice(kTestDevicePath); | 302 RemoveDevice(kTestDevicePath); |
298 message_loop_.RunUntilIdle(); | 303 message_loop_.RunUntilIdle(); |
299 EXPECT_EQ(3, listener_->list_updates(flimflam::kDevicesProperty)); | 304 EXPECT_EQ(3, listener_->list_updates(flimflam::kDevicesProperty)); |
300 EXPECT_EQ(kNumShillManagerClientStubImplDevices, | 305 EXPECT_EQ(kNumShillManagerClientStubImplDevices, |
301 listener_->entries(flimflam::kDevicesProperty).size()); | 306 listener_->entries(flimflam::kDevicesProperty).size()); |
302 | 307 |
303 EXPECT_EQ(0, listener_->errors()); | 308 EXPECT_EQ(0, listener_->errors()); |
304 } | 309 } |
305 | 310 |
306 TEST_F(ShillPropertyHandlerTest, ShillPropertyHandlerServicePropertyChanged) { | 311 TEST_F(ShillPropertyHandlerTest, ShillPropertyHandlerServicePropertyChanged) { |
307 SetupShillPropertyHandler(); | |
308 message_loop_.RunUntilIdle(); | |
309 EXPECT_EQ(1, listener_->manager_updates()); | 312 EXPECT_EQ(1, listener_->manager_updates()); |
310 EXPECT_EQ(1, listener_->list_updates(flimflam::kServicesProperty)); | 313 EXPECT_EQ(1, listener_->list_updates(flimflam::kServicesProperty)); |
311 const size_t kNumShillManagerClientStubImplServices = 4; | 314 const size_t kNumShillManagerClientStubImplServices = 4; |
312 EXPECT_EQ(kNumShillManagerClientStubImplServices, | 315 EXPECT_EQ(kNumShillManagerClientStubImplServices, |
313 listener_->entries(flimflam::kServicesProperty).size()); | 316 listener_->entries(flimflam::kServicesProperty).size()); |
314 | 317 |
315 // Add an unwatched service. | 318 // Add an unwatched service. |
316 const std::string kTestServicePath("test_wifi_service1"); | 319 const std::string kTestServicePath("test_wifi_service1"); |
317 AddService(flimflam::kTypeWifi, kTestServicePath, | 320 AddService(flimflam::kTypeWifi, kTestServicePath, |
318 flimflam::kStateIdle, false); | 321 flimflam::kStateIdle, false); |
(...skipping 42 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
361 // Remove a service | 364 // Remove a service |
362 RemoveService(kTestServicePath); | 365 RemoveService(kTestServicePath); |
363 message_loop_.RunUntilIdle(); | 366 message_loop_.RunUntilIdle(); |
364 EXPECT_EQ(3, listener_->list_updates(flimflam::kServicesProperty)); | 367 EXPECT_EQ(3, listener_->list_updates(flimflam::kServicesProperty)); |
365 EXPECT_EQ(kNumShillManagerClientStubImplServices, | 368 EXPECT_EQ(kNumShillManagerClientStubImplServices, |
366 listener_->entries(flimflam::kServicesProperty).size()); | 369 listener_->entries(flimflam::kServicesProperty).size()); |
367 | 370 |
368 EXPECT_EQ(0, listener_->errors()); | 371 EXPECT_EQ(0, listener_->errors()); |
369 } | 372 } |
370 | 373 |
371 // TODO(stevenjb): Test IP Configs. | 374 TEST_F(ShillPropertyHandlerTest, ShillPropertyHandlerIPConfigPropertyChanged) { |
| 375 // Set the properties for an IP Config object. |
| 376 const std::string kTestIPConfigPath("test_ip_config_path"); |
| 377 base::StringValue ip_address("192.168.1.1"); |
| 378 DBusThreadManager::Get()->GetShillIPConfigClient()->SetProperty( |
| 379 dbus::ObjectPath(kTestIPConfigPath), |
| 380 flimflam::kAddressProperty, |
| 381 ip_address, |
| 382 base::Bind(&DoNothingWithCallStatus)); |
| 383 base::ListValue dns_servers; |
| 384 dns_servers.Append(base::Value::CreateStringValue("192.168.1.100")); |
| 385 dns_servers.Append(base::Value::CreateStringValue("192.168.1.101")); |
| 386 DBusThreadManager::Get()->GetShillIPConfigClient()->SetProperty( |
| 387 dbus::ObjectPath(kTestIPConfigPath), |
| 388 flimflam::kNameServersProperty, |
| 389 dns_servers, |
| 390 base::Bind(&DoNothingWithCallStatus)); |
| 391 message_loop_.RunUntilIdle(); |
| 392 |
| 393 // Add a service with an empty ipconfig and then update |
| 394 // its ipconfig property. |
| 395 const std::string kTestServicePath1("test_wifi_service1"); |
| 396 AddService(flimflam::kTypeWifi, kTestServicePath1, |
| 397 flimflam::kStateIdle, true); |
| 398 message_loop_.RunUntilIdle(); |
| 399 // This is the initial property update. |
| 400 EXPECT_EQ(1, listener_-> |
| 401 property_updates(flimflam::kServicesProperty)[kTestServicePath1]); |
| 402 DBusThreadManager::Get()->GetShillServiceClient()->SetProperty( |
| 403 dbus::ObjectPath(kTestServicePath1), |
| 404 shill::kIPConfigProperty, |
| 405 base::StringValue(kTestIPConfigPath), |
| 406 base::Bind(&base::DoNothing), base::Bind(&ErrorCallbackFunction)); |
| 407 message_loop_.RunUntilIdle(); |
| 408 // IPConfig property change on the service should trigger property updates for |
| 409 // IP Address and DNS. |
| 410 EXPECT_EQ(3, listener_-> |
| 411 property_updates(flimflam::kServicesProperty)[kTestServicePath1]); |
| 412 |
| 413 // Now, Add a new watched service with the IPConfig already set. |
| 414 const std::string kTestServicePath2("test_wifi_service2"); |
| 415 AddServiceWithIPConfig(flimflam::kTypeWifi, kTestServicePath2, |
| 416 flimflam::kStateIdle, kTestIPConfigPath, true); |
| 417 message_loop_.RunUntilIdle(); |
| 418 // A watched service with the IPConfig property already set must |
| 419 // trigger property updates for IP Address and DNS when added. |
| 420 EXPECT_EQ(3, listener_-> |
| 421 property_updates(flimflam::kServicesProperty)[kTestServicePath2]); |
| 422 } |
372 | 423 |
373 } // namespace chromeos | 424 } // namespace chromeos |
OLD | NEW |