| Index: chromeos/dbus/fake_shill_device_client.cc
|
| diff --git a/chromeos/dbus/fake_shill_device_client.cc b/chromeos/dbus/fake_shill_device_client.cc
|
| index 2bf0b655ea58e9471bb681f52f92c288095d4710..1e121adf4f7a2292c0aeda375ae35aa07cf3a7d0 100644
|
| --- a/chromeos/dbus/fake_shill_device_client.cc
|
| +++ b/chromeos/dbus/fake_shill_device_client.cc
|
| @@ -4,35 +4,71 @@
|
|
|
| #include "chromeos/dbus/fake_shill_device_client.h"
|
|
|
| +#include "base/bind.h"
|
| +#include "base/message_loop/message_loop.h"
|
| +#include "base/stl_util.h"
|
| +#include "base/values.h"
|
| +#include "chromeos/dbus/dbus_thread_manager.h"
|
| +#include "chromeos/dbus/shill_manager_client.h"
|
| +#include "chromeos/dbus/shill_property_changed_observer.h"
|
| +#include "dbus/bus.h"
|
| +#include "dbus/message.h"
|
| +#include "dbus/object_path.h"
|
| +#include "dbus/object_proxy.h"
|
| +#include "dbus/values_util.h"
|
| +#include "third_party/cros_system_api/dbus/service_constants.h"
|
| +
|
| namespace chromeos {
|
|
|
| -FakeShillDeviceClient::FakeShillDeviceClient() {
|
| +namespace {
|
| +
|
| +void ErrorFunction(const std::string& device_path,
|
| + const std::string& error_name,
|
| + const std::string& error_message) {
|
| + LOG(ERROR) << "Shill Error for: " << device_path
|
| + << ": " << error_name << " : " << error_message;
|
| }
|
|
|
| -FakeShillDeviceClient::~FakeShillDeviceClient() {
|
| +} // namespace
|
| +
|
| +FakeShillDeviceClient::FakeShillDeviceClient() : weak_ptr_factory_(this) {
|
| }
|
|
|
| -void FakeShillDeviceClient::Init(dbus::Bus* bus) {
|
| +FakeShillDeviceClient::~FakeShillDeviceClient() {
|
| + STLDeleteContainerPairSecondPointers(
|
| + observer_list_.begin(), observer_list_.end());
|
| }
|
|
|
| +// ShillDeviceClient overrides.
|
| +
|
| +void FakeShillDeviceClient::Init(dbus::Bus* bus) {}
|
| +
|
| void FakeShillDeviceClient::AddPropertyChangedObserver(
|
| const dbus::ObjectPath& device_path,
|
| ShillPropertyChangedObserver* observer) {
|
| + GetObserverList(device_path).AddObserver(observer);
|
| }
|
|
|
| void FakeShillDeviceClient::RemovePropertyChangedObserver(
|
| const dbus::ObjectPath& device_path,
|
| ShillPropertyChangedObserver* observer) {
|
| + GetObserverList(device_path).RemoveObserver(observer);
|
| }
|
|
|
| void FakeShillDeviceClient::GetProperties(
|
| const dbus::ObjectPath& device_path,
|
| const DictionaryValueCallback& callback) {
|
| + base::MessageLoop::current()->PostTask(
|
| + FROM_HERE,
|
| + base::Bind(&FakeShillDeviceClient::PassStubDeviceProperties,
|
| + weak_ptr_factory_.GetWeakPtr(),
|
| + device_path, callback));
|
| }
|
|
|
| void FakeShillDeviceClient::ProposeScan(
|
| const dbus::ObjectPath& device_path,
|
| const VoidDBusMethodCallback& callback) {
|
| + PostVoidCallback(callback, DBUS_METHOD_CALL_SUCCESS);
|
| }
|
|
|
| void FakeShillDeviceClient::SetProperty(const dbus::ObjectPath& device_path,
|
| @@ -40,18 +76,47 @@ void FakeShillDeviceClient::SetProperty(const dbus::ObjectPath& device_path,
|
| const base::Value& value,
|
| const base::Closure& callback,
|
| const ErrorCallback& error_callback) {
|
| + base::DictionaryValue* device_properties = NULL;
|
| + if (!stub_devices_.GetDictionaryWithoutPathExpansion(device_path.value(),
|
| + &device_properties)) {
|
| + std::string error_name("org.chromium.flimflam.Error.Failure");
|
| + std::string error_message("Failed");
|
| + base::MessageLoop::current()->PostTask(FROM_HERE,
|
| + base::Bind(error_callback,
|
| + error_name,
|
| + error_message));
|
| + return;
|
| + }
|
| + device_properties->SetWithoutPathExpansion(name, value.DeepCopy());
|
| + base::MessageLoop::current()->PostTask(
|
| + FROM_HERE,
|
| + base::Bind(&FakeShillDeviceClient::NotifyObserversPropertyChanged,
|
| + weak_ptr_factory_.GetWeakPtr(), device_path, name));
|
| + base::MessageLoop::current()->PostTask(FROM_HERE, callback);
|
| }
|
|
|
| void FakeShillDeviceClient::ClearProperty(
|
| const dbus::ObjectPath& device_path,
|
| const std::string& name,
|
| const VoidDBusMethodCallback& callback) {
|
| + base::DictionaryValue* device_properties = NULL;
|
| + if (!stub_devices_.GetDictionaryWithoutPathExpansion(device_path.value(),
|
| + &device_properties)) {
|
| + PostVoidCallback(callback, DBUS_METHOD_CALL_FAILURE);
|
| + return;
|
| + }
|
| + device_properties->RemoveWithoutPathExpansion(name, NULL);
|
| + PostVoidCallback(callback, DBUS_METHOD_CALL_SUCCESS);
|
| }
|
|
|
| void FakeShillDeviceClient::AddIPConfig(
|
| const dbus::ObjectPath& device_path,
|
| const std::string& method,
|
| const ObjectPathDBusMethodCallback& callback) {
|
| + base::MessageLoop::current()->PostTask(FROM_HERE,
|
| + base::Bind(callback,
|
| + DBUS_METHOD_CALL_SUCCESS,
|
| + dbus::ObjectPath()));
|
| }
|
|
|
| void FakeShillDeviceClient::RequirePin(const dbus::ObjectPath& device_path,
|
| @@ -59,12 +124,14 @@ void FakeShillDeviceClient::RequirePin(const dbus::ObjectPath& device_path,
|
| bool require,
|
| const base::Closure& callback,
|
| const ErrorCallback& error_callback) {
|
| + base::MessageLoop::current()->PostTask(FROM_HERE, callback);
|
| }
|
|
|
| void FakeShillDeviceClient::EnterPin(const dbus::ObjectPath& device_path,
|
| const std::string& pin,
|
| const base::Closure& callback,
|
| const ErrorCallback& error_callback) {
|
| + base::MessageLoop::current()->PostTask(FROM_HERE, callback);
|
| }
|
|
|
| void FakeShillDeviceClient::UnblockPin(const dbus::ObjectPath& device_path,
|
| @@ -72,6 +139,7 @@ void FakeShillDeviceClient::UnblockPin(const dbus::ObjectPath& device_path,
|
| const std::string& pin,
|
| const base::Closure& callback,
|
| const ErrorCallback& error_callback) {
|
| + base::MessageLoop::current()->PostTask(FROM_HERE, callback);
|
| }
|
|
|
| void FakeShillDeviceClient::ChangePin(const dbus::ObjectPath& device_path,
|
| @@ -79,28 +147,155 @@ void FakeShillDeviceClient::ChangePin(const dbus::ObjectPath& device_path,
|
| const std::string& new_pin,
|
| const base::Closure& callback,
|
| const ErrorCallback& error_callback) {
|
| + base::MessageLoop::current()->PostTask(FROM_HERE, callback);
|
| }
|
|
|
| void FakeShillDeviceClient::Register(const dbus::ObjectPath& device_path,
|
| const std::string& network_id,
|
| const base::Closure& callback,
|
| const ErrorCallback& error_callback) {
|
| + base::MessageLoop::current()->PostTask(FROM_HERE, callback);
|
| }
|
|
|
| void FakeShillDeviceClient::SetCarrier(const dbus::ObjectPath& device_path,
|
| const std::string& carrier,
|
| const base::Closure& callback,
|
| const ErrorCallback& error_callback) {
|
| + base::MessageLoop::current()->PostTask(FROM_HERE, callback);
|
| }
|
|
|
| void FakeShillDeviceClient::Reset(const dbus::ObjectPath& device_path,
|
| const base::Closure& callback,
|
| const ErrorCallback& error_callback) {
|
| + base::MessageLoop::current()->PostTask(FROM_HERE, callback);
|
| +}
|
| +
|
| +ShillDeviceClient::TestInterface* FakeShillDeviceClient::GetTestInterface() {
|
| + return this;
|
| +}
|
| +
|
| +// ShillDeviceClient::TestInterface overrides.
|
| +
|
| +void FakeShillDeviceClient::AddDevice(const std::string& device_path,
|
| + const std::string& type,
|
| + const std::string& object_path) {
|
| + DBusThreadManager::Get()->GetShillManagerClient()->GetTestInterface()->
|
| + AddDevice(device_path);
|
| +
|
| + base::DictionaryValue* properties = GetDeviceProperties(device_path);
|
| + properties->SetWithoutPathExpansion(
|
| + shill::kTypeProperty,
|
| + base::Value::CreateStringValue(type));
|
| + properties->SetWithoutPathExpansion(
|
| + shill::kDBusObjectProperty,
|
| + base::Value::CreateStringValue(object_path));
|
| + properties->SetWithoutPathExpansion(
|
| + shill::kDBusConnectionProperty,
|
| + base::Value::CreateStringValue("/stub"));
|
| +}
|
| +
|
| +void FakeShillDeviceClient::RemoveDevice(const std::string& device_path) {
|
| + DBusThreadManager::Get()->GetShillManagerClient()->GetTestInterface()->
|
| + RemoveDevice(device_path);
|
| +
|
| + stub_devices_.RemoveWithoutPathExpansion(device_path, NULL);
|
| +}
|
| +
|
| +void FakeShillDeviceClient::ClearDevices() {
|
| + DBusThreadManager::Get()->GetShillManagerClient()->GetTestInterface()->
|
| + ClearDevices();
|
| +
|
| + stub_devices_.Clear();
|
| +}
|
| +
|
| +void FakeShillDeviceClient::SetDeviceProperty(const std::string& device_path,
|
| + const std::string& name,
|
| + const base::Value& value) {
|
| + VLOG(1) << "SetDeviceProperty: " << device_path
|
| + << ": " << name << " = " << value;
|
| + SetProperty(dbus::ObjectPath(device_path), name, value,
|
| + base::Bind(&base::DoNothing),
|
| + base::Bind(&ErrorFunction, device_path));
|
| +}
|
| +
|
| +std::string FakeShillDeviceClient::GetDevicePathForType(
|
| + const std::string& type) {
|
| + for (base::DictionaryValue::Iterator iter(stub_devices_);
|
| + !iter.IsAtEnd(); iter.Advance()) {
|
| + const base::DictionaryValue* properties = NULL;
|
| + if (!iter.value().GetAsDictionary(&properties))
|
| + continue;
|
| + std::string prop_type;
|
| + if (!properties->GetStringWithoutPathExpansion(
|
| + shill::kTypeProperty, &prop_type) ||
|
| + prop_type != type)
|
| + continue;
|
| + return iter.key();
|
| + }
|
| + return std::string();
|
| +}
|
| +
|
| +void FakeShillDeviceClient::PassStubDeviceProperties(
|
| + const dbus::ObjectPath& device_path,
|
| + const DictionaryValueCallback& callback) const {
|
| + const base::DictionaryValue* device_properties = NULL;
|
| + if (!stub_devices_.GetDictionaryWithoutPathExpansion(
|
| + device_path.value(), &device_properties)) {
|
| + base::DictionaryValue empty_dictionary;
|
| + callback.Run(DBUS_METHOD_CALL_FAILURE, empty_dictionary);
|
| + return;
|
| + }
|
| + callback.Run(DBUS_METHOD_CALL_SUCCESS, *device_properties);
|
| +}
|
| +
|
| +// Posts a task to run a void callback with status code |status|.
|
| +void FakeShillDeviceClient::PostVoidCallback(
|
| + const VoidDBusMethodCallback& callback,
|
| + DBusMethodCallStatus status) {
|
| + base::MessageLoop::current()->PostTask(FROM_HERE,
|
| + base::Bind(callback, status));
|
| +}
|
| +
|
| +void FakeShillDeviceClient::NotifyObserversPropertyChanged(
|
| + const dbus::ObjectPath& device_path,
|
| + const std::string& property) {
|
| + base::DictionaryValue* dict = NULL;
|
| + std::string path = device_path.value();
|
| + if (!stub_devices_.GetDictionaryWithoutPathExpansion(path, &dict)) {
|
| + LOG(ERROR) << "Notify for unknown service: " << path;
|
| + return;
|
| + }
|
| + base::Value* value = NULL;
|
| + if (!dict->GetWithoutPathExpansion(property, &value)) {
|
| + LOG(ERROR) << "Notify for unknown property: "
|
| + << path << " : " << property;
|
| + return;
|
| + }
|
| + FOR_EACH_OBSERVER(ShillPropertyChangedObserver,
|
| + GetObserverList(device_path),
|
| + OnPropertyChanged(property, *value));
|
| +}
|
| +
|
| +base::DictionaryValue* FakeShillDeviceClient::GetDeviceProperties(
|
| + const std::string& device_path) {
|
| + base::DictionaryValue* properties = NULL;
|
| + if (!stub_devices_.GetDictionaryWithoutPathExpansion(
|
| + device_path, &properties)) {
|
| + properties = new base::DictionaryValue;
|
| + stub_devices_.SetWithoutPathExpansion(device_path, properties);
|
| + }
|
| + return properties;
|
| }
|
|
|
| -FakeShillDeviceClient::TestInterface*
|
| -FakeShillDeviceClient::GetTestInterface() {
|
| - return NULL;
|
| +FakeShillDeviceClient::PropertyObserverList&
|
| +FakeShillDeviceClient::GetObserverList(const dbus::ObjectPath& device_path) {
|
| + std::map<dbus::ObjectPath, PropertyObserverList*>::iterator iter =
|
| + observer_list_.find(device_path);
|
| + if (iter != observer_list_.end())
|
| + return *(iter->second);
|
| + PropertyObserverList* observer_list = new PropertyObserverList();
|
| + observer_list_[device_path] = observer_list;
|
| + return *observer_list;
|
| }
|
|
|
| } // namespace chromeos
|
|
|