| Index: chromeos/dbus/experimental_bluetooth_agent_manager_client.cc
|
| diff --git a/chromeos/dbus/experimental_bluetooth_agent_manager_client.cc b/chromeos/dbus/experimental_bluetooth_agent_manager_client.cc
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..d20e874aabf08aa7a61358968b81226c394104e9
|
| --- /dev/null
|
| +++ b/chromeos/dbus/experimental_bluetooth_agent_manager_client.cc
|
| @@ -0,0 +1,193 @@
|
| +// Copyright (c) 2013 The Chromium Authors. All rights reserved.
|
| +// Use of this source code is governed by a BSD-style license that can be
|
| +// found in the LICENSE file.
|
| +
|
| +#include "chromeos/dbus/experimental_bluetooth_agent_manager_client.h"
|
| +
|
| +#include "base/bind.h"
|
| +#include "base/logging.h"
|
| +#include "dbus/bus.h"
|
| +#include "dbus/message.h"
|
| +#include "dbus/object_path.h"
|
| +#include "dbus/object_proxy.h"
|
| +#include "third_party/cros_system_api/dbus/service_constants.h"
|
| +
|
| +namespace chromeos {
|
| +
|
| +const char ExperimentalBluetoothAgentManagerClient::kNoResponseError[] =
|
| + "org.chromium.Error.NoResponse";
|
| +
|
| +// The ExperimentalBluetoothAgentManagerClient implementation used in
|
| +// production.
|
| +class ExperimentalBluetoothAgentManagerClientImpl
|
| + : public ExperimentalBluetoothAgentManagerClient {
|
| + public:
|
| + explicit ExperimentalBluetoothAgentManagerClientImpl(dbus::Bus* bus)
|
| + : bus_(bus),
|
| + weak_ptr_factory_(this) {
|
| + DCHECK(bus_);
|
| + object_proxy_ = bus_->GetObjectProxy(
|
| + bluetooth_agent_manager::kBluetoothAgentManagerServiceName,
|
| + dbus::ObjectPath(
|
| + bluetooth_agent_manager::kExperimentalBluetoothAgentManagerInterface));
|
| + }
|
| +
|
| + virtual ~ExperimentalBluetoothAgentManagerClientImpl() {
|
| + }
|
| +
|
| + // ExperimentalBluetoothAgentManagerClient override.
|
| + virtual void RegisterAgent(const dbus::ObjectPath& agent_path,
|
| + const std::string& capability,
|
| + const base::Closure& callback,
|
| + const ErrorCallback& error_callback) OVERRIDE {
|
| + dbus::MethodCall method_call(
|
| + bluetooth_agent_manager::kExperimentalBluetoothAgentManagerInterface,
|
| + bluetooth_agent_manager::kRegisterAgent);
|
| +
|
| + dbus::MessageWriter writer(&method_call);
|
| + writer.AppendObjectPath(agent_path);
|
| + writer.AppendString(capability);
|
| +
|
| + object_proxy_->CallMethodWithErrorCallback(
|
| + &method_call,
|
| + dbus::ObjectProxy::TIMEOUT_USE_DEFAULT,
|
| + base::Bind(&ExperimentalBluetoothAgentManagerClientImpl::OnSuccess,
|
| + weak_ptr_factory_.GetWeakPtr(), callback),
|
| + base::Bind(&ExperimentalBluetoothAgentManagerClientImpl::OnError,
|
| + weak_ptr_factory_.GetWeakPtr(), error_callback));
|
| + }
|
| +
|
| + // ExperimentalBluetoothAgentManagerClient override.
|
| + virtual void UnregisterAgent(const dbus::ObjectPath& agent_path,
|
| + const base::Closure& callback,
|
| + const ErrorCallback& error_callback) OVERRIDE {
|
| + dbus::MethodCall method_call(
|
| + bluetooth_agent_manager::kExperimentalBluetoothAgentManagerInterface,
|
| + bluetooth_agent_manager::kUnregisterAgent);
|
| +
|
| + dbus::MessageWriter writer(&method_call);
|
| + writer.AppendObjectPath(agent_path);
|
| +
|
| + object_proxy_->CallMethodWithErrorCallback(
|
| + &method_call,
|
| + dbus::ObjectProxy::TIMEOUT_USE_DEFAULT,
|
| + base::Bind(&ExperimentalBluetoothAgentManagerClientImpl::OnSuccess,
|
| + weak_ptr_factory_.GetWeakPtr(), callback),
|
| + base::Bind(&ExperimentalBluetoothAgentManagerClientImpl::OnError,
|
| + weak_ptr_factory_.GetWeakPtr(), error_callback));
|
| + }
|
| +
|
| +
|
| + // ExperimentalBluetoothAgentManagerClient override.
|
| + virtual void RequestDefaultAgent(const dbus::ObjectPath& agent_path,
|
| + const base::Closure& callback,
|
| + const ErrorCallback& error_callback)
|
| + OVERRIDE {
|
| + dbus::MethodCall method_call(
|
| + bluetooth_agent_manager::kExperimentalBluetoothAgentManagerInterface,
|
| + bluetooth_agent_manager::kRequestDefaultAgent);
|
| +
|
| + dbus::MessageWriter writer(&method_call);
|
| + writer.AppendObjectPath(agent_path);
|
| +
|
| + object_proxy_->CallMethodWithErrorCallback(
|
| + &method_call,
|
| + dbus::ObjectProxy::TIMEOUT_USE_DEFAULT,
|
| + base::Bind(&ExperimentalBluetoothAgentManagerClientImpl::OnSuccess,
|
| + weak_ptr_factory_.GetWeakPtr(), callback),
|
| + base::Bind(&ExperimentalBluetoothAgentManagerClientImpl::OnError,
|
| + weak_ptr_factory_.GetWeakPtr(), error_callback));
|
| + }
|
| +
|
| + private:
|
| + // Called when a response for successful method call is received.
|
| + void OnSuccess(const base::Closure& callback,
|
| + dbus::Response* response) {
|
| + DCHECK(response);
|
| + callback.Run();
|
| + }
|
| +
|
| + // Called when a response for a failed method call is received.
|
| + void OnError(const ErrorCallback& error_callback,
|
| + dbus::ErrorResponse* response) {
|
| + // Error response has optional error message argument.
|
| + std::string error_name;
|
| + std::string error_message;
|
| + if (response) {
|
| + dbus::MessageReader reader(response);
|
| + error_name = response->GetErrorName();
|
| + reader.PopString(&error_message);
|
| + } else {
|
| + error_name = kNoResponseError;
|
| + error_message = "";
|
| + }
|
| + error_callback.Run(error_name, error_message);
|
| + }
|
| +
|
| + dbus::Bus* bus_;
|
| + dbus::ObjectProxy* object_proxy_;
|
| +
|
| + // Weak pointer factory for generating 'this' pointers that might live longer
|
| + // than we do.
|
| + // Note: This should remain the last member so it'll be destroyed and
|
| + // invalidate its weak pointers before any other members are destroyed.
|
| + base::WeakPtrFactory<ExperimentalBluetoothAgentManagerClientImpl>
|
| + weak_ptr_factory_;
|
| +
|
| + DISALLOW_COPY_AND_ASSIGN(ExperimentalBluetoothAgentManagerClientImpl);
|
| +};
|
| +
|
| +// The ExperimentalBluetoothAgentManagerClient implementation used on Linux
|
| +// desktop, which does nothing.
|
| +class ExperimentalBluetoothAgentManagerClientStubImpl
|
| + : public ExperimentalBluetoothAgentManagerClient {
|
| + public:
|
| + ExperimentalBluetoothAgentManagerClientStubImpl() {
|
| + }
|
| +
|
| + // ExperimentalBluetoothAgentManagerClient override.
|
| + virtual void RegisterAgent(const dbus::ObjectPath& agent_path,
|
| + const std::string& capability,
|
| + const base::Closure& callback,
|
| + const ErrorCallback& error_callback) OVERRIDE {
|
| + VLOG(1) << "RegisterAgent: " << agent_path.value();
|
| + error_callback.Run(kNoResponseError, "");
|
| + }
|
| +
|
| + // ExperimentalBluetoothAgentManagerClient override.
|
| + virtual void UnregisterAgent(const dbus::ObjectPath& agent_path,
|
| + const base::Closure& callback,
|
| + const ErrorCallback& error_callback) OVERRIDE {
|
| + VLOG(1) << "UnregisterAgent: " << agent_path.value();
|
| + error_callback.Run(kNoResponseError, "");
|
| + }
|
| +
|
| + // ExperimentalBluetoothAgentManagerClient override.
|
| + virtual void RequestDefaultAgent(const dbus::ObjectPath& agent_path,
|
| + const base::Closure& callback,
|
| + const ErrorCallback& error_callback)
|
| + OVERRIDE {
|
| + VLOG(1) << "RequestDefaultAgent: " << agent_path.value();
|
| + error_callback.Run(kNoResponseError, "");
|
| + }
|
| +};
|
| +
|
| +ExperimentalBluetoothAgentManagerClient::
|
| + ExperimentalBluetoothAgentManagerClient() {
|
| +}
|
| +
|
| +ExperimentalBluetoothAgentManagerClient::
|
| + ~ExperimentalBluetoothAgentManagerClient() {
|
| +}
|
| +
|
| +ExperimentalBluetoothAgentManagerClient*
|
| + ExperimentalBluetoothAgentManagerClient::Create(
|
| + DBusClientImplementationType type,
|
| + dbus::Bus* bus) {
|
| + if (type == REAL_DBUS_CLIENT_IMPLEMENTATION)
|
| + return new ExperimentalBluetoothAgentManagerClientImpl(bus);
|
| + DCHECK_EQ(STUB_DBUS_CLIENT_IMPLEMENTATION, type);
|
| + return new ExperimentalBluetoothAgentManagerClientStubImpl();
|
| +}
|
| +
|
| +} // namespace chromeos
|
|
|