Index: net/quic/reliable_quic_stream.cc |
diff --git a/net/quic/reliable_quic_stream.cc b/net/quic/reliable_quic_stream.cc |
index d3e7cf81c4dc3887f105bdad05b1be726fb63d0d..1ad557bcc826e1798931d0c20b58e59d633db3bb 100644 |
--- a/net/quic/reliable_quic_stream.cc |
+++ b/net/quic/reliable_quic_stream.cc |
@@ -90,18 +90,22 @@ bool ReliableQuicStream::HasBytesToRead() const { |
return sequencer_.HasBytesToRead(); |
} |
+const IPEndPoint& ReliableQuicStream::GetPeerAddress() const { |
+ return session_->peer_address(); |
+} |
+ |
int ReliableQuicStream::WriteData(StringPiece data, bool fin) { |
if (write_side_closed_) { |
DLOG(ERROR) << "Attempt to write when the write side is closed"; |
return 0; |
} |
- session()->WriteData(id(), data, offset_, fin); |
+ int rv = session()->WriteData(id(), data, offset_, fin); |
offset_ += data.length(); |
if (fin) { |
CloseWriteSide(); |
} |
- return data.length(); |
+ return rv; |
} |
void ReliableQuicStream::CloseReadSide() { |
@@ -112,6 +116,7 @@ void ReliableQuicStream::CloseReadSide() { |
read_side_closed_ = true; |
if (write_side_closed_) { |
+ DLOG(INFO) << "Closing stream: " << id(); |
session_->CloseStream(id()); |
} |
} |
@@ -124,6 +129,7 @@ void ReliableQuicStream::CloseWriteSide() { |
write_side_closed_ = true; |
if (read_side_closed_) { |
+ DLOG(INFO) << "Closing stream: " << id(); |
session_->CloseStream(id()); |
} |
} |