| 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 "components/proximity_auth/ble/bluetooth_low_energy_connection.h" | 5 #include "components/proximity_auth/ble/bluetooth_low_energy_connection.h" |
| 6 | 6 |
| 7 #include <utility> | 7 #include <utility> |
| 8 | 8 |
| 9 #include "base/bind.h" | 9 #include "base/bind.h" |
| 10 #include "base/location.h" | 10 #include "base/location.h" |
| 11 #include "base/memory/ref_counted.h" | 11 #include "base/memory/ref_counted.h" |
| 12 #include "base/memory/weak_ptr.h" | 12 #include "base/memory/weak_ptr.h" |
| 13 #include "base/task_runner.h" | 13 #include "base/task_runner.h" |
| 14 #include "base/thread_task_runner_handle.h" | 14 #include "base/thread_task_runner_handle.h" |
| 15 #include "base/time/time.h" | 15 #include "base/time/time.h" |
| 16 #include "components/proximity_auth/ble/bluetooth_low_energy_characteristics_fin
der.h" | 16 #include "components/proximity_auth/ble/bluetooth_low_energy_characteristics_fin
der.h" |
| 17 #include "components/proximity_auth/ble/fake_wire_message.h" | 17 #include "components/proximity_auth/ble/fake_wire_message.h" |
| 18 #include "components/proximity_auth/bluetooth_throttler.h" | 18 #include "components/proximity_auth/bluetooth_throttler.h" |
| 19 #include "components/proximity_auth/connection_finder.h" | 19 #include "components/proximity_auth/connection_finder.h" |
| 20 #include "components/proximity_auth/logging/logging.h" | 20 #include "components/proximity_auth/logging/logging.h" |
| 21 #include "components/proximity_auth/wire_message.h" | 21 #include "components/proximity_auth/wire_message.h" |
| 22 #include "device/bluetooth/bluetooth_adapter.h" | 22 #include "device/bluetooth/bluetooth_adapter.h" |
| 23 #include "device/bluetooth/bluetooth_device.h" | 23 #include "device/bluetooth/bluetooth_device.h" |
| 24 #include "device/bluetooth/bluetooth_gatt_characteristic.h" | |
| 25 #include "device/bluetooth/bluetooth_gatt_connection.h" | 24 #include "device/bluetooth/bluetooth_gatt_connection.h" |
| 26 #include "device/bluetooth/bluetooth_gatt_notify_session.h" | 25 #include "device/bluetooth/bluetooth_gatt_notify_session.h" |
| 26 #include "device/bluetooth/bluetooth_remote_gatt_characteristic.h" |
| 27 #include "device/bluetooth/bluetooth_uuid.h" | 27 #include "device/bluetooth/bluetooth_uuid.h" |
| 28 | 28 |
| 29 using device::BluetoothAdapter; | 29 using device::BluetoothAdapter; |
| 30 using device::BluetoothDevice; | 30 using device::BluetoothDevice; |
| 31 using device::BluetoothGattConnection; | 31 using device::BluetoothGattConnection; |
| 32 using device::BluetoothGattService; | 32 using device::BluetoothRemoteGattService; |
| 33 using device::BluetoothGattCharacteristic; | 33 using device::BluetoothRemoteGattCharacteristic; |
| 34 using device::BluetoothGattNotifySession; | 34 using device::BluetoothGattNotifySession; |
| 35 using device::BluetoothUUID; | 35 using device::BluetoothUUID; |
| 36 | 36 |
| 37 namespace proximity_auth { | 37 namespace proximity_auth { |
| 38 namespace { | 38 namespace { |
| 39 | 39 |
| 40 // The UUID of the characteristic used to send data to the peripheral. | 40 // The UUID of the characteristic used to send data to the peripheral. |
| 41 const char kToPeripheralCharUUID[] = "977c6674-1239-4e72-993b-502369b8bb5a"; | 41 const char kToPeripheralCharUUID[] = "977c6674-1239-4e72-993b-502369b8bb5a"; |
| 42 | 42 |
| 43 // The UUID of the characteristic used to receive data from the peripheral. | 43 // The UUID of the characteristic used to receive data from the peripheral. |
| (...skipping 196 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 240 if (sub_status_ == SubStatus::DISCONNECTED || | 240 if (sub_status_ == SubStatus::DISCONNECTED || |
| 241 device->GetAddress() != GetDeviceAddress()) | 241 device->GetAddress() != GetDeviceAddress()) |
| 242 return; | 242 return; |
| 243 | 243 |
| 244 PA_LOG(INFO) << "Device removed " << GetDeviceAddress(); | 244 PA_LOG(INFO) << "Device removed " << GetDeviceAddress(); |
| 245 Disconnect(); | 245 Disconnect(); |
| 246 } | 246 } |
| 247 | 247 |
| 248 void BluetoothLowEnergyConnection::GattCharacteristicValueChanged( | 248 void BluetoothLowEnergyConnection::GattCharacteristicValueChanged( |
| 249 BluetoothAdapter* adapter, | 249 BluetoothAdapter* adapter, |
| 250 BluetoothGattCharacteristic* characteristic, | 250 BluetoothRemoteGattCharacteristic* characteristic, |
| 251 const std::vector<uint8_t>& value) { | 251 const std::vector<uint8_t>& value) { |
| 252 DCHECK_EQ(adapter, adapter_.get()); | 252 DCHECK_EQ(adapter, adapter_.get()); |
| 253 if (sub_status() != SubStatus::WAITING_RESPONSE_SIGNAL && | 253 if (sub_status() != SubStatus::WAITING_RESPONSE_SIGNAL && |
| 254 sub_status() != SubStatus::CONNECTED) | 254 sub_status() != SubStatus::CONNECTED) |
| 255 return; | 255 return; |
| 256 | 256 |
| 257 PA_LOG(INFO) << "Characteristic value changed: " | 257 PA_LOG(INFO) << "Characteristic value changed: " |
| 258 << characteristic->GetUUID().canonical_value(); | 258 << characteristic->GetUUID().canonical_value(); |
| 259 | 259 |
| 260 if (characteristic->GetIdentifier() == from_peripheral_char_.id) { | 260 if (characteristic->GetIdentifier() == from_peripheral_char_.id) { |
| (...skipping 134 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 395 : "") | 395 : "") |
| 396 << (from_peripheral_char.id.empty() | 396 << (from_peripheral_char.id.empty() |
| 397 ? ", " + from_peripheral_char.uuid.canonical_value() | 397 ? ", " + from_peripheral_char.uuid.canonical_value() |
| 398 : "") << " not found."; | 398 : "") << " not found."; |
| 399 | 399 |
| 400 Disconnect(); | 400 Disconnect(); |
| 401 } | 401 } |
| 402 | 402 |
| 403 void BluetoothLowEnergyConnection::StartNotifySession() { | 403 void BluetoothLowEnergyConnection::StartNotifySession() { |
| 404 if (sub_status() == SubStatus::CHARACTERISTICS_FOUND) { | 404 if (sub_status() == SubStatus::CHARACTERISTICS_FOUND) { |
| 405 BluetoothGattCharacteristic* characteristic = | 405 BluetoothRemoteGattCharacteristic* characteristic = |
| 406 GetGattCharacteristic(from_peripheral_char_.id); | 406 GetGattCharacteristic(from_peripheral_char_.id); |
| 407 DCHECK(characteristic); | 407 DCHECK(characteristic); |
| 408 | 408 |
| 409 // This is a workaround for crbug.com/507325. If |characteristic| is already | 409 // This is a workaround for crbug.com/507325. If |characteristic| is already |
| 410 // notifying |characteristic->StartNotifySession()| will fail with | 410 // notifying |characteristic->StartNotifySession()| will fail with |
| 411 // GATT_ERROR_FAILED. | 411 // GATT_ERROR_FAILED. |
| 412 if (characteristic->IsNotifying()) { | 412 if (characteristic->IsNotifying()) { |
| 413 PA_LOG(INFO) << characteristic->GetUUID().canonical_value() | 413 PA_LOG(INFO) << characteristic->GetUUID().canonical_value() |
| 414 << " already notifying."; | 414 << " already notifying."; |
| 415 SetSubStatus(SubStatus::NOTIFY_SESSION_READY); | 415 SetSubStatus(SubStatus::NOTIFY_SESSION_READY); |
| 416 SendInviteToConnectSignal(); | 416 SendInviteToConnectSignal(); |
| 417 return; | 417 return; |
| 418 } | 418 } |
| 419 | 419 |
| 420 SetSubStatus(SubStatus::WAITING_NOTIFY_SESSION); | 420 SetSubStatus(SubStatus::WAITING_NOTIFY_SESSION); |
| 421 characteristic->StartNotifySession( | 421 characteristic->StartNotifySession( |
| 422 base::Bind(&BluetoothLowEnergyConnection::OnNotifySessionStarted, | 422 base::Bind(&BluetoothLowEnergyConnection::OnNotifySessionStarted, |
| 423 weak_ptr_factory_.GetWeakPtr()), | 423 weak_ptr_factory_.GetWeakPtr()), |
| 424 base::Bind(&BluetoothLowEnergyConnection::OnNotifySessionError, | 424 base::Bind(&BluetoothLowEnergyConnection::OnNotifySessionError, |
| 425 weak_ptr_factory_.GetWeakPtr())); | 425 weak_ptr_factory_.GetWeakPtr())); |
| 426 } | 426 } |
| 427 } | 427 } |
| 428 | 428 |
| 429 void BluetoothLowEnergyConnection::OnNotifySessionError( | 429 void BluetoothLowEnergyConnection::OnNotifySessionError( |
| 430 BluetoothGattService::GattErrorCode error) { | 430 BluetoothRemoteGattService::GattErrorCode error) { |
| 431 DCHECK(sub_status() == SubStatus::WAITING_NOTIFY_SESSION); | 431 DCHECK(sub_status() == SubStatus::WAITING_NOTIFY_SESSION); |
| 432 PA_LOG(WARNING) << "Error starting notification session: " << error; | 432 PA_LOG(WARNING) << "Error starting notification session: " << error; |
| 433 Disconnect(); | 433 Disconnect(); |
| 434 } | 434 } |
| 435 | 435 |
| 436 void BluetoothLowEnergyConnection::OnNotifySessionStarted( | 436 void BluetoothLowEnergyConnection::OnNotifySessionStarted( |
| 437 scoped_ptr<BluetoothGattNotifySession> notify_session) { | 437 scoped_ptr<BluetoothGattNotifySession> notify_session) { |
| 438 DCHECK(sub_status() == SubStatus::WAITING_NOTIFY_SESSION); | 438 DCHECK(sub_status() == SubStatus::WAITING_NOTIFY_SESSION); |
| 439 PA_LOG(INFO) << "Notification session started " | 439 PA_LOG(INFO) << "Notification session started " |
| 440 << notify_session->GetCharacteristicIdentifier(); | 440 << notify_session->GetCharacteristicIdentifier(); |
| (...skipping 26 matching lines...) Expand all Loading... |
| 467 } | 467 } |
| 468 } | 468 } |
| 469 | 469 |
| 470 void BluetoothLowEnergyConnection::WriteRemoteCharacteristic( | 470 void BluetoothLowEnergyConnection::WriteRemoteCharacteristic( |
| 471 WriteRequest request) { | 471 WriteRequest request) { |
| 472 write_requests_queue_.push(request); | 472 write_requests_queue_.push(request); |
| 473 ProcessNextWriteRequest(); | 473 ProcessNextWriteRequest(); |
| 474 } | 474 } |
| 475 | 475 |
| 476 void BluetoothLowEnergyConnection::ProcessNextWriteRequest() { | 476 void BluetoothLowEnergyConnection::ProcessNextWriteRequest() { |
| 477 BluetoothGattCharacteristic* characteristic = | 477 BluetoothRemoteGattCharacteristic* characteristic = |
| 478 GetGattCharacteristic(to_peripheral_char_.id); | 478 GetGattCharacteristic(to_peripheral_char_.id); |
| 479 if (!write_requests_queue_.empty() && !write_remote_characteristic_pending_ && | 479 if (!write_requests_queue_.empty() && !write_remote_characteristic_pending_ && |
| 480 characteristic) { | 480 characteristic) { |
| 481 write_remote_characteristic_pending_ = true; | 481 write_remote_characteristic_pending_ = true; |
| 482 WriteRequest next_request = write_requests_queue_.front(); | 482 WriteRequest next_request = write_requests_queue_.front(); |
| 483 PA_LOG(INFO) << "Writing characteristic..."; | 483 PA_LOG(INFO) << "Writing characteristic..."; |
| 484 characteristic->WriteRemoteCharacteristic( | 484 characteristic->WriteRemoteCharacteristic( |
| 485 next_request.value, | 485 next_request.value, |
| 486 base::Bind(&BluetoothLowEnergyConnection::OnRemoteCharacteristicWritten, | 486 base::Bind(&BluetoothLowEnergyConnection::OnRemoteCharacteristicWritten, |
| 487 weak_ptr_factory_.GetWeakPtr(), | 487 weak_ptr_factory_.GetWeakPtr(), |
| (...skipping 14 matching lines...) Expand all Loading... |
| 502 OnDidSendMessage(WireMessage(std::string(), std::string()), true); | 502 OnDidSendMessage(WireMessage(std::string(), std::string()), true); |
| 503 | 503 |
| 504 // Removes the top of queue (already processed) and process the next request. | 504 // Removes the top of queue (already processed) and process the next request. |
| 505 DCHECK(!write_requests_queue_.empty()); | 505 DCHECK(!write_requests_queue_.empty()); |
| 506 write_requests_queue_.pop(); | 506 write_requests_queue_.pop(); |
| 507 ProcessNextWriteRequest(); | 507 ProcessNextWriteRequest(); |
| 508 } | 508 } |
| 509 | 509 |
| 510 void BluetoothLowEnergyConnection::OnWriteRemoteCharacteristicError( | 510 void BluetoothLowEnergyConnection::OnWriteRemoteCharacteristicError( |
| 511 bool run_did_send_message_callback, | 511 bool run_did_send_message_callback, |
| 512 BluetoothGattService::GattErrorCode error) { | 512 BluetoothRemoteGattService::GattErrorCode error) { |
| 513 PA_LOG(WARNING) << "Error " << error << " writing characteristic: " | 513 PA_LOG(WARNING) << "Error " << error << " writing characteristic: " |
| 514 << to_peripheral_char_.uuid.canonical_value(); | 514 << to_peripheral_char_.uuid.canonical_value(); |
| 515 write_remote_characteristic_pending_ = false; | 515 write_remote_characteristic_pending_ = false; |
| 516 // TODO(sacomoto): Actually pass the current message to the observer. | 516 // TODO(sacomoto): Actually pass the current message to the observer. |
| 517 if (run_did_send_message_callback) | 517 if (run_did_send_message_callback) |
| 518 OnDidSendMessage(WireMessage(std::string(), std::string()), false); | 518 OnDidSendMessage(WireMessage(std::string(), std::string()), false); |
| 519 | 519 |
| 520 // Increases the number of failed attempts and retry. | 520 // Increases the number of failed attempts and retry. |
| 521 DCHECK(!write_requests_queue_.empty()); | 521 DCHECK(!write_requests_queue_.empty()); |
| 522 if (++write_requests_queue_.front().number_of_failed_attempts >= | 522 if (++write_requests_queue_.front().number_of_failed_attempts >= |
| (...skipping 37 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 560 // crbug.com/497841). | 560 // crbug.com/497841). |
| 561 std::vector<BluetoothDevice*> devices = adapter_->GetDevices(); | 561 std::vector<BluetoothDevice*> devices = adapter_->GetDevices(); |
| 562 for (const auto& device : devices) { | 562 for (const auto& device : devices) { |
| 563 if (device->GetAddress() == GetDeviceAddress()) | 563 if (device->GetAddress() == GetDeviceAddress()) |
| 564 return device; | 564 return device; |
| 565 } | 565 } |
| 566 | 566 |
| 567 return nullptr; | 567 return nullptr; |
| 568 } | 568 } |
| 569 | 569 |
| 570 BluetoothGattService* BluetoothLowEnergyConnection::GetRemoteService() { | 570 BluetoothRemoteGattService* BluetoothLowEnergyConnection::GetRemoteService() { |
| 571 BluetoothDevice* remote_device = GetRemoteDevice(); | 571 BluetoothDevice* remote_device = GetRemoteDevice(); |
| 572 if (!remote_device) { | 572 if (!remote_device) { |
| 573 PA_LOG(WARNING) << "Remote device not found."; | 573 PA_LOG(WARNING) << "Remote device not found."; |
| 574 return NULL; | 574 return NULL; |
| 575 } | 575 } |
| 576 if (remote_service_.id.empty()) { | 576 if (remote_service_.id.empty()) { |
| 577 std::vector<BluetoothGattService*> services = | 577 std::vector<BluetoothRemoteGattService*> services = |
| 578 remote_device->GetGattServices(); | 578 remote_device->GetGattServices(); |
| 579 for (const auto& service : services) | 579 for (const auto& service : services) |
| 580 if (service->GetUUID() == remote_service_.uuid) { | 580 if (service->GetUUID() == remote_service_.uuid) { |
| 581 remote_service_.id = service->GetIdentifier(); | 581 remote_service_.id = service->GetIdentifier(); |
| 582 break; | 582 break; |
| 583 } | 583 } |
| 584 } | 584 } |
| 585 return remote_device->GetGattService(remote_service_.id); | 585 return remote_device->GetGattService(remote_service_.id); |
| 586 } | 586 } |
| 587 | 587 |
| 588 BluetoothGattCharacteristic* | 588 BluetoothRemoteGattCharacteristic* |
| 589 BluetoothLowEnergyConnection::GetGattCharacteristic( | 589 BluetoothLowEnergyConnection::GetGattCharacteristic( |
| 590 const std::string& gatt_characteristic) { | 590 const std::string& gatt_characteristic) { |
| 591 BluetoothGattService* remote_service = GetRemoteService(); | 591 BluetoothRemoteGattService* remote_service = GetRemoteService(); |
| 592 if (!remote_service) { | 592 if (!remote_service) { |
| 593 PA_LOG(WARNING) << "Remote service not found."; | 593 PA_LOG(WARNING) << "Remote service not found."; |
| 594 return NULL; | 594 return NULL; |
| 595 } | 595 } |
| 596 return remote_service->GetCharacteristic(gatt_characteristic); | 596 return remote_service->GetCharacteristic(gatt_characteristic); |
| 597 } | 597 } |
| 598 | 598 |
| 599 // TODO(sacomoto): make this robust to byte ordering in both sides of the | 599 // TODO(sacomoto): make this robust to byte ordering in both sides of the |
| 600 // SmartLock BLE socket. | 600 // SmartLock BLE socket. |
| 601 uint32_t BluetoothLowEnergyConnection::ToUint32( | 601 uint32_t BluetoothLowEnergyConnection::ToUint32( |
| 602 const std::vector<uint8_t>& bytes) { | 602 const std::vector<uint8_t>& bytes) { |
| 603 return bytes[0] | (bytes[1] << 8) | (bytes[2] << 16) | (bytes[3] << 24); | 603 return bytes[0] | (bytes[1] << 8) | (bytes[2] << 16) | (bytes[3] << 24); |
| 604 } | 604 } |
| 605 | 605 |
| 606 // TODO(sacomoto): make this robust to byte ordering in both sides of the | 606 // TODO(sacomoto): make this robust to byte ordering in both sides of the |
| 607 // SmartLock BLE socket. | 607 // SmartLock BLE socket. |
| 608 const std::vector<uint8_t> BluetoothLowEnergyConnection::ToByteVector( | 608 const std::vector<uint8_t> BluetoothLowEnergyConnection::ToByteVector( |
| 609 const uint32_t value) { | 609 const uint32_t value) { |
| 610 std::vector<uint8_t> bytes(4, 0); | 610 std::vector<uint8_t> bytes(4, 0); |
| 611 bytes[0] = static_cast<uint8_t>(value); | 611 bytes[0] = static_cast<uint8_t>(value); |
| 612 bytes[1] = static_cast<uint8_t>(value >> 8); | 612 bytes[1] = static_cast<uint8_t>(value >> 8); |
| 613 bytes[2] = static_cast<uint8_t>(value >> 16); | 613 bytes[2] = static_cast<uint8_t>(value >> 16); |
| 614 bytes[3] = static_cast<uint8_t>(value >> 24); | 614 bytes[3] = static_cast<uint8_t>(value >> 24); |
| 615 return bytes; | 615 return bytes; |
| 616 } | 616 } |
| 617 | 617 |
| 618 } // namespace proximity_auth | 618 } // namespace proximity_auth |
| OLD | NEW |