Index: net/quic/quic_session.cc |
diff --git a/net/quic/quic_session.cc b/net/quic/quic_session.cc |
index 7fd5ae9c73217341e85c514be95b31e94174d03d..0f5be9c9dffd3b3f625dc6ee06dd45acbf6b70e7 100644 |
--- a/net/quic/quic_session.cc |
+++ b/net/quic/quic_session.cc |
@@ -428,12 +428,6 @@ 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); |
@@ -760,6 +754,13 @@ bool QuicSession::GetSSLInfo(SSLInfo* ssl_info) const { |
void QuicSession::PostProcessAfterData() { |
STLDeleteElements(&closed_streams_); |
closed_streams_.clear(); |
+ |
+ if (FLAGS_close_quic_connection_unfinished_streams_2 && |
+ 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); |
+ } |
} |
void QuicSession::OnSuccessfulVersionNegotiation(const QuicVersion& version) { |