OLD | NEW |
1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 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/bluetooth_low_energy_device_mac.h" | 5 #include "device/bluetooth/bluetooth_low_energy_device_mac.h" |
6 | 6 |
7 #import <CoreFoundation/CoreFoundation.h> | 7 #import <CoreFoundation/CoreFoundation.h> |
8 #include <stddef.h> | 8 #include <stddef.h> |
9 | 9 |
10 #include "base/mac/mac_util.h" | 10 #include "base/mac/mac_util.h" |
(...skipping 221 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
232 } | 232 } |
233 } | 233 } |
234 | 234 |
235 void BluetoothLowEnergyDeviceMac::DisconnectGatt() { | 235 void BluetoothLowEnergyDeviceMac::DisconnectGatt() { |
236 GetMacAdapter()->DisconnectGatt(this); | 236 GetMacAdapter()->DisconnectGatt(this); |
237 } | 237 } |
238 | 238 |
239 void BluetoothLowEnergyDeviceMac::DidDiscoverPrimaryServices(NSError* error) { | 239 void BluetoothLowEnergyDeviceMac::DidDiscoverPrimaryServices(NSError* error) { |
240 if (error) { | 240 if (error) { |
241 // TODO(http://crbug.com/609320): Need to pass the error. | 241 // TODO(http://crbug.com/609320): Need to pass the error. |
242 // TODO(http://crbug.com/609844): Decide what to do if we fail to discover | 242 // TODO(http://crbug.com/609844): Decide what to do if discover failed |
243 // a device services. | 243 // a device services. |
244 VLOG(1) << "Can't discover primary services: " | 244 VLOG(1) << "Can't discover primary services: " |
245 << error.localizedDescription.UTF8String << " (" << error.domain | 245 << error.localizedDescription.UTF8String << " (" << error.domain |
246 << ": " << error.code << ")"; | 246 << ": " << error.code << ")"; |
247 return; | 247 return; |
248 } | 248 } |
249 for (CBService* cb_service in GetPeripheral().services) { | 249 for (CBService* cb_service in GetPeripheral().services) { |
250 BluetoothRemoteGattServiceMac* gatt_service = | 250 BluetoothRemoteGattServiceMac* gatt_service = |
251 GetBluetoothRemoteGattService(cb_service); | 251 GetBluetoothRemoteGattService(cb_service); |
252 if (!gatt_service) { | 252 if (!gatt_service) { |
253 gatt_service = new BluetoothRemoteGattServiceMac(this, cb_service, | 253 gatt_service = new BluetoothRemoteGattServiceMac(this, cb_service, |
254 true /* is_primary */); | 254 true /* is_primary */); |
255 auto result_iter = gatt_services_.add(gatt_service->GetIdentifier(), | 255 auto result_iter = gatt_services_.add(gatt_service->GetIdentifier(), |
256 base::WrapUnique(gatt_service)); | 256 base::WrapUnique(gatt_service)); |
257 DCHECK(result_iter.second); | 257 DCHECK(result_iter.second); |
258 adapter_->NotifyGattServiceAdded(gatt_service); | 258 adapter_->NotifyGattServiceAdded(gatt_service); |
259 } | 259 } |
260 } | 260 } |
261 // TODO(http://crbug.com/609064): Services are fully discovered once all | 261 for (GattServiceMap::const_iterator it = gatt_services_.begin(); |
262 // characteristics have been found. | 262 it != gatt_services_.end(); ++it) { |
263 SetGattServicesDiscoveryComplete(true); | 263 device::BluetoothRemoteGattService* gatt_service = it->second; |
264 adapter_->NotifyGattServicesDiscovered(this); | 264 device::BluetoothRemoteGattServiceMac* gatt_service_mac = |
| 265 static_cast<BluetoothRemoteGattServiceMac*>(gatt_service); |
| 266 gatt_service_mac->DiscoverCharacteristics(); |
| 267 } |
| 268 } |
| 269 |
| 270 void BluetoothLowEnergyDeviceMac::DidDiscoverCharacteristics( |
| 271 CBService* cb_service, |
| 272 NSError* error) { |
| 273 if (error) { |
| 274 // TODO(http://crbug.com/609320): Need to pass the error. |
| 275 // TODO(http://crbug.com/609844): Decide what to do if discover failed |
| 276 VLOG(1) << "Can't discover characteristics: " |
| 277 << error.localizedDescription.UTF8String << " (" << error.domain |
| 278 << ": " << error.code << ")"; |
| 279 return; |
| 280 } |
| 281 BluetoothRemoteGattServiceMac* gatt_service = |
| 282 GetBluetoothRemoteGattService(cb_service); |
| 283 DCHECK(gatt_service); |
| 284 gatt_service->DidDiscoverCharacteristics(); |
| 285 |
| 286 // Notify when all services have been discovered. |
| 287 bool discovery_complete = |
| 288 std::find_if_not( |
| 289 gatt_services_.begin(), gatt_services_.end(), |
| 290 [](std::pair<std::string, BluetoothRemoteGattService*> pair) { |
| 291 BluetoothRemoteGattService* gatt_service = pair.second; |
| 292 return static_cast<BluetoothRemoteGattServiceMac*>(gatt_service) |
| 293 ->IsDiscoveryComplete(); |
| 294 }) == gatt_services_.end(); |
| 295 if (discovery_complete) { |
| 296 SetGattServicesDiscoveryComplete(true); |
| 297 adapter_->NotifyGattServicesDiscovered(this); |
| 298 } |
265 } | 299 } |
266 | 300 |
267 void BluetoothLowEnergyDeviceMac::DidModifyServices( | 301 void BluetoothLowEnergyDeviceMac::DidModifyServices( |
268 NSArray* invalidatedServices) { | 302 NSArray* invalidatedServices) { |
269 for (CBService* cb_service in invalidatedServices) { | 303 for (CBService* cb_service in invalidatedServices) { |
270 BluetoothRemoteGattServiceMac* gatt_service = | 304 BluetoothRemoteGattServiceMac* gatt_service = |
271 GetBluetoothRemoteGattService(cb_service); | 305 GetBluetoothRemoteGattService(cb_service); |
272 DCHECK(gatt_service); | 306 DCHECK(gatt_service); |
273 std::unique_ptr<BluetoothRemoteGattService> scoped_service = | 307 std::unique_ptr<BluetoothRemoteGattService> scoped_service = |
274 gatt_services_.take_and_erase(gatt_service->GetIdentifier()); | 308 gatt_services_.take_and_erase(gatt_service->GetIdentifier()); |
(...skipping 53 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
328 GattServiceMap gatt_services_swapped; | 362 GattServiceMap gatt_services_swapped; |
329 gatt_services_swapped.swap(gatt_services_); | 363 gatt_services_swapped.swap(gatt_services_); |
330 gatt_services_swapped.clear(); | 364 gatt_services_swapped.clear(); |
331 if (create_gatt_connection_error_callbacks_.empty()) { | 365 if (create_gatt_connection_error_callbacks_.empty()) { |
332 // TODO(http://crbug.com/585897): Need to pass the error. | 366 // TODO(http://crbug.com/585897): Need to pass the error. |
333 DidDisconnectGatt(); | 367 DidDisconnectGatt(); |
334 } else { | 368 } else { |
335 DidFailToConnectGatt(error_code); | 369 DidFailToConnectGatt(error_code); |
336 } | 370 } |
337 } | 371 } |
OLD | NEW |