Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(811)

Unified Diff: components/proximity_auth/connection.cc

Issue 2561203002: Migrate weave-related classes from proximity_auth/ble to cryptauth/ble. (Closed)
Patch Set: Rebase. Created 4 years ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
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

Powered by Google App Engine
This is Rietveld 408576698