| OLD | NEW |
| 1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "device/bluetooth/bluez/bluetooth_device_bluez.h" | 5 #include "device/bluetooth/bluez/bluetooth_device_bluez.h" |
| 6 | 6 |
| 7 #include <stdio.h> | 7 #include <stdio.h> |
| 8 | 8 |
| 9 #include <algorithm> | 9 #include <algorithm> |
| 10 #include <memory> | 10 #include <memory> |
| (...skipping 162 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 173 ->GetBluetoothGattServiceClient() | 173 ->GetBluetoothGattServiceClient() |
| 174 ->RemoveObserver(this); | 174 ->RemoveObserver(this); |
| 175 | 175 |
| 176 // Copy the GATT services list here and clear the original so that when we | 176 // Copy the GATT services list here and clear the original so that when we |
| 177 // send GattServiceRemoved(), GetGattServices() returns no services. | 177 // send GattServiceRemoved(), GetGattServices() returns no services. |
| 178 GattServiceMap gatt_services_swapped; | 178 GattServiceMap gatt_services_swapped; |
| 179 gatt_services_swapped.swap(gatt_services_); | 179 gatt_services_swapped.swap(gatt_services_); |
| 180 for (const auto& iter : gatt_services_swapped) { | 180 for (const auto& iter : gatt_services_swapped) { |
| 181 DCHECK(adapter()); | 181 DCHECK(adapter()); |
| 182 adapter()->NotifyGattServiceRemoved( | 182 adapter()->NotifyGattServiceRemoved( |
| 183 static_cast<BluetoothRemoteGattServiceBlueZ*>(iter.second)); | 183 static_cast<BluetoothRemoteGattServiceBlueZ*>(iter.second.get())); |
| 184 } | 184 } |
| 185 } | 185 } |
| 186 | 186 |
| 187 uint32_t BluetoothDeviceBlueZ::GetBluetoothClass() const { | 187 uint32_t BluetoothDeviceBlueZ::GetBluetoothClass() const { |
| 188 bluez::BluetoothDeviceClient::Properties* properties = | 188 bluez::BluetoothDeviceClient::Properties* properties = |
| 189 bluez::BluezDBusManager::Get()->GetBluetoothDeviceClient()->GetProperties( | 189 bluez::BluezDBusManager::Get()->GetBluetoothDeviceClient()->GetProperties( |
| 190 object_path_); | 190 object_path_); |
| 191 DCHECK(properties); | 191 DCHECK(properties); |
| 192 | 192 |
| 193 return properties->bluetooth_class.value(); | 193 return properties->bluetooth_class.value(); |
| (...skipping 474 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 668 ->GetBluetoothGattServiceClient() | 668 ->GetBluetoothGattServiceClient() |
| 669 ->GetProperties(object_path); | 669 ->GetProperties(object_path); |
| 670 DCHECK(properties); | 670 DCHECK(properties); |
| 671 if (properties->device.value() != object_path_) { | 671 if (properties->device.value() != object_path_) { |
| 672 VLOG(2) << "Remote GATT service does not belong to this device."; | 672 VLOG(2) << "Remote GATT service does not belong to this device."; |
| 673 return; | 673 return; |
| 674 } | 674 } |
| 675 | 675 |
| 676 VLOG(1) << "Adding new remote GATT service for device: " << GetAddress(); | 676 VLOG(1) << "Adding new remote GATT service for device: " << GetAddress(); |
| 677 | 677 |
| 678 BluetoothRemoteGattServiceBlueZ* service = | 678 std::unique_ptr<device::BluetoothRemoteGattService> service( |
| 679 new BluetoothRemoteGattServiceBlueZ(adapter(), this, object_path); | 679 new BluetoothRemoteGattServiceBlueZ(adapter(), this, object_path)); |
| 680 | 680 auto insertion = gatt_services_.insert( |
| 681 gatt_services_.set(service->GetIdentifier(), | 681 std::make_pair(service->GetIdentifier(), std::move(service))); |
| 682 std::unique_ptr<BluetoothRemoteGattService>(service)); | 682 if (!insertion.second) { |
| 683 DCHECK(service->object_path() == object_path); | 683 // insertion failed. |
| 684 DCHECK(service->GetUUID().IsValid()); | 684 VLOG(1) << "Insertion of new remote GATT service failed for device: " |
| 685 << GetAddress(); |
| 686 return; |
| 687 } |
| 688 BluetoothRemoteGattServiceBlueZ* bluez = |
| 689 static_cast<BluetoothRemoteGattServiceBlueZ*>( |
| 690 insertion.first->second.get()); |
| 691 DCHECK(bluez->object_path() == object_path); |
| 692 DCHECK(bluez->GetUUID().IsValid()); |
| 685 | 693 |
| 686 DCHECK(adapter()); | 694 DCHECK(adapter()); |
| 687 adapter()->NotifyGattServiceAdded(service); | 695 adapter()->NotifyGattServiceAdded(bluez); |
| 688 } | 696 } |
| 689 | 697 |
| 690 void BluetoothDeviceBlueZ::GattServiceRemoved( | 698 void BluetoothDeviceBlueZ::GattServiceRemoved( |
| 691 const dbus::ObjectPath& object_path) { | 699 const dbus::ObjectPath& object_path) { |
| 692 GattServiceMap::const_iterator iter = | 700 auto iter = gatt_services_.find(object_path.value()); |
| 693 gatt_services_.find(object_path.value()); | |
| 694 if (iter == gatt_services_.end()) { | 701 if (iter == gatt_services_.end()) { |
| 695 VLOG(3) << "Unknown GATT service removed: " << object_path.value(); | 702 VLOG(3) << "Unknown GATT service removed: " << object_path.value(); |
| 696 return; | 703 return; |
| 697 } | 704 } |
| 705 // Hold onto the service so that we can erase it safely. |
| 706 auto scoped_service = std::move(iter->second); |
| 707 gatt_services_.erase(iter); |
| 708 discovery_complete_notified_.erase(scoped_service.get()); |
| 698 | 709 |
| 699 BluetoothRemoteGattServiceBlueZ* service = | 710 BluetoothRemoteGattServiceBlueZ* bluez = |
| 700 static_cast<BluetoothRemoteGattServiceBlueZ*>(iter->second); | 711 static_cast<BluetoothRemoteGattServiceBlueZ*>(scoped_service.get()); |
| 701 | 712 DCHECK(bluez->object_path() == object_path); |
| 702 VLOG(1) << "Removing remote GATT service with UUID: '" | 713 VLOG(1) << "Removing remote GATT service with UUID: '" |
| 703 << service->GetUUID().canonical_value() | 714 << scoped_service->GetUUID().canonical_value() |
| 704 << "' from device: " << GetAddress(); | 715 << "' from device: " << GetAddress(); |
| 705 | 716 |
| 706 DCHECK(service->object_path() == object_path); | |
| 707 std::unique_ptr<BluetoothRemoteGattService> scoped_service = | |
| 708 gatt_services_.take_and_erase(iter->first); | |
| 709 | |
| 710 DCHECK(adapter()); | 717 DCHECK(adapter()); |
| 711 discovery_complete_notified_.erase(service); | 718 adapter()->NotifyGattServiceRemoved(scoped_service.get()); |
| 712 adapter()->NotifyGattServiceRemoved(service); | |
| 713 } | 719 } |
| 714 | 720 |
| 715 void BluetoothDeviceBlueZ::UpdateGattServices( | 721 void BluetoothDeviceBlueZ::UpdateGattServices( |
| 716 const dbus::ObjectPath& object_path) { | 722 const dbus::ObjectPath& object_path) { |
| 717 if (object_path != object_path_) { | 723 if (object_path != object_path_) { |
| 718 // No need to update map if update is for a different device. | 724 // No need to update map if update is for a different device. |
| 719 return; | 725 return; |
| 720 } | 726 } |
| 721 | 727 |
| 722 DCHECK(IsGattServicesDiscoveryComplete()); | 728 DCHECK(IsGattServicesDiscoveryComplete()); |
| (...skipping 221 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 944 void BluetoothDeviceBlueZ::OnForgetError(const ErrorCallback& error_callback, | 950 void BluetoothDeviceBlueZ::OnForgetError(const ErrorCallback& error_callback, |
| 945 const std::string& error_name, | 951 const std::string& error_name, |
| 946 const std::string& error_message) { | 952 const std::string& error_message) { |
| 947 LOG(WARNING) << object_path_.value() | 953 LOG(WARNING) << object_path_.value() |
| 948 << ": Failed to remove device: " << error_name << ": " | 954 << ": Failed to remove device: " << error_name << ": " |
| 949 << error_message; | 955 << error_message; |
| 950 error_callback.Run(); | 956 error_callback.Run(); |
| 951 } | 957 } |
| 952 | 958 |
| 953 } // namespace bluez | 959 } // namespace bluez |
| OLD | NEW |