diff options
Diffstat (limited to 'remoting/jingle_glue/stream_socket_adapter.cc')
| -rw-r--r-- | remoting/jingle_glue/stream_socket_adapter.cc | 238 |
1 files changed, 0 insertions, 238 deletions
diff --git a/remoting/jingle_glue/stream_socket_adapter.cc b/remoting/jingle_glue/stream_socket_adapter.cc deleted file mode 100644 index 4c5e6cf..0000000 --- a/remoting/jingle_glue/stream_socket_adapter.cc +++ /dev/null @@ -1,238 +0,0 @@ -// Copyright (c) 2010 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/jingle_glue/stream_socket_adapter.h" - -#include "base/logging.h" -#include "base/message_loop.h" -#include "net/base/address_list.h" -#include "net/base/io_buffer.h" -#include "net/base/net_errors.h" -#include "remoting/jingle_glue/utils.h" -#include "third_party/libjingle/source/talk/base/stream.h" - -namespace remoting { - -StreamSocketAdapter::StreamSocketAdapter(talk_base::StreamInterface* stream) - : stream_(stream), - read_pending_(false), - write_pending_(false), - closed_error_code_(net::OK) { - DCHECK_EQ(MessageLoop::TYPE_IO, MessageLoop::current()->type()); - DCHECK(stream); - stream_->SignalEvent.connect(this, &StreamSocketAdapter::OnStreamEvent); -} - -StreamSocketAdapter::~StreamSocketAdapter() { -} - -int StreamSocketAdapter::Connect(net::CompletionCallback* callback) { - return net::OK; -} - -void StreamSocketAdapter::Disconnect() { -} - -bool StreamSocketAdapter::IsConnected() const { - return true; -} - -bool StreamSocketAdapter::IsConnectedAndIdle() const { - return true; -} - -int StreamSocketAdapter::GetPeerAddress(net::AddressList* address) const { - // We actually don't know the peer address. Returning so the upper layers - // won't complain. - net::IPAddressNumber ip_address(4); - *address = net::AddressList(ip_address, 0, false); - return net::OK; -} - -const net::BoundNetLog& StreamSocketAdapter::NetLog() const { - return net_log_; -} - -void StreamSocketAdapter::SetSubresourceSpeculation() { -} - -void StreamSocketAdapter::SetOmniboxSpeculation() { -} - -bool StreamSocketAdapter::WasEverUsed() const { - return true; -} - -bool StreamSocketAdapter::UsingTCPFastOpen() const { - return false; -} - -int StreamSocketAdapter::Read( - net::IOBuffer* buffer, int buffer_size, net::CompletionCallback* callback) { - DCHECK_EQ(MessageLoop::TYPE_IO, MessageLoop::current()->type()); - DCHECK(buffer); - CHECK(!read_pending_); - - if (!stream_.get()) { - DCHECK(closed_error_code_ != net::OK); - return closed_error_code_; - } - - int result = ReadStream(buffer, buffer_size); - if (result == net::ERR_CONNECTION_CLOSED && - stream_->GetState() == talk_base::SS_OPENING) - result = net::ERR_IO_PENDING; - if (result == net::ERR_IO_PENDING) { - read_pending_ = true; - read_callback_ = callback; - read_buffer_ = buffer; - read_buffer_size_ = buffer_size; - } - return result; -} - -int StreamSocketAdapter::Write( - net::IOBuffer* buffer, int buffer_size, net::CompletionCallback* callback) { - DCHECK_EQ(MessageLoop::TYPE_IO, MessageLoop::current()->type()); - DCHECK(buffer); - CHECK(!write_pending_); - - if (!stream_.get()) { - DCHECK(closed_error_code_ != net::OK); - return closed_error_code_; - } - - int result = WriteStream(buffer, buffer_size); - if (result == net::ERR_CONNECTION_CLOSED && - stream_->GetState() == talk_base::SS_OPENING) - result = net::ERR_IO_PENDING; - - if (result == net::ERR_IO_PENDING) { - write_pending_ = true; - write_callback_ = callback; - write_buffer_ = buffer; - write_buffer_size_ = buffer_size; - } - return result; -} - -bool StreamSocketAdapter::SetReceiveBufferSize(int32 size) { - NOTIMPLEMENTED(); - return false; -} - -bool StreamSocketAdapter::SetSendBufferSize(int32 size) { - NOTIMPLEMENTED(); - return false; -} - -void StreamSocketAdapter::Close(int error_code) { - DCHECK_EQ(MessageLoop::TYPE_IO, MessageLoop::current()->type()); - - if (!stream_.get()) // Already closed. - return; - - DCHECK(error_code != net::OK); - closed_error_code_ = error_code; - stream_->SignalEvent.disconnect(this); - stream_->Close(); - stream_.reset(NULL); - - if (read_pending_) { - net::CompletionCallback* callback = read_callback_; - read_pending_ = false; - read_buffer_ = NULL; - callback->Run(error_code); - } - - if (write_pending_) { - net::CompletionCallback* callback = write_callback_; - write_pending_ = false; - write_buffer_ = NULL; - callback->Run(error_code); - } -} - -void StreamSocketAdapter::OnStreamEvent( - talk_base::StreamInterface* stream, int events, int error) { - DCHECK_EQ(MessageLoop::TYPE_IO, MessageLoop::current()->type()); - - if (events & talk_base::SE_WRITE) - DoWrite(); - - if (events & talk_base::SE_READ) - DoRead(); -} - -void StreamSocketAdapter::DoWrite() { - // Write if there is a pending read. - if (write_buffer_) { - int result = WriteStream(write_buffer_, write_buffer_size_); - if (result != net::ERR_IO_PENDING) { - net::CompletionCallback* callback = write_callback_; - write_pending_ = false; - write_buffer_ = NULL; - callback->Run(result); - } - } -} - -void StreamSocketAdapter::DoRead() { - // Read if there is a pending read. - if (read_pending_) { - int result = ReadStream(read_buffer_, read_buffer_size_); - if (result != net::ERR_IO_PENDING) { - net::CompletionCallback* callback = read_callback_;\ - read_pending_ = false; - read_buffer_ = NULL; - callback->Run(result); - } - } -} - -int StreamSocketAdapter::ReadStream(net::IOBuffer* buffer, int buffer_size) { - size_t bytes_read; - int error; - talk_base::StreamResult result = stream_->Read( - buffer->data(), buffer_size, &bytes_read, &error); - switch (result) { - case talk_base::SR_SUCCESS: - return bytes_read; - - case talk_base::SR_BLOCK: - return net::ERR_IO_PENDING; - - case talk_base::SR_EOS: - return net::ERR_CONNECTION_CLOSED; - - case talk_base::SR_ERROR: - return MapPosixToChromeError(error); - } - NOTREACHED(); - return net::ERR_FAILED; -} - -int StreamSocketAdapter::WriteStream(net::IOBuffer* buffer, int buffer_size) { - size_t bytes_written; - int error; - talk_base::StreamResult result = stream_->Write( - buffer->data(), buffer_size, &bytes_written, &error); - switch (result) { - case talk_base::SR_SUCCESS: - return bytes_written; - - case talk_base::SR_BLOCK: - return net::ERR_IO_PENDING; - - case talk_base::SR_EOS: - return net::ERR_CONNECTION_CLOSED; - - case talk_base::SR_ERROR: - return MapPosixToChromeError(error); - } - NOTREACHED(); - return net::ERR_FAILED; -} - -} // namespace remoting |