| Index: components/proximity_auth/ble/bluetooth_low_energy_weave_client_connection.cc
|
| diff --git a/components/proximity_auth/ble/bluetooth_low_energy_weave_client_connection.cc b/components/proximity_auth/ble/bluetooth_low_energy_weave_client_connection.cc
|
| deleted file mode 100644
|
| index 3fde2722609660df66b3ee9544bea3494e224ec2..0000000000000000000000000000000000000000
|
| --- a/components/proximity_auth/ble/bluetooth_low_energy_weave_client_connection.cc
|
| +++ /dev/null
|
| @@ -1,639 +0,0 @@
|
| -// Copyright 2016 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 "components/proximity_auth/ble/bluetooth_low_energy_weave_client_connection.h"
|
| -
|
| -#include <utility>
|
| -
|
| -#include "base/bind.h"
|
| -#include "base/location.h"
|
| -#include "base/task_runner.h"
|
| -#include "base/threading/thread_task_runner_handle.h"
|
| -#include "components/proximity_auth/bluetooth_throttler.h"
|
| -#include "components/proximity_auth/connection_finder.h"
|
| -#include "components/proximity_auth/logging/logging.h"
|
| -#include "components/proximity_auth/wire_message.h"
|
| -#include "device/bluetooth/bluetooth_gatt_connection.h"
|
| -
|
| -using device::BluetoothAdapter;
|
| -using device::BluetoothDevice;
|
| -using device::BluetoothGattConnection;
|
| -using device::BluetoothRemoteGattService;
|
| -using device::BluetoothRemoteGattCharacteristic;
|
| -using device::BluetoothGattNotifySession;
|
| -using device::BluetoothUUID;
|
| -
|
| -namespace proximity_auth {
|
| -namespace weave {
|
| -namespace {
|
| -
|
| -typedef BluetoothLowEnergyWeavePacketReceiver::State ReceiverState;
|
| -
|
| -// The UUID of the TX characteristic used to transmit data to the server.
|
| -const char kTXCharacteristicUUID[] = "00000100-0004-1000-8000-001A11000101";
|
| -
|
| -// The UUID of the RX characteristic used to receive data from the server.
|
| -const char kRXCharacteristicUUID[] = "00000100-0004-1000-8000-001A11000102";
|
| -
|
| -} // namespace
|
| -
|
| -BluetoothLowEnergyWeaveClientConnection::
|
| - BluetoothLowEnergyWeaveClientConnection(
|
| - const RemoteDevice& device,
|
| - scoped_refptr<device::BluetoothAdapter> adapter,
|
| - const BluetoothUUID remote_service_uuid,
|
| - BluetoothThrottler* bluetooth_throttler,
|
| - int max_number_of_write_attempts)
|
| - : Connection(device),
|
| - adapter_(adapter),
|
| - remote_service_({remote_service_uuid, ""}),
|
| - packet_generator_(
|
| - BluetoothLowEnergyWeavePacketGenerator::Factory::NewInstance()),
|
| - packet_receiver_(
|
| - BluetoothLowEnergyWeavePacketReceiver::Factory::NewInstance(
|
| - BluetoothLowEnergyWeavePacketReceiver::ReceiverType::CLIENT)),
|
| - tx_characteristic_({BluetoothUUID(kTXCharacteristicUUID), ""}),
|
| - rx_characteristic_({BluetoothUUID(kRXCharacteristicUUID), ""}),
|
| - bluetooth_throttler_(bluetooth_throttler),
|
| - task_runner_(base::ThreadTaskRunnerHandle::Get()),
|
| - sub_status_(SubStatus::DISCONNECTED),
|
| - write_remote_characteristic_pending_(false),
|
| - max_number_of_write_attempts_(max_number_of_write_attempts),
|
| - weak_ptr_factory_(this) {
|
| - DCHECK(adapter_);
|
| - DCHECK(adapter_->IsInitialized());
|
| -
|
| - adapter_->AddObserver(this);
|
| -}
|
| -
|
| -BluetoothLowEnergyWeaveClientConnection::
|
| - ~BluetoothLowEnergyWeaveClientConnection() {
|
| - // Since the destructor can be called at anytime, it would be unwise to send a
|
| - // connection close since we might not be connected at all.
|
| - DestroyConnection();
|
| -
|
| - if (adapter_) {
|
| - adapter_->RemoveObserver(this);
|
| - adapter_ = NULL;
|
| - }
|
| -}
|
| -
|
| -void BluetoothLowEnergyWeaveClientConnection::Connect() {
|
| - DCHECK(sub_status() == SubStatus::DISCONNECTED);
|
| -
|
| - SetSubStatus(SubStatus::WAITING_GATT_CONNECTION);
|
| - base::TimeDelta throttler_delay = bluetooth_throttler_->GetDelay();
|
| - PA_LOG(INFO) << "Connecting in " << throttler_delay;
|
| -
|
| - start_time_ = base::TimeTicks::Now();
|
| -
|
| - // If necessary, wait to create a new GATT connection.
|
| - //
|
| - // Avoid creating a new GATT connection immediately after a given device was
|
| - // disconnected. This is a workaround for crbug.com/508919.
|
| - if (!throttler_delay.is_zero()) {
|
| - task_runner_->PostDelayedTask(
|
| - FROM_HERE,
|
| - base::Bind(
|
| - &BluetoothLowEnergyWeaveClientConnection::CreateGattConnection,
|
| - weak_ptr_factory_.GetWeakPtr()),
|
| - throttler_delay);
|
| - return;
|
| - }
|
| -
|
| - CreateGattConnection();
|
| -}
|
| -
|
| -void BluetoothLowEnergyWeaveClientConnection::CreateGattConnection() {
|
| - DCHECK(sub_status() == SubStatus::WAITING_GATT_CONNECTION);
|
| -
|
| - BluetoothDevice* remote_device = GetRemoteDevice();
|
| - if (remote_device) {
|
| - PA_LOG(INFO) << "Creating GATT connection with "
|
| - << remote_device->GetAddress();
|
| -
|
| - remote_device->CreateGattConnection(
|
| - base::Bind(
|
| - &BluetoothLowEnergyWeaveClientConnection::OnGattConnectionCreated,
|
| - weak_ptr_factory_.GetWeakPtr()),
|
| - base::Bind(&BluetoothLowEnergyWeaveClientConnection::
|
| - OnCreateGattConnectionError,
|
| - weak_ptr_factory_.GetWeakPtr()));
|
| - } else {
|
| - SetSubStatus(SubStatus::DISCONNECTED);
|
| - }
|
| -}
|
| -
|
| -void BluetoothLowEnergyWeaveClientConnection::Disconnect() {
|
| - if (sub_status_ == SubStatus::CONNECTED) {
|
| - // Friendly disconnect by sending a connection close and then destroy the
|
| - // the connection once the connection close has been sent.
|
| - WriteRequest request(packet_generator_->CreateConnectionClose(
|
| - ReasonForClose::CLOSE_WITHOUT_ERROR),
|
| - WriteRequestType::CONNECTION_CLOSE);
|
| - WriteRemoteCharacteristic(request);
|
| - } else {
|
| - DestroyConnection();
|
| - }
|
| -}
|
| -
|
| -void BluetoothLowEnergyWeaveClientConnection::DestroyConnection() {
|
| - if (sub_status() != SubStatus::DISCONNECTED) {
|
| - weak_ptr_factory_.InvalidateWeakPtrs();
|
| - StopNotifySession();
|
| - characteristic_finder_.reset();
|
| - if (gatt_connection_) {
|
| - PA_LOG(INFO) << "Disconnect from device "
|
| - << gatt_connection_->GetDeviceAddress();
|
| -
|
| - // Destroying BluetoothGattConnection also disconnects it.
|
| - gatt_connection_.reset();
|
| - }
|
| -
|
| - // Only transition to the DISCONNECTED state after perfoming all necessary
|
| - // operations. Otherwise, it'll trigger observers that can pontentially
|
| - // destroy the current instance (causing a crash).
|
| - SetSubStatus(SubStatus::DISCONNECTED);
|
| - }
|
| -}
|
| -
|
| -void BluetoothLowEnergyWeaveClientConnection::SetSubStatus(
|
| - SubStatus new_sub_status) {
|
| - sub_status_ = new_sub_status;
|
| -
|
| - // Sets the status of parent class proximity_auth::Connection accordingly.
|
| - if (new_sub_status == SubStatus::CONNECTED) {
|
| - SetStatus(Status::CONNECTED);
|
| - } else if (new_sub_status == SubStatus::DISCONNECTED) {
|
| - SetStatus(Status::DISCONNECTED);
|
| - } else {
|
| - SetStatus(Status::IN_PROGRESS);
|
| - }
|
| -}
|
| -
|
| -void BluetoothLowEnergyWeaveClientConnection::SetTaskRunnerForTesting(
|
| - scoped_refptr<base::TaskRunner> task_runner) {
|
| - task_runner_ = task_runner;
|
| -}
|
| -
|
| -void BluetoothLowEnergyWeaveClientConnection::SendMessageImpl(
|
| - std::unique_ptr<WireMessage> message) {
|
| - PA_LOG(INFO) << "Sending message " << message->Serialize();
|
| - std::string serialized_msg = message->Serialize();
|
| -
|
| - std::vector<Packet> packets =
|
| - packet_generator_->EncodeDataMessage(serialized_msg);
|
| -
|
| - std::shared_ptr<WireMessage> request_message(message.release());
|
| -
|
| - for (uint32_t i = 0; i < packets.size(); ++i) {
|
| - WriteRequestType request_type = (i == packets.size() - 1)
|
| - ? WriteRequestType::MESSAGE_COMPLETE
|
| - : WriteRequestType::REGULAR;
|
| - WriteRequest request(packets[i], request_type, request_message);
|
| - WriteRemoteCharacteristic(request);
|
| - }
|
| -}
|
| -
|
| -// Changes in the GATT connection with the remote device should be observed
|
| -// here. If the GATT connection is dropped, we should call DestroyConnection()
|
| -// anyway, so the object can notify its observers.
|
| -void BluetoothLowEnergyWeaveClientConnection::DeviceChanged(
|
| - BluetoothAdapter* adapter,
|
| - BluetoothDevice* device) {
|
| - DCHECK(device);
|
| - if (sub_status() == SubStatus::DISCONNECTED ||
|
| - device->GetAddress() != GetDeviceAddress())
|
| - return;
|
| -
|
| - if (sub_status() != SubStatus::WAITING_GATT_CONNECTION &&
|
| - !device->IsConnected()) {
|
| - PA_LOG(INFO) << "GATT connection dropped " << GetDeviceAddress()
|
| - << "\ndevice connected: " << device->IsConnected()
|
| - << "\ngatt connection: "
|
| - << (gatt_connection_ ? gatt_connection_->IsConnected()
|
| - : false);
|
| - DestroyConnection();
|
| - }
|
| -}
|
| -
|
| -void BluetoothLowEnergyWeaveClientConnection::DeviceRemoved(
|
| - BluetoothAdapter* adapter,
|
| - BluetoothDevice* device) {
|
| - DCHECK(device);
|
| - if (sub_status_ == SubStatus::DISCONNECTED ||
|
| - device->GetAddress() != GetDeviceAddress())
|
| - return;
|
| -
|
| - PA_LOG(INFO) << "Device removed " << GetDeviceAddress();
|
| - DestroyConnection();
|
| -}
|
| -
|
| -void BluetoothLowEnergyWeaveClientConnection::GattCharacteristicValueChanged(
|
| - BluetoothAdapter* adapter,
|
| - BluetoothRemoteGattCharacteristic* characteristic,
|
| - const Packet& value) {
|
| - DCHECK_EQ(adapter, adapter_.get());
|
| - if (sub_status() != SubStatus::WAITING_CONNECTION_RESPONSE &&
|
| - sub_status() != SubStatus::CONNECTED)
|
| - return;
|
| -
|
| - PA_LOG(INFO) << "Characteristic value changed: "
|
| - << characteristic->GetUUID().canonical_value();
|
| -
|
| - if (characteristic->GetIdentifier() == rx_characteristic_.id) {
|
| - ReceiverState state = packet_receiver_->ReceivePacket(value);
|
| -
|
| - PA_LOG(INFO) << "\nReceiver State: " << state;
|
| - switch (state) {
|
| - case ReceiverState::DATA_READY:
|
| - OnBytesReceived(packet_receiver_->GetDataMessage());
|
| - break;
|
| - case ReceiverState::CONNECTION_CLOSED:
|
| - PA_LOG(ERROR) << "Connection closed due to: " << GetReasonForClose();
|
| - DestroyConnection();
|
| - break;
|
| - case ReceiverState::ERROR_DETECTED:
|
| - OnPacketReceiverError();
|
| - break;
|
| - case ReceiverState::WAITING:
|
| - // Receiver state should have changed from CONNECTING to WAITING if
|
| - // a proper connection response had been received.
|
| - // The max packet size selected from the connection response will be
|
| - // used to generate future data packets.
|
| - packet_generator_->SetMaxPacketSize(
|
| - packet_receiver_->GetMaxPacketSize());
|
| - DCHECK(sub_status() == SubStatus::WAITING_CONNECTION_RESPONSE);
|
| - CompleteConnection();
|
| - break;
|
| - case ReceiverState::RECEIVING_DATA:
|
| - // Normal in between states, so do nothing.
|
| - break;
|
| - default:
|
| - NOTREACHED();
|
| - }
|
| - }
|
| -}
|
| -
|
| -void BluetoothLowEnergyWeaveClientConnection::CompleteConnection() {
|
| - PA_LOG(INFO) << "Connection completed. Time elapsed: "
|
| - << base::TimeTicks::Now() - start_time_;
|
| - SetSubStatus(SubStatus::CONNECTED);
|
| -}
|
| -
|
| -void BluetoothLowEnergyWeaveClientConnection::OnCreateGattConnectionError(
|
| - device::BluetoothDevice::ConnectErrorCode error_code) {
|
| - DCHECK(sub_status_ == SubStatus::WAITING_GATT_CONNECTION);
|
| - PA_LOG(WARNING) << "Error creating GATT connection to "
|
| - << remote_device().bluetooth_address
|
| - << " error code: " << error_code;
|
| - DestroyConnection();
|
| -}
|
| -
|
| -void BluetoothLowEnergyWeaveClientConnection::OnGattConnectionCreated(
|
| - std::unique_ptr<device::BluetoothGattConnection> gatt_connection) {
|
| - DCHECK(sub_status() == SubStatus::WAITING_GATT_CONNECTION);
|
| - PA_LOG(INFO) << "GATT connection with " << gatt_connection->GetDeviceAddress()
|
| - << " created.";
|
| - PrintTimeElapsed();
|
| -
|
| - // Informing |bluetooth_trottler_| a new connection was established.
|
| - bluetooth_throttler_->OnConnection(this);
|
| -
|
| - gatt_connection_ = std::move(gatt_connection);
|
| - SetSubStatus(SubStatus::WAITING_CHARACTERISTICS);
|
| - characteristic_finder_.reset(CreateCharacteristicsFinder(
|
| - base::Bind(
|
| - &BluetoothLowEnergyWeaveClientConnection::OnCharacteristicsFound,
|
| - weak_ptr_factory_.GetWeakPtr()),
|
| - base::Bind(&BluetoothLowEnergyWeaveClientConnection::
|
| - OnCharacteristicsFinderError,
|
| - weak_ptr_factory_.GetWeakPtr())));
|
| -}
|
| -
|
| -BluetoothLowEnergyCharacteristicsFinder*
|
| -BluetoothLowEnergyWeaveClientConnection::CreateCharacteristicsFinder(
|
| - const BluetoothLowEnergyCharacteristicsFinder::SuccessCallback&
|
| - success_callback,
|
| - const BluetoothLowEnergyCharacteristicsFinder::ErrorCallback&
|
| - error_callback) {
|
| - return new BluetoothLowEnergyCharacteristicsFinder(
|
| - adapter_, GetRemoteDevice(), remote_service_, tx_characteristic_,
|
| - rx_characteristic_, success_callback, error_callback);
|
| -}
|
| -
|
| -void BluetoothLowEnergyWeaveClientConnection::OnCharacteristicsFound(
|
| - const RemoteAttribute& service,
|
| - const RemoteAttribute& tx_characteristic,
|
| - const RemoteAttribute& rx_characteristic) {
|
| - PA_LOG(INFO) << "Remote chacteristics found.";
|
| - PrintTimeElapsed();
|
| -
|
| - DCHECK(sub_status() == SubStatus::WAITING_CHARACTERISTICS);
|
| - remote_service_ = service;
|
| - tx_characteristic_ = tx_characteristic;
|
| - rx_characteristic_ = rx_characteristic;
|
| -
|
| - SetSubStatus(SubStatus::CHARACTERISTICS_FOUND);
|
| - StartNotifySession();
|
| -}
|
| -
|
| -void BluetoothLowEnergyWeaveClientConnection::OnCharacteristicsFinderError(
|
| - const RemoteAttribute& tx_characteristic,
|
| - const RemoteAttribute& rx_characteristic) {
|
| - DCHECK(sub_status() == SubStatus::WAITING_CHARACTERISTICS);
|
| - PA_LOG(WARNING) << "Connection error, missing characteristics for SmartLock "
|
| - "service.\n"
|
| - << (tx_characteristic.id.empty()
|
| - ? tx_characteristic.uuid.canonical_value()
|
| - : "")
|
| - << ", "
|
| - << (rx_characteristic.id.empty()
|
| - ? ", " + rx_characteristic.uuid.canonical_value()
|
| - : "")
|
| - << " not found.";
|
| -
|
| - DestroyConnection();
|
| -}
|
| -
|
| -void BluetoothLowEnergyWeaveClientConnection::StartNotifySession() {
|
| - DCHECK(sub_status() == SubStatus::CHARACTERISTICS_FOUND);
|
| - BluetoothRemoteGattCharacteristic* characteristic =
|
| - GetGattCharacteristic(rx_characteristic_.id);
|
| - CHECK(characteristic);
|
| -
|
| - // This is a workaround for crbug.com/507325. If |characteristic| is already
|
| - // notifying |characteristic->StartNotifySession()| will fail with
|
| - // GATT_ERROR_FAILED.
|
| - if (characteristic->IsNotifying()) {
|
| - PA_LOG(INFO) << characteristic->GetUUID().canonical_value()
|
| - << " already notifying.";
|
| - SetSubStatus(SubStatus::NOTIFY_SESSION_READY);
|
| - SendConnectionRequest();
|
| - return;
|
| - }
|
| -
|
| - SetSubStatus(SubStatus::WAITING_NOTIFY_SESSION);
|
| - characteristic->StartNotifySession(
|
| - base::Bind(
|
| - &BluetoothLowEnergyWeaveClientConnection::OnNotifySessionStarted,
|
| - weak_ptr_factory_.GetWeakPtr()),
|
| - base::Bind(&BluetoothLowEnergyWeaveClientConnection::OnNotifySessionError,
|
| - weak_ptr_factory_.GetWeakPtr()));
|
| -}
|
| -
|
| -void BluetoothLowEnergyWeaveClientConnection::OnNotifySessionStarted(
|
| - std::unique_ptr<BluetoothGattNotifySession> notify_session) {
|
| - DCHECK(sub_status() == SubStatus::WAITING_NOTIFY_SESSION);
|
| - PA_LOG(INFO) << "Notification session started "
|
| - << notify_session->GetCharacteristicIdentifier();
|
| - PrintTimeElapsed();
|
| -
|
| - SetSubStatus(SubStatus::NOTIFY_SESSION_READY);
|
| - notify_session_ = std::move(notify_session);
|
| -
|
| - SendConnectionRequest();
|
| -}
|
| -
|
| -void BluetoothLowEnergyWeaveClientConnection::OnNotifySessionError(
|
| - BluetoothRemoteGattService::GattErrorCode error) {
|
| - DCHECK(sub_status() == SubStatus::WAITING_NOTIFY_SESSION);
|
| - PA_LOG(WARNING) << "Error starting notification session: " << error;
|
| - DestroyConnection();
|
| -}
|
| -
|
| -void BluetoothLowEnergyWeaveClientConnection::StopNotifySession() {
|
| - if (notify_session_) {
|
| - notify_session_->Stop(base::Bind(&base::DoNothing));
|
| - notify_session_.reset();
|
| - }
|
| -}
|
| -
|
| -void BluetoothLowEnergyWeaveClientConnection::SendConnectionRequest() {
|
| - if (sub_status() == SubStatus::NOTIFY_SESSION_READY) {
|
| - PA_LOG(INFO) << "Sending connection request to the server";
|
| - SetSubStatus(SubStatus::WAITING_CONNECTION_RESPONSE);
|
| -
|
| - WriteRequest write_request(packet_generator_->CreateConnectionRequest(),
|
| - WriteRequestType::CONNECTION_REQUEST);
|
| -
|
| - WriteRemoteCharacteristic(write_request);
|
| - }
|
| -}
|
| -
|
| -void BluetoothLowEnergyWeaveClientConnection::WriteRemoteCharacteristic(
|
| - const WriteRequest& request) {
|
| - write_requests_queue_.push(request);
|
| - PA_LOG(ERROR) << "you got " << request.message.get();
|
| - ProcessNextWriteRequest();
|
| -}
|
| -
|
| -void BluetoothLowEnergyWeaveClientConnection::ProcessNextWriteRequest() {
|
| - BluetoothRemoteGattCharacteristic* characteristic =
|
| - GetGattCharacteristic(tx_characteristic_.id);
|
| - if (!write_requests_queue_.empty() && !write_remote_characteristic_pending_ &&
|
| - characteristic) {
|
| - write_remote_characteristic_pending_ = true;
|
| - const WriteRequest& next_request = write_requests_queue_.front();
|
| -
|
| - PA_LOG(INFO) << "Writing to characteristic " << next_request.value.size()
|
| - << " bytes";
|
| - characteristic->WriteRemoteCharacteristic(
|
| - next_request.value,
|
| - base::Bind(&BluetoothLowEnergyWeaveClientConnection::
|
| - OnRemoteCharacteristicWritten,
|
| - weak_ptr_factory_.GetWeakPtr()),
|
| - base::Bind(&BluetoothLowEnergyWeaveClientConnection::
|
| - OnWriteRemoteCharacteristicError,
|
| - weak_ptr_factory_.GetWeakPtr()));
|
| - }
|
| -}
|
| -
|
| -void BluetoothLowEnergyWeaveClientConnection::OnRemoteCharacteristicWritten() {
|
| - PA_LOG(INFO) << "Characteristic written.";
|
| -
|
| - DCHECK(!write_requests_queue_.empty());
|
| -
|
| - const WriteRequest& request = write_requests_queue_.front();
|
| -
|
| - switch (request.request_type) {
|
| - case WriteRequestType::REGULAR:
|
| - case WriteRequestType::CONNECTION_REQUEST:
|
| - break;
|
| - case WriteRequestType::MESSAGE_COMPLETE:
|
| - OnDidSendMessage(*request.message, true);
|
| - break;
|
| - case WriteRequestType::CONNECTION_CLOSE:
|
| - DestroyConnection();
|
| - break;
|
| - default:
|
| - NOTREACHED();
|
| - }
|
| -
|
| - // Removes the top of queue (already processed) and process the next request.
|
| - write_requests_queue_.pop();
|
| - write_remote_characteristic_pending_ = false;
|
| - ProcessNextWriteRequest();
|
| -}
|
| -
|
| -void BluetoothLowEnergyWeaveClientConnection::OnWriteRemoteCharacteristicError(
|
| - BluetoothRemoteGattService::GattErrorCode error) {
|
| - PA_LOG(WARNING) << "Error " << error << " writing characteristic: "
|
| - << tx_characteristic_.uuid.canonical_value();
|
| -
|
| - write_remote_characteristic_pending_ = false;
|
| -
|
| - DCHECK(!write_requests_queue_.empty());
|
| - WriteRequest* request = &write_requests_queue_.front();
|
| -
|
| - // Increases the number of failed attempts and retry.
|
| -
|
| - if (++request->number_of_failed_attempts >= max_number_of_write_attempts_) {
|
| - switch (request->request_type) {
|
| - case WriteRequestType::REGULAR:
|
| - case WriteRequestType::MESSAGE_COMPLETE:
|
| - OnDidSendMessage(*request->message, false);
|
| - break;
|
| - case WriteRequestType::CONNECTION_CLOSE:
|
| - case WriteRequestType::CONNECTION_REQUEST:
|
| - break;
|
| - default:
|
| - NOTREACHED();
|
| - }
|
| -
|
| - // If the previous write failed that many times, probably can't write a
|
| - // connection close either, so just destroy the connection.
|
| - DestroyConnection();
|
| - } else {
|
| - ProcessNextWriteRequest();
|
| - }
|
| -}
|
| -
|
| -void BluetoothLowEnergyWeaveClientConnection::OnPacketReceiverError() {
|
| - PA_LOG(ERROR) << "Received erroneous packet. Closing connection.";
|
| -
|
| - WriteRequest request(packet_generator_->CreateConnectionClose(
|
| - packet_receiver_->GetReasonToClose()),
|
| - WriteRequestType::CONNECTION_CLOSE);
|
| -
|
| - // Skip all other writes that's not in progress.
|
| -
|
| - // C++ queue does not have a clear method.
|
| - // According to stackoverflow
|
| - // "http://stackoverflow.com/questions/709146/how-do-i-clear-the-stdqueue-
|
| - // efficiently"
|
| - std::queue<WriteRequest> empty;
|
| - std::swap(write_requests_queue_, empty);
|
| -
|
| - if (write_remote_characteristic_pending_) {
|
| - // Add the in progress write back to the queue.
|
| - write_requests_queue_.push(empty.front());
|
| - }
|
| -
|
| - WriteRemoteCharacteristic(request);
|
| -}
|
| -
|
| -void BluetoothLowEnergyWeaveClientConnection::PrintTimeElapsed() {
|
| - PA_LOG(INFO) << "Time elapsed: " << base::TimeTicks::Now() - start_time_;
|
| -}
|
| -
|
| -std::string BluetoothLowEnergyWeaveClientConnection::GetDeviceAddress() {
|
| - // When the remote device is connected we should rely on the address given by
|
| - // |gatt_connection_|. As the device address may change if the device is
|
| - // paired. The address in |gatt_connection_| is automatically updated in this
|
| - // case.
|
| - return gatt_connection_ ? gatt_connection_->GetDeviceAddress()
|
| - : remote_device().bluetooth_address;
|
| -}
|
| -
|
| -BluetoothDevice* BluetoothLowEnergyWeaveClientConnection::GetRemoteDevice() {
|
| - // It's not possible to simply use
|
| - // |adapter_->GetDevice(GetDeviceAddress())| to find the device with MAC
|
| - // address |GetDeviceAddress()|. For paired devices,
|
| - // BluetoothAdapter::GetDevice(XXX) searches for the temporary MAC address
|
| - // XXX, whereas |GetDeviceAddress()| is the real MAC address. This is a
|
| - // bug in the way device::BluetoothAdapter is storing the devices (see
|
| - // crbug.com/497841).
|
| - std::vector<BluetoothDevice*> devices = adapter_->GetDevices();
|
| - for (const auto& device : devices) {
|
| - if (device->GetAddress() == GetDeviceAddress())
|
| - return device;
|
| - }
|
| -
|
| - return nullptr;
|
| -}
|
| -
|
| -BluetoothRemoteGattService*
|
| -BluetoothLowEnergyWeaveClientConnection::GetRemoteService() {
|
| - BluetoothDevice* remote_device = GetRemoteDevice();
|
| - if (!remote_device) {
|
| - PA_LOG(WARNING) << "Remote device not found.";
|
| - return NULL;
|
| - }
|
| - if (remote_service_.id.empty()) {
|
| - std::vector<BluetoothRemoteGattService*> services =
|
| - remote_device->GetGattServices();
|
| - for (const auto& service : services)
|
| - if (service->GetUUID() == remote_service_.uuid) {
|
| - remote_service_.id = service->GetIdentifier();
|
| - break;
|
| - }
|
| - }
|
| - return remote_device->GetGattService(remote_service_.id);
|
| -}
|
| -
|
| -BluetoothRemoteGattCharacteristic*
|
| -BluetoothLowEnergyWeaveClientConnection::GetGattCharacteristic(
|
| - const std::string& gatt_characteristic) {
|
| - BluetoothRemoteGattService* remote_service = GetRemoteService();
|
| - if (!remote_service) {
|
| - PA_LOG(WARNING) << "Remote service not found.";
|
| - return NULL;
|
| - }
|
| - return remote_service->GetCharacteristic(gatt_characteristic);
|
| -}
|
| -
|
| -std::string BluetoothLowEnergyWeaveClientConnection::GetReasonForClose() {
|
| - switch (packet_receiver_->GetReasonForClose()) {
|
| - case ReasonForClose::CLOSE_WITHOUT_ERROR:
|
| - return "CLOSE_WITHOUT_ERROR";
|
| - case ReasonForClose::UNKNOWN_ERROR:
|
| - return "UNKNOWN_ERROR";
|
| - case ReasonForClose::NO_COMMON_VERSION_SUPPORTED:
|
| - return "NO_COMMON_VERSION_SUPPORTED";
|
| - case ReasonForClose::RECEIVED_PACKET_OUT_OF_SEQUENCE:
|
| - return "RECEIVED_PACKET_OUT_OF_SEQUENCE";
|
| - case ReasonForClose::APPLICATION_ERROR:
|
| - return "APPLICATION_ERROR";
|
| - default:
|
| - NOTREACHED();
|
| - return "";
|
| - }
|
| -}
|
| -
|
| -BluetoothLowEnergyWeaveClientConnection::WriteRequest::WriteRequest(
|
| - const Packet& val,
|
| - WriteRequestType request_type,
|
| - std::shared_ptr<WireMessage> message)
|
| - : value(val),
|
| - request_type(request_type),
|
| - message(message),
|
| - number_of_failed_attempts(0) {}
|
| -
|
| -BluetoothLowEnergyWeaveClientConnection::WriteRequest::WriteRequest(
|
| - const Packet& val,
|
| - WriteRequestType request_type)
|
| - : value(val),
|
| - request_type(request_type),
|
| - message(nullptr),
|
| - number_of_failed_attempts(0) {}
|
| -
|
| -BluetoothLowEnergyWeaveClientConnection::WriteRequest::WriteRequest(
|
| - const WriteRequest& other) = default;
|
| -
|
| -BluetoothLowEnergyWeaveClientConnection::WriteRequest::~WriteRequest() {}
|
| -
|
| -} // namespace weave
|
| -
|
| -} // namespace proximity_auth
|
|
|