Connection level flow control (CLFC) accounting on receipt of FIN/RST

net/quic/reliable_quic_stream.cc

Index: net/quic/reliable_quic_stream.cc
diff --git a/net/quic/reliable_quic_stream.cc b/net/quic/reliable_quic_stream.cc
index b73185b71a728adb7e95fd400727068ea7a1a3f2..a223673e3e69296c6ea0374348c5b6f10b5e9874 100644
--- a/net/quic/reliable_quic_stream.cc
+++ b/net/quic/reliable_quic_stream.cc
@@ -121,7 +121,9 @@ ReliableQuicStream::ReliableQuicStream(QuicStreamId id, QuicSession* session)
       write_side_closed_(false),
       fin_buffered_(false),
       fin_sent_(false),
+      fin_received_(false),
       rst_sent_(false),
+      rst_received_(false),
       is_server_(session_->is_server()),
       flow_controller_(
           session_->connection(),
@@ -150,6 +152,10 @@ bool ReliableQuicStream::OnStreamFrame(const QuicStreamFrame& frame) {
     return false;
   }
 
+  if (frame.fin) {
+    fin_received_ = true;
+  }
+
   // This count include duplicate data received.
   size_t frame_payload_size = frame.data.TotalBufferSize();
   stream_bytes_read_ += frame_payload_size;
@@ -178,6 +184,7 @@ int ReliableQuicStream::num_duplicate_frames_received() const {
 }
 
 void ReliableQuicStream::OnStreamReset(const QuicRstStreamFrame& frame) {
+  rst_received_ = true;
   MaybeIncreaseHighestReceivedOffset(frame.byte_offset);
 
   stream_error_ = frame.error_code;