Index: components/copresence_endpoints/transports/bluetooth/copresence_socket_bluetooth.cc |
diff --git a/components/copresence_endpoints/transports/bluetooth/copresence_socket_bluetooth.cc b/components/copresence_endpoints/transports/bluetooth/copresence_socket_bluetooth.cc |
deleted file mode 100644 |
index bfee046a17812eaf0d9c48a8eb38b1fe83736ee4..0000000000000000000000000000000000000000 |
--- a/components/copresence_endpoints/transports/bluetooth/copresence_socket_bluetooth.cc |
+++ /dev/null |
@@ -1,94 +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/copresence_endpoints/transports/bluetooth/copresence_socket_bluetooth.h" |
- |
-#include "base/bind.h" |
-#include "base/message_loop/message_loop.h" |
-#include "base/strings/string_piece.h" |
-#include "device/bluetooth/bluetooth_socket.h" |
-#include "net/base/io_buffer.h" |
- |
-namespace { |
- |
-// TODO(rkc): This number is totally arbitrary. Figure out what this should be. |
-const int kMaxReceiveBytes = 4096; |
- |
-} // namespace |
- |
-namespace copresence_endpoints { |
- |
-CopresenceSocketBluetooth::CopresenceSocketBluetooth( |
- const scoped_refptr<device::BluetoothSocket>& socket) |
- : socket_(socket), receiving_(false), weak_ptr_factory_(this) { |
-} |
- |
-CopresenceSocketBluetooth::~CopresenceSocketBluetooth() { |
- receiving_ = false; |
-} |
- |
-bool CopresenceSocketBluetooth::Send(const scoped_refptr<net::IOBuffer>& buffer, |
- int buffer_size) { |
- VLOG(3) << "Starting sending of data with size = " << buffer_size; |
- socket_->Send(buffer, buffer_size, |
- base::Bind(&CopresenceSocketBluetooth::OnSendComplete, |
- weak_ptr_factory_.GetWeakPtr()), |
- base::Bind(&CopresenceSocketBluetooth::OnSendError, |
- weak_ptr_factory_.GetWeakPtr())); |
- return true; |
-} |
- |
-void CopresenceSocketBluetooth::Receive(const ReceiveCallback& callback) { |
- VLOG(3) << "Starting Receive."; |
- receiving_ = true; |
- receive_callback_ = callback; |
- socket_->Receive(kMaxReceiveBytes, |
- base::Bind(&CopresenceSocketBluetooth::OnReceive, |
- weak_ptr_factory_.GetWeakPtr()), |
- base::Bind(&CopresenceSocketBluetooth::OnReceiveError, |
- weak_ptr_factory_.GetWeakPtr())); |
-} |
- |
-void CopresenceSocketBluetooth::OnSendComplete(int status) { |
- VLOG(3) << "Send Completed. Status = " << status; |
-} |
- |
-void CopresenceSocketBluetooth::OnSendError(const std::string& message) { |
- LOG(ERROR) << "Bluetooth send error: " << message; |
-} |
- |
-void CopresenceSocketBluetooth::OnReceive( |
- int size, |
- scoped_refptr<net::IOBuffer> io_buffer) { |
- VLOG(3) << "Data received with size = " << size |
- << " and receiving_ = " << receiving_; |
- // Dispatch the data to the callback and go back to listening for more data. |
- receive_callback_.Run(io_buffer, size); |
- |
- // We cancelled receiving due to an error. Don't post more receive tasks. |
- if (!receiving_) |
- return; |
- |
- // Post a task to delay the read until the socket is available, as |
- // calling Receive again at this point would error with ERR_IO_PENDING. |
- base::MessageLoop::current()->PostTask( |
- FROM_HERE, |
- base::Bind(&device::BluetoothSocket::Receive, socket_, kMaxReceiveBytes, |
- base::Bind(&CopresenceSocketBluetooth::OnReceive, |
- weak_ptr_factory_.GetWeakPtr()), |
- base::Bind(&CopresenceSocketBluetooth::OnReceiveError, |
- weak_ptr_factory_.GetWeakPtr()))); |
-} |
- |
-void CopresenceSocketBluetooth::OnReceiveError( |
- device::BluetoothSocket::ErrorReason reason, |
- const std::string& message) { |
- LOG(ERROR) << "Bluetooth receive error: " << message; |
- if (reason == device::BluetoothSocket::kIOPending) |
- return; |
- |
- receiving_ = false; |
-} |
- |
-} // namespace copresence_endpoints |