| 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/dbus/shill_client_helper.h" | 5 #include "chromeos/dbus/shill_client_helper.h" |
| 6 | 6 |
| 7 #include "base/bind.h" | 7 #include "base/bind.h" |
| 8 #include "base/values.h" | 8 #include "base/values.h" |
| 9 #include "dbus/message.h" | 9 #include "dbus/message.h" |
| 10 #include "dbus/object_proxy.h" | 10 #include "dbus/object_proxy.h" |
| 11 #include "dbus/values_util.h" | 11 #include "dbus/values_util.h" |
| 12 #include "third_party/cros_system_api/dbus/service_constants.h" | 12 #include "third_party/cros_system_api/dbus/service_constants.h" |
| 13 | 13 |
| 14 namespace chromeos { | 14 namespace chromeos { |
| 15 | 15 |
| 16 namespace { |
| 17 |
| 18 const char kInvalidResponseErrorName[] = ""; // No error name. |
| 19 const char kInvalidResponseErrorMessage[] = "Invalid response."; |
| 20 |
| 21 } // namespace |
| 22 |
| 16 ShillClientHelper::ShillClientHelper(dbus::Bus* bus, | 23 ShillClientHelper::ShillClientHelper(dbus::Bus* bus, |
| 17 dbus::ObjectProxy* proxy) | 24 dbus::ObjectProxy* proxy) |
| 18 : blocking_method_caller_(bus, proxy), | 25 : blocking_method_caller_(bus, proxy), |
| 19 proxy_(proxy), | 26 proxy_(proxy), |
| 20 weak_ptr_factory_(this) { | 27 weak_ptr_factory_(this) { |
| 21 } | 28 } |
| 22 | 29 |
| 23 ShillClientHelper::~ShillClientHelper() { | 30 ShillClientHelper::~ShillClientHelper() { |
| 24 } | 31 } |
| 25 | 32 |
| (...skipping 22 matching lines...) Expand all Loading... |
| 48 dbus::MethodCall* method_call, | 55 dbus::MethodCall* method_call, |
| 49 const VoidDBusMethodCallback& callback) { | 56 const VoidDBusMethodCallback& callback) { |
| 50 proxy_->CallMethod(method_call, dbus::ObjectProxy::TIMEOUT_USE_DEFAULT, | 57 proxy_->CallMethod(method_call, dbus::ObjectProxy::TIMEOUT_USE_DEFAULT, |
| 51 base::Bind(&ShillClientHelper::OnVoidMethod, | 58 base::Bind(&ShillClientHelper::OnVoidMethod, |
| 52 weak_ptr_factory_.GetWeakPtr(), | 59 weak_ptr_factory_.GetWeakPtr(), |
| 53 callback)); | 60 callback)); |
| 54 } | 61 } |
| 55 | 62 |
| 56 void ShillClientHelper::CallObjectPathMethod( | 63 void ShillClientHelper::CallObjectPathMethod( |
| 57 dbus::MethodCall* method_call, | 64 dbus::MethodCall* method_call, |
| 58 const ObjectPathDBusMethodCallback& callback) { | 65 const ObjectPathCallback& callback) { |
| 59 proxy_->CallMethod(method_call, dbus::ObjectProxy::TIMEOUT_USE_DEFAULT, | 66 proxy_->CallMethod(method_call, dbus::ObjectProxy::TIMEOUT_USE_DEFAULT, |
| 60 base::Bind(&ShillClientHelper::OnObjectPathMethod, | 67 base::Bind(&ShillClientHelper::OnObjectPathMethod, |
| 61 weak_ptr_factory_.GetWeakPtr(), | 68 weak_ptr_factory_.GetWeakPtr(), |
| 62 callback)); | 69 callback)); |
| 63 } | 70 } |
| 64 | 71 |
| 72 void ShillClientHelper::CallObjectPathMethodWithErrorCallback( |
| 73 dbus::MethodCall* method_call, |
| 74 const ObjectPathCallbackWithoutStatus& callback, |
| 75 const ErrorCallback& error_callback) { |
| 76 proxy_->CallMethodWithErrorCallback( |
| 77 method_call, |
| 78 dbus::ObjectProxy::TIMEOUT_USE_DEFAULT, |
| 79 base::Bind(&ShillClientHelper::OnObjectPathMethodWithoutStatus, |
| 80 weak_ptr_factory_.GetWeakPtr(), |
| 81 callback, |
| 82 error_callback), |
| 83 base::Bind(&ShillClientHelper::OnError, |
| 84 weak_ptr_factory_.GetWeakPtr(), |
| 85 error_callback)); |
| 86 } |
| 87 |
| 65 void ShillClientHelper::CallDictionaryValueMethod( | 88 void ShillClientHelper::CallDictionaryValueMethod( |
| 66 dbus::MethodCall* method_call, | 89 dbus::MethodCall* method_call, |
| 67 const DictionaryValueCallback& callback) { | 90 const DictionaryValueCallback& callback) { |
| 68 proxy_->CallMethod(method_call, dbus::ObjectProxy::TIMEOUT_USE_DEFAULT, | 91 proxy_->CallMethod(method_call, dbus::ObjectProxy::TIMEOUT_USE_DEFAULT, |
| 69 base::Bind(&ShillClientHelper::OnDictionaryValueMethod, | 92 base::Bind(&ShillClientHelper::OnDictionaryValueMethod, |
| 70 weak_ptr_factory_.GetWeakPtr(), | 93 weak_ptr_factory_.GetWeakPtr(), |
| 71 callback)); | 94 callback)); |
| 72 } | 95 } |
| 73 | 96 |
| 74 void ShillClientHelper::CallVoidMethodWithErrorCallback( | 97 void ShillClientHelper::CallVoidMethodWithErrorCallback( |
| (...skipping 133 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 208 void ShillClientHelper::OnVoidMethod(const VoidDBusMethodCallback& callback, | 231 void ShillClientHelper::OnVoidMethod(const VoidDBusMethodCallback& callback, |
| 209 dbus::Response* response) { | 232 dbus::Response* response) { |
| 210 if (!response) { | 233 if (!response) { |
| 211 callback.Run(DBUS_METHOD_CALL_FAILURE); | 234 callback.Run(DBUS_METHOD_CALL_FAILURE); |
| 212 return; | 235 return; |
| 213 } | 236 } |
| 214 callback.Run(DBUS_METHOD_CALL_SUCCESS); | 237 callback.Run(DBUS_METHOD_CALL_SUCCESS); |
| 215 } | 238 } |
| 216 | 239 |
| 217 void ShillClientHelper::OnObjectPathMethod( | 240 void ShillClientHelper::OnObjectPathMethod( |
| 218 const ObjectPathDBusMethodCallback& callback, | 241 const ObjectPathCallback& callback, |
| 219 dbus::Response* response) { | 242 dbus::Response* response) { |
| 220 if (!response) { | 243 if (!response) { |
| 221 callback.Run(DBUS_METHOD_CALL_FAILURE, dbus::ObjectPath()); | 244 callback.Run(DBUS_METHOD_CALL_FAILURE, dbus::ObjectPath()); |
| 222 return; | 245 return; |
| 223 } | 246 } |
| 224 dbus::MessageReader reader(response); | 247 dbus::MessageReader reader(response); |
| 225 dbus::ObjectPath result; | 248 dbus::ObjectPath result; |
| 226 if (!reader.PopObjectPath(&result)) { | 249 if (!reader.PopObjectPath(&result)) { |
| 227 callback.Run(DBUS_METHOD_CALL_FAILURE, dbus::ObjectPath()); | 250 callback.Run(DBUS_METHOD_CALL_FAILURE, dbus::ObjectPath()); |
| 228 return; | 251 return; |
| 229 } | 252 } |
| 230 callback.Run(DBUS_METHOD_CALL_SUCCESS, result); | 253 callback.Run(DBUS_METHOD_CALL_SUCCESS, result); |
| 231 } | 254 } |
| 232 | 255 |
| 256 void ShillClientHelper::OnObjectPathMethodWithoutStatus( |
| 257 const ObjectPathCallbackWithoutStatus& callback, |
| 258 const ErrorCallback& error_callback, |
| 259 dbus::Response* response) { |
| 260 if (!response) { |
| 261 error_callback.Run(kInvalidResponseErrorName, kInvalidResponseErrorMessage); |
| 262 return; |
| 263 } |
| 264 dbus::MessageReader reader(response); |
| 265 dbus::ObjectPath result; |
| 266 if (!reader.PopObjectPath(&result)) { |
| 267 error_callback.Run(kInvalidResponseErrorName, kInvalidResponseErrorMessage); |
| 268 return; |
| 269 } |
| 270 callback.Run(result); |
| 271 } |
| 272 |
| 233 void ShillClientHelper::OnDictionaryValueMethod( | 273 void ShillClientHelper::OnDictionaryValueMethod( |
| 234 const DictionaryValueCallback& callback, | 274 const DictionaryValueCallback& callback, |
| 235 dbus::Response* response) { | 275 dbus::Response* response) { |
| 236 if (!response) { | 276 if (!response) { |
| 237 base::DictionaryValue result; | 277 base::DictionaryValue result; |
| 238 callback.Run(DBUS_METHOD_CALL_FAILURE, result); | 278 callback.Run(DBUS_METHOD_CALL_FAILURE, result); |
| 239 return; | 279 return; |
| 240 } | 280 } |
| 241 dbus::MessageReader reader(response); | 281 dbus::MessageReader reader(response); |
| 242 scoped_ptr<base::Value> value(dbus::PopDataAsValue(&reader)); | 282 scoped_ptr<base::Value> value(dbus::PopDataAsValue(&reader)); |
| (...skipping 13 matching lines...) Expand all Loading... |
| 256 } | 296 } |
| 257 | 297 |
| 258 void ShillClientHelper::OnDictionaryValueMethodWithErrorCallback( | 298 void ShillClientHelper::OnDictionaryValueMethodWithErrorCallback( |
| 259 const DictionaryValueCallbackWithoutStatus& callback, | 299 const DictionaryValueCallbackWithoutStatus& callback, |
| 260 const ErrorCallback& error_callback, | 300 const ErrorCallback& error_callback, |
| 261 dbus::Response* response) { | 301 dbus::Response* response) { |
| 262 dbus::MessageReader reader(response); | 302 dbus::MessageReader reader(response); |
| 263 scoped_ptr<base::Value> value(dbus::PopDataAsValue(&reader)); | 303 scoped_ptr<base::Value> value(dbus::PopDataAsValue(&reader)); |
| 264 base::DictionaryValue* result = NULL; | 304 base::DictionaryValue* result = NULL; |
| 265 if (!value.get() || !value->GetAsDictionary(&result)) { | 305 if (!value.get() || !value->GetAsDictionary(&result)) { |
| 266 const std::string error_name; // No error name. | 306 error_callback.Run(kInvalidResponseErrorName, kInvalidResponseErrorMessage); |
| 267 const std::string error_message = "Invalid response."; | |
| 268 error_callback.Run(error_name, error_message); | |
| 269 return; | 307 return; |
| 270 } | 308 } |
| 271 callback.Run(*result); | 309 callback.Run(*result); |
| 272 } | 310 } |
| 273 | 311 |
| 274 void ShillClientHelper::OnError(const ErrorCallback& error_callback, | 312 void ShillClientHelper::OnError(const ErrorCallback& error_callback, |
| 275 dbus::ErrorResponse* response) { | 313 dbus::ErrorResponse* response) { |
| 276 std::string error_name; | 314 std::string error_name; |
| 277 std::string error_message; | 315 std::string error_message; |
| 278 if (response) { | 316 if (response) { |
| 279 // Error message may contain the error message as string. | 317 // Error message may contain the error message as string. |
| 280 dbus::MessageReader reader(response); | 318 dbus::MessageReader reader(response); |
| 281 error_name = response->GetErrorName(); | 319 error_name = response->GetErrorName(); |
| 282 reader.PopString(&error_message); | 320 reader.PopString(&error_message); |
| 283 } | 321 } |
| 284 error_callback.Run(error_name, error_message); | 322 error_callback.Run(error_name, error_message); |
| 285 } | 323 } |
| 286 | 324 |
| 287 } // namespace chromeos | 325 } // namespace chromeos |
| OLD | NEW |