123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265 |
- // Copyright 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 "device/bluetooth/dbus/bluetooth_profile_service_provider.h"
- #include <memory>
- #include <utility>
- #include "base/bind.h"
- #include "base/logging.h"
- #include "base/memory/raw_ptr.h"
- #include "base/memory/ref_counted.h"
- #include "base/threading/platform_thread.h"
- #include "dbus/exported_object.h"
- #include "dbus/message.h"
- #include "device/bluetooth/dbus/bluez_dbus_manager.h"
- #include "device/bluetooth/dbus/fake_bluetooth_profile_service_provider.h"
- #include "third_party/cros_system_api/dbus/service_constants.h"
- namespace bluez {
- // The BluetoothProfileServiceProvider implementation used in production.
- class BluetoothProfileServiceProviderImpl
- : public BluetoothProfileServiceProvider {
- public:
- BluetoothProfileServiceProviderImpl(dbus::Bus* bus,
- const dbus::ObjectPath& object_path,
- Delegate* delegate)
- : origin_thread_id_(base::PlatformThread::CurrentId()),
- bus_(bus),
- delegate_(delegate),
- object_path_(object_path) {
- DVLOG(1) << "Creating Bluetooth Profile: " << object_path_.value();
- exported_object_ = bus_->GetExportedObject(object_path_);
- exported_object_->ExportMethod(
- bluetooth_profile::kBluetoothProfileInterface,
- bluetooth_profile::kRelease,
- base::BindRepeating(&BluetoothProfileServiceProviderImpl::Release,
- weak_ptr_factory_.GetWeakPtr()),
- base::BindOnce(&BluetoothProfileServiceProviderImpl::OnExported,
- weak_ptr_factory_.GetWeakPtr()));
- exported_object_->ExportMethod(
- bluetooth_profile::kBluetoothProfileInterface,
- bluetooth_profile::kNewConnection,
- base::BindRepeating(&BluetoothProfileServiceProviderImpl::NewConnection,
- weak_ptr_factory_.GetWeakPtr()),
- base::BindOnce(&BluetoothProfileServiceProviderImpl::OnExported,
- weak_ptr_factory_.GetWeakPtr()));
- exported_object_->ExportMethod(
- bluetooth_profile::kBluetoothProfileInterface,
- bluetooth_profile::kRequestDisconnection,
- base::BindRepeating(
- &BluetoothProfileServiceProviderImpl::RequestDisconnection,
- weak_ptr_factory_.GetWeakPtr()),
- base::BindOnce(&BluetoothProfileServiceProviderImpl::OnExported,
- weak_ptr_factory_.GetWeakPtr()));
- exported_object_->ExportMethod(
- bluetooth_profile::kBluetoothProfileInterface,
- bluetooth_profile::kCancel,
- base::BindRepeating(&BluetoothProfileServiceProviderImpl::Cancel,
- weak_ptr_factory_.GetWeakPtr()),
- base::BindOnce(&BluetoothProfileServiceProviderImpl::OnExported,
- weak_ptr_factory_.GetWeakPtr()));
- }
- BluetoothProfileServiceProviderImpl(
- const BluetoothProfileServiceProviderImpl&) = delete;
- BluetoothProfileServiceProviderImpl& operator=(
- const BluetoothProfileServiceProviderImpl&) = delete;
- ~BluetoothProfileServiceProviderImpl() override {
- DVLOG(1) << "Cleaning up Bluetooth Profile: " << object_path_.value();
- // Unregister the object path so we can reuse with a new agent.
- bus_->UnregisterExportedObject(object_path_);
- }
- private:
- // Returns true if the current thread is on the origin thread.
- bool OnOriginThread() {
- return base::PlatformThread::CurrentId() == origin_thread_id_;
- }
- // Called by dbus:: when the profile is unregistered from the Bluetooth
- // daemon, generally by our request.
- void Release(dbus::MethodCall* method_call,
- dbus::ExportedObject::ResponseSender response_sender) {
- DCHECK(OnOriginThread());
- DCHECK(delegate_);
- delegate_->Released();
- std::move(response_sender).Run(dbus::Response::FromMethodCall(method_call));
- }
- // Called by dbus:: when the Bluetooth daemon establishes a new connection
- // to the profile.
- void NewConnection(dbus::MethodCall* method_call,
- dbus::ExportedObject::ResponseSender response_sender) {
- DCHECK(OnOriginThread());
- DCHECK(delegate_);
- dbus::MessageReader reader(method_call);
- dbus::ObjectPath device_path;
- base::ScopedFD fd;
- dbus::MessageReader array_reader(NULL);
- if (!reader.PopObjectPath(&device_path) || !reader.PopFileDescriptor(&fd) ||
- !reader.PopArray(&array_reader)) {
- LOG(WARNING) << "NewConnection called with incorrect paramters: "
- << method_call->ToString();
- return;
- }
- Delegate::Options options;
- while (array_reader.HasMoreData()) {
- dbus::MessageReader dict_entry_reader(NULL);
- std::string key;
- if (!array_reader.PopDictEntry(&dict_entry_reader) ||
- !dict_entry_reader.PopString(&key)) {
- LOG(WARNING) << "NewConnection called with incorrect paramters: "
- << method_call->ToString();
- } else {
- if (key == bluetooth_profile::kVersionProperty)
- dict_entry_reader.PopVariantOfUint16(&options.version);
- else if (key == bluetooth_profile::kFeaturesProperty)
- dict_entry_reader.PopVariantOfUint16(&options.features);
- }
- }
- Delegate::ConfirmationCallback callback =
- base::BindOnce(&BluetoothProfileServiceProviderImpl::OnConfirmation,
- weak_ptr_factory_.GetWeakPtr(), method_call,
- std::move(response_sender));
- delegate_->NewConnection(device_path, std::move(fd), options,
- std::move(callback));
- }
- // Called by dbus:: when the Bluetooth daemon is about to disconnect the
- // profile.
- void RequestDisconnection(
- dbus::MethodCall* method_call,
- dbus::ExportedObject::ResponseSender response_sender) {
- DCHECK(OnOriginThread());
- DCHECK(delegate_);
- dbus::MessageReader reader(method_call);
- dbus::ObjectPath device_path;
- if (!reader.PopObjectPath(&device_path)) {
- LOG(WARNING) << "RequestDisconnection called with incorrect paramters: "
- << method_call->ToString();
- return;
- }
- Delegate::ConfirmationCallback callback =
- base::BindOnce(&BluetoothProfileServiceProviderImpl::OnConfirmation,
- weak_ptr_factory_.GetWeakPtr(), method_call,
- std::move(response_sender));
- delegate_->RequestDisconnection(device_path, std::move(callback));
- }
- // Called by dbus:: when the request failed before a reply was returned
- // from the device.
- void Cancel(dbus::MethodCall* method_call,
- dbus::ExportedObject::ResponseSender response_sender) {
- DCHECK(OnOriginThread());
- DCHECK(delegate_);
- delegate_->Cancel();
- std::move(response_sender).Run(dbus::Response::FromMethodCall(method_call));
- }
- // Called by dbus:: when a method is exported.
- void OnExported(const std::string& interface_name,
- const std::string& method_name,
- bool success) {
- DVLOG_IF(1, !success) << "Failed to export " << interface_name << "."
- << method_name;
- }
- // Called by the Delegate in response to a method requiring confirmation.
- void OnConfirmation(dbus::MethodCall* method_call,
- dbus::ExportedObject::ResponseSender response_sender,
- Delegate::Status status) {
- DCHECK(OnOriginThread());
- switch (status) {
- case Delegate::SUCCESS: {
- std::move(response_sender)
- .Run(dbus::Response::FromMethodCall(method_call));
- break;
- }
- case Delegate::REJECTED: {
- std::move(response_sender)
- .Run(dbus::ErrorResponse::FromMethodCall(
- method_call, bluetooth_profile::kErrorRejected, "rejected"));
- break;
- }
- case Delegate::CANCELLED: {
- std::move(response_sender)
- .Run(dbus::ErrorResponse::FromMethodCall(
- method_call, bluetooth_profile::kErrorCanceled, "canceled"));
- break;
- }
- default:
- NOTREACHED() << "Unexpected status code from delegate: " << status;
- }
- }
- // Origin thread (i.e. the UI thread in production).
- base::PlatformThreadId origin_thread_id_;
- // D-Bus bus object is exported on, not owned by this object and must
- // outlive it.
- raw_ptr<dbus::Bus> bus_;
- // All incoming method calls are passed on to the Delegate and a callback
- // passed to generate the reply. |delegate_| is generally the object that
- // owns this one, and must outlive it.
- raw_ptr<Delegate> delegate_;
- // D-Bus object path of object we are exporting, kept so we can unregister
- // again in our destructor.
- dbus::ObjectPath object_path_;
- // D-Bus object we are exporting, owned by this object.
- scoped_refptr<dbus::ExportedObject> exported_object_;
- // 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<BluetoothProfileServiceProviderImpl> weak_ptr_factory_{
- this};
- };
- BluetoothProfileServiceProvider::BluetoothProfileServiceProvider() = default;
- BluetoothProfileServiceProvider::~BluetoothProfileServiceProvider() = default;
- // static
- BluetoothProfileServiceProvider* BluetoothProfileServiceProvider::Create(
- dbus::Bus* bus,
- const dbus::ObjectPath& object_path,
- Delegate* delegate) {
- if (!bluez::BluezDBusManager::Get()->IsUsingFakes()) {
- return new BluetoothProfileServiceProviderImpl(bus, object_path, delegate);
- }
- #if defined(USE_REAL_DBUS_CLIENTS)
- LOG(FATAL) << "Fake is unavailable if USE_REAL_DBUS_CLIENTS is defined.";
- return nullptr;
- #else
- return new FakeBluetoothProfileServiceProvider(object_path, delegate);
- #endif // defined(USE_REAL_DBUS_CLIENTS)
- }
- } // namespace bluez
|