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 |