Index: remoting/protocol/socket_reader_base.cc |
diff --git a/remoting/protocol/socket_reader_base.cc b/remoting/protocol/socket_reader_base.cc |
deleted file mode 100644 |
index bb315db2414db6679f9013816312b3436dbcb6b3..0000000000000000000000000000000000000000 |
--- a/remoting/protocol/socket_reader_base.cc |
+++ /dev/null |
@@ -1,62 +0,0 @@ |
-// Copyright (c) 2011 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 "remoting/protocol/socket_reader_base.h" |
- |
-#include "net/base/completion_callback.h" |
-#include "net/base/io_buffer.h" |
-#include "net/base/net_errors.h" |
-#include "net/socket/socket.h" |
- |
-namespace remoting { |
- |
-namespace { |
-int kReadBufferSize = 4096; |
-} // namespace |
- |
-SocketReaderBase::SocketReaderBase() |
- : socket_(NULL), |
- closed_(false) { |
-} |
- |
-SocketReaderBase::~SocketReaderBase() { } |
- |
-void SocketReaderBase::Init(net::Socket* socket) { |
- DCHECK(socket); |
- socket_ = socket; |
- DoRead(); |
-} |
- |
-void SocketReaderBase::DoRead() { |
- while (true) { |
- read_buffer_ = new net::IOBuffer(kReadBufferSize); |
- int result = socket_->Read( |
- read_buffer_, kReadBufferSize, base::Bind(&SocketReaderBase::OnRead, |
- base::Unretained(this))); |
- HandleReadResult(result); |
- if (result < 0) |
- break; |
- } |
-} |
- |
-void SocketReaderBase::OnRead(int result) { |
- if (!closed_) { |
- HandleReadResult(result); |
- DoRead(); |
- } |
-} |
- |
-void SocketReaderBase::HandleReadResult(int result) { |
- if (result > 0) { |
- OnDataReceived(read_buffer_, result); |
- } else { |
- if (result == net::ERR_CONNECTION_CLOSED) { |
- closed_ = true; |
- } else if (result != net::ERR_IO_PENDING) { |
- LOG(ERROR) << "Read() returned error " << result; |
- } |
- } |
-} |
- |
-} // namespace remoting |