diff options
Diffstat (limited to 'chromium/net/third_party/quiche/src/quic/test_tools/quic_session_peer.cc')
-rw-r--r-- | chromium/net/third_party/quiche/src/quic/test_tools/quic_session_peer.cc | 22 |
1 files changed, 16 insertions, 6 deletions
diff --git a/chromium/net/third_party/quiche/src/quic/test_tools/quic_session_peer.cc b/chromium/net/third_party/quiche/src/quic/test_tools/quic_session_peer.cc index cbaf5d62be9..ab28828cc14 100644 --- a/chromium/net/third_party/quiche/src/quic/test_tools/quic_session_peer.cc +++ b/chromium/net/third_party/quiche/src/quic/test_tools/quic_session_peer.cc @@ -143,12 +143,6 @@ QuicSession::ZombieStreamMap& QuicSessionPeer::zombie_streams( } // static -QuicUnorderedSet<QuicStreamId>* QuicSessionPeer::GetDrainingStreams( - QuicSession* session) { - return &session->draining_streams_; -} - -// static void QuicSessionPeer::ActivateStream(QuicSession* session, std::unique_ptr<QuicStream> stream) { return session->ActivateStream(std::move(stream)); @@ -239,5 +233,21 @@ void QuicSessionPeer::SetPerspective(QuicSession* session, session->perspective_ = perspective; } +// static +size_t QuicSessionPeer::GetNumOpenDynamicStreams(QuicSession* session) { + size_t result = 0; + for (const auto& it : session->stream_map_) { + if (!it.second->is_static()) { + ++result; + } + } + // Exclude draining streams. + result -= session->GetNumDrainingStreams(); + // Add locally closed streams. + result += session->locally_closed_streams_highest_offset_.size(); + + return result; +} + } // namespace test } // namespace quic |