| 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) {
|
|
|