Index: net/quic/reliable_quic_stream.cc |
diff --git a/net/quic/reliable_quic_stream.cc b/net/quic/reliable_quic_stream.cc |
index b60a94db68b67bdedfb3db955b6e042d29a0219d..f72dc09f3c334bc7e82cda718887b374370f1932 100644 |
--- a/net/quic/reliable_quic_stream.cc |
+++ b/net/quic/reliable_quic_stream.cc |
@@ -307,9 +307,9 @@ QuicConsumedData ReliableQuicStream::WritevData( |
write_length = static_cast<size_t>(send_window); |
} |
- QuicConsumedData consumed_data = |
- session()->WritevData(id(), QuicIOVector(iov, iov_count, write_length), |
- stream_bytes_written_, fin, ack_listener); |
+ QuicConsumedData consumed_data = session()->WritevData( |
+ this, id(), QuicIOVector(iov, iov_count, write_length), |
+ stream_bytes_written_, fin, ack_listener); |
stream_bytes_written_ += consumed_data.bytes_consumed; |
AddBytesSent(consumed_data.bytes_consumed); |
@@ -378,6 +378,10 @@ void ReliableQuicStream::StopReading() { |
sequencer_.StopReading(); |
} |
+const IPEndPoint& ReliableQuicStream::PeerAddressOfLatestPacket() const { |
+ return session_->connection()->last_packet_source_address(); |
+} |
+ |
void ReliableQuicStream::OnClose() { |
CloseReadSide(); |
CloseWriteSide(); |