diff options
Diffstat (limited to 'chromium/net/socket/buffered_write_stream_socket.cc')
-rw-r--r-- | chromium/net/socket/buffered_write_stream_socket.cc | 161 |
1 files changed, 0 insertions, 161 deletions
diff --git a/chromium/net/socket/buffered_write_stream_socket.cc b/chromium/net/socket/buffered_write_stream_socket.cc index 87d3c337e24..e69de29bb2d 100644 --- a/chromium/net/socket/buffered_write_stream_socket.cc +++ b/chromium/net/socket/buffered_write_stream_socket.cc @@ -1,161 +0,0 @@ -// Copyright (c) 2012 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 "net/socket/buffered_write_stream_socket.h" - -#include "base/bind.h" -#include "base/location.h" -#include "base/message_loop/message_loop.h" -#include "net/base/io_buffer.h" -#include "net/base/net_errors.h" - -namespace net { - -namespace { - -void AppendBuffer(GrowableIOBuffer* dst, IOBuffer* src, int src_len) { - int old_capacity = dst->capacity(); - dst->SetCapacity(old_capacity + src_len); - memcpy(dst->StartOfBuffer() + old_capacity, src->data(), src_len); -} - -} // anonymous namespace - -BufferedWriteStreamSocket::BufferedWriteStreamSocket( - scoped_ptr<StreamSocket> socket_to_wrap) - : wrapped_socket_(socket_to_wrap.Pass()), - io_buffer_(new GrowableIOBuffer()), - backup_buffer_(new GrowableIOBuffer()), - callback_pending_(false), - wrapped_write_in_progress_(false), - error_(0), - weak_factory_(this) { -} - -BufferedWriteStreamSocket::~BufferedWriteStreamSocket() { -} - -int BufferedWriteStreamSocket::Read(IOBuffer* buf, int buf_len, - const CompletionCallback& callback) { - return wrapped_socket_->Read(buf, buf_len, callback); -} - -int BufferedWriteStreamSocket::Write(IOBuffer* buf, int buf_len, - const CompletionCallback& callback) { - if (error_) { - return error_; - } - GrowableIOBuffer* idle_buffer = - wrapped_write_in_progress_ ? backup_buffer_.get() : io_buffer_.get(); - AppendBuffer(idle_buffer, buf, buf_len); - if (!callback_pending_) { - base::MessageLoop::current()->PostTask( - FROM_HERE, - base::Bind(&BufferedWriteStreamSocket::DoDelayedWrite, - weak_factory_.GetWeakPtr())); - callback_pending_ = true; - } - return buf_len; -} - -bool BufferedWriteStreamSocket::SetReceiveBufferSize(int32 size) { - return wrapped_socket_->SetReceiveBufferSize(size); -} - -bool BufferedWriteStreamSocket::SetSendBufferSize(int32 size) { - return wrapped_socket_->SetSendBufferSize(size); -} - -int BufferedWriteStreamSocket::Connect(const CompletionCallback& callback) { - return wrapped_socket_->Connect(callback); -} - -void BufferedWriteStreamSocket::Disconnect() { - wrapped_socket_->Disconnect(); -} - -bool BufferedWriteStreamSocket::IsConnected() const { - return wrapped_socket_->IsConnected(); -} - -bool BufferedWriteStreamSocket::IsConnectedAndIdle() const { - return wrapped_socket_->IsConnectedAndIdle(); -} - -int BufferedWriteStreamSocket::GetPeerAddress(IPEndPoint* address) const { - return wrapped_socket_->GetPeerAddress(address); -} - -int BufferedWriteStreamSocket::GetLocalAddress(IPEndPoint* address) const { - return wrapped_socket_->GetLocalAddress(address); -} - -const BoundNetLog& BufferedWriteStreamSocket::NetLog() const { - return wrapped_socket_->NetLog(); -} - -void BufferedWriteStreamSocket::SetSubresourceSpeculation() { - wrapped_socket_->SetSubresourceSpeculation(); -} - -void BufferedWriteStreamSocket::SetOmniboxSpeculation() { - wrapped_socket_->SetOmniboxSpeculation(); -} - -bool BufferedWriteStreamSocket::WasEverUsed() const { - return wrapped_socket_->WasEverUsed(); -} - -bool BufferedWriteStreamSocket::UsingTCPFastOpen() const { - return wrapped_socket_->UsingTCPFastOpen(); -} - -bool BufferedWriteStreamSocket::WasNpnNegotiated() const { - return wrapped_socket_->WasNpnNegotiated(); -} - -NextProto BufferedWriteStreamSocket::GetNegotiatedProtocol() const { - return wrapped_socket_->GetNegotiatedProtocol(); -} - -bool BufferedWriteStreamSocket::GetSSLInfo(SSLInfo* ssl_info) { - return wrapped_socket_->GetSSLInfo(ssl_info); -} - -void BufferedWriteStreamSocket::DoDelayedWrite() { - int result = wrapped_socket_->Write( - io_buffer_.get(), - io_buffer_->RemainingCapacity(), - base::Bind(&BufferedWriteStreamSocket::OnIOComplete, - base::Unretained(this))); - if (result == ERR_IO_PENDING) { - callback_pending_ = true; - wrapped_write_in_progress_ = true; - } else { - OnIOComplete(result); - } -} - -void BufferedWriteStreamSocket::OnIOComplete(int result) { - callback_pending_ = false; - wrapped_write_in_progress_ = false; - if (backup_buffer_->RemainingCapacity()) { - AppendBuffer(io_buffer_.get(), backup_buffer_.get(), - backup_buffer_->RemainingCapacity()); - backup_buffer_->SetCapacity(0); - } - if (result < 0) { - error_ = result; - io_buffer_->SetCapacity(0); - } else { - io_buffer_->set_offset(io_buffer_->offset() + result); - if (io_buffer_->RemainingCapacity()) { - DoDelayedWrite(); - } else { - io_buffer_->SetCapacity(0); - } - } -} - -} // namespace net |