| Index: components/proximity_auth/connection.cc
|
| diff --git a/components/proximity_auth/connection.cc b/components/proximity_auth/connection.cc
|
| deleted file mode 100644
|
| index b191d5f0fce4440968437a1a340d81e89b2d84f9..0000000000000000000000000000000000000000
|
| --- a/components/proximity_auth/connection.cc
|
| +++ /dev/null
|
| @@ -1,106 +0,0 @@
|
| -// Copyright 2014 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/connection.h"
|
| -
|
| -#include <utility>
|
| -
|
| -#include "base/logging.h"
|
| -#include "components/proximity_auth/connection_observer.h"
|
| -#include "components/proximity_auth/wire_message.h"
|
| -
|
| -namespace proximity_auth {
|
| -
|
| -Connection::Connection(const cryptauth::RemoteDevice& remote_device)
|
| - : remote_device_(remote_device),
|
| - status_(DISCONNECTED),
|
| - is_sending_message_(false) {}
|
| -
|
| -Connection::~Connection() {
|
| -}
|
| -
|
| -bool Connection::IsConnected() const {
|
| - return status_ == CONNECTED;
|
| -}
|
| -
|
| -void Connection::SendMessage(std::unique_ptr<WireMessage> message) {
|
| - if (!IsConnected()) {
|
| - VLOG(1) << "Cannot send message when disconnected.";
|
| - return;
|
| - }
|
| -
|
| - if (is_sending_message_) {
|
| - VLOG(1) << "Another message is currently in progress.";
|
| - return;
|
| - }
|
| -
|
| - is_sending_message_ = true;
|
| - SendMessageImpl(std::move(message));
|
| -}
|
| -
|
| -void Connection::AddObserver(ConnectionObserver* observer) {
|
| - observers_.AddObserver(observer);
|
| -}
|
| -
|
| -void Connection::RemoveObserver(ConnectionObserver* observer) {
|
| - observers_.RemoveObserver(observer);
|
| -}
|
| -
|
| -std::string Connection::GetDeviceAddress() {
|
| - return remote_device_.bluetooth_address;
|
| -}
|
| -
|
| -void Connection::SetStatus(Status status) {
|
| - if (status_ == status)
|
| - return;
|
| -
|
| - received_bytes_.clear();
|
| -
|
| - Status old_status = status_;
|
| - status_ = status;
|
| - for (auto& observer : observers_)
|
| - observer.OnConnectionStatusChanged(this, old_status, status_);
|
| -}
|
| -
|
| -void Connection::OnDidSendMessage(const WireMessage& message, bool success) {
|
| - if (!is_sending_message_) {
|
| - VLOG(1) << "Send completed, but no message in progress.";
|
| - return;
|
| - }
|
| -
|
| - is_sending_message_ = false;
|
| - for (auto& observer : observers_)
|
| - observer.OnSendCompleted(*this, message, success);
|
| -}
|
| -
|
| -void Connection::OnBytesReceived(const std::string& bytes) {
|
| - if (!IsConnected()) {
|
| - VLOG(1) << "Received bytes, but not connected.";
|
| - return;
|
| - }
|
| -
|
| - received_bytes_ += bytes;
|
| -
|
| - bool is_incomplete_message;
|
| - std::unique_ptr<WireMessage> message =
|
| - DeserializeWireMessage(&is_incomplete_message);
|
| - if (is_incomplete_message)
|
| - return;
|
| -
|
| - if (message) {
|
| - for (auto& observer : observers_)
|
| - observer.OnMessageReceived(*this, *message);
|
| - }
|
| -
|
| - // Whether the message was parsed successfully or not, clear the
|
| - // |received_bytes_| buffer.
|
| - received_bytes_.clear();
|
| -}
|
| -
|
| -std::unique_ptr<WireMessage> Connection::DeserializeWireMessage(
|
| - bool* is_incomplete_message) {
|
| - return WireMessage::Deserialize(received_bytes_, is_incomplete_message);
|
| -}
|
| -
|
| -} // namespace proximity_auth
|
|
|