Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(58)

Unified Diff: chromeos/dbus/experimental_bluetooth_agent_manager_client.cc

Issue 12605008: D-Bus Clients for BlueZ 5 API (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: mock dbus thread manager without gmock? I didn't even know that was a thing! Created 7 years, 9 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
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

Powered by Google App Engine
This is Rietveld 408576698