Index: net/quic/quic_reliable_client_stream.cc |
diff --git a/net/quic/quic_reliable_client_stream.cc b/net/quic/quic_reliable_client_stream.cc |
deleted file mode 100644 |
index 68651cb049cec25bdede56ee9121e3da9879fdaa..0000000000000000000000000000000000000000 |
--- a/net/quic/quic_reliable_client_stream.cc |
+++ /dev/null |
@@ -1,108 +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/quic/quic_reliable_client_stream.h" |
- |
-#include "base/callback_helpers.h" |
-#include "net/base/net_errors.h" |
-#include "net/quic/quic_session.h" |
-#include "net/quic/quic_write_blocked_list.h" |
- |
-namespace net { |
- |
-QuicReliableClientStream::QuicReliableClientStream(QuicStreamId id, |
- QuicSession* session, |
- const BoundNetLog& net_log) |
- : QuicDataStream(id, session), |
- net_log_(net_log), |
- delegate_(nullptr) { |
-} |
- |
-QuicReliableClientStream::~QuicReliableClientStream() { |
- if (delegate_) |
- delegate_->OnClose(connection_error()); |
-} |
- |
-uint32 QuicReliableClientStream::ProcessData(const char* data, |
- uint32 data_len) { |
- // TODO(rch): buffer data if we don't have a delegate. |
- if (!delegate_) { |
- DLOG(ERROR) << "Missing delegate"; |
- Reset(QUIC_STREAM_CANCELLED); |
- return 0; |
- } |
- |
- int rv = delegate_->OnDataReceived(data, data_len); |
- if (rv != OK) { |
- DLOG(ERROR) << "Delegate refused data, rv: " << rv; |
- Reset(QUIC_BAD_APPLICATION_PAYLOAD); |
- return 0; |
- } |
- return data_len; |
-} |
- |
-void QuicReliableClientStream::OnClose() { |
- if (delegate_) { |
- delegate_->OnClose(connection_error()); |
- delegate_ = nullptr; |
- } |
- ReliableQuicStream::OnClose(); |
-} |
- |
-void QuicReliableClientStream::OnCanWrite() { |
- ReliableQuicStream::OnCanWrite(); |
- |
- if (!HasBufferedData() && !callback_.is_null()) { |
- base::ResetAndReturn(&callback_).Run(OK); |
- } |
-} |
- |
-QuicPriority QuicReliableClientStream::EffectivePriority() const { |
- if (delegate_ && delegate_->HasSendHeadersComplete()) { |
- return QuicDataStream::EffectivePriority(); |
- } |
- return QuicWriteBlockedList::kHighestPriority; |
-} |
- |
-int QuicReliableClientStream::WriteStreamData( |
- base::StringPiece data, |
- bool fin, |
- const CompletionCallback& callback) { |
- // We should not have data buffered. |
- DCHECK(!HasBufferedData()); |
- // Writes the data, or buffers it. |
- WriteOrBufferData(data, fin, nullptr); |
- if (!HasBufferedData()) { |
- return OK; |
- } |
- |
- callback_ = callback; |
- return ERR_IO_PENDING; |
-} |
- |
-void QuicReliableClientStream::SetDelegate( |
- QuicReliableClientStream::Delegate* delegate) { |
- DCHECK(!(delegate_ && delegate)); |
- delegate_ = delegate; |
-} |
- |
-void QuicReliableClientStream::OnError(int error) { |
- if (delegate_) { |
- QuicReliableClientStream::Delegate* delegate = delegate_; |
- delegate_ = nullptr; |
- delegate->OnError(error); |
- } |
-} |
- |
-bool QuicReliableClientStream::CanWrite(const CompletionCallback& callback) { |
- bool can_write = session()->connection()->CanWrite(HAS_RETRANSMITTABLE_DATA); |
- if (!can_write) { |
- session()->MarkWriteBlocked(id(), EffectivePriority()); |
- DCHECK(callback_.is_null()); |
- callback_ = callback; |
- } |
- return can_write; |
-} |
- |
-} // namespace net |