Index: device/bluetooth/bluetooth_adapter_bluez.cc |
diff --git a/device/bluetooth/bluetooth_adapter_bluez.cc b/device/bluetooth/bluetooth_adapter_bluez.cc |
deleted file mode 100644 |
index 4c64f0eb1360c403fc63e947fe69fe714de0bf64..0000000000000000000000000000000000000000 |
--- a/device/bluetooth/bluetooth_adapter_bluez.cc |
+++ /dev/null |
@@ -1,1458 +0,0 @@ |
-// 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/bluetooth_adapter_bluez.h" |
- |
-#include <memory> |
-#include <set> |
-#include <string> |
-#include <utility> |
- |
-#include "base/bind.h" |
-#include "base/location.h" |
-#include "base/logging.h" |
-#include "base/metrics/histogram.h" |
-#include "base/sequenced_task_runner.h" |
-#include "base/single_thread_task_runner.h" |
-#include "base/strings/stringprintf.h" |
-#include "base/thread_task_runner_handle.h" |
-#include "build/build_config.h" |
-#include "device/bluetooth/bluetooth_adapter_profile_bluez.h" |
-#include "device/bluetooth/bluetooth_advertisement_bluez.h" |
-#include "device/bluetooth/bluetooth_audio_sink_bluez.h" |
-#include "device/bluetooth/bluetooth_device.h" |
-#include "device/bluetooth/bluetooth_device_bluez.h" |
-#include "device/bluetooth/bluetooth_discovery_session_outcome.h" |
-#include "device/bluetooth/bluetooth_pairing_bluez.h" |
-#include "device/bluetooth/bluetooth_socket_bluez.h" |
-#include "device/bluetooth/bluetooth_socket_thread.h" |
-#include "device/bluetooth/bluetooth_uuid.h" |
-#include "device/bluetooth/dbus/bluetooth_adapter_client.h" |
-#include "device/bluetooth/dbus/bluetooth_agent_manager_client.h" |
-#include "device/bluetooth/dbus/bluetooth_agent_service_provider.h" |
-#include "device/bluetooth/dbus/bluetooth_device_client.h" |
-#include "device/bluetooth/dbus/bluetooth_input_client.h" |
-#include "device/bluetooth/dbus/bluez_dbus_manager.h" |
-#include "third_party/cros_system_api/dbus/service_constants.h" |
- |
-#if defined(OS_CHROMEOS) |
-#include "chromeos/system/devicetype.h" |
-#endif |
- |
-using device::BluetoothAdapter; |
-using device::BluetoothAudioSink; |
-using device::BluetoothDevice; |
-using device::BluetoothDiscoveryFilter; |
-using device::BluetoothSocket; |
-using device::BluetoothUUID; |
-using device::UMABluetoothDiscoverySessionOutcome; |
- |
-namespace { |
- |
-// The agent path is relatively meaningless since BlueZ only permits one to |
-// exist per D-Bus connection, it just has to be unique within Chromium. |
-const char kAgentPath[] = "/org/chromium/bluetooth_agent"; |
- |
-void OnUnregisterAgentError(const std::string& error_name, |
- const std::string& error_message) { |
- // It's okay if the agent didn't exist, it means we never saw an adapter. |
- if (error_name == bluetooth_agent_manager::kErrorDoesNotExist) |
- return; |
- |
- LOG(WARNING) << "Failed to unregister pairing agent: " << error_name << ": " |
- << error_message; |
-} |
- |
-UMABluetoothDiscoverySessionOutcome TranslateDiscoveryErrorToUMA( |
- const std::string& error_name) { |
- if (error_name == bluez::BluetoothAdapterClient::kUnknownAdapterError) { |
- return UMABluetoothDiscoverySessionOutcome::BLUEZ_DBUS_UNKNOWN_ADAPTER; |
- } else if (error_name == bluez::BluetoothAdapterClient::kNoResponseError) { |
- return UMABluetoothDiscoverySessionOutcome::BLUEZ_DBUS_NO_RESPONSE; |
- } else if (error_name == bluetooth_device::kErrorInProgress) { |
- return UMABluetoothDiscoverySessionOutcome::BLUEZ_DBUS_IN_PROGRESS; |
- } else if (error_name == bluetooth_device::kErrorNotReady) { |
- return UMABluetoothDiscoverySessionOutcome::BLUEZ_DBUS_NOT_READY; |
- } else if (error_name == bluetooth_device::kErrorNotSupported) { |
- return UMABluetoothDiscoverySessionOutcome::BLUEZ_DBUS_UNSUPPORTED_DEVICE; |
- } else if (error_name == bluetooth_device::kErrorFailed) { |
- return UMABluetoothDiscoverySessionOutcome::FAILED; |
- } else { |
- LOG(WARNING) << "Can't histogram DBus error " << error_name; |
- return UMABluetoothDiscoverySessionOutcome::UNKNOWN; |
- } |
-} |
- |
-} // namespace |
- |
-namespace device { |
- |
-// static |
-base::WeakPtr<BluetoothAdapter> BluetoothAdapter::CreateAdapter( |
- const InitCallback& init_callback) { |
- return bluez::BluetoothAdapterBlueZ::CreateAdapter(init_callback); |
-} |
- |
-} // namespace device |
- |
-namespace bluez { |
- |
-// static |
-base::WeakPtr<BluetoothAdapter> BluetoothAdapterBlueZ::CreateAdapter( |
- const InitCallback& init_callback) { |
- BluetoothAdapterBlueZ* adapter = new BluetoothAdapterBlueZ(init_callback); |
- return adapter->weak_ptr_factory_.GetWeakPtr(); |
-} |
- |
-void BluetoothAdapterBlueZ::Shutdown() { |
- if (dbus_is_shutdown_) |
- return; |
- DCHECK(bluez::BluezDBusManager::IsInitialized()) |
- << "Call BluetoothAdapterFactory::Shutdown() before " |
- "BluezDBusManager::Shutdown()."; |
- |
- // Since we don't initialize anything if Object Manager is not supported, |
- // no need to do any clean up. |
- if (!bluez::BluezDBusManager::Get()->IsObjectManagerSupported()) { |
- dbus_is_shutdown_ = true; |
- return; |
- } |
- |
- if (IsPresent()) |
- RemoveAdapter(); // Also deletes devices_. |
- DCHECK(devices_.empty()); |
- // profiles_ is empty because all BluetoothSockets have been notified |
- // that this adapter is disappearing. |
- DCHECK(profiles_.empty()); |
- |
- for (auto& it : profile_queues_) |
- delete it.second; |
- profile_queues_.clear(); |
- |
- bluez::BluezDBusManager::Get()->GetBluetoothAdapterClient()->RemoveObserver( |
- this); |
- bluez::BluezDBusManager::Get()->GetBluetoothDeviceClient()->RemoveObserver( |
- this); |
- bluez::BluezDBusManager::Get()->GetBluetoothInputClient()->RemoveObserver( |
- this); |
- |
- VLOG(1) << "Unregistering pairing agent"; |
- bluez::BluezDBusManager::Get() |
- ->GetBluetoothAgentManagerClient() |
- ->UnregisterAgent(dbus::ObjectPath(kAgentPath), |
- base::Bind(&base::DoNothing), |
- base::Bind(&OnUnregisterAgentError)); |
- |
- agent_.reset(); |
- dbus_is_shutdown_ = true; |
-} |
- |
-BluetoothAdapterBlueZ::BluetoothAdapterBlueZ(const InitCallback& init_callback) |
- : init_callback_(init_callback), |
- initialized_(false), |
- dbus_is_shutdown_(false), |
- num_discovery_sessions_(0), |
- discovery_request_pending_(false), |
- weak_ptr_factory_(this) { |
- ui_task_runner_ = base::ThreadTaskRunnerHandle::Get(); |
- socket_thread_ = device::BluetoothSocketThread::Get(); |
- |
- // Can't initialize the adapter until DBus clients are ready. |
- if (bluez::BluezDBusManager::Get()->IsObjectManagerSupportKnown()) { |
- base::ThreadTaskRunnerHandle::Get()->PostTask( |
- FROM_HERE, base::Bind(&BluetoothAdapterBlueZ::Init, |
- weak_ptr_factory_.GetWeakPtr())); |
- return; |
- } |
- bluez::BluezDBusManager::Get()->CallWhenObjectManagerSupportIsKnown( |
- base::Bind(&BluetoothAdapterBlueZ::Init, weak_ptr_factory_.GetWeakPtr())); |
-} |
- |
-void BluetoothAdapterBlueZ::Init() { |
- // If the platform doesn't support Object Manager then Bluez 5 is probably |
- // not present. In this case we just return without initializing anything. |
- if (!bluez::BluezDBusManager::Get()->IsObjectManagerSupported()) { |
- initialized_ = true; |
- init_callback_.Run(); |
- return; |
- } |
- |
- bluez::BluezDBusManager::Get()->GetBluetoothAdapterClient()->AddObserver( |
- this); |
- bluez::BluezDBusManager::Get()->GetBluetoothDeviceClient()->AddObserver(this); |
- bluez::BluezDBusManager::Get()->GetBluetoothInputClient()->AddObserver(this); |
- |
- // Register the pairing agent. |
- dbus::Bus* system_bus = bluez::BluezDBusManager::Get()->GetSystemBus(); |
- agent_.reset(bluez::BluetoothAgentServiceProvider::Create( |
- system_bus, dbus::ObjectPath(kAgentPath), this)); |
- DCHECK(agent_.get()); |
- |
- std::vector<dbus::ObjectPath> object_paths = bluez::BluezDBusManager::Get() |
- ->GetBluetoothAdapterClient() |
- ->GetAdapters(); |
- |
- if (!object_paths.empty()) { |
- VLOG(1) << object_paths.size() << " Bluetooth adapter(s) available."; |
- SetAdapter(object_paths[0]); |
- } |
- initialized_ = true; |
- init_callback_.Run(); |
-} |
- |
-BluetoothAdapterBlueZ::~BluetoothAdapterBlueZ() { |
- Shutdown(); |
-} |
- |
-std::string BluetoothAdapterBlueZ::GetAddress() const { |
- if (!IsPresent()) |
- return std::string(); |
- |
- bluez::BluetoothAdapterClient::Properties* properties = |
- bluez::BluezDBusManager::Get() |
- ->GetBluetoothAdapterClient() |
- ->GetProperties(object_path_); |
- DCHECK(properties); |
- |
- return BluetoothDevice::CanonicalizeAddress(properties->address.value()); |
-} |
- |
-std::string BluetoothAdapterBlueZ::GetName() const { |
- if (!IsPresent()) |
- return std::string(); |
- |
- bluez::BluetoothAdapterClient::Properties* properties = |
- bluez::BluezDBusManager::Get() |
- ->GetBluetoothAdapterClient() |
- ->GetProperties(object_path_); |
- DCHECK(properties); |
- |
- return properties->alias.value(); |
-} |
- |
-void BluetoothAdapterBlueZ::SetName(const std::string& name, |
- const base::Closure& callback, |
- const ErrorCallback& error_callback) { |
- if (!IsPresent()) { |
- error_callback.Run(); |
- return; |
- } |
- |
- bluez::BluezDBusManager::Get() |
- ->GetBluetoothAdapterClient() |
- ->GetProperties(object_path_) |
- ->alias.Set( |
- name, |
- base::Bind(&BluetoothAdapterBlueZ::OnPropertyChangeCompleted, |
- weak_ptr_factory_.GetWeakPtr(), callback, error_callback)); |
-} |
- |
-bool BluetoothAdapterBlueZ::IsInitialized() const { |
- return initialized_; |
-} |
- |
-bool BluetoothAdapterBlueZ::IsPresent() const { |
- return !dbus_is_shutdown_ && !object_path_.value().empty(); |
-} |
- |
-bool BluetoothAdapterBlueZ::IsPowered() const { |
- if (!IsPresent()) |
- return false; |
- |
- bluez::BluetoothAdapterClient::Properties* properties = |
- bluez::BluezDBusManager::Get() |
- ->GetBluetoothAdapterClient() |
- ->GetProperties(object_path_); |
- |
- return properties->powered.value(); |
-} |
- |
-void BluetoothAdapterBlueZ::SetPowered(bool powered, |
- const base::Closure& callback, |
- const ErrorCallback& error_callback) { |
- if (!IsPresent()) { |
- error_callback.Run(); |
- return; |
- } |
- |
- bluez::BluezDBusManager::Get() |
- ->GetBluetoothAdapterClient() |
- ->GetProperties(object_path_) |
- ->powered.Set( |
- powered, |
- base::Bind(&BluetoothAdapterBlueZ::OnPropertyChangeCompleted, |
- weak_ptr_factory_.GetWeakPtr(), callback, error_callback)); |
-} |
- |
-bool BluetoothAdapterBlueZ::IsDiscoverable() const { |
- if (!IsPresent()) |
- return false; |
- |
- bluez::BluetoothAdapterClient::Properties* properties = |
- bluez::BluezDBusManager::Get() |
- ->GetBluetoothAdapterClient() |
- ->GetProperties(object_path_); |
- |
- return properties->discoverable.value(); |
-} |
- |
-void BluetoothAdapterBlueZ::SetDiscoverable( |
- bool discoverable, |
- const base::Closure& callback, |
- const ErrorCallback& error_callback) { |
- if (!IsPresent()) { |
- error_callback.Run(); |
- return; |
- } |
- |
- bluez::BluezDBusManager::Get() |
- ->GetBluetoothAdapterClient() |
- ->GetProperties(object_path_) |
- ->discoverable.Set( |
- discoverable, |
- base::Bind(&BluetoothAdapterBlueZ::OnSetDiscoverable, |
- weak_ptr_factory_.GetWeakPtr(), callback, error_callback)); |
-} |
- |
-bool BluetoothAdapterBlueZ::IsDiscovering() const { |
- if (!IsPresent()) |
- return false; |
- |
- bluez::BluetoothAdapterClient::Properties* properties = |
- bluez::BluezDBusManager::Get() |
- ->GetBluetoothAdapterClient() |
- ->GetProperties(object_path_); |
- |
- return properties->discovering.value(); |
-} |
- |
-BluetoothAdapterBlueZ::UUIDList BluetoothAdapterBlueZ::GetUUIDs() const { |
- bluez::BluetoothAdapterClient::Properties* properties = |
- bluez::BluezDBusManager::Get() |
- ->GetBluetoothAdapterClient() |
- ->GetProperties(object_path_); |
- DCHECK(properties); |
- |
- std::vector<std::string> uuids = properties->uuids.value(); |
- |
- return UUIDList(uuids.begin(), uuids.end()); |
-} |
- |
-void BluetoothAdapterBlueZ::CreateRfcommService( |
- const BluetoothUUID& uuid, |
- const ServiceOptions& options, |
- const CreateServiceCallback& callback, |
- const CreateServiceErrorCallback& error_callback) { |
- DCHECK(!dbus_is_shutdown_); |
- VLOG(1) << object_path_.value() |
- << ": Creating RFCOMM service: " << uuid.canonical_value(); |
- scoped_refptr<BluetoothSocketBlueZ> socket = |
- BluetoothSocketBlueZ::CreateBluetoothSocket(ui_task_runner_, |
- socket_thread_); |
- socket->Listen(this, BluetoothSocketBlueZ::kRfcomm, uuid, options, |
- base::Bind(callback, socket), error_callback); |
-} |
- |
-void BluetoothAdapterBlueZ::CreateL2capService( |
- const BluetoothUUID& uuid, |
- const ServiceOptions& options, |
- const CreateServiceCallback& callback, |
- const CreateServiceErrorCallback& error_callback) { |
- DCHECK(!dbus_is_shutdown_); |
- VLOG(1) << object_path_.value() |
- << ": Creating L2CAP service: " << uuid.canonical_value(); |
- scoped_refptr<BluetoothSocketBlueZ> socket = |
- BluetoothSocketBlueZ::CreateBluetoothSocket(ui_task_runner_, |
- socket_thread_); |
- socket->Listen(this, BluetoothSocketBlueZ::kL2cap, uuid, options, |
- base::Bind(callback, socket), error_callback); |
-} |
- |
-void BluetoothAdapterBlueZ::RegisterAudioSink( |
- const BluetoothAudioSink::Options& options, |
- const device::BluetoothAdapter::AcquiredCallback& callback, |
- const BluetoothAudioSink::ErrorCallback& error_callback) { |
- VLOG(1) << "Registering audio sink"; |
- if (!this->IsPresent()) { |
- error_callback.Run(BluetoothAudioSink::ERROR_INVALID_ADAPTER); |
- return; |
- } |
- scoped_refptr<BluetoothAudioSinkBlueZ> audio_sink( |
- new BluetoothAudioSinkBlueZ(this)); |
- audio_sink->Register(options, |
- base::Bind(&BluetoothAdapterBlueZ::OnRegisterAudioSink, |
- weak_ptr_factory_.GetWeakPtr(), callback, |
- error_callback, audio_sink), |
- error_callback); |
-} |
- |
-void BluetoothAdapterBlueZ::RegisterAdvertisement( |
- std::unique_ptr<device::BluetoothAdvertisement::Data> advertisement_data, |
- const CreateAdvertisementCallback& callback, |
- const CreateAdvertisementErrorCallback& error_callback) { |
- scoped_refptr<BluetoothAdvertisementBlueZ> advertisement( |
- new BluetoothAdvertisementBlueZ(std::move(advertisement_data), this)); |
- advertisement->Register(base::Bind(callback, advertisement), error_callback); |
-} |
- |
-void BluetoothAdapterBlueZ::RemovePairingDelegateInternal( |
- BluetoothDevice::PairingDelegate* pairing_delegate) { |
- // Check if any device is using the pairing delegate. |
- // If so, clear the pairing context which will make any responses no-ops. |
- for (DevicesMap::const_iterator iter = devices_.begin(); |
- iter != devices_.end(); ++iter) { |
- BluetoothDeviceBlueZ* device_bluez = |
- static_cast<BluetoothDeviceBlueZ*>(iter->second); |
- |
- BluetoothPairingBlueZ* pairing = device_bluez->GetPairing(); |
- if (pairing && pairing->GetPairingDelegate() == pairing_delegate) |
- device_bluez->EndPairing(); |
- } |
-} |
- |
-void BluetoothAdapterBlueZ::AdapterAdded(const dbus::ObjectPath& object_path) { |
- // Set the adapter to the newly added adapter only if no adapter is present. |
- if (!IsPresent()) |
- SetAdapter(object_path); |
-} |
- |
-void BluetoothAdapterBlueZ::AdapterRemoved( |
- const dbus::ObjectPath& object_path) { |
- if (object_path == object_path_) |
- RemoveAdapter(); |
-} |
- |
-void BluetoothAdapterBlueZ::AdapterPropertyChanged( |
- const dbus::ObjectPath& object_path, |
- const std::string& property_name) { |
- if (object_path != object_path_) |
- return; |
- DCHECK(IsPresent()); |
- |
- bluez::BluetoothAdapterClient::Properties* properties = |
- bluez::BluezDBusManager::Get() |
- ->GetBluetoothAdapterClient() |
- ->GetProperties(object_path_); |
- |
- if (property_name == properties->powered.name()) { |
- PoweredChanged(properties->powered.value()); |
- } else if (property_name == properties->discoverable.name()) { |
- DiscoverableChanged(properties->discoverable.value()); |
- } else if (property_name == properties->discovering.name()) { |
- DiscoveringChanged(properties->discovering.value()); |
- } |
-} |
- |
-void BluetoothAdapterBlueZ::DeviceAdded(const dbus::ObjectPath& object_path) { |
- DCHECK(bluez::BluezDBusManager::Get()); |
- bluez::BluetoothDeviceClient::Properties* properties = |
- bluez::BluezDBusManager::Get()->GetBluetoothDeviceClient()->GetProperties( |
- object_path); |
- if (!properties || properties->adapter.value() != object_path_) |
- return; |
- DCHECK(IsPresent()); |
- |
- BluetoothDeviceBlueZ* device_bluez = new BluetoothDeviceBlueZ( |
- this, object_path, ui_task_runner_, socket_thread_); |
- DCHECK(devices_.find(device_bluez->GetAddress()) == devices_.end()); |
- |
- devices_.set(device_bluez->GetAddress(), |
- std::unique_ptr<BluetoothDevice>(device_bluez)); |
- |
- FOR_EACH_OBSERVER(BluetoothAdapter::Observer, observers_, |
- DeviceAdded(this, device_bluez)); |
-} |
- |
-void BluetoothAdapterBlueZ::DeviceRemoved(const dbus::ObjectPath& object_path) { |
- for (DevicesMap::const_iterator iter = devices_.begin(); |
- iter != devices_.end(); ++iter) { |
- BluetoothDeviceBlueZ* device_bluez = |
- static_cast<BluetoothDeviceBlueZ*>(iter->second); |
- if (device_bluez->object_path() == object_path) { |
- std::unique_ptr<BluetoothDevice> scoped_device = |
- devices_.take_and_erase(iter->first); |
- |
- FOR_EACH_OBSERVER(BluetoothAdapter::Observer, observers_, |
- DeviceRemoved(this, device_bluez)); |
- return; |
- } |
- } |
-} |
- |
-void BluetoothAdapterBlueZ::DevicePropertyChanged( |
- const dbus::ObjectPath& object_path, |
- const std::string& property_name) { |
- BluetoothDeviceBlueZ* device_bluez = GetDeviceWithPath(object_path); |
- if (!device_bluez) |
- return; |
- |
- bluez::BluetoothDeviceClient::Properties* properties = |
- bluez::BluezDBusManager::Get()->GetBluetoothDeviceClient()->GetProperties( |
- object_path); |
- |
- if (property_name == properties->address.name()) { |
- for (DevicesMap::iterator iter = devices_.begin(); iter != devices_.end(); |
- ++iter) { |
- if (iter->second->GetAddress() == device_bluez->GetAddress()) { |
- std::string old_address = iter->first; |
- VLOG(1) << "Device changed address, old: " << old_address |
- << " new: " << device_bluez->GetAddress(); |
- std::unique_ptr<BluetoothDevice> scoped_device = |
- devices_.take_and_erase(iter); |
- ignore_result(scoped_device.release()); |
- |
- DCHECK(devices_.find(device_bluez->GetAddress()) == devices_.end()); |
- devices_.set(device_bluez->GetAddress(), |
- std::unique_ptr<BluetoothDevice>(device_bluez)); |
- NotifyDeviceAddressChanged(device_bluez, old_address); |
- break; |
- } |
- } |
- } |
- |
- if (property_name == properties->bluetooth_class.name() || |
- property_name == properties->appearance.name() || |
- property_name == properties->address.name() || |
- property_name == properties->alias.name() || |
- property_name == properties->paired.name() || |
- property_name == properties->trusted.name() || |
- property_name == properties->connected.name() || |
- property_name == properties->uuids.name() || |
- property_name == properties->rssi.name() || |
- property_name == properties->tx_power.name()) { |
- NotifyDeviceChanged(device_bluez); |
- } |
- |
- if (property_name == properties->gatt_services.name()) { |
- device_bluez->SetGattServicesDiscoveryComplete(true); |
- NotifyGattServicesDiscovered(device_bluez); |
- } |
- |
- // When a device becomes paired, mark it as trusted so that the user does |
- // not need to approve every incoming connection |
- if (property_name == properties->paired.name()) { |
- if (properties->paired.value() && !properties->trusted.value()) { |
- device_bluez->SetTrusted(); |
- } |
- NotifyDevicePairedChanged(device_bluez, properties->paired.value()); |
- } |
- |
- // UMA connection counting |
- if (property_name == properties->connected.name()) { |
- // PlayStation joystick tries to reconnect after disconnection from USB. |
- // If it is still not trusted, set it, so it becomes available on the |
- // list of known devices. |
- if (properties->connected.value()) { |
- if (device_bluez->IsTrustable() && !properties->trusted.value()) |
- device_bluez->SetTrusted(); |
- } else { |
- device_bluez->SetGattServicesDiscoveryComplete(false); |
- } |
- |
- int count = 0; |
- |
- for (DevicesMap::const_iterator iter = devices_.begin(); |
- iter != devices_.end(); ++iter) { |
- if (iter->second->IsPaired() && iter->second->IsConnected()) |
- ++count; |
- } |
- |
- UMA_HISTOGRAM_COUNTS_100("Bluetooth.ConnectedDeviceCount", count); |
- } |
-} |
- |
-void BluetoothAdapterBlueZ::InputPropertyChanged( |
- const dbus::ObjectPath& object_path, |
- const std::string& property_name) { |
- BluetoothDeviceBlueZ* device_bluez = GetDeviceWithPath(object_path); |
- if (!device_bluez) |
- return; |
- |
- bluez::BluetoothInputClient::Properties* properties = |
- bluez::BluezDBusManager::Get()->GetBluetoothInputClient()->GetProperties( |
- object_path); |
- |
- // Properties structure can be removed, which triggers a change in the |
- // BluetoothDevice::IsConnectable() property, as does a change in the |
- // actual reconnect_mode property. |
- if (!properties || property_name == properties->reconnect_mode.name()) { |
- NotifyDeviceChanged(device_bluez); |
- } |
-} |
- |
-void BluetoothAdapterBlueZ::Released() { |
- VLOG(1) << "Release"; |
- if (!IsPresent()) |
- return; |
- DCHECK(agent_.get()); |
- |
- // Called after we unregister the pairing agent, e.g. when changing I/O |
- // capabilities. Nothing much to be done right now. |
-} |
- |
-void BluetoothAdapterBlueZ::RequestPinCode(const dbus::ObjectPath& device_path, |
- const PinCodeCallback& callback) { |
- DCHECK(IsPresent()); |
- DCHECK(agent_.get()); |
- VLOG(1) << device_path.value() << ": RequestPinCode"; |
- |
- BluetoothPairingBlueZ* pairing = GetPairing(device_path); |
- if (!pairing) { |
- callback.Run(REJECTED, ""); |
- return; |
- } |
- |
- pairing->RequestPinCode(callback); |
-} |
- |
-void BluetoothAdapterBlueZ::DisplayPinCode(const dbus::ObjectPath& device_path, |
- const std::string& pincode) { |
- DCHECK(IsPresent()); |
- DCHECK(agent_.get()); |
- VLOG(1) << device_path.value() << ": DisplayPinCode: " << pincode; |
- |
- BluetoothPairingBlueZ* pairing = GetPairing(device_path); |
- if (!pairing) |
- return; |
- |
- pairing->DisplayPinCode(pincode); |
-} |
- |
-void BluetoothAdapterBlueZ::RequestPasskey(const dbus::ObjectPath& device_path, |
- const PasskeyCallback& callback) { |
- DCHECK(IsPresent()); |
- DCHECK(agent_.get()); |
- VLOG(1) << device_path.value() << ": RequestPasskey"; |
- |
- BluetoothPairingBlueZ* pairing = GetPairing(device_path); |
- if (!pairing) { |
- callback.Run(REJECTED, 0); |
- return; |
- } |
- |
- pairing->RequestPasskey(callback); |
-} |
- |
-void BluetoothAdapterBlueZ::DisplayPasskey(const dbus::ObjectPath& device_path, |
- uint32_t passkey, |
- uint16_t entered) { |
- DCHECK(IsPresent()); |
- DCHECK(agent_.get()); |
- VLOG(1) << device_path.value() << ": DisplayPasskey: " << passkey << " (" |
- << entered << " entered)"; |
- |
- BluetoothPairingBlueZ* pairing = GetPairing(device_path); |
- if (!pairing) |
- return; |
- |
- if (entered == 0) |
- pairing->DisplayPasskey(passkey); |
- |
- pairing->KeysEntered(entered); |
-} |
- |
-void BluetoothAdapterBlueZ::RequestConfirmation( |
- const dbus::ObjectPath& device_path, |
- uint32_t passkey, |
- const ConfirmationCallback& callback) { |
- DCHECK(IsPresent()); |
- DCHECK(agent_.get()); |
- VLOG(1) << device_path.value() << ": RequestConfirmation: " << passkey; |
- |
- BluetoothPairingBlueZ* pairing = GetPairing(device_path); |
- if (!pairing) { |
- callback.Run(REJECTED); |
- return; |
- } |
- |
- pairing->RequestConfirmation(passkey, callback); |
-} |
- |
-void BluetoothAdapterBlueZ::RequestAuthorization( |
- const dbus::ObjectPath& device_path, |
- const ConfirmationCallback& callback) { |
- DCHECK(IsPresent()); |
- DCHECK(agent_.get()); |
- VLOG(1) << device_path.value() << ": RequestAuthorization"; |
- |
- BluetoothPairingBlueZ* pairing = GetPairing(device_path); |
- if (!pairing) { |
- callback.Run(REJECTED); |
- return; |
- } |
- |
- pairing->RequestAuthorization(callback); |
-} |
- |
-void BluetoothAdapterBlueZ::AuthorizeService( |
- const dbus::ObjectPath& device_path, |
- const std::string& uuid, |
- const ConfirmationCallback& callback) { |
- DCHECK(IsPresent()); |
- DCHECK(agent_.get()); |
- VLOG(1) << device_path.value() << ": AuthorizeService: " << uuid; |
- |
- BluetoothDeviceBlueZ* device_bluez = GetDeviceWithPath(device_path); |
- if (!device_bluez) { |
- callback.Run(CANCELLED); |
- return; |
- } |
- |
- // We always set paired devices to Trusted, so the only reason that this |
- // method call would ever be called is in the case of a race condition where |
- // our "Set('Trusted', true)" method call is still pending in the Bluetooth |
- // daemon because it's busy handling the incoming connection. |
- if (device_bluez->IsPaired()) { |
- callback.Run(SUCCESS); |
- return; |
- } |
- |
- // TODO(keybuk): reject service authorizations when not paired, determine |
- // whether this is acceptable long-term. |
- LOG(WARNING) << "Rejecting service connection from unpaired device " |
- << device_bluez->GetAddress() << " for UUID " << uuid; |
- callback.Run(REJECTED); |
-} |
- |
-void BluetoothAdapterBlueZ::Cancel() { |
- DCHECK(IsPresent()); |
- DCHECK(agent_.get()); |
- VLOG(1) << "Cancel"; |
-} |
- |
-void BluetoothAdapterBlueZ::OnRegisterAgent() { |
- VLOG(1) << "Pairing agent registered, requesting to be made default"; |
- |
- bluez::BluezDBusManager::Get() |
- ->GetBluetoothAgentManagerClient() |
- ->RequestDefaultAgent( |
- dbus::ObjectPath(kAgentPath), |
- base::Bind(&BluetoothAdapterBlueZ::OnRequestDefaultAgent, |
- weak_ptr_factory_.GetWeakPtr()), |
- base::Bind(&BluetoothAdapterBlueZ::OnRequestDefaultAgentError, |
- weak_ptr_factory_.GetWeakPtr())); |
-} |
- |
-void BluetoothAdapterBlueZ::OnRegisterAgentError( |
- const std::string& error_name, |
- const std::string& error_message) { |
- // Our agent being already registered isn't an error. |
- if (error_name == bluetooth_agent_manager::kErrorAlreadyExists) |
- return; |
- |
- LOG(WARNING) << ": Failed to register pairing agent: " << error_name << ": " |
- << error_message; |
-} |
- |
-void BluetoothAdapterBlueZ::OnRequestDefaultAgent() { |
- VLOG(1) << "Pairing agent now default"; |
-} |
- |
-void BluetoothAdapterBlueZ::OnRequestDefaultAgentError( |
- const std::string& error_name, |
- const std::string& error_message) { |
- LOG(WARNING) << ": Failed to make pairing agent default: " << error_name |
- << ": " << error_message; |
-} |
- |
-void BluetoothAdapterBlueZ::OnRegisterAudioSink( |
- const device::BluetoothAdapter::AcquiredCallback& callback, |
- const device::BluetoothAudioSink::ErrorCallback& error_callback, |
- scoped_refptr<BluetoothAudioSink> audio_sink) { |
- if (!IsPresent()) { |
- VLOG(1) << "Failed to register audio sink, adapter not present"; |
- error_callback.Run(BluetoothAudioSink::ERROR_INVALID_ADAPTER); |
- return; |
- } |
- DCHECK(audio_sink.get()); |
- callback.Run(audio_sink); |
-} |
- |
-BluetoothDeviceBlueZ* BluetoothAdapterBlueZ::GetDeviceWithPath( |
- const dbus::ObjectPath& object_path) { |
- if (!IsPresent()) |
- return nullptr; |
- |
- for (DevicesMap::const_iterator iter = devices_.begin(); |
- iter != devices_.end(); ++iter) { |
- BluetoothDeviceBlueZ* device_bluez = |
- static_cast<BluetoothDeviceBlueZ*>(iter->second); |
- if (device_bluez->object_path() == object_path) |
- return device_bluez; |
- } |
- |
- return nullptr; |
-} |
- |
-BluetoothPairingBlueZ* BluetoothAdapterBlueZ::GetPairing( |
- const dbus::ObjectPath& object_path) { |
- DCHECK(IsPresent()); |
- BluetoothDeviceBlueZ* device_bluez = GetDeviceWithPath(object_path); |
- if (!device_bluez) { |
- LOG(WARNING) << "Pairing Agent request for unknown device: " |
- << object_path.value(); |
- return nullptr; |
- } |
- |
- BluetoothPairingBlueZ* pairing = device_bluez->GetPairing(); |
- if (pairing) |
- return pairing; |
- |
- // The device doesn't have its own pairing context, so this is an incoming |
- // pairing request that should use our best default delegate (if we have one). |
- BluetoothDevice::PairingDelegate* pairing_delegate = DefaultPairingDelegate(); |
- if (!pairing_delegate) |
- return nullptr; |
- |
- return device_bluez->BeginPairing(pairing_delegate); |
-} |
- |
-void BluetoothAdapterBlueZ::SetAdapter(const dbus::ObjectPath& object_path) { |
- DCHECK(!IsPresent()); |
- DCHECK(!dbus_is_shutdown_); |
- object_path_ = object_path; |
- |
- VLOG(1) << object_path_.value() << ": using adapter."; |
- |
- VLOG(1) << "Registering pairing agent"; |
- bluez::BluezDBusManager::Get() |
- ->GetBluetoothAgentManagerClient() |
- ->RegisterAgent(dbus::ObjectPath(kAgentPath), |
- bluetooth_agent_manager::kKeyboardDisplayCapability, |
- base::Bind(&BluetoothAdapterBlueZ::OnRegisterAgent, |
- weak_ptr_factory_.GetWeakPtr()), |
- base::Bind(&BluetoothAdapterBlueZ::OnRegisterAgentError, |
- weak_ptr_factory_.GetWeakPtr())); |
- |
-#if defined(OS_CHROMEOS) |
- SetStandardChromeOSAdapterName(); |
-#endif |
- |
- bluez::BluetoothAdapterClient::Properties* properties = |
- bluez::BluezDBusManager::Get() |
- ->GetBluetoothAdapterClient() |
- ->GetProperties(object_path_); |
- |
- PresentChanged(true); |
- |
- if (properties->powered.value()) |
- PoweredChanged(true); |
- if (properties->discoverable.value()) |
- DiscoverableChanged(true); |
- if (properties->discovering.value()) |
- DiscoveringChanged(true); |
- |
- std::vector<dbus::ObjectPath> device_paths = |
- bluez::BluezDBusManager::Get() |
- ->GetBluetoothDeviceClient() |
- ->GetDevicesForAdapter(object_path_); |
- |
- for (std::vector<dbus::ObjectPath>::iterator iter = device_paths.begin(); |
- iter != device_paths.end(); ++iter) { |
- DeviceAdded(*iter); |
- } |
-} |
- |
-#if defined(OS_CHROMEOS) |
-void BluetoothAdapterBlueZ::SetStandardChromeOSAdapterName() { |
- DCHECK(IsPresent()); |
- |
- std::string alias; |
- switch (chromeos::GetDeviceType()) { |
- case chromeos::DeviceType::kChromebase: |
- alias = "Chromebase"; |
- break; |
- case chromeos::DeviceType::kChromebit: |
- alias = "Chromebit"; |
- break; |
- case chromeos::DeviceType::kChromebook: |
- alias = "Chromebook"; |
- break; |
- case chromeos::DeviceType::kChromebox: |
- alias = "Chromebox"; |
- break; |
- case chromeos::DeviceType::kUnknown: |
- alias = "Chromebook"; |
- break; |
- } |
- // Take the lower 2 bytes of hashed Bluetooth address and combine it with the |
- // device type to create a more identifiable device name. |
- const std::string address = GetAddress(); |
- alias = base::StringPrintf( |
- "%s_%04X", alias.c_str(), |
- base::SuperFastHash(address.data(), address.size()) & 0xFFFF); |
- SetName(alias, base::Bind(&base::DoNothing), base::Bind(&base::DoNothing)); |
-} |
-#endif |
- |
-void BluetoothAdapterBlueZ::RemoveAdapter() { |
- DCHECK(IsPresent()); |
- VLOG(1) << object_path_.value() << ": adapter removed."; |
- |
- bluez::BluetoothAdapterClient::Properties* properties = |
- bluez::BluezDBusManager::Get() |
- ->GetBluetoothAdapterClient() |
- ->GetProperties(object_path_); |
- |
- object_path_ = dbus::ObjectPath(""); |
- |
- if (properties->powered.value()) |
- PoweredChanged(false); |
- if (properties->discoverable.value()) |
- DiscoverableChanged(false); |
- if (properties->discovering.value()) |
- DiscoveringChanged(false); |
- |
- // Move all elements of the original devices list to a new list here, |
- // leaving the original list empty so that when we send DeviceRemoved(), |
- // GetDevices() returns no devices. |
- DevicesMap devices_swapped; |
- devices_swapped.swap(devices_); |
- |
- for (auto& iter : devices_swapped) { |
- FOR_EACH_OBSERVER(BluetoothAdapter::Observer, observers_, |
- DeviceRemoved(this, iter.second)); |
- } |
- |
- PresentChanged(false); |
-} |
- |
-void BluetoothAdapterBlueZ::PoweredChanged(bool powered) { |
- FOR_EACH_OBSERVER(BluetoothAdapter::Observer, observers_, |
- AdapterPoweredChanged(this, powered)); |
-} |
- |
-void BluetoothAdapterBlueZ::DiscoverableChanged(bool discoverable) { |
- FOR_EACH_OBSERVER(BluetoothAdapter::Observer, observers_, |
- AdapterDiscoverableChanged(this, discoverable)); |
-} |
- |
-void BluetoothAdapterBlueZ::DiscoveringChanged(bool discovering) { |
- // If the adapter stopped discovery due to a reason other than a request by |
- // us, reset the count to 0. |
- VLOG(1) << "Discovering changed: " << discovering; |
- if (!discovering && !discovery_request_pending_ && |
- num_discovery_sessions_ > 0) { |
- VLOG(1) << "Marking sessions as inactive."; |
- num_discovery_sessions_ = 0; |
- MarkDiscoverySessionsAsInactive(); |
- } |
- FOR_EACH_OBSERVER(BluetoothAdapter::Observer, observers_, |
- AdapterDiscoveringChanged(this, discovering)); |
-} |
- |
-void BluetoothAdapterBlueZ::PresentChanged(bool present) { |
- FOR_EACH_OBSERVER(BluetoothAdapter::Observer, observers_, |
- AdapterPresentChanged(this, present)); |
-} |
- |
-void BluetoothAdapterBlueZ::NotifyDeviceChanged(BluetoothDeviceBlueZ* device) { |
- DCHECK(device); |
- DCHECK(device->adapter_ == this); |
- |
- FOR_EACH_OBSERVER(BluetoothAdapter::Observer, observers_, |
- DeviceChanged(this, device)); |
-} |
- |
-void BluetoothAdapterBlueZ::NotifyDeviceAddressChanged( |
- BluetoothDeviceBlueZ* device, |
- const std::string& old_address) { |
- DCHECK(device->adapter_ == this); |
- |
- FOR_EACH_OBSERVER(BluetoothAdapter::Observer, observers_, |
- DeviceAddressChanged(this, device, old_address)); |
-} |
- |
-void BluetoothAdapterBlueZ::UseProfile( |
- const BluetoothUUID& uuid, |
- const dbus::ObjectPath& device_path, |
- const bluez::BluetoothProfileManagerClient::Options& options, |
- bluez::BluetoothProfileServiceProvider::Delegate* delegate, |
- const ProfileRegisteredCallback& success_callback, |
- const ErrorCompletionCallback& error_callback) { |
- DCHECK(delegate); |
- |
- if (!IsPresent()) { |
- VLOG(2) << "Adapter not present, erroring out"; |
- error_callback.Run("Adapter not present"); |
- return; |
- } |
- |
- if (profiles_.find(uuid) != profiles_.end()) { |
- // TODO(jamuraa) check that the options are the same and error when they are |
- // not. |
- SetProfileDelegate(uuid, device_path, delegate, success_callback, |
- error_callback); |
- return; |
- } |
- |
- if (profile_queues_.find(uuid) == profile_queues_.end()) { |
- BluetoothAdapterProfileBlueZ::Register( |
- uuid, options, |
- base::Bind(&BluetoothAdapterBlueZ::OnRegisterProfile, this, uuid), |
- base::Bind(&BluetoothAdapterBlueZ::OnRegisterProfileError, this, uuid)); |
- |
- profile_queues_[uuid] = new std::vector<RegisterProfileCompletionPair>(); |
- } |
- |
- profile_queues_[uuid]->push_back(std::make_pair( |
- base::Bind(&BluetoothAdapterBlueZ::SetProfileDelegate, this, uuid, |
- device_path, delegate, success_callback, error_callback), |
- error_callback)); |
-} |
- |
-void BluetoothAdapterBlueZ::ReleaseProfile( |
- const dbus::ObjectPath& device_path, |
- BluetoothAdapterProfileBlueZ* profile) { |
- VLOG(2) << "Releasing Profile: " << profile->uuid().canonical_value() |
- << " from " << device_path.value(); |
- profile->RemoveDelegate( |
- device_path, base::Bind(&BluetoothAdapterBlueZ::RemoveProfile, |
- weak_ptr_factory_.GetWeakPtr(), profile->uuid())); |
-} |
- |
-void BluetoothAdapterBlueZ::RemoveProfile(const BluetoothUUID& uuid) { |
- VLOG(2) << "Remove Profile: " << uuid.canonical_value(); |
- |
- if (profiles_.find(uuid) != profiles_.end()) { |
- delete profiles_[uuid]; |
- profiles_.erase(uuid); |
- } |
-} |
- |
-void BluetoothAdapterBlueZ::OnRegisterProfile( |
- const BluetoothUUID& uuid, |
- std::unique_ptr<BluetoothAdapterProfileBlueZ> profile) { |
- profiles_[uuid] = profile.release(); |
- |
- if (profile_queues_.find(uuid) == profile_queues_.end()) |
- return; |
- |
- for (auto& it : *profile_queues_[uuid]) |
- it.first.Run(); |
- delete profile_queues_[uuid]; |
- profile_queues_.erase(uuid); |
-} |
- |
-void BluetoothAdapterBlueZ::SetProfileDelegate( |
- const BluetoothUUID& uuid, |
- const dbus::ObjectPath& device_path, |
- bluez::BluetoothProfileServiceProvider::Delegate* delegate, |
- const ProfileRegisteredCallback& success_callback, |
- const ErrorCompletionCallback& error_callback) { |
- if (profiles_.find(uuid) == profiles_.end()) { |
- error_callback.Run("Cannot find profile!"); |
- return; |
- } |
- |
- if (profiles_[uuid]->SetDelegate(device_path, delegate)) { |
- success_callback.Run(profiles_[uuid]); |
- return; |
- } |
- // Already set |
- error_callback.Run(bluetooth_agent_manager::kErrorAlreadyExists); |
-} |
- |
-void BluetoothAdapterBlueZ::OnRegisterProfileError( |
- const BluetoothUUID& uuid, |
- const std::string& error_name, |
- const std::string& error_message) { |
- VLOG(2) << object_path_.value() |
- << ": Failed to register profile: " << error_name << ": " |
- << error_message; |
- if (profile_queues_.find(uuid) == profile_queues_.end()) |
- return; |
- |
- for (auto& it : *profile_queues_[uuid]) |
- it.second.Run(error_message); |
- |
- delete profile_queues_[uuid]; |
- profile_queues_.erase(uuid); |
-} |
- |
-void BluetoothAdapterBlueZ::OnSetDiscoverable( |
- const base::Closure& callback, |
- const ErrorCallback& error_callback, |
- bool success) { |
- if (!IsPresent()) { |
- error_callback.Run(); |
- return; |
- } |
- |
- // Set the discoverable_timeout property to zero so the adapter remains |
- // discoverable forever. |
- bluez::BluezDBusManager::Get() |
- ->GetBluetoothAdapterClient() |
- ->GetProperties(object_path_) |
- ->discoverable_timeout.Set( |
- 0, |
- base::Bind(&BluetoothAdapterBlueZ::OnPropertyChangeCompleted, |
- weak_ptr_factory_.GetWeakPtr(), callback, error_callback)); |
-} |
- |
-void BluetoothAdapterBlueZ::OnPropertyChangeCompleted( |
- const base::Closure& callback, |
- const ErrorCallback& error_callback, |
- bool success) { |
- if (IsPresent() && success) { |
- callback.Run(); |
- } else { |
- error_callback.Run(); |
- } |
-} |
- |
-void BluetoothAdapterBlueZ::AddDiscoverySession( |
- BluetoothDiscoveryFilter* discovery_filter, |
- const base::Closure& callback, |
- const DiscoverySessionErrorCallback& error_callback) { |
- if (!IsPresent()) { |
- error_callback.Run( |
- UMABluetoothDiscoverySessionOutcome::ADAPTER_NOT_PRESENT); |
- return; |
- } |
- VLOG(1) << __func__; |
- if (discovery_request_pending_) { |
- // The pending request is either to stop a previous session or to start a |
- // new one. Either way, queue this one. |
- DCHECK(num_discovery_sessions_ == 1 || num_discovery_sessions_ == 0); |
- VLOG(1) << "Pending request to start/stop device discovery. Queueing " |
- << "request to start a new discovery session."; |
- discovery_request_queue_.push( |
- std::make_tuple(discovery_filter, callback, error_callback)); |
- return; |
- } |
- |
- // The adapter is already discovering. |
- if (num_discovery_sessions_ > 0) { |
- DCHECK(IsDiscovering()); |
- DCHECK(!discovery_request_pending_); |
- num_discovery_sessions_++; |
- SetDiscoveryFilter(BluetoothDiscoveryFilter::Merge( |
- GetMergedDiscoveryFilter().get(), discovery_filter), |
- callback, error_callback); |
- return; |
- } |
- |
- // There are no active discovery sessions. |
- DCHECK_EQ(num_discovery_sessions_, 0); |
- |
- if (discovery_filter) { |
- discovery_request_pending_ = true; |
- |
- std::unique_ptr<BluetoothDiscoveryFilter> df(new BluetoothDiscoveryFilter( |
- BluetoothDiscoveryFilter::Transport::TRANSPORT_DUAL)); |
- df->CopyFrom(*discovery_filter); |
- SetDiscoveryFilter( |
- std::move(df), |
- base::Bind(&BluetoothAdapterBlueZ::OnPreSetDiscoveryFilter, |
- weak_ptr_factory_.GetWeakPtr(), callback, error_callback), |
- base::Bind(&BluetoothAdapterBlueZ::OnPreSetDiscoveryFilterError, |
- weak_ptr_factory_.GetWeakPtr(), callback, error_callback)); |
- return; |
- } else { |
- current_filter_.reset(); |
- } |
- |
- // This is the first request to start device discovery. |
- discovery_request_pending_ = true; |
- bluez::BluezDBusManager::Get()->GetBluetoothAdapterClient()->StartDiscovery( |
- object_path_, |
- base::Bind(&BluetoothAdapterBlueZ::OnStartDiscovery, |
- weak_ptr_factory_.GetWeakPtr(), callback, error_callback), |
- base::Bind(&BluetoothAdapterBlueZ::OnStartDiscoveryError, |
- weak_ptr_factory_.GetWeakPtr(), callback, error_callback)); |
-} |
- |
-void BluetoothAdapterBlueZ::RemoveDiscoverySession( |
- BluetoothDiscoveryFilter* discovery_filter, |
- const base::Closure& callback, |
- const DiscoverySessionErrorCallback& error_callback) { |
- if (!IsPresent()) { |
- error_callback.Run( |
- UMABluetoothDiscoverySessionOutcome::ADAPTER_NOT_PRESENT); |
- return; |
- } |
- |
- VLOG(1) << __func__; |
- // There are active sessions other than the one currently being removed. |
- if (num_discovery_sessions_ > 1) { |
- DCHECK(IsDiscovering()); |
- DCHECK(!discovery_request_pending_); |
- num_discovery_sessions_--; |
- |
- SetDiscoveryFilter(GetMergedDiscoveryFilterMasked(discovery_filter), |
- callback, error_callback); |
- return; |
- } |
- |
- // If there is a pending request to BlueZ, then queue this request. |
- if (discovery_request_pending_) { |
- VLOG(1) << "Pending request to start/stop device discovery. Queueing " |
- << "request to stop discovery session."; |
- error_callback.Run( |
- UMABluetoothDiscoverySessionOutcome::REMOVE_WITH_PENDING_REQUEST); |
- return; |
- } |
- |
- // There are no active sessions. Return error. |
- if (num_discovery_sessions_ == 0) { |
- // TODO(armansito): This should never happen once we have the |
- // DiscoverySession API. Replace this case with an assert once it's |
- // the deprecated methods have been removed. (See crbug.com/3445008). |
- VLOG(1) << "No active discovery sessions. Returning error."; |
- error_callback.Run( |
- UMABluetoothDiscoverySessionOutcome::ACTIVE_SESSION_NOT_IN_ADAPTER); |
- return; |
- } |
- |
- // There is exactly one active discovery session. Request BlueZ to stop |
- // discovery. |
- DCHECK_EQ(num_discovery_sessions_, 1); |
- discovery_request_pending_ = true; |
- bluez::BluezDBusManager::Get()->GetBluetoothAdapterClient()->StopDiscovery( |
- object_path_, base::Bind(&BluetoothAdapterBlueZ::OnStopDiscovery, |
- weak_ptr_factory_.GetWeakPtr(), callback), |
- base::Bind(&BluetoothAdapterBlueZ::OnStopDiscoveryError, |
- weak_ptr_factory_.GetWeakPtr(), error_callback)); |
-} |
- |
-void BluetoothAdapterBlueZ::SetDiscoveryFilter( |
- std::unique_ptr<BluetoothDiscoveryFilter> discovery_filter, |
- const base::Closure& callback, |
- const DiscoverySessionErrorCallback& error_callback) { |
- if (!IsPresent()) { |
- error_callback.Run(UMABluetoothDiscoverySessionOutcome::ADAPTER_REMOVED); |
- return; |
- } |
- |
- // If old and new filter are equal (null) then don't make request, just call |
- // succes callback |
- if (!current_filter_ && !discovery_filter.get()) { |
- callback.Run(); |
- return; |
- } |
- |
- // If old and new filter are not null and equal then don't make request, just |
- // call succes callback |
- if (current_filter_ && discovery_filter && |
- current_filter_->Equals(*discovery_filter)) { |
- callback.Run(); |
- return; |
- } |
- |
- current_filter_.reset(discovery_filter.release()); |
- |
- bluez::BluetoothAdapterClient::DiscoveryFilter dbus_discovery_filter; |
- |
- if (current_filter_.get()) { |
- uint16_t pathloss; |
- int16_t rssi; |
- uint8_t transport; |
- std::set<device::BluetoothUUID> uuids; |
- |
- if (current_filter_->GetPathloss(&pathloss)) |
- dbus_discovery_filter.pathloss.reset(new uint16_t(pathloss)); |
- |
- if (current_filter_->GetRSSI(&rssi)) |
- dbus_discovery_filter.rssi.reset(new int16_t(rssi)); |
- |
- transport = current_filter_->GetTransport(); |
- if (transport == BluetoothDiscoveryFilter::Transport::TRANSPORT_LE) { |
- dbus_discovery_filter.transport.reset(new std::string("le")); |
- } else if (transport == |
- BluetoothDiscoveryFilter::Transport::TRANSPORT_CLASSIC) { |
- dbus_discovery_filter.transport.reset(new std::string("bredr")); |
- } else if (transport == |
- BluetoothDiscoveryFilter::Transport::TRANSPORT_DUAL) { |
- dbus_discovery_filter.transport.reset(new std::string("auto")); |
- } |
- |
- current_filter_->GetUUIDs(uuids); |
- if (uuids.size()) { |
- dbus_discovery_filter.uuids = std::unique_ptr<std::vector<std::string>>( |
- new std::vector<std::string>); |
- |
- for (const auto& it : uuids) |
- dbus_discovery_filter.uuids.get()->push_back(it.value()); |
- } |
- } |
- |
- bluez::BluezDBusManager::Get() |
- ->GetBluetoothAdapterClient() |
- ->SetDiscoveryFilter( |
- object_path_, dbus_discovery_filter, |
- base::Bind(&BluetoothAdapterBlueZ::OnSetDiscoveryFilter, |
- weak_ptr_factory_.GetWeakPtr(), callback, error_callback), |
- base::Bind(&BluetoothAdapterBlueZ::OnSetDiscoveryFilterError, |
- weak_ptr_factory_.GetWeakPtr(), callback, error_callback)); |
-} |
- |
-void BluetoothAdapterBlueZ::OnStartDiscovery( |
- const base::Closure& callback, |
- const DiscoverySessionErrorCallback& error_callback) { |
- // Report success on the original request and increment the count. |
- VLOG(1) << __func__; |
- DCHECK(discovery_request_pending_); |
- DCHECK_EQ(num_discovery_sessions_, 0); |
- discovery_request_pending_ = false; |
- num_discovery_sessions_++; |
- if (IsPresent()) { |
- callback.Run(); |
- } else { |
- error_callback.Run(UMABluetoothDiscoverySessionOutcome::ADAPTER_REMOVED); |
- } |
- |
- // Try to add a new discovery session for each queued request. |
- ProcessQueuedDiscoveryRequests(); |
-} |
- |
-void BluetoothAdapterBlueZ::OnStartDiscoveryError( |
- const base::Closure& callback, |
- const DiscoverySessionErrorCallback& error_callback, |
- const std::string& error_name, |
- const std::string& error_message) { |
- LOG(WARNING) << object_path_.value() |
- << ": Failed to start discovery: " << error_name << ": " |
- << error_message; |
- |
- // Failed to start discovery. This can only happen if the count is at 0. |
- DCHECK_EQ(num_discovery_sessions_, 0); |
- DCHECK(discovery_request_pending_); |
- discovery_request_pending_ = false; |
- |
- // Discovery request may fail if discovery was previously initiated by Chrome, |
- // but the session were invalidated due to the discovery state unexpectedly |
- // changing to false and then back to true. In this case, report success. |
- if (IsPresent() && error_name == bluetooth_device::kErrorInProgress && |
- IsDiscovering()) { |
- VLOG(1) << "Discovery previously initiated. Reporting success."; |
- num_discovery_sessions_++; |
- callback.Run(); |
- } else { |
- error_callback.Run(TranslateDiscoveryErrorToUMA(error_name)); |
- } |
- |
- // Try to add a new discovery session for each queued request. |
- ProcessQueuedDiscoveryRequests(); |
-} |
- |
-void BluetoothAdapterBlueZ::OnStopDiscovery(const base::Closure& callback) { |
- // Report success on the original request and decrement the count. |
- VLOG(1) << __func__; |
- DCHECK(discovery_request_pending_); |
- DCHECK_EQ(num_discovery_sessions_, 1); |
- discovery_request_pending_ = false; |
- num_discovery_sessions_--; |
- callback.Run(); |
- |
- current_filter_.reset(); |
- |
- // Try to add a new discovery session for each queued request. |
- ProcessQueuedDiscoveryRequests(); |
-} |
- |
-void BluetoothAdapterBlueZ::OnStopDiscoveryError( |
- const DiscoverySessionErrorCallback& error_callback, |
- const std::string& error_name, |
- const std::string& error_message) { |
- LOG(WARNING) << object_path_.value() |
- << ": Failed to stop discovery: " << error_name << ": " |
- << error_message; |
- |
- // Failed to stop discovery. This can only happen if the count is at 1. |
- DCHECK(discovery_request_pending_); |
- DCHECK_EQ(num_discovery_sessions_, 1); |
- discovery_request_pending_ = false; |
- error_callback.Run(TranslateDiscoveryErrorToUMA(error_name)); |
- |
- // Try to add a new discovery session for each queued request. |
- ProcessQueuedDiscoveryRequests(); |
-} |
- |
-void BluetoothAdapterBlueZ::OnPreSetDiscoveryFilter( |
- const base::Closure& callback, |
- const DiscoverySessionErrorCallback& error_callback) { |
- // This is the first request to start device discovery. |
- DCHECK(discovery_request_pending_); |
- DCHECK_EQ(num_discovery_sessions_, 0); |
- |
- bluez::BluezDBusManager::Get()->GetBluetoothAdapterClient()->StartDiscovery( |
- object_path_, |
- base::Bind(&BluetoothAdapterBlueZ::OnStartDiscovery, |
- weak_ptr_factory_.GetWeakPtr(), callback, error_callback), |
- base::Bind(&BluetoothAdapterBlueZ::OnStartDiscoveryError, |
- weak_ptr_factory_.GetWeakPtr(), callback, error_callback)); |
-} |
- |
-void BluetoothAdapterBlueZ::OnPreSetDiscoveryFilterError( |
- const base::Closure& callback, |
- const DiscoverySessionErrorCallback& error_callback, |
- UMABluetoothDiscoverySessionOutcome outcome) { |
- LOG(WARNING) << object_path_.value() |
- << ": Failed to pre set discovery filter."; |
- |
- // Failed to start discovery. This can only happen if the count is at 0. |
- DCHECK_EQ(num_discovery_sessions_, 0); |
- DCHECK(discovery_request_pending_); |
- discovery_request_pending_ = false; |
- |
- error_callback.Run(outcome); |
- |
- // Try to add a new discovery session for each queued request. |
- ProcessQueuedDiscoveryRequests(); |
-} |
- |
-void BluetoothAdapterBlueZ::OnSetDiscoveryFilter( |
- const base::Closure& callback, |
- const DiscoverySessionErrorCallback& error_callback) { |
- // Report success on the original request and increment the count. |
- VLOG(1) << __func__; |
- if (IsPresent()) { |
- callback.Run(); |
- } else { |
- error_callback.Run(UMABluetoothDiscoverySessionOutcome::ADAPTER_REMOVED); |
- } |
-} |
- |
-void BluetoothAdapterBlueZ::OnSetDiscoveryFilterError( |
- const base::Closure& callback, |
- const DiscoverySessionErrorCallback& error_callback, |
- const std::string& error_name, |
- const std::string& error_message) { |
- LOG(WARNING) << object_path_.value() |
- << ": Failed to set discovery filter: " << error_name << ": " |
- << error_message; |
- |
- UMABluetoothDiscoverySessionOutcome outcome = |
- TranslateDiscoveryErrorToUMA(error_name); |
- if (outcome == UMABluetoothDiscoverySessionOutcome::FAILED) { |
- // bluez/doc/adapter-api.txt says "Failed" is returned from |
- // SetDiscoveryFilter when the controller doesn't support the requested |
- // transport. |
- outcome = UMABluetoothDiscoverySessionOutcome:: |
- BLUEZ_DBUS_FAILED_MAYBE_UNSUPPORTED_TRANSPORT; |
- } |
- error_callback.Run(outcome); |
- |
- // Try to add a new discovery session for each queued request. |
- ProcessQueuedDiscoveryRequests(); |
-} |
- |
-void BluetoothAdapterBlueZ::ProcessQueuedDiscoveryRequests() { |
- while (!discovery_request_queue_.empty()) { |
- VLOG(1) << "Process queued discovery request."; |
- DiscoveryParamTuple params = discovery_request_queue_.front(); |
- discovery_request_queue_.pop(); |
- AddDiscoverySession(std::get<0>(params), std::get<1>(params), |
- std::get<2>(params)); |
- |
- // If the queued request resulted in a pending call, then let it |
- // asynchonously process the remaining queued requests once the pending |
- // call returns. |
- if (discovery_request_pending_) |
- return; |
- } |
-} |
- |
-} // namespace bluez |