Landing Recent QUIC changes until 5/14/2016 02:25:25 UTC

net/quic/reliable_quic_stream.cc

 // 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/reliable_quic_stream.h"
 
 #include "base/logging.h"
 #include "net/quic/iovector.h"
 #include "net/quic/quic_bug_tracker.h"
 #include "net/quic/quic_flags.h"
@@ skipping 289 matching lines @@
   }
 
   if (write_length > send_window) {
     // Don't send the FIN unless all the data will be sent.
     fin = false;
 
     // Writing more data would be a violation of flow control.
     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);
 
   // The write may have generated a write error causing this stream to be
   // closed. If so, simply return without marking the stream write blocked.
   if (write_side_closed_) {
     return consumed_data;
   }
 
@@ skipping 48 matching lines @@
 
 QuicVersion ReliableQuicStream::version() const {
   return session_->connection()->version();
 }
 
 void ReliableQuicStream::StopReading() {
   DVLOG(1) << ENDPOINT << "Stop reading from stream " << id();
   sequencer_.StopReading();
 }
 
+const IPEndPoint& ReliableQuicStream::PeerAddressOfLatestPacket() const {
+  return session_->connection()->last_packet_source_address();
+}
+
 void ReliableQuicStream::OnClose() {
   CloseReadSide();
   CloseWriteSide();
 
   if (!fin_sent_ && !rst_sent_) {
     // For flow control accounting, tell the peer how many bytes have been
     // written on this stream before termination. Done here if needed, using a
     // RST_STREAM frame.
     DVLOG(1) << ENDPOINT << "Sending RST_STREAM in OnClose: " << id();
     session_->SendRstStream(id(), QUIC_RST_ACKNOWLEDGEMENT,
@@ skipping 60 matching lines @@
   }
 }
 
 void ReliableQuicStream::UpdateSendWindowOffset(QuicStreamOffset new_window) {
   if (flow_controller_.UpdateSendWindowOffset(new_window)) {
     OnCanWrite();
   }
 }
 
 }  // namespace net