Index: net/quic/quic_session.cc |
diff --git a/net/quic/quic_session.cc b/net/quic/quic_session.cc |
index 2a325d680a087dc95e36401f2292ee96cbbfb93f..0eba20fe96901177675db3c9ff84d4d7f0741430 100644 |
--- a/net/quic/quic_session.cc |
+++ b/net/quic/quic_session.cc |
@@ -712,31 +712,18 @@ bool QuicSession::IsClosedStream(QuicStreamId id) { |
} |
size_t QuicSession::GetNumOpenStreams() const { |
- if (FLAGS_quic_count_unfinished_as_open_streams) { |
- if (FLAGS_allow_many_available_streams) { |
- return dynamic_stream_map_.size() - draining_streams_.size() + |
- locally_closed_streams_highest_offset_.size(); |
- } else { |
- return dynamic_stream_map_.size() + available_streams_.size() - |
- draining_streams_.size() + |
- locally_closed_streams_highest_offset_.size(); |
- } |
+ if (FLAGS_allow_many_available_streams) { |
+ return dynamic_stream_map_.size() - draining_streams_.size() + |
+ locally_closed_streams_highest_offset_.size(); |
} else { |
- if (FLAGS_allow_many_available_streams) { |
- return dynamic_stream_map_.size() - draining_streams_.size(); |
- } else { |
- return dynamic_stream_map_.size() + available_streams_.size() - |
- draining_streams_.size(); |
- } |
+ return dynamic_stream_map_.size() + available_streams_.size() - |
+ draining_streams_.size() + |
+ locally_closed_streams_highest_offset_.size(); |
} |
} |
size_t QuicSession::GetNumActiveStreams() const { |
- if (FLAGS_quic_count_unfinished_as_open_streams) { |
- return GetNumOpenStreams() - locally_closed_streams_highest_offset_.size(); |
- } else { |
- return GetNumOpenStreams(); |
- } |
+ return GetNumOpenStreams() - locally_closed_streams_highest_offset_.size(); |
} |
size_t QuicSession::GetNumAvailableStreams() const { |
@@ -776,12 +763,7 @@ bool QuicSession::HasDataToWrite() const { |
void QuicSession::PostProcessAfterData() { |
STLDeleteElements(&closed_streams_); |
- |
- // A buggy client may fail to send FIN/RSTs. Don't tolerate this. |
- if (!FLAGS_quic_count_unfinished_as_open_streams && |
- locally_closed_streams_highest_offset_.size() > max_open_streams_) { |
- CloseConnection(QUIC_TOO_MANY_UNFINISHED_STREAMS); |
- } |
+ closed_streams_.clear(); |
} |
bool QuicSession::IsConnectionFlowControlBlocked() const { |