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