Index: net/quic/quic_session.cc |
diff --git a/net/quic/quic_session.cc b/net/quic/quic_session.cc |
index ab69d3d0e48926a28a8366e5e70d3d08da8facc3..f2277271695e183fa1dd83cf27320e676fb21176 100644 |
--- a/net/quic/quic_session.cc |
+++ b/net/quic/quic_session.cc |
@@ -430,6 +430,12 @@ void QuicSession::CloseStreamInner(QuicStreamId stream_id, |
stream->flow_controller()->IsEnabled()) { |
locally_closed_streams_highest_offset_[stream_id] = |
stream->flow_controller()->highest_received_byte_offset(); |
+ if (FLAGS_close_quic_connection_unfinished_streams && |
+ connection()->connected() && |
+ locally_closed_streams_highest_offset_.size() > max_open_streams_) { |
+ // A buggy client may fail to send FIN/RSTs. Don't tolerate this. |
+ connection_->SendConnectionClose(QUIC_TOO_MANY_UNFINISHED_STREAMS); |
+ } |
} |
stream_map_.erase(it); |