| 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();
|
|
|