Index: net/quic/quic_chromium_client_stream.cc |
diff --git a/net/quic/quic_reliable_client_stream.cc b/net/quic/quic_chromium_client_stream.cc |
similarity index 76% |
rename from net/quic/quic_reliable_client_stream.cc |
rename to net/quic/quic_chromium_client_stream.cc |
index ada28695f4eea7579bee69c4405abb9699cff4ff..2c558e553696564e3ecba2658ac17c99b64f6160 100644 |
--- a/net/quic/quic_reliable_client_stream.cc |
+++ b/net/quic/quic_chromium_client_stream.cc |
@@ -2,7 +2,7 @@ |
// 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 "net/quic/quic_chromium_client_stream.h" |
#include "base/callback_helpers.h" |
#include "base/location.h" |
@@ -15,7 +15,7 @@ |
namespace net { |
-QuicReliableClientStream::QuicReliableClientStream(QuicStreamId id, |
+QuicChromiumClientStream::QuicChromiumClientStream(QuicStreamId id, |
QuicSpdySession* session, |
const BoundNetLog& net_log) |
: QuicSpdyStream(id, session), |
@@ -24,19 +24,19 @@ QuicReliableClientStream::QuicReliableClientStream(QuicStreamId id, |
headers_delivered_(false), |
weak_factory_(this) {} |
-QuicReliableClientStream::~QuicReliableClientStream() { |
+QuicChromiumClientStream::~QuicChromiumClientStream() { |
if (delegate_) |
delegate_->OnClose(connection_error()); |
} |
-void QuicReliableClientStream::OnStreamHeadersComplete(bool fin, |
+void QuicChromiumClientStream::OnStreamHeadersComplete(bool fin, |
size_t frame_len) { |
QuicSpdyStream::OnStreamHeadersComplete(fin, frame_len); |
// The delegate will read the headers via a posted task. |
NotifyDelegateOfHeadersCompleteLater(frame_len); |
} |
-void QuicReliableClientStream::OnDataAvailable() { |
+void QuicChromiumClientStream::OnDataAvailable() { |
// TODO(rch): buffer data if we don't have a delegate. |
if (!delegate_) { |
DLOG(ERROR) << "Missing delegate"; |
@@ -54,7 +54,7 @@ void QuicReliableClientStream::OnDataAvailable() { |
NotifyDelegateOfDataAvailableLater(); |
} |
-void QuicReliableClientStream::OnClose() { |
+void QuicChromiumClientStream::OnClose() { |
if (delegate_) { |
delegate_->OnClose(connection_error()); |
delegate_ = nullptr; |
@@ -62,7 +62,7 @@ void QuicReliableClientStream::OnClose() { |
ReliableQuicStream::OnClose(); |
} |
-void QuicReliableClientStream::OnCanWrite() { |
+void QuicChromiumClientStream::OnCanWrite() { |
ReliableQuicStream::OnCanWrite(); |
if (!HasBufferedData() && !callback_.is_null()) { |
@@ -70,14 +70,14 @@ void QuicReliableClientStream::OnCanWrite() { |
} |
} |
-SpdyPriority QuicReliableClientStream::Priority() const { |
+SpdyPriority QuicChromiumClientStream::Priority() const { |
if (delegate_ && delegate_->HasSendHeadersComplete()) { |
return QuicSpdyStream::Priority(); |
} |
return net::kV3HighestPriority; |
} |
-int QuicReliableClientStream::WriteStreamData( |
+int QuicChromiumClientStream::WriteStreamData( |
base::StringPiece data, |
bool fin, |
const CompletionCallback& callback) { |
@@ -93,8 +93,8 @@ int QuicReliableClientStream::WriteStreamData( |
return ERR_IO_PENDING; |
} |
-void QuicReliableClientStream::SetDelegate( |
- QuicReliableClientStream::Delegate* delegate) { |
+void QuicChromiumClientStream::SetDelegate( |
+ QuicChromiumClientStream::Delegate* delegate) { |
DCHECK(!(delegate_ && delegate)); |
delegate_ = delegate; |
if (delegate == nullptr && sequencer()->IsClosed()) { |
@@ -102,15 +102,15 @@ void QuicReliableClientStream::SetDelegate( |
} |
} |
-void QuicReliableClientStream::OnError(int error) { |
+void QuicChromiumClientStream::OnError(int error) { |
if (delegate_) { |
- QuicReliableClientStream::Delegate* delegate = delegate_; |
+ QuicChromiumClientStream::Delegate* delegate = delegate_; |
delegate_ = nullptr; |
delegate->OnError(error); |
} |
} |
-int QuicReliableClientStream::Read(IOBuffer* buf, int buf_len) { |
+int QuicChromiumClientStream::Read(IOBuffer* buf, int buf_len) { |
if (sequencer()->IsClosed()) |
return 0; // EOF |
@@ -123,7 +123,7 @@ int QuicReliableClientStream::Read(IOBuffer* buf, int buf_len) { |
return Readv(&iov, 1); |
} |
-bool QuicReliableClientStream::CanWrite(const CompletionCallback& callback) { |
+bool QuicChromiumClientStream::CanWrite(const CompletionCallback& callback) { |
bool can_write = session()->connection()->CanWrite(HAS_RETRANSMITTABLE_DATA); |
if (!can_write) { |
session()->MarkConnectionLevelWriteBlocked(id(), Priority()); |
@@ -133,16 +133,16 @@ bool QuicReliableClientStream::CanWrite(const CompletionCallback& callback) { |
return can_write; |
} |
-void QuicReliableClientStream::NotifyDelegateOfHeadersCompleteLater( |
+void QuicChromiumClientStream::NotifyDelegateOfHeadersCompleteLater( |
size_t frame_len) { |
DCHECK(delegate_); |
base::ThreadTaskRunnerHandle::Get()->PostTask( |
FROM_HERE, |
- base::Bind(&QuicReliableClientStream::NotifyDelegateOfHeadersComplete, |
+ base::Bind(&QuicChromiumClientStream::NotifyDelegateOfHeadersComplete, |
weak_factory_.GetWeakPtr(), frame_len)); |
} |
-void QuicReliableClientStream::NotifyDelegateOfHeadersComplete( |
+void QuicChromiumClientStream::NotifyDelegateOfHeadersComplete( |
size_t frame_len) { |
if (!delegate_) |
return; |
@@ -162,15 +162,15 @@ void QuicReliableClientStream::NotifyDelegateOfHeadersComplete( |
delegate_->OnHeadersAvailable(headers, frame_len); |
} |
-void QuicReliableClientStream::NotifyDelegateOfDataAvailableLater() { |
+void QuicChromiumClientStream::NotifyDelegateOfDataAvailableLater() { |
DCHECK(delegate_); |
base::ThreadTaskRunnerHandle::Get()->PostTask( |
FROM_HERE, |
- base::Bind(&QuicReliableClientStream::NotifyDelegateOfDataAvailable, |
+ base::Bind(&QuicChromiumClientStream::NotifyDelegateOfDataAvailable, |
weak_factory_.GetWeakPtr())); |
} |
-void QuicReliableClientStream::NotifyDelegateOfDataAvailable() { |
+void QuicChromiumClientStream::NotifyDelegateOfDataAvailable() { |
if (delegate_) |
delegate_->OnDataAvailable(); |
} |