|  | // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 
|  | // Use of this source code is governed by a BSD-style license that can be | 
|  | // found in the LICENSE file. | 
|  |  | 
|  | #include "quic/core/quic_session.h" | 
|  |  | 
|  | #include <cstdint> | 
|  | #include <set> | 
|  | #include <string> | 
|  | #include <utility> | 
|  |  | 
|  | #include "absl/base/macros.h" | 
|  | #include "absl/memory/memory.h" | 
|  | #include "absl/strings/str_cat.h" | 
|  | #include "absl/strings/string_view.h" | 
|  | #include "absl/types/optional.h" | 
|  | #include "quic/core/crypto/crypto_protocol.h" | 
|  | #include "quic/core/crypto/null_decrypter.h" | 
|  | #include "quic/core/crypto/null_encrypter.h" | 
|  | #include "quic/core/crypto/transport_parameters.h" | 
|  | #include "quic/core/frames/quic_max_streams_frame.h" | 
|  | #include "quic/core/quic_crypto_stream.h" | 
|  | #include "quic/core/quic_data_writer.h" | 
|  | #include "quic/core/quic_packets.h" | 
|  | #include "quic/core/quic_stream.h" | 
|  | #include "quic/core/quic_types.h" | 
|  | #include "quic/core/quic_utils.h" | 
|  | #include "quic/core/quic_versions.h" | 
|  | #include "quic/platform/api/quic_expect_bug.h" | 
|  | #include "quic/platform/api/quic_flags.h" | 
|  | #include "quic/platform/api/quic_mem_slice_storage.h" | 
|  | #include "quic/platform/api/quic_test.h" | 
|  | #include "quic/test_tools/mock_quic_session_visitor.h" | 
|  | #include "quic/test_tools/quic_config_peer.h" | 
|  | #include "quic/test_tools/quic_connection_peer.h" | 
|  | #include "quic/test_tools/quic_flow_controller_peer.h" | 
|  | #include "quic/test_tools/quic_session_peer.h" | 
|  | #include "quic/test_tools/quic_stream_id_manager_peer.h" | 
|  | #include "quic/test_tools/quic_stream_peer.h" | 
|  | #include "quic/test_tools/quic_stream_send_buffer_peer.h" | 
|  | #include "quic/test_tools/quic_test_utils.h" | 
|  |  | 
|  | using spdy::kV3HighestPriority; | 
|  | using spdy::SpdyPriority; | 
|  | using ::testing::_; | 
|  | using ::testing::AnyNumber; | 
|  | using ::testing::AtLeast; | 
|  | using ::testing::InSequence; | 
|  | using ::testing::Invoke; | 
|  | using ::testing::NiceMock; | 
|  | using ::testing::Return; | 
|  | using ::testing::StrictMock; | 
|  | using ::testing::WithArg; | 
|  |  | 
|  | namespace quic { | 
|  | namespace test { | 
|  | namespace { | 
|  |  | 
|  | class TestCryptoStream : public QuicCryptoStream, public QuicCryptoHandshaker { | 
|  | public: | 
|  | explicit TestCryptoStream(QuicSession* session) | 
|  | : QuicCryptoStream(session), | 
|  | QuicCryptoHandshaker(this, session), | 
|  | encryption_established_(false), | 
|  | one_rtt_keys_available_(false), | 
|  | params_(new QuicCryptoNegotiatedParameters) { | 
|  | // Simulate a negotiated cipher_suite with a fake value. | 
|  | params_->cipher_suite = 1; | 
|  | } | 
|  |  | 
|  | void EstablishZeroRttEncryption() { | 
|  | encryption_established_ = true; | 
|  | session()->connection()->SetEncrypter( | 
|  | ENCRYPTION_ZERO_RTT, | 
|  | std::make_unique<NullEncrypter>(session()->perspective())); | 
|  | } | 
|  |  | 
|  | void OnHandshakeMessage(const CryptoHandshakeMessage& /*message*/) override { | 
|  | encryption_established_ = true; | 
|  | one_rtt_keys_available_ = true; | 
|  | QuicErrorCode error; | 
|  | std::string error_details; | 
|  | session()->config()->SetInitialStreamFlowControlWindowToSend( | 
|  | kInitialStreamFlowControlWindowForTest); | 
|  | session()->config()->SetInitialSessionFlowControlWindowToSend( | 
|  | kInitialSessionFlowControlWindowForTest); | 
|  | if (session()->version().UsesTls()) { | 
|  | if (session()->perspective() == Perspective::IS_CLIENT) { | 
|  | session()->config()->SetOriginalConnectionIdToSend( | 
|  | session()->connection()->connection_id()); | 
|  | session()->config()->SetInitialSourceConnectionIdToSend( | 
|  | session()->connection()->connection_id()); | 
|  | } else { | 
|  | session()->config()->SetInitialSourceConnectionIdToSend( | 
|  | session()->connection()->client_connection_id()); | 
|  | } | 
|  | TransportParameters transport_parameters; | 
|  | EXPECT_TRUE( | 
|  | session()->config()->FillTransportParameters(&transport_parameters)); | 
|  | error = session()->config()->ProcessTransportParameters( | 
|  | transport_parameters, /* is_resumption = */ false, &error_details); | 
|  | } else { | 
|  | CryptoHandshakeMessage msg; | 
|  | session()->config()->ToHandshakeMessage(&msg, transport_version()); | 
|  | error = | 
|  | session()->config()->ProcessPeerHello(msg, CLIENT, &error_details); | 
|  | } | 
|  | EXPECT_THAT(error, IsQuicNoError()); | 
|  | session()->OnNewEncryptionKeyAvailable( | 
|  | ENCRYPTION_FORWARD_SECURE, | 
|  | std::make_unique<NullEncrypter>(session()->perspective())); | 
|  | session()->OnConfigNegotiated(); | 
|  | if (session()->connection()->version().handshake_protocol == | 
|  | PROTOCOL_TLS1_3) { | 
|  | session()->OnTlsHandshakeComplete(); | 
|  | } else { | 
|  | session()->SetDefaultEncryptionLevel(ENCRYPTION_FORWARD_SECURE); | 
|  | } | 
|  | session()->DiscardOldEncryptionKey(ENCRYPTION_INITIAL); | 
|  | } | 
|  |  | 
|  | // QuicCryptoStream implementation | 
|  | ssl_early_data_reason_t EarlyDataReason() const override { | 
|  | return ssl_early_data_unknown; | 
|  | } | 
|  | bool encryption_established() const override { | 
|  | return encryption_established_; | 
|  | } | 
|  | bool one_rtt_keys_available() const override { | 
|  | return one_rtt_keys_available_; | 
|  | } | 
|  | const QuicCryptoNegotiatedParameters& crypto_negotiated_params() | 
|  | const override { | 
|  | return *params_; | 
|  | } | 
|  | CryptoMessageParser* crypto_message_parser() override { | 
|  | return QuicCryptoHandshaker::crypto_message_parser(); | 
|  | } | 
|  | void OnPacketDecrypted(EncryptionLevel /*level*/) override {} | 
|  | void OnOneRttPacketAcknowledged() override {} | 
|  | void OnHandshakePacketSent() override {} | 
|  | void OnHandshakeDoneReceived() override {} | 
|  | void OnNewTokenReceived(absl::string_view /*token*/) override {} | 
|  | std::string GetAddressToken( | 
|  | const CachedNetworkParameters* /*cached_network_parameters*/) | 
|  | const override { | 
|  | return ""; | 
|  | } | 
|  | bool ValidateAddressToken(absl::string_view /*token*/) const override { | 
|  | return true; | 
|  | } | 
|  | const CachedNetworkParameters* PreviousCachedNetworkParams() const override { | 
|  | return nullptr; | 
|  | } | 
|  | void SetPreviousCachedNetworkParams( | 
|  | CachedNetworkParameters /*cached_network_params*/) override {} | 
|  | HandshakeState GetHandshakeState() const override { | 
|  | return one_rtt_keys_available() ? HANDSHAKE_COMPLETE : HANDSHAKE_START; | 
|  | } | 
|  | void SetServerApplicationStateForResumption( | 
|  | std::unique_ptr<ApplicationState> /*application_state*/) override {} | 
|  | MOCK_METHOD(bool, KeyUpdateSupportedLocally, (), (const, override)); | 
|  | MOCK_METHOD(std::unique_ptr<QuicDecrypter>, | 
|  | AdvanceKeysAndCreateCurrentOneRttDecrypter, | 
|  | (), | 
|  | (override)); | 
|  | MOCK_METHOD(std::unique_ptr<QuicEncrypter>, | 
|  | CreateCurrentOneRttEncrypter, | 
|  | (), | 
|  | (override)); | 
|  |  | 
|  | MOCK_METHOD(void, OnCanWrite, (), (override)); | 
|  | bool HasPendingCryptoRetransmission() const override { return false; } | 
|  |  | 
|  | MOCK_METHOD(bool, HasPendingRetransmission, (), (const, override)); | 
|  |  | 
|  | void OnConnectionClosed(QuicErrorCode /*error*/, | 
|  | ConnectionCloseSource /*source*/) override {} | 
|  |  | 
|  | bool ExportKeyingMaterial(absl::string_view /*label*/, | 
|  | absl::string_view /*context*/, | 
|  | size_t /*result_len*/, | 
|  | std::string* /*result*/) override { | 
|  | return false; | 
|  | } | 
|  |  | 
|  | SSL* GetSsl() const override { return nullptr; } | 
|  |  | 
|  | private: | 
|  | using QuicCryptoStream::session; | 
|  |  | 
|  | bool encryption_established_; | 
|  | bool one_rtt_keys_available_; | 
|  | QuicReferenceCountedPointer<QuicCryptoNegotiatedParameters> params_; | 
|  | }; | 
|  |  | 
|  | class TestStream : public QuicStream { | 
|  | public: | 
|  | TestStream(QuicStreamId id, QuicSession* session, StreamType type) | 
|  | : TestStream(id, session, /*is_static=*/false, type) {} | 
|  |  | 
|  | TestStream(QuicStreamId id, | 
|  | QuicSession* session, | 
|  | bool is_static, | 
|  | StreamType type) | 
|  | : QuicStream(id, session, is_static, type) {} | 
|  |  | 
|  | TestStream(PendingStream* pending, QuicSession* session) | 
|  | : QuicStream(pending, session, /*is_static=*/false) {} | 
|  |  | 
|  | using QuicStream::CloseWriteSide; | 
|  | using QuicStream::WriteMemSlices; | 
|  |  | 
|  | void OnDataAvailable() override {} | 
|  |  | 
|  | MOCK_METHOD(void, OnCanWrite, (), (override)); | 
|  | MOCK_METHOD(bool, | 
|  | RetransmitStreamData, | 
|  | (QuicStreamOffset, QuicByteCount, bool, TransmissionType), | 
|  | (override)); | 
|  |  | 
|  | MOCK_METHOD(bool, HasPendingRetransmission, (), (const, override)); | 
|  | }; | 
|  |  | 
|  | class TestSession : public QuicSession { | 
|  | public: | 
|  | explicit TestSession(QuicConnection* connection, | 
|  | MockQuicSessionVisitor* session_visitor) | 
|  | : QuicSession(connection, | 
|  | session_visitor, | 
|  | DefaultQuicConfig(), | 
|  | CurrentSupportedVersions(), | 
|  | /*num_expected_unidirectional_static_streams = */ 0), | 
|  | crypto_stream_(this), | 
|  | writev_consumes_all_data_(false), | 
|  | uses_pending_streams_(false), | 
|  | num_incoming_streams_created_(0) { | 
|  | EXPECT_CALL(*GetMutableCryptoStream(), KeyUpdateSupportedLocally()) | 
|  | .WillRepeatedly(Return(false)); | 
|  | Initialize(); | 
|  | this->connection()->SetEncrypter( | 
|  | ENCRYPTION_FORWARD_SECURE, | 
|  | std::make_unique<NullEncrypter>(connection->perspective())); | 
|  | if (this->connection()->version().SupportsAntiAmplificationLimit()) { | 
|  | QuicConnectionPeer::SetAddressValidated(this->connection()); | 
|  | } | 
|  | } | 
|  |  | 
|  | ~TestSession() override { DeleteConnection(); } | 
|  |  | 
|  | TestCryptoStream* GetMutableCryptoStream() override { | 
|  | return &crypto_stream_; | 
|  | } | 
|  |  | 
|  | const TestCryptoStream* GetCryptoStream() const override { | 
|  | return &crypto_stream_; | 
|  | } | 
|  |  | 
|  | TestStream* CreateOutgoingBidirectionalStream() { | 
|  | QuicStreamId id = GetNextOutgoingBidirectionalStreamId(); | 
|  | if (id == | 
|  | QuicUtils::GetInvalidStreamId(connection()->transport_version())) { | 
|  | return nullptr; | 
|  | } | 
|  | TestStream* stream = new TestStream(id, this, BIDIRECTIONAL); | 
|  | ActivateStream(absl::WrapUnique(stream)); | 
|  | return stream; | 
|  | } | 
|  |  | 
|  | TestStream* CreateOutgoingUnidirectionalStream() { | 
|  | TestStream* stream = new TestStream(GetNextOutgoingUnidirectionalStreamId(), | 
|  | this, WRITE_UNIDIRECTIONAL); | 
|  | ActivateStream(absl::WrapUnique(stream)); | 
|  | return stream; | 
|  | } | 
|  |  | 
|  | TestStream* CreateIncomingStream(QuicStreamId id) override { | 
|  | // Enforce the limit on the number of open streams. | 
|  | if (!VersionHasIetfQuicFrames(connection()->transport_version()) && | 
|  | stream_id_manager().num_open_incoming_streams() + 1 > | 
|  | max_open_incoming_bidirectional_streams()) { | 
|  | // No need to do this test for version 99; it's done by | 
|  | // QuicSession::GetOrCreateStream. | 
|  | connection()->CloseConnection( | 
|  | QUIC_TOO_MANY_OPEN_STREAMS, "Too many streams!", | 
|  | ConnectionCloseBehavior::SEND_CONNECTION_CLOSE_PACKET); | 
|  | return nullptr; | 
|  | } | 
|  |  | 
|  | TestStream* stream = new TestStream( | 
|  | id, this, | 
|  | DetermineStreamType(id, connection()->version(), perspective(), | 
|  | /*is_incoming=*/true, BIDIRECTIONAL)); | 
|  | ActivateStream(absl::WrapUnique(stream)); | 
|  | ++num_incoming_streams_created_; | 
|  | return stream; | 
|  | } | 
|  |  | 
|  | TestStream* CreateIncomingStream(PendingStream* pending) override { | 
|  | TestStream* stream = new TestStream(pending, this); | 
|  | ActivateStream(absl::WrapUnique(stream)); | 
|  | ++num_incoming_streams_created_; | 
|  | return stream; | 
|  | } | 
|  |  | 
|  | // QuicSession doesn't do anything in this method. So it's overridden here to | 
|  | // test that the session handles pending streams correctly in terms of | 
|  | // receiving stream frames. | 
|  | QuicStream* ProcessPendingStream(PendingStream* pending) override { | 
|  | if (pending->is_bidirectional()) { | 
|  | return CreateIncomingStream(pending); | 
|  | } | 
|  | struct iovec iov; | 
|  | if (pending->sequencer()->GetReadableRegion(&iov)) { | 
|  | // Create TestStream once the first byte is received. | 
|  | return CreateIncomingStream(pending); | 
|  | } | 
|  | return nullptr; | 
|  | } | 
|  |  | 
|  | bool IsClosedStream(QuicStreamId id) { | 
|  | return QuicSession::IsClosedStream(id); | 
|  | } | 
|  |  | 
|  | QuicStream* GetOrCreateStream(QuicStreamId stream_id) { | 
|  | return QuicSession::GetOrCreateStream(stream_id); | 
|  | } | 
|  |  | 
|  | bool ShouldKeepConnectionAlive() const override { | 
|  | return GetNumActiveStreams() > 0; | 
|  | } | 
|  |  | 
|  | QuicConsumedData WritevData(QuicStreamId id, size_t write_length, | 
|  | QuicStreamOffset offset, StreamSendingState state, | 
|  | TransmissionType type, | 
|  | EncryptionLevel level) override { | 
|  | bool fin = state != NO_FIN; | 
|  | QuicConsumedData consumed(write_length, fin); | 
|  | if (!writev_consumes_all_data_) { | 
|  | consumed = | 
|  | QuicSession::WritevData(id, write_length, offset, state, type, level); | 
|  | } | 
|  | QuicSessionPeer::GetWriteBlockedStreams(this)->UpdateBytesForStream( | 
|  | id, consumed.bytes_consumed); | 
|  | return consumed; | 
|  | } | 
|  |  | 
|  | MOCK_METHOD(void, | 
|  | OnCanCreateNewOutgoingStream, | 
|  | (bool unidirectional), | 
|  | (override)); | 
|  |  | 
|  | void set_writev_consumes_all_data(bool val) { | 
|  | writev_consumes_all_data_ = val; | 
|  | } | 
|  |  | 
|  | QuicConsumedData SendStreamData(QuicStream* stream) { | 
|  | struct iovec iov; | 
|  | if (!QuicUtils::IsCryptoStreamId(connection()->transport_version(), | 
|  | stream->id()) && | 
|  | this->connection()->encryption_level() != ENCRYPTION_FORWARD_SECURE) { | 
|  | this->connection()->SetDefaultEncryptionLevel(ENCRYPTION_FORWARD_SECURE); | 
|  | } | 
|  | MakeIOVector("not empty", &iov); | 
|  | QuicStreamPeer::SendBuffer(stream).SaveStreamData(&iov, 1, 0, 9); | 
|  | QuicConsumedData consumed = | 
|  | WritevData(stream->id(), 9, 0, FIN, NOT_RETRANSMISSION, | 
|  | GetEncryptionLevelToSendApplicationData()); | 
|  | QuicStreamPeer::SendBuffer(stream).OnStreamDataConsumed( | 
|  | consumed.bytes_consumed); | 
|  | return consumed; | 
|  | } | 
|  |  | 
|  | const QuicFrame& save_frame() { return save_frame_; } | 
|  |  | 
|  | bool SaveFrame(const QuicFrame& frame) { | 
|  | save_frame_ = frame; | 
|  | DeleteFrame(&const_cast<QuicFrame&>(frame)); | 
|  | return true; | 
|  | } | 
|  |  | 
|  | QuicConsumedData SendLargeFakeData(QuicStream* stream, int bytes) { | 
|  | QUICHE_DCHECK(writev_consumes_all_data_); | 
|  | return WritevData(stream->id(), bytes, 0, FIN, NOT_RETRANSMISSION, | 
|  | GetEncryptionLevelToSendApplicationData()); | 
|  | } | 
|  |  | 
|  | bool UsesPendingStreamForFrame(QuicFrameType type, | 
|  | QuicStreamId stream_id) const override { | 
|  | if (!uses_pending_streams_) { | 
|  | return false; | 
|  | } | 
|  | // Uses pending stream for STREAM/RST_STREAM frames with unidirectional read | 
|  | // stream and uses pending stream for | 
|  | // STREAM/RST_STREAM/STOP_SENDING/WINDOW_UPDATE frames with bidirectional | 
|  | // stream. | 
|  | bool is_incoming_stream = IsIncomingStream(stream_id); | 
|  | StreamType stream_type = QuicUtils::GetStreamType( | 
|  | stream_id, perspective(), is_incoming_stream, version()); | 
|  | switch (type) { | 
|  | case STREAM_FRAME: | 
|  | ABSL_FALLTHROUGH_INTENDED; | 
|  | case RST_STREAM_FRAME: | 
|  | return is_incoming_stream; | 
|  | case STOP_SENDING_FRAME: | 
|  | ABSL_FALLTHROUGH_INTENDED; | 
|  | case WINDOW_UPDATE_FRAME: | 
|  | return stream_type == BIDIRECTIONAL; | 
|  | default: | 
|  | return false; | 
|  | } | 
|  | } | 
|  |  | 
|  | bool ShouldProcessPendingStreamImmediately() const override { | 
|  | return process_pending_stream_immediately_; | 
|  | } | 
|  |  | 
|  | void set_uses_pending_streams(bool uses_pending_streams) { | 
|  | uses_pending_streams_ = uses_pending_streams; | 
|  | } | 
|  |  | 
|  | void set_process_pending_stream_immediately( | 
|  | bool process_pending_stream_immediately) { | 
|  | process_pending_stream_immediately_ = process_pending_stream_immediately; | 
|  | } | 
|  |  | 
|  | int num_incoming_streams_created() const { | 
|  | return num_incoming_streams_created_; | 
|  | } | 
|  |  | 
|  | using QuicSession::ActivateStream; | 
|  | using QuicSession::CanOpenNextOutgoingBidirectionalStream; | 
|  | using QuicSession::CanOpenNextOutgoingUnidirectionalStream; | 
|  | using QuicSession::closed_streams; | 
|  | using QuicSession::GetNextOutgoingBidirectionalStreamId; | 
|  | using QuicSession::GetNextOutgoingUnidirectionalStreamId; | 
|  |  | 
|  | private: | 
|  | StrictMock<TestCryptoStream> crypto_stream_; | 
|  |  | 
|  | bool writev_consumes_all_data_; | 
|  | bool uses_pending_streams_; | 
|  | bool process_pending_stream_immediately_ = true; | 
|  | QuicFrame save_frame_; | 
|  | int num_incoming_streams_created_; | 
|  | }; | 
|  |  | 
|  | class QuicSessionTestBase : public QuicTestWithParam<ParsedQuicVersion> { | 
|  | protected: | 
|  | QuicSessionTestBase(Perspective perspective, bool configure_session) | 
|  | : connection_( | 
|  | new StrictMock<MockQuicConnection>(&helper_, | 
|  | &alarm_factory_, | 
|  | perspective, | 
|  | SupportedVersions(GetParam()))), | 
|  | session_(connection_, &session_visitor_), | 
|  | configure_session_(configure_session) { | 
|  | session_.config()->SetInitialStreamFlowControlWindowToSend( | 
|  | kInitialStreamFlowControlWindowForTest); | 
|  | session_.config()->SetInitialSessionFlowControlWindowToSend( | 
|  | kInitialSessionFlowControlWindowForTest); | 
|  |  | 
|  | if (configure_session) { | 
|  | if (VersionHasIetfQuicFrames(transport_version())) { | 
|  | EXPECT_CALL(session_, OnCanCreateNewOutgoingStream(false)).Times(1); | 
|  | EXPECT_CALL(session_, OnCanCreateNewOutgoingStream(true)).Times(1); | 
|  | } | 
|  | QuicConfigPeer::SetReceivedMaxBidirectionalStreams( | 
|  | session_.config(), kDefaultMaxStreamsPerConnection); | 
|  | QuicConfigPeer::SetReceivedMaxUnidirectionalStreams( | 
|  | session_.config(), kDefaultMaxStreamsPerConnection); | 
|  | QuicConfigPeer::SetReceivedInitialMaxStreamDataBytesUnidirectional( | 
|  | session_.config(), kMinimumFlowControlSendWindow); | 
|  | QuicConfigPeer::SetReceivedInitialMaxStreamDataBytesIncomingBidirectional( | 
|  | session_.config(), kMinimumFlowControlSendWindow); | 
|  | QuicConfigPeer::SetReceivedInitialMaxStreamDataBytesOutgoingBidirectional( | 
|  | session_.config(), kMinimumFlowControlSendWindow); | 
|  | QuicConfigPeer::SetReceivedInitialSessionFlowControlWindow( | 
|  | session_.config(), kMinimumFlowControlSendWindow); | 
|  | connection_->AdvanceTime(QuicTime::Delta::FromSeconds(1)); | 
|  | session_.OnConfigNegotiated(); | 
|  | } | 
|  | TestCryptoStream* crypto_stream = session_.GetMutableCryptoStream(); | 
|  | EXPECT_CALL(*crypto_stream, HasPendingRetransmission()) | 
|  | .Times(testing::AnyNumber()); | 
|  | testing::Mock::VerifyAndClearExpectations(&session_); | 
|  | } | 
|  |  | 
|  | ~QuicSessionTestBase() { | 
|  | if (configure_session_) { | 
|  | EXPECT_TRUE(session_.is_configured()); | 
|  | } | 
|  | } | 
|  |  | 
|  | void CheckClosedStreams() { | 
|  | QuicStreamId first_stream_id = QuicUtils::GetFirstBidirectionalStreamId( | 
|  | connection_->transport_version(), Perspective::IS_CLIENT); | 
|  | if (!QuicVersionUsesCryptoFrames(connection_->transport_version())) { | 
|  | first_stream_id = | 
|  | QuicUtils::GetCryptoStreamId(connection_->transport_version()); | 
|  | } | 
|  | for (QuicStreamId i = first_stream_id; i < 100; i++) { | 
|  | if (closed_streams_.find(i) == closed_streams_.end()) { | 
|  | EXPECT_FALSE(session_.IsClosedStream(i)) << " stream id: " << i; | 
|  | } else { | 
|  | EXPECT_TRUE(session_.IsClosedStream(i)) << " stream id: " << i; | 
|  | } | 
|  | } | 
|  | } | 
|  |  | 
|  | void CloseStream(QuicStreamId id) { | 
|  | if (VersionHasIetfQuicFrames(transport_version())) { | 
|  | if (QuicUtils::GetStreamType( | 
|  | id, session_.perspective(), session_.IsIncomingStream(id), | 
|  | connection_->version()) == READ_UNIDIRECTIONAL) { | 
|  | // Verify STOP_SENDING but no RESET_STREAM is sent for | 
|  | // READ_UNIDIRECTIONAL streams. | 
|  | EXPECT_CALL(*connection_, SendControlFrame(_)) | 
|  | .Times(1) | 
|  | .WillOnce(Invoke(&ClearControlFrame)); | 
|  | EXPECT_CALL(*connection_, OnStreamReset(id, _)).Times(1); | 
|  | } else if (QuicUtils::GetStreamType( | 
|  | id, session_.perspective(), session_.IsIncomingStream(id), | 
|  | connection_->version()) == WRITE_UNIDIRECTIONAL) { | 
|  | // Verify RESET_STREAM but not STOP_SENDING is sent for write-only | 
|  | // stream. | 
|  | EXPECT_CALL(*connection_, SendControlFrame(_)) | 
|  | .Times(1) | 
|  | .WillOnce(Invoke(&ClearControlFrame)); | 
|  | EXPECT_CALL(*connection_, OnStreamReset(id, _)); | 
|  | } else { | 
|  | // Verify RESET_STREAM and STOP_SENDING are sent for BIDIRECTIONAL | 
|  | // streams. | 
|  | EXPECT_CALL(*connection_, SendControlFrame(_)) | 
|  | .Times(2) | 
|  | .WillRepeatedly(Invoke(&ClearControlFrame)); | 
|  | EXPECT_CALL(*connection_, OnStreamReset(id, _)); | 
|  | } | 
|  | } else { | 
|  | EXPECT_CALL(*connection_, SendControlFrame(_)) | 
|  | .WillOnce(Invoke(&ClearControlFrame)); | 
|  | EXPECT_CALL(*connection_, OnStreamReset(id, _)); | 
|  | } | 
|  | session_.ResetStream(id, QUIC_STREAM_CANCELLED); | 
|  | closed_streams_.insert(id); | 
|  | } | 
|  |  | 
|  | void CompleteHandshake() { | 
|  | CryptoHandshakeMessage msg; | 
|  | if (connection_->version().UsesTls() && | 
|  | connection_->perspective() == Perspective::IS_SERVER) { | 
|  | // HANDSHAKE_DONE frame. | 
|  | EXPECT_CALL(*connection_, SendControlFrame(_)) | 
|  | .WillOnce(Invoke(&ClearControlFrame)); | 
|  | } | 
|  | session_.GetMutableCryptoStream()->OnHandshakeMessage(msg); | 
|  | } | 
|  |  | 
|  | QuicTransportVersion transport_version() const { | 
|  | return connection_->transport_version(); | 
|  | } | 
|  |  | 
|  | QuicStreamId GetNthClientInitiatedBidirectionalId(int n) { | 
|  | return QuicUtils::GetFirstBidirectionalStreamId( | 
|  | connection_->transport_version(), Perspective::IS_CLIENT) + | 
|  | QuicUtils::StreamIdDelta(connection_->transport_version()) * n; | 
|  | } | 
|  |  | 
|  | QuicStreamId GetNthClientInitiatedUnidirectionalId(int n) { | 
|  | return QuicUtils::GetFirstUnidirectionalStreamId( | 
|  | connection_->transport_version(), Perspective::IS_CLIENT) + | 
|  | QuicUtils::StreamIdDelta(connection_->transport_version()) * n; | 
|  | } | 
|  |  | 
|  | QuicStreamId GetNthServerInitiatedBidirectionalId(int n) { | 
|  | return QuicUtils::GetFirstBidirectionalStreamId( | 
|  | connection_->transport_version(), Perspective::IS_SERVER) + | 
|  | QuicUtils::StreamIdDelta(connection_->transport_version()) * n; | 
|  | } | 
|  |  | 
|  | QuicStreamId GetNthServerInitiatedUnidirectionalId(int n) { | 
|  | return QuicUtils::GetFirstUnidirectionalStreamId( | 
|  | connection_->transport_version(), Perspective::IS_SERVER) + | 
|  | QuicUtils::StreamIdDelta(connection_->transport_version()) * n; | 
|  | } | 
|  |  | 
|  | QuicStreamId StreamCountToId(QuicStreamCount stream_count, | 
|  | Perspective perspective, | 
|  | bool bidirectional) { | 
|  | // Calculate and build up stream ID rather than use | 
|  | // GetFirst... because tests that rely on this method | 
|  | // needs to do the stream count where #1 is 0/1/2/3, and not | 
|  | // take into account that stream 0 is special. | 
|  | QuicStreamId id = | 
|  | ((stream_count - 1) * QuicUtils::StreamIdDelta(transport_version())); | 
|  | if (!bidirectional) { | 
|  | id |= 0x2; | 
|  | } | 
|  | if (perspective == Perspective::IS_SERVER) { | 
|  | id |= 0x1; | 
|  | } | 
|  | return id; | 
|  | } | 
|  |  | 
|  | MockQuicConnectionHelper helper_; | 
|  | MockAlarmFactory alarm_factory_; | 
|  | NiceMock<MockQuicSessionVisitor> session_visitor_; | 
|  | StrictMock<MockQuicConnection>* connection_; | 
|  | TestSession session_; | 
|  | std::set<QuicStreamId> closed_streams_; | 
|  | bool configure_session_; | 
|  | }; | 
|  |  | 
|  | class QuicSessionTestServer : public QuicSessionTestBase { | 
|  | public: | 
|  | // CheckMultiPathResponse validates that a written packet | 
|  | // contains both expected path responses. | 
|  | WriteResult CheckMultiPathResponse(const char* buffer, | 
|  | size_t buf_len, | 
|  | const QuicIpAddress& /*self_address*/, | 
|  | const QuicSocketAddress& /*peer_address*/, | 
|  | PerPacketOptions* /*options*/) { | 
|  | QuicEncryptedPacket packet(buffer, buf_len); | 
|  | { | 
|  | InSequence s; | 
|  | EXPECT_CALL(framer_visitor_, OnPacket()); | 
|  | EXPECT_CALL(framer_visitor_, OnUnauthenticatedPublicHeader(_)); | 
|  | EXPECT_CALL(framer_visitor_, OnUnauthenticatedHeader(_)); | 
|  | EXPECT_CALL(framer_visitor_, OnDecryptedPacket(_, _)); | 
|  | EXPECT_CALL(framer_visitor_, OnPacketHeader(_)); | 
|  | EXPECT_CALL(framer_visitor_, OnPathResponseFrame(_)) | 
|  | .WillOnce( | 
|  | WithArg<0>(Invoke([this](const QuicPathResponseFrame& frame) { | 
|  | EXPECT_EQ(path_frame_buffer1_, frame.data_buffer); | 
|  | return true; | 
|  | }))); | 
|  | EXPECT_CALL(framer_visitor_, OnPathResponseFrame(_)) | 
|  | .WillOnce( | 
|  | WithArg<0>(Invoke([this](const QuicPathResponseFrame& frame) { | 
|  | EXPECT_EQ(path_frame_buffer2_, frame.data_buffer); | 
|  | return true; | 
|  | }))); | 
|  | EXPECT_CALL(framer_visitor_, OnPacketComplete()); | 
|  | } | 
|  | client_framer_.ProcessPacket(packet); | 
|  | return WriteResult(WRITE_STATUS_OK, 0); | 
|  | } | 
|  |  | 
|  | protected: | 
|  | QuicSessionTestServer() | 
|  | : QuicSessionTestBase(Perspective::IS_SERVER, /*configure_session=*/true), | 
|  | path_frame_buffer1_({0, 1, 2, 3, 4, 5, 6, 7}), | 
|  | path_frame_buffer2_({8, 9, 10, 11, 12, 13, 14, 15}), | 
|  | client_framer_(SupportedVersions(GetParam()), | 
|  | QuicTime::Zero(), | 
|  | Perspective::IS_CLIENT, | 
|  | kQuicDefaultConnectionIdLength) { | 
|  | client_framer_.set_visitor(&framer_visitor_); | 
|  | client_framer_.SetInitialObfuscators(TestConnectionId()); | 
|  | if (client_framer_.version().KnowsWhichDecrypterToUse()) { | 
|  | client_framer_.InstallDecrypter( | 
|  | ENCRYPTION_FORWARD_SECURE, | 
|  | std::make_unique<NullDecrypter>(Perspective::IS_CLIENT)); | 
|  | } | 
|  | } | 
|  |  | 
|  | QuicPathFrameBuffer path_frame_buffer1_; | 
|  | QuicPathFrameBuffer path_frame_buffer2_; | 
|  | StrictMock<MockFramerVisitor> framer_visitor_; | 
|  | // Framer used to process packets sent by server. | 
|  | QuicFramer client_framer_; | 
|  | }; | 
|  |  | 
|  | INSTANTIATE_TEST_SUITE_P(Tests, | 
|  | QuicSessionTestServer, | 
|  | ::testing::ValuesIn(AllSupportedVersions()), | 
|  | ::testing::PrintToStringParamName()); | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, PeerAddress) { | 
|  | EXPECT_EQ(QuicSocketAddress(QuicIpAddress::Loopback4(), kTestPort), | 
|  | session_.peer_address()); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, SelfAddress) { | 
|  | EXPECT_TRUE(session_.self_address().IsInitialized()); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, DontCallOnWriteBlockedForDisconnectedConnection) { | 
|  | EXPECT_CALL(*connection_, CloseConnection(_, _, _)) | 
|  | .WillOnce( | 
|  | Invoke(connection_, &MockQuicConnection::ReallyCloseConnection)); | 
|  | connection_->CloseConnection(QUIC_NO_ERROR, "Everything is fine.", | 
|  | ConnectionCloseBehavior::SILENT_CLOSE); | 
|  | ASSERT_FALSE(connection_->connected()); | 
|  |  | 
|  | EXPECT_CALL(session_visitor_, OnWriteBlocked(_)).Times(0); | 
|  | session_.OnWriteBlocked(); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, OneRttKeysAvailable) { | 
|  | EXPECT_FALSE(session_.OneRttKeysAvailable()); | 
|  | CompleteHandshake(); | 
|  | EXPECT_TRUE(session_.OneRttKeysAvailable()); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, IsClosedStreamDefault) { | 
|  | // Ensure that no streams are initially closed. | 
|  | QuicStreamId first_stream_id = QuicUtils::GetFirstBidirectionalStreamId( | 
|  | connection_->transport_version(), Perspective::IS_CLIENT); | 
|  | if (!QuicVersionUsesCryptoFrames(connection_->transport_version())) { | 
|  | first_stream_id = | 
|  | QuicUtils::GetCryptoStreamId(connection_->transport_version()); | 
|  | } | 
|  | for (QuicStreamId i = first_stream_id; i < 100; i++) { | 
|  | EXPECT_FALSE(session_.IsClosedStream(i)) << "stream id: " << i; | 
|  | } | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, AvailableBidirectionalStreams) { | 
|  | ASSERT_TRUE(session_.GetOrCreateStream( | 
|  | GetNthClientInitiatedBidirectionalId(3)) != nullptr); | 
|  | // Smaller bidirectional streams should be available. | 
|  | EXPECT_TRUE(QuicSessionPeer::IsStreamAvailable( | 
|  | &session_, GetNthClientInitiatedBidirectionalId(1))); | 
|  | EXPECT_TRUE(QuicSessionPeer::IsStreamAvailable( | 
|  | &session_, GetNthClientInitiatedBidirectionalId(2))); | 
|  | ASSERT_TRUE(session_.GetOrCreateStream( | 
|  | GetNthClientInitiatedBidirectionalId(2)) != nullptr); | 
|  | ASSERT_TRUE(session_.GetOrCreateStream( | 
|  | GetNthClientInitiatedBidirectionalId(1)) != nullptr); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, AvailableUnidirectionalStreams) { | 
|  | ASSERT_TRUE(session_.GetOrCreateStream( | 
|  | GetNthClientInitiatedUnidirectionalId(3)) != nullptr); | 
|  | // Smaller unidirectional streams should be available. | 
|  | EXPECT_TRUE(QuicSessionPeer::IsStreamAvailable( | 
|  | &session_, GetNthClientInitiatedUnidirectionalId(1))); | 
|  | EXPECT_TRUE(QuicSessionPeer::IsStreamAvailable( | 
|  | &session_, GetNthClientInitiatedUnidirectionalId(2))); | 
|  | ASSERT_TRUE(session_.GetOrCreateStream( | 
|  | GetNthClientInitiatedUnidirectionalId(2)) != nullptr); | 
|  | ASSERT_TRUE(session_.GetOrCreateStream( | 
|  | GetNthClientInitiatedUnidirectionalId(1)) != nullptr); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, MaxAvailableBidirectionalStreams) { | 
|  | if (VersionHasIetfQuicFrames(transport_version())) { | 
|  | EXPECT_EQ(session_.max_open_incoming_bidirectional_streams(), | 
|  | session_.MaxAvailableBidirectionalStreams()); | 
|  | } else { | 
|  | // The protocol specification requires that there can be at least 10 times | 
|  | // as many available streams as the connection's maximum open streams. | 
|  | EXPECT_EQ(session_.max_open_incoming_bidirectional_streams() * | 
|  | kMaxAvailableStreamsMultiplier, | 
|  | session_.MaxAvailableBidirectionalStreams()); | 
|  | } | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, MaxAvailableUnidirectionalStreams) { | 
|  | if (VersionHasIetfQuicFrames(transport_version())) { | 
|  | EXPECT_EQ(session_.max_open_incoming_unidirectional_streams(), | 
|  | session_.MaxAvailableUnidirectionalStreams()); | 
|  | } else { | 
|  | // The protocol specification requires that there can be at least 10 times | 
|  | // as many available streams as the connection's maximum open streams. | 
|  | EXPECT_EQ(session_.max_open_incoming_unidirectional_streams() * | 
|  | kMaxAvailableStreamsMultiplier, | 
|  | session_.MaxAvailableUnidirectionalStreams()); | 
|  | } | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, IsClosedBidirectionalStreamLocallyCreated) { | 
|  | CompleteHandshake(); | 
|  | TestStream* stream2 = session_.CreateOutgoingBidirectionalStream(); | 
|  | EXPECT_EQ(GetNthServerInitiatedBidirectionalId(0), stream2->id()); | 
|  | TestStream* stream4 = session_.CreateOutgoingBidirectionalStream(); | 
|  | EXPECT_EQ(GetNthServerInitiatedBidirectionalId(1), stream4->id()); | 
|  |  | 
|  | CheckClosedStreams(); | 
|  | CloseStream(GetNthServerInitiatedBidirectionalId(0)); | 
|  | CheckClosedStreams(); | 
|  | CloseStream(GetNthServerInitiatedBidirectionalId(1)); | 
|  | CheckClosedStreams(); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, IsClosedUnidirectionalStreamLocallyCreated) { | 
|  | CompleteHandshake(); | 
|  | TestStream* stream2 = session_.CreateOutgoingUnidirectionalStream(); | 
|  | EXPECT_EQ(GetNthServerInitiatedUnidirectionalId(0), stream2->id()); | 
|  | TestStream* stream4 = session_.CreateOutgoingUnidirectionalStream(); | 
|  | EXPECT_EQ(GetNthServerInitiatedUnidirectionalId(1), stream4->id()); | 
|  |  | 
|  | CheckClosedStreams(); | 
|  | CloseStream(GetNthServerInitiatedUnidirectionalId(0)); | 
|  | CheckClosedStreams(); | 
|  | CloseStream(GetNthServerInitiatedUnidirectionalId(1)); | 
|  | CheckClosedStreams(); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, IsClosedBidirectionalStreamPeerCreated) { | 
|  | CompleteHandshake(); | 
|  | QuicStreamId stream_id1 = GetNthClientInitiatedBidirectionalId(0); | 
|  | QuicStreamId stream_id2 = GetNthClientInitiatedBidirectionalId(1); | 
|  | session_.GetOrCreateStream(stream_id1); | 
|  | session_.GetOrCreateStream(stream_id2); | 
|  |  | 
|  | CheckClosedStreams(); | 
|  | CloseStream(stream_id1); | 
|  | CheckClosedStreams(); | 
|  | CloseStream(stream_id2); | 
|  | // Create a stream, and make another available. | 
|  | QuicStream* stream3 = session_.GetOrCreateStream( | 
|  | stream_id2 + | 
|  | 2 * QuicUtils::StreamIdDelta(connection_->transport_version())); | 
|  | CheckClosedStreams(); | 
|  | // Close one, but make sure the other is still not closed | 
|  | CloseStream(stream3->id()); | 
|  | CheckClosedStreams(); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, IsClosedUnidirectionalStreamPeerCreated) { | 
|  | CompleteHandshake(); | 
|  | QuicStreamId stream_id1 = GetNthClientInitiatedUnidirectionalId(0); | 
|  | QuicStreamId stream_id2 = GetNthClientInitiatedUnidirectionalId(1); | 
|  | session_.GetOrCreateStream(stream_id1); | 
|  | session_.GetOrCreateStream(stream_id2); | 
|  |  | 
|  | CheckClosedStreams(); | 
|  | CloseStream(stream_id1); | 
|  | CheckClosedStreams(); | 
|  | CloseStream(stream_id2); | 
|  | // Create a stream, and make another available. | 
|  | QuicStream* stream3 = session_.GetOrCreateStream( | 
|  | stream_id2 + | 
|  | 2 * QuicUtils::StreamIdDelta(connection_->transport_version())); | 
|  | CheckClosedStreams(); | 
|  | // Close one, but make sure the other is still not closed | 
|  | CloseStream(stream3->id()); | 
|  | CheckClosedStreams(); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, MaximumAvailableOpenedBidirectionalStreams) { | 
|  | QuicStreamId stream_id = GetNthClientInitiatedBidirectionalId(0); | 
|  | session_.GetOrCreateStream(stream_id); | 
|  | EXPECT_CALL(*connection_, CloseConnection(_, _, _)).Times(0); | 
|  | EXPECT_NE(nullptr, | 
|  | session_.GetOrCreateStream(GetNthClientInitiatedBidirectionalId( | 
|  | session_.max_open_incoming_bidirectional_streams() - 1))); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, MaximumAvailableOpenedUnidirectionalStreams) { | 
|  | QuicStreamId stream_id = GetNthClientInitiatedUnidirectionalId(0); | 
|  | session_.GetOrCreateStream(stream_id); | 
|  | EXPECT_CALL(*connection_, CloseConnection(_, _, _)).Times(0); | 
|  | EXPECT_NE(nullptr, | 
|  | session_.GetOrCreateStream(GetNthClientInitiatedUnidirectionalId( | 
|  | session_.max_open_incoming_unidirectional_streams() - 1))); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, TooManyAvailableBidirectionalStreams) { | 
|  | QuicStreamId stream_id1 = GetNthClientInitiatedBidirectionalId(0); | 
|  | QuicStreamId stream_id2; | 
|  | EXPECT_NE(nullptr, session_.GetOrCreateStream(stream_id1)); | 
|  | // A stream ID which is too large to create. | 
|  | stream_id2 = GetNthClientInitiatedBidirectionalId( | 
|  | session_.MaxAvailableBidirectionalStreams() + 2); | 
|  | if (VersionHasIetfQuicFrames(transport_version())) { | 
|  | // IETF QUIC terminates the connection with invalid stream id | 
|  | EXPECT_CALL(*connection_, CloseConnection(QUIC_INVALID_STREAM_ID, _, _)); | 
|  | } else { | 
|  | // other versions terminate the connection with | 
|  | // QUIC_TOO_MANY_AVAILABLE_STREAMS. | 
|  | EXPECT_CALL(*connection_, | 
|  | CloseConnection(QUIC_TOO_MANY_AVAILABLE_STREAMS, _, _)); | 
|  | } | 
|  | EXPECT_EQ(nullptr, session_.GetOrCreateStream(stream_id2)); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, TooManyAvailableUnidirectionalStreams) { | 
|  | QuicStreamId stream_id1 = GetNthClientInitiatedUnidirectionalId(0); | 
|  | QuicStreamId stream_id2; | 
|  | EXPECT_NE(nullptr, session_.GetOrCreateStream(stream_id1)); | 
|  | // A stream ID which is too large to create. | 
|  | stream_id2 = GetNthClientInitiatedUnidirectionalId( | 
|  | session_.MaxAvailableUnidirectionalStreams() + 2); | 
|  | if (VersionHasIetfQuicFrames(transport_version())) { | 
|  | // IETF QUIC terminates the connection with invalid stream id | 
|  | EXPECT_CALL(*connection_, CloseConnection(QUIC_INVALID_STREAM_ID, _, _)); | 
|  | } else { | 
|  | // other versions terminate the connection with | 
|  | // QUIC_TOO_MANY_AVAILABLE_STREAMS. | 
|  | EXPECT_CALL(*connection_, | 
|  | CloseConnection(QUIC_TOO_MANY_AVAILABLE_STREAMS, _, _)); | 
|  | } | 
|  | EXPECT_EQ(nullptr, session_.GetOrCreateStream(stream_id2)); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, ManyAvailableBidirectionalStreams) { | 
|  | // When max_open_streams_ is 200, should be able to create 200 streams | 
|  | // out-of-order, that is, creating the one with the largest stream ID first. | 
|  | if (VersionHasIetfQuicFrames(transport_version())) { | 
|  | QuicSessionPeer::SetMaxOpenIncomingBidirectionalStreams(&session_, 200); | 
|  | // Smaller limit on unidirectional streams to help detect crossed wires. | 
|  | QuicSessionPeer::SetMaxOpenIncomingUnidirectionalStreams(&session_, 50); | 
|  | } else { | 
|  | QuicSessionPeer::SetMaxOpenIncomingStreams(&session_, 200); | 
|  | } | 
|  | // Create a stream at the start of the range. | 
|  | QuicStreamId stream_id = GetNthClientInitiatedBidirectionalId(0); | 
|  | EXPECT_NE(nullptr, session_.GetOrCreateStream(stream_id)); | 
|  |  | 
|  | // Create the largest stream ID of a threatened total of 200 streams. | 
|  | // GetNth... starts at 0, so for 200 streams, get the 199th. | 
|  | EXPECT_CALL(*connection_, CloseConnection(_, _, _)).Times(0); | 
|  | EXPECT_NE(nullptr, session_.GetOrCreateStream( | 
|  | GetNthClientInitiatedBidirectionalId(199))); | 
|  |  | 
|  | if (VersionHasIetfQuicFrames(transport_version())) { | 
|  | // If IETF QUIC, check to make sure that creating bidirectional | 
|  | // streams does not mess up the unidirectional streams. | 
|  | stream_id = GetNthClientInitiatedUnidirectionalId(0); | 
|  | EXPECT_NE(nullptr, session_.GetOrCreateStream(stream_id)); | 
|  | // Now try to get the last possible unidirectional stream. | 
|  | EXPECT_NE(nullptr, session_.GetOrCreateStream( | 
|  | GetNthClientInitiatedUnidirectionalId(49))); | 
|  | // and this should fail because it exceeds the unidirectional limit | 
|  | // (but not the bi-) | 
|  | EXPECT_CALL( | 
|  | *connection_, | 
|  | CloseConnection(QUIC_INVALID_STREAM_ID, | 
|  | "Stream id 798 would exceed stream count limit 50", | 
|  | ConnectionCloseBehavior::SEND_CONNECTION_CLOSE_PACKET)) | 
|  | .Times(1); | 
|  | EXPECT_EQ(nullptr, session_.GetOrCreateStream( | 
|  | GetNthClientInitiatedUnidirectionalId(199))); | 
|  | } | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, ManyAvailableUnidirectionalStreams) { | 
|  | // When max_open_streams_ is 200, should be able to create 200 streams | 
|  | // out-of-order, that is, creating the one with the largest stream ID first. | 
|  | if (VersionHasIetfQuicFrames(transport_version())) { | 
|  | QuicSessionPeer::SetMaxOpenIncomingUnidirectionalStreams(&session_, 200); | 
|  | // Smaller limit on unidirectional streams to help detect crossed wires. | 
|  | QuicSessionPeer::SetMaxOpenIncomingBidirectionalStreams(&session_, 50); | 
|  | } else { | 
|  | QuicSessionPeer::SetMaxOpenIncomingStreams(&session_, 200); | 
|  | } | 
|  | // Create one stream. | 
|  | QuicStreamId stream_id = GetNthClientInitiatedUnidirectionalId(0); | 
|  | EXPECT_NE(nullptr, session_.GetOrCreateStream(stream_id)); | 
|  |  | 
|  | // Create the largest stream ID of a threatened total of 200 streams. | 
|  | // GetNth... starts at 0, so for 200 streams, get the 199th. | 
|  | EXPECT_CALL(*connection_, CloseConnection(_, _, _)).Times(0); | 
|  | EXPECT_NE(nullptr, session_.GetOrCreateStream( | 
|  | GetNthClientInitiatedUnidirectionalId(199))); | 
|  | if (VersionHasIetfQuicFrames(transport_version())) { | 
|  | // If IETF QUIC, check to make sure that creating unidirectional | 
|  | // streams does not mess up the bidirectional streams. | 
|  | stream_id = GetNthClientInitiatedBidirectionalId(0); | 
|  | EXPECT_NE(nullptr, session_.GetOrCreateStream(stream_id)); | 
|  | // Now try to get the last possible bidirectional stream. | 
|  | EXPECT_NE(nullptr, session_.GetOrCreateStream( | 
|  | GetNthClientInitiatedBidirectionalId(49))); | 
|  | // and this should fail because it exceeds the bnidirectional limit | 
|  | // (but not the uni-) | 
|  | std::string error_detail; | 
|  | if (QuicVersionUsesCryptoFrames(transport_version())) { | 
|  | error_detail = "Stream id 796 would exceed stream count limit 50"; | 
|  | } else { | 
|  | error_detail = "Stream id 800 would exceed stream count limit 50"; | 
|  | } | 
|  | EXPECT_CALL( | 
|  | *connection_, | 
|  | CloseConnection(QUIC_INVALID_STREAM_ID, error_detail, | 
|  | ConnectionCloseBehavior::SEND_CONNECTION_CLOSE_PACKET)) | 
|  | .Times(1); | 
|  | EXPECT_EQ(nullptr, session_.GetOrCreateStream( | 
|  | GetNthClientInitiatedBidirectionalId(199))); | 
|  | } | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, DebugDFatalIfMarkingClosedStreamWriteBlocked) { | 
|  | CompleteHandshake(); | 
|  | TestStream* stream2 = session_.CreateOutgoingBidirectionalStream(); | 
|  | QuicStreamId closed_stream_id = stream2->id(); | 
|  | // Close the stream. | 
|  | EXPECT_CALL(*connection_, SendControlFrame(_)); | 
|  | EXPECT_CALL(*connection_, OnStreamReset(closed_stream_id, _)); | 
|  | stream2->Reset(QUIC_BAD_APPLICATION_PAYLOAD); | 
|  | std::string msg = | 
|  | absl::StrCat("Marking unknown stream ", closed_stream_id, " blocked."); | 
|  | EXPECT_QUIC_BUG(session_.MarkConnectionLevelWriteBlocked(closed_stream_id), | 
|  | msg); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, OnCanWrite) { | 
|  | CompleteHandshake(); | 
|  | session_.set_writev_consumes_all_data(true); | 
|  | TestStream* stream2 = session_.CreateOutgoingBidirectionalStream(); | 
|  | TestStream* stream4 = session_.CreateOutgoingBidirectionalStream(); | 
|  | TestStream* stream6 = session_.CreateOutgoingBidirectionalStream(); | 
|  |  | 
|  | session_.MarkConnectionLevelWriteBlocked(stream2->id()); | 
|  | session_.MarkConnectionLevelWriteBlocked(stream6->id()); | 
|  | session_.MarkConnectionLevelWriteBlocked(stream4->id()); | 
|  |  | 
|  | InSequence s; | 
|  |  | 
|  | // Reregister, to test the loop limit. | 
|  | EXPECT_CALL(*stream2, OnCanWrite()).WillOnce(Invoke([this, stream2]() { | 
|  | session_.SendStreamData(stream2); | 
|  | session_.MarkConnectionLevelWriteBlocked(stream2->id()); | 
|  | })); | 
|  | // 2 will get called a second time as it didn't finish its block | 
|  | EXPECT_CALL(*stream2, OnCanWrite()).WillOnce(Invoke([this, stream2]() { | 
|  | session_.SendStreamData(stream2); | 
|  | })); | 
|  | EXPECT_CALL(*stream6, OnCanWrite()).WillOnce(Invoke([this, stream6]() { | 
|  | session_.SendStreamData(stream6); | 
|  | })); | 
|  | // 4 will not get called, as we exceeded the loop limit. | 
|  | session_.OnCanWrite(); | 
|  | EXPECT_TRUE(session_.WillingAndAbleToWrite()); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, TestBatchedWrites) { | 
|  | session_.set_writev_consumes_all_data(true); | 
|  | TestStream* stream2 = session_.CreateOutgoingBidirectionalStream(); | 
|  | TestStream* stream4 = session_.CreateOutgoingBidirectionalStream(); | 
|  | TestStream* stream6 = session_.CreateOutgoingBidirectionalStream(); | 
|  |  | 
|  | session_.set_writev_consumes_all_data(true); | 
|  | session_.MarkConnectionLevelWriteBlocked(stream2->id()); | 
|  | session_.MarkConnectionLevelWriteBlocked(stream4->id()); | 
|  |  | 
|  | // With two sessions blocked, we should get two write calls.  They should both | 
|  | // go to the first stream as it will only write 6k and mark itself blocked | 
|  | // again. | 
|  | InSequence s; | 
|  | EXPECT_CALL(*stream2, OnCanWrite()).WillOnce(Invoke([this, stream2]() { | 
|  | session_.SendLargeFakeData(stream2, 6000); | 
|  | session_.MarkConnectionLevelWriteBlocked(stream2->id()); | 
|  | })); | 
|  | EXPECT_CALL(*stream2, OnCanWrite()).WillOnce(Invoke([this, stream2]() { | 
|  | session_.SendLargeFakeData(stream2, 6000); | 
|  | session_.MarkConnectionLevelWriteBlocked(stream2->id()); | 
|  | })); | 
|  | session_.OnCanWrite(); | 
|  |  | 
|  | // We should get one more call for stream2, at which point it has used its | 
|  | // write quota and we move over to stream 4. | 
|  | EXPECT_CALL(*stream2, OnCanWrite()).WillOnce(Invoke([this, stream2]() { | 
|  | session_.SendLargeFakeData(stream2, 6000); | 
|  | session_.MarkConnectionLevelWriteBlocked(stream2->id()); | 
|  | })); | 
|  | EXPECT_CALL(*stream4, OnCanWrite()).WillOnce(Invoke([this, stream4]() { | 
|  | session_.SendLargeFakeData(stream4, 6000); | 
|  | session_.MarkConnectionLevelWriteBlocked(stream4->id()); | 
|  | })); | 
|  | session_.OnCanWrite(); | 
|  |  | 
|  | // Now let stream 4 do the 2nd of its 3 writes, but add a block for a high | 
|  | // priority stream 6.  4 should be preempted.  6 will write but *not* block so | 
|  | // will cede back to 4. | 
|  | stream6->SetPriority(spdy::SpdyStreamPrecedence(kV3HighestPriority)); | 
|  | EXPECT_CALL(*stream4, OnCanWrite()) | 
|  | .WillOnce(Invoke([this, stream4, stream6]() { | 
|  | session_.SendLargeFakeData(stream4, 6000); | 
|  | session_.MarkConnectionLevelWriteBlocked(stream4->id()); | 
|  | session_.MarkConnectionLevelWriteBlocked(stream6->id()); | 
|  | })); | 
|  | EXPECT_CALL(*stream6, OnCanWrite()) | 
|  | .WillOnce(Invoke([this, stream4, stream6]() { | 
|  | session_.SendStreamData(stream6); | 
|  | session_.SendLargeFakeData(stream4, 6000); | 
|  | })); | 
|  | session_.OnCanWrite(); | 
|  |  | 
|  | // Stream4 alread did 6k worth of writes, so after doing another 12k it should | 
|  | // cede and 2 should resume. | 
|  | EXPECT_CALL(*stream4, OnCanWrite()).WillOnce(Invoke([this, stream4]() { | 
|  | session_.SendLargeFakeData(stream4, 12000); | 
|  | session_.MarkConnectionLevelWriteBlocked(stream4->id()); | 
|  | })); | 
|  | EXPECT_CALL(*stream2, OnCanWrite()).WillOnce(Invoke([this, stream2]() { | 
|  | session_.SendLargeFakeData(stream2, 6000); | 
|  | session_.MarkConnectionLevelWriteBlocked(stream2->id()); | 
|  | })); | 
|  | session_.OnCanWrite(); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, OnCanWriteBundlesStreams) { | 
|  | // Encryption needs to be established before data can be sent. | 
|  | CompleteHandshake(); | 
|  | MockPacketWriter* writer = static_cast<MockPacketWriter*>( | 
|  | QuicConnectionPeer::GetWriter(session_.connection())); | 
|  |  | 
|  | // Drive congestion control manually. | 
|  | MockSendAlgorithm* send_algorithm = new StrictMock<MockSendAlgorithm>; | 
|  | QuicConnectionPeer::SetSendAlgorithm(session_.connection(), send_algorithm); | 
|  |  | 
|  | TestStream* stream2 = session_.CreateOutgoingBidirectionalStream(); | 
|  | TestStream* stream4 = session_.CreateOutgoingBidirectionalStream(); | 
|  | TestStream* stream6 = session_.CreateOutgoingBidirectionalStream(); | 
|  |  | 
|  | session_.MarkConnectionLevelWriteBlocked(stream2->id()); | 
|  | session_.MarkConnectionLevelWriteBlocked(stream6->id()); | 
|  | session_.MarkConnectionLevelWriteBlocked(stream4->id()); | 
|  |  | 
|  | EXPECT_CALL(*send_algorithm, CanSend(_)).WillRepeatedly(Return(true)); | 
|  | EXPECT_CALL(*send_algorithm, GetCongestionWindow()) | 
|  | .WillRepeatedly(Return(kMaxOutgoingPacketSize * 10)); | 
|  | EXPECT_CALL(*send_algorithm, InRecovery()).WillRepeatedly(Return(false)); | 
|  | EXPECT_CALL(*stream2, OnCanWrite()).WillOnce(Invoke([this, stream2]() { | 
|  | session_.SendStreamData(stream2); | 
|  | })); | 
|  | EXPECT_CALL(*stream4, OnCanWrite()).WillOnce(Invoke([this, stream4]() { | 
|  | session_.SendStreamData(stream4); | 
|  | })); | 
|  | EXPECT_CALL(*stream6, OnCanWrite()).WillOnce(Invoke([this, stream6]() { | 
|  | session_.SendStreamData(stream6); | 
|  | })); | 
|  |  | 
|  | // Expect that we only send one packet, the writes from different streams | 
|  | // should be bundled together. | 
|  | EXPECT_CALL(*writer, WritePacket(_, _, _, _, _)) | 
|  | .WillOnce(Return(WriteResult(WRITE_STATUS_OK, 0))); | 
|  | EXPECT_CALL(*send_algorithm, OnPacketSent(_, _, _, _, _)); | 
|  | EXPECT_CALL(*send_algorithm, OnApplicationLimited(_)); | 
|  | session_.OnCanWrite(); | 
|  | EXPECT_FALSE(session_.WillingAndAbleToWrite()); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, OnCanWriteCongestionControlBlocks) { | 
|  | CompleteHandshake(); | 
|  | session_.set_writev_consumes_all_data(true); | 
|  | InSequence s; | 
|  |  | 
|  | // Drive congestion control manually. | 
|  | MockSendAlgorithm* send_algorithm = new StrictMock<MockSendAlgorithm>; | 
|  | QuicConnectionPeer::SetSendAlgorithm(session_.connection(), send_algorithm); | 
|  |  | 
|  | TestStream* stream2 = session_.CreateOutgoingBidirectionalStream(); | 
|  | TestStream* stream4 = session_.CreateOutgoingBidirectionalStream(); | 
|  | TestStream* stream6 = session_.CreateOutgoingBidirectionalStream(); | 
|  |  | 
|  | session_.MarkConnectionLevelWriteBlocked(stream2->id()); | 
|  | session_.MarkConnectionLevelWriteBlocked(stream6->id()); | 
|  | session_.MarkConnectionLevelWriteBlocked(stream4->id()); | 
|  |  | 
|  | EXPECT_CALL(*send_algorithm, CanSend(_)).WillOnce(Return(true)); | 
|  | EXPECT_CALL(*stream2, OnCanWrite()).WillOnce(Invoke([this, stream2]() { | 
|  | session_.SendStreamData(stream2); | 
|  | })); | 
|  | EXPECT_CALL(*send_algorithm, GetCongestionWindow()).Times(AnyNumber()); | 
|  | EXPECT_CALL(*send_algorithm, CanSend(_)).WillOnce(Return(true)); | 
|  | EXPECT_CALL(*stream6, OnCanWrite()).WillOnce(Invoke([this, stream6]() { | 
|  | session_.SendStreamData(stream6); | 
|  | })); | 
|  | EXPECT_CALL(*send_algorithm, CanSend(_)).WillOnce(Return(false)); | 
|  | // stream4->OnCanWrite is not called. | 
|  |  | 
|  | session_.OnCanWrite(); | 
|  | EXPECT_TRUE(session_.WillingAndAbleToWrite()); | 
|  |  | 
|  | // Still congestion-control blocked. | 
|  | EXPECT_CALL(*send_algorithm, CanSend(_)).WillOnce(Return(false)); | 
|  | session_.OnCanWrite(); | 
|  | EXPECT_TRUE(session_.WillingAndAbleToWrite()); | 
|  |  | 
|  | // stream4->OnCanWrite is called once the connection stops being | 
|  | // congestion-control blocked. | 
|  | EXPECT_CALL(*send_algorithm, CanSend(_)).WillOnce(Return(true)); | 
|  | EXPECT_CALL(*stream4, OnCanWrite()).WillOnce(Invoke([this, stream4]() { | 
|  | session_.SendStreamData(stream4); | 
|  | })); | 
|  | EXPECT_CALL(*send_algorithm, OnApplicationLimited(_)); | 
|  | session_.OnCanWrite(); | 
|  | EXPECT_FALSE(session_.WillingAndAbleToWrite()); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, OnCanWriteWriterBlocks) { | 
|  | CompleteHandshake(); | 
|  | // Drive congestion control manually in order to ensure that | 
|  | // application-limited signaling is handled correctly. | 
|  | MockSendAlgorithm* send_algorithm = new StrictMock<MockSendAlgorithm>; | 
|  | QuicConnectionPeer::SetSendAlgorithm(session_.connection(), send_algorithm); | 
|  | EXPECT_CALL(*send_algorithm, CanSend(_)).WillRepeatedly(Return(true)); | 
|  |  | 
|  | // Drive packet writer manually. | 
|  | MockPacketWriter* writer = static_cast<MockPacketWriter*>( | 
|  | QuicConnectionPeer::GetWriter(session_.connection())); | 
|  | EXPECT_CALL(*writer, IsWriteBlocked()).WillRepeatedly(Return(true)); | 
|  | EXPECT_CALL(*writer, WritePacket(_, _, _, _, _)).Times(0); | 
|  |  | 
|  | TestStream* stream2 = session_.CreateOutgoingBidirectionalStream(); | 
|  |  | 
|  | session_.MarkConnectionLevelWriteBlocked(stream2->id()); | 
|  |  | 
|  | EXPECT_CALL(*stream2, OnCanWrite()).Times(0); | 
|  | EXPECT_CALL(*send_algorithm, OnApplicationLimited(_)).Times(0); | 
|  |  | 
|  | session_.OnCanWrite(); | 
|  | EXPECT_TRUE(session_.WillingAndAbleToWrite()); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, SendStreamsBlocked) { | 
|  | if (!VersionHasIetfQuicFrames(transport_version())) { | 
|  | return; | 
|  | } | 
|  | CompleteHandshake(); | 
|  | for (size_t i = 0; i < kDefaultMaxStreamsPerConnection; ++i) { | 
|  | ASSERT_TRUE(session_.CanOpenNextOutgoingBidirectionalStream()); | 
|  | session_.GetNextOutgoingBidirectionalStreamId(); | 
|  | } | 
|  | // Next checking causes STREAMS_BLOCKED to be sent. | 
|  | EXPECT_CALL(*connection_, SendControlFrame(_)) | 
|  | .WillOnce(Invoke([](const QuicFrame& frame) { | 
|  | EXPECT_FALSE(frame.streams_blocked_frame.unidirectional); | 
|  | EXPECT_EQ(kDefaultMaxStreamsPerConnection, | 
|  | frame.streams_blocked_frame.stream_count); | 
|  | ClearControlFrame(frame); | 
|  | return true; | 
|  | })); | 
|  | EXPECT_FALSE(session_.CanOpenNextOutgoingBidirectionalStream()); | 
|  |  | 
|  | for (size_t i = 0; i < kDefaultMaxStreamsPerConnection; ++i) { | 
|  | ASSERT_TRUE(session_.CanOpenNextOutgoingUnidirectionalStream()); | 
|  | session_.GetNextOutgoingUnidirectionalStreamId(); | 
|  | } | 
|  | // Next checking causes STREAM_BLOCKED to be sent. | 
|  | EXPECT_CALL(*connection_, SendControlFrame(_)) | 
|  | .WillOnce(Invoke([](const QuicFrame& frame) { | 
|  | EXPECT_TRUE(frame.streams_blocked_frame.unidirectional); | 
|  | EXPECT_EQ(kDefaultMaxStreamsPerConnection, | 
|  | frame.streams_blocked_frame.stream_count); | 
|  | ClearControlFrame(frame); | 
|  | return true; | 
|  | })); | 
|  | EXPECT_FALSE(session_.CanOpenNextOutgoingUnidirectionalStream()); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, BufferedHandshake) { | 
|  | // This test is testing behavior of crypto stream flow control, but when | 
|  | // CRYPTO frames are used, there is no flow control for the crypto handshake. | 
|  | if (QuicVersionUsesCryptoFrames(connection_->transport_version())) { | 
|  | return; | 
|  | } | 
|  | session_.set_writev_consumes_all_data(true); | 
|  | EXPECT_FALSE(session_.HasPendingHandshake());  // Default value. | 
|  |  | 
|  | // Test that blocking other streams does not change our status. | 
|  | TestStream* stream2 = session_.CreateOutgoingBidirectionalStream(); | 
|  | session_.MarkConnectionLevelWriteBlocked(stream2->id()); | 
|  | EXPECT_FALSE(session_.HasPendingHandshake()); | 
|  |  | 
|  | TestStream* stream3 = session_.CreateOutgoingBidirectionalStream(); | 
|  | session_.MarkConnectionLevelWriteBlocked(stream3->id()); | 
|  | EXPECT_FALSE(session_.HasPendingHandshake()); | 
|  |  | 
|  | // Blocking (due to buffering of) the Crypto stream is detected. | 
|  | session_.MarkConnectionLevelWriteBlocked( | 
|  | QuicUtils::GetCryptoStreamId(connection_->transport_version())); | 
|  | EXPECT_TRUE(session_.HasPendingHandshake()); | 
|  |  | 
|  | TestStream* stream4 = session_.CreateOutgoingBidirectionalStream(); | 
|  | session_.MarkConnectionLevelWriteBlocked(stream4->id()); | 
|  | EXPECT_TRUE(session_.HasPendingHandshake()); | 
|  |  | 
|  | InSequence s; | 
|  | // Force most streams to re-register, which is common scenario when we block | 
|  | // the Crypto stream, and only the crypto stream can "really" write. | 
|  |  | 
|  | // Due to prioritization, we *should* be asked to write the crypto stream | 
|  | // first. | 
|  | // Don't re-register the crypto stream (which signals complete writing). | 
|  | TestCryptoStream* crypto_stream = session_.GetMutableCryptoStream(); | 
|  | EXPECT_CALL(*crypto_stream, OnCanWrite()); | 
|  |  | 
|  | EXPECT_CALL(*stream2, OnCanWrite()).WillOnce(Invoke([this, stream2]() { | 
|  | session_.SendStreamData(stream2); | 
|  | })); | 
|  | EXPECT_CALL(*stream3, OnCanWrite()).WillOnce(Invoke([this, stream3]() { | 
|  | session_.SendStreamData(stream3); | 
|  | })); | 
|  | EXPECT_CALL(*stream4, OnCanWrite()).WillOnce(Invoke([this, stream4]() { | 
|  | session_.SendStreamData(stream4); | 
|  | session_.MarkConnectionLevelWriteBlocked(stream4->id()); | 
|  | })); | 
|  |  | 
|  | session_.OnCanWrite(); | 
|  | EXPECT_TRUE(session_.WillingAndAbleToWrite()); | 
|  | EXPECT_FALSE(session_.HasPendingHandshake());  // Crypto stream wrote. | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, OnCanWriteWithClosedStream) { | 
|  | CompleteHandshake(); | 
|  | session_.set_writev_consumes_all_data(true); | 
|  | TestStream* stream2 = session_.CreateOutgoingBidirectionalStream(); | 
|  | TestStream* stream4 = session_.CreateOutgoingBidirectionalStream(); | 
|  | TestStream* stream6 = session_.CreateOutgoingBidirectionalStream(); | 
|  |  | 
|  | session_.MarkConnectionLevelWriteBlocked(stream2->id()); | 
|  | session_.MarkConnectionLevelWriteBlocked(stream6->id()); | 
|  | session_.MarkConnectionLevelWriteBlocked(stream4->id()); | 
|  | CloseStream(stream6->id()); | 
|  |  | 
|  | InSequence s; | 
|  | EXPECT_CALL(*connection_, SendControlFrame(_)) | 
|  | .WillRepeatedly(Invoke(&ClearControlFrame)); | 
|  | EXPECT_CALL(*stream2, OnCanWrite()).WillOnce(Invoke([this, stream2]() { | 
|  | session_.SendStreamData(stream2); | 
|  | })); | 
|  | EXPECT_CALL(*stream4, OnCanWrite()).WillOnce(Invoke([this, stream4]() { | 
|  | session_.SendStreamData(stream4); | 
|  | })); | 
|  | session_.OnCanWrite(); | 
|  | EXPECT_FALSE(session_.WillingAndAbleToWrite()); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, OnCanWriteLimitsNumWritesIfFlowControlBlocked) { | 
|  | // Drive congestion control manually in order to ensure that | 
|  | // application-limited signaling is handled correctly. | 
|  | MockSendAlgorithm* send_algorithm = new StrictMock<MockSendAlgorithm>; | 
|  | QuicConnectionPeer::SetSendAlgorithm(session_.connection(), send_algorithm); | 
|  | EXPECT_CALL(*send_algorithm, CanSend(_)).WillRepeatedly(Return(true)); | 
|  |  | 
|  | // Ensure connection level flow control blockage. | 
|  | QuicFlowControllerPeer::SetSendWindowOffset(session_.flow_controller(), 0); | 
|  | EXPECT_TRUE(session_.flow_controller()->IsBlocked()); | 
|  | EXPECT_TRUE(session_.IsConnectionFlowControlBlocked()); | 
|  | EXPECT_FALSE(session_.IsStreamFlowControlBlocked()); | 
|  |  | 
|  | // Mark the crypto and headers streams as write blocked, we expect them to be | 
|  | // allowed to write later. | 
|  | if (!QuicVersionUsesCryptoFrames(connection_->transport_version())) { | 
|  | session_.MarkConnectionLevelWriteBlocked( | 
|  | QuicUtils::GetCryptoStreamId(connection_->transport_version())); | 
|  | } | 
|  |  | 
|  | // Create a data stream, and although it is write blocked we never expect it | 
|  | // to be allowed to write as we are connection level flow control blocked. | 
|  | TestStream* stream = session_.CreateOutgoingBidirectionalStream(); | 
|  | session_.MarkConnectionLevelWriteBlocked(stream->id()); | 
|  | EXPECT_CALL(*stream, OnCanWrite()).Times(0); | 
|  |  | 
|  | // The crypto and headers streams should be called even though we are | 
|  | // connection flow control blocked. | 
|  | if (!QuicVersionUsesCryptoFrames(connection_->transport_version())) { | 
|  | TestCryptoStream* crypto_stream = session_.GetMutableCryptoStream(); | 
|  | EXPECT_CALL(*crypto_stream, OnCanWrite()); | 
|  | } | 
|  |  | 
|  | // After the crypto and header streams perform a write, the connection will be | 
|  | // blocked by the flow control, hence it should become application-limited. | 
|  | EXPECT_CALL(*send_algorithm, OnApplicationLimited(_)); | 
|  |  | 
|  | session_.OnCanWrite(); | 
|  | EXPECT_FALSE(session_.WillingAndAbleToWrite()); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, SendGoAway) { | 
|  | if (VersionHasIetfQuicFrames(transport_version())) { | 
|  | // In IETF QUIC, GOAWAY lives up in the HTTP layer. | 
|  | return; | 
|  | } | 
|  | CompleteHandshake(); | 
|  | connection_->SetDefaultEncryptionLevel(ENCRYPTION_FORWARD_SECURE); | 
|  | MockPacketWriter* writer = static_cast<MockPacketWriter*>( | 
|  | QuicConnectionPeer::GetWriter(session_.connection())); | 
|  | EXPECT_CALL(*writer, WritePacket(_, _, _, _, _)) | 
|  | .WillOnce(Return(WriteResult(WRITE_STATUS_OK, 0))); | 
|  |  | 
|  | EXPECT_CALL(*connection_, SendControlFrame(_)) | 
|  | .WillOnce( | 
|  | Invoke(connection_, &MockQuicConnection::ReallySendControlFrame)); | 
|  | session_.SendGoAway(QUIC_PEER_GOING_AWAY, "Going Away."); | 
|  | EXPECT_TRUE(session_.transport_goaway_sent()); | 
|  |  | 
|  | const QuicStreamId kTestStreamId = 5u; | 
|  | EXPECT_CALL(*connection_, SendControlFrame(_)).Times(0); | 
|  | EXPECT_CALL(*connection_, | 
|  | OnStreamReset(kTestStreamId, QUIC_STREAM_PEER_GOING_AWAY)) | 
|  | .Times(0); | 
|  | EXPECT_TRUE(session_.GetOrCreateStream(kTestStreamId)); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, DoNotSendGoAwayTwice) { | 
|  | CompleteHandshake(); | 
|  | if (VersionHasIetfQuicFrames(transport_version())) { | 
|  | // In IETF QUIC, GOAWAY lives up in the HTTP layer. | 
|  | return; | 
|  | } | 
|  | EXPECT_CALL(*connection_, SendControlFrame(_)) | 
|  | .WillOnce(Invoke(&ClearControlFrame)); | 
|  | session_.SendGoAway(QUIC_PEER_GOING_AWAY, "Going Away."); | 
|  | EXPECT_TRUE(session_.transport_goaway_sent()); | 
|  | session_.SendGoAway(QUIC_PEER_GOING_AWAY, "Going Away."); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, InvalidGoAway) { | 
|  | if (VersionHasIetfQuicFrames(transport_version())) { | 
|  | // In IETF QUIC, GOAWAY lives up in the HTTP layer. | 
|  | return; | 
|  | } | 
|  | QuicGoAwayFrame go_away(kInvalidControlFrameId, QUIC_PEER_GOING_AWAY, | 
|  | session_.next_outgoing_bidirectional_stream_id(), ""); | 
|  | session_.OnGoAway(go_away); | 
|  | } | 
|  |  | 
|  | // Test that server session will send a connectivity probe in response to a | 
|  | // connectivity probe on the same path. | 
|  | TEST_P(QuicSessionTestServer, ServerReplyToConnectivityProbe) { | 
|  | if (connection_->send_path_response() && | 
|  | VersionHasIetfQuicFrames(transport_version())) { | 
|  | return; | 
|  | } | 
|  | connection_->SetDefaultEncryptionLevel(ENCRYPTION_FORWARD_SECURE); | 
|  | QuicSocketAddress old_peer_address = | 
|  | QuicSocketAddress(QuicIpAddress::Loopback4(), kTestPort); | 
|  | EXPECT_EQ(old_peer_address, session_.peer_address()); | 
|  |  | 
|  | QuicSocketAddress new_peer_address = | 
|  | QuicSocketAddress(QuicIpAddress::Loopback4(), kTestPort + 1); | 
|  |  | 
|  | MockPacketWriter* writer = static_cast<MockPacketWriter*>( | 
|  | QuicConnectionPeer::GetWriter(session_.connection())); | 
|  | EXPECT_CALL(*writer, WritePacket(_, _, _, new_peer_address, _)) | 
|  | .WillOnce(Return(WriteResult(WRITE_STATUS_OK, 0))); | 
|  | if (connection_->send_path_response()) { | 
|  | EXPECT_CALL(*connection_, SendConnectivityProbingPacket(_, _)) | 
|  | .WillOnce( | 
|  | Invoke(connection_, | 
|  | &MockQuicConnection::ReallySendConnectivityProbingPacket)); | 
|  | } else { | 
|  | EXPECT_CALL(*connection_, SendConnectivityProbingResponsePacket(_)) | 
|  | .WillOnce(Invoke( | 
|  | connection_, | 
|  | &MockQuicConnection::ReallySendConnectivityProbingResponsePacket)); | 
|  | } | 
|  | if (VersionHasIetfQuicFrames(transport_version())) { | 
|  | // Need to explicitly do this to emulate the reception of a PathChallenge, | 
|  | // which stores its payload for use in generating the response. | 
|  | connection_->OnPathChallengeFrame( | 
|  | QuicPathChallengeFrame(0, path_frame_buffer1_)); | 
|  | } | 
|  | session_.OnPacketReceived(session_.self_address(), new_peer_address, | 
|  | /*is_connectivity_probe=*/true); | 
|  | EXPECT_EQ(old_peer_address, session_.peer_address()); | 
|  | } | 
|  |  | 
|  | // Same as above, but check that if there are two PATH_CHALLENGE frames in the | 
|  | // packet, the response has both of them AND we do not do migration.  This for | 
|  | // IETF QUIC only. | 
|  | TEST_P(QuicSessionTestServer, ServerReplyToConnectivityProbes) { | 
|  | if (connection_->send_path_response() || | 
|  | !VersionHasIetfQuicFrames(transport_version())) { | 
|  | return; | 
|  | } | 
|  | connection_->SetDefaultEncryptionLevel(ENCRYPTION_FORWARD_SECURE); | 
|  | QuicSocketAddress old_peer_address = | 
|  | QuicSocketAddress(QuicIpAddress::Loopback4(), kTestPort); | 
|  | EXPECT_EQ(old_peer_address, session_.peer_address()); | 
|  |  | 
|  | MockPacketWriter* writer = static_cast<MockPacketWriter*>( | 
|  | QuicConnectionPeer::GetWriter(session_.connection())); | 
|  | // CheckMultiPathResponse validates that the written packet | 
|  | // contains both path responses. | 
|  | EXPECT_CALL(*writer, WritePacket(_, _, _, old_peer_address, _)) | 
|  | .WillOnce(Invoke(this, &QuicSessionTestServer::CheckMultiPathResponse)); | 
|  |  | 
|  | EXPECT_CALL(*connection_, SendConnectivityProbingResponsePacket(_)) | 
|  | .WillOnce(Invoke( | 
|  | connection_, | 
|  | &MockQuicConnection::ReallySendConnectivityProbingResponsePacket)); | 
|  | QuicConnectionPeer::SetLastHeaderFormat(connection_, | 
|  | IETF_QUIC_SHORT_HEADER_PACKET); | 
|  | // Need to explicitly do this to emulate the reception of a PathChallenge, | 
|  | // which stores its payload for use in generating the response. | 
|  | connection_->OnPathChallengeFrame( | 
|  | QuicPathChallengeFrame(0, path_frame_buffer1_)); | 
|  | connection_->OnPathChallengeFrame( | 
|  | QuicPathChallengeFrame(0, path_frame_buffer2_)); | 
|  | session_.OnPacketReceived(session_.self_address(), old_peer_address, | 
|  | /*is_connectivity_probe=*/true); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, IncreasedTimeoutAfterCryptoHandshake) { | 
|  | EXPECT_EQ(kInitialIdleTimeoutSecs + 3, | 
|  | QuicConnectionPeer::GetNetworkTimeout(connection_).ToSeconds()); | 
|  | CompleteHandshake(); | 
|  | EXPECT_EQ(kMaximumIdleTimeoutSecs + 3, | 
|  | QuicConnectionPeer::GetNetworkTimeout(connection_).ToSeconds()); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, OnStreamFrameFinStaticStreamId) { | 
|  | if (VersionUsesHttp3(connection_->transport_version())) { | 
|  | // The test relies on headers stream, which no longer exists in IETF QUIC. | 
|  | return; | 
|  | } | 
|  | QuicStreamId headers_stream_id = | 
|  | QuicUtils::GetHeadersStreamId(connection_->transport_version()); | 
|  | std::unique_ptr<TestStream> fake_headers_stream = | 
|  | std::make_unique<TestStream>(headers_stream_id, &session_, | 
|  | /*is_static*/ true, BIDIRECTIONAL); | 
|  | QuicSessionPeer::ActivateStream(&session_, std::move(fake_headers_stream)); | 
|  | // Send two bytes of payload. | 
|  | QuicStreamFrame data1(headers_stream_id, true, 0, absl::string_view("HT")); | 
|  | EXPECT_CALL(*connection_, | 
|  | CloseConnection( | 
|  | QUIC_INVALID_STREAM_ID, "Attempt to close a static stream", | 
|  | ConnectionCloseBehavior::SEND_CONNECTION_CLOSE_PACKET)); | 
|  | session_.OnStreamFrame(data1); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, OnStreamFrameInvalidStreamId) { | 
|  | // Send two bytes of payload. | 
|  | QuicStreamFrame data1( | 
|  | QuicUtils::GetInvalidStreamId(connection_->transport_version()), true, 0, | 
|  | absl::string_view("HT")); | 
|  | EXPECT_CALL(*connection_, | 
|  | CloseConnection( | 
|  | QUIC_INVALID_STREAM_ID, "Received data for an invalid stream", | 
|  | ConnectionCloseBehavior::SEND_CONNECTION_CLOSE_PACKET)); | 
|  | session_.OnStreamFrame(data1); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, OnRstStreamInvalidStreamId) { | 
|  | // Send two bytes of payload. | 
|  | QuicRstStreamFrame rst1( | 
|  | kInvalidControlFrameId, | 
|  | QuicUtils::GetInvalidStreamId(connection_->transport_version()), | 
|  | QUIC_ERROR_PROCESSING_STREAM, 0); | 
|  | EXPECT_CALL(*connection_, | 
|  | CloseConnection( | 
|  | QUIC_INVALID_STREAM_ID, "Received data for an invalid stream", | 
|  | ConnectionCloseBehavior::SEND_CONNECTION_CLOSE_PACKET)); | 
|  | session_.OnRstStream(rst1); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, HandshakeUnblocksFlowControlBlockedStream) { | 
|  | if (connection_->version().handshake_protocol == PROTOCOL_TLS1_3) { | 
|  | // This test requires Google QUIC crypto because it assumes streams start | 
|  | // off unblocked. | 
|  | return; | 
|  | } | 
|  | // Test that if a stream is flow control blocked, then on receipt of the SHLO | 
|  | // containing a suitable send window offset, the stream becomes unblocked. | 
|  |  | 
|  | // Ensure that Writev consumes all the data it is given (simulate no socket | 
|  | // blocking). | 
|  | session_.set_writev_consumes_all_data(true); | 
|  | session_.GetMutableCryptoStream()->EstablishZeroRttEncryption(); | 
|  |  | 
|  | // Create a stream, and send enough data to make it flow control blocked. | 
|  | TestStream* stream2 = session_.CreateOutgoingBidirectionalStream(); | 
|  | std::string body(kMinimumFlowControlSendWindow, '.'); | 
|  | EXPECT_FALSE(stream2->IsFlowControlBlocked()); | 
|  | EXPECT_FALSE(session_.IsConnectionFlowControlBlocked()); | 
|  | EXPECT_FALSE(session_.IsStreamFlowControlBlocked()); | 
|  | EXPECT_CALL(*connection_, SendControlFrame(_)).Times(AtLeast(1)); | 
|  | stream2->WriteOrBufferData(body, false, nullptr); | 
|  | EXPECT_TRUE(stream2->IsFlowControlBlocked()); | 
|  | EXPECT_TRUE(session_.IsConnectionFlowControlBlocked()); | 
|  | EXPECT_TRUE(session_.IsStreamFlowControlBlocked()); | 
|  |  | 
|  | // Now complete the crypto handshake, resulting in an increased flow control | 
|  | // send window. | 
|  | CompleteHandshake(); | 
|  | EXPECT_TRUE(QuicSessionPeer::IsStreamWriteBlocked(&session_, stream2->id())); | 
|  | // Stream is now unblocked. | 
|  | EXPECT_FALSE(stream2->IsFlowControlBlocked()); | 
|  | EXPECT_FALSE(session_.IsConnectionFlowControlBlocked()); | 
|  | EXPECT_FALSE(session_.IsStreamFlowControlBlocked()); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, ConnectionFlowControlAccountingRstOutOfOrder) { | 
|  | CompleteHandshake(); | 
|  | // Test that when we receive an out of order stream RST we correctly adjust | 
|  | // our connection level flow control receive window. | 
|  | // On close, the stream should mark as consumed all bytes between the highest | 
|  | // byte consumed so far and the final byte offset from the RST frame. | 
|  | TestStream* stream = session_.CreateOutgoingBidirectionalStream(); | 
|  |  | 
|  | const QuicStreamOffset kByteOffset = | 
|  | 1 + kInitialSessionFlowControlWindowForTest / 2; | 
|  |  | 
|  | EXPECT_CALL(*connection_, SendControlFrame(_)) | 
|  | .Times(2) | 
|  | .WillRepeatedly(Invoke(&ClearControlFrame)); | 
|  | EXPECT_CALL(*connection_, OnStreamReset(stream->id(), _)); | 
|  |  | 
|  | QuicRstStreamFrame rst_frame(kInvalidControlFrameId, stream->id(), | 
|  | QUIC_STREAM_CANCELLED, kByteOffset); | 
|  | session_.OnRstStream(rst_frame); | 
|  | if (VersionHasIetfQuicFrames(transport_version())) { | 
|  | // The test requires the stream to be fully closed in both directions. For | 
|  | // IETF QUIC, the RST_STREAM only closes one side. | 
|  | QuicStopSendingFrame frame(kInvalidControlFrameId, stream->id(), | 
|  | QUIC_STREAM_CANCELLED); | 
|  | EXPECT_CALL(*connection_, CloseConnection(_, _, _)).Times(0); | 
|  | session_.OnStopSendingFrame(frame); | 
|  | } | 
|  | EXPECT_EQ(kByteOffset, session_.flow_controller()->bytes_consumed()); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, ConnectionFlowControlAccountingFinAndLocalReset) { | 
|  | CompleteHandshake(); | 
|  | // Test the situation where we receive a FIN on a stream, and before we fully | 
|  | // consume all the data from the sequencer buffer we locally RST the stream. | 
|  | // The bytes between highest consumed byte, and the final byte offset that we | 
|  | // determined when the FIN arrived, should be marked as consumed at the | 
|  | // connection level flow controller when the stream is reset. | 
|  | TestStream* stream = session_.CreateOutgoingBidirectionalStream(); | 
|  |  | 
|  | const QuicStreamOffset kByteOffset = | 
|  | kInitialSessionFlowControlWindowForTest / 2 - 1; | 
|  | QuicStreamFrame frame(stream->id(), true, kByteOffset, "."); | 
|  | session_.OnStreamFrame(frame); | 
|  | EXPECT_TRUE(connection_->connected()); | 
|  |  | 
|  | EXPECT_EQ(0u, session_.flow_controller()->bytes_consumed()); | 
|  | EXPECT_EQ(kByteOffset + frame.data_length, | 
|  | stream->highest_received_byte_offset()); | 
|  |  | 
|  | // Reset stream locally. | 
|  | EXPECT_CALL(*connection_, SendControlFrame(_)); | 
|  | EXPECT_CALL(*connection_, OnStreamReset(stream->id(), _)); | 
|  | stream->Reset(QUIC_STREAM_CANCELLED); | 
|  | EXPECT_EQ(kByteOffset + frame.data_length, | 
|  | session_.flow_controller()->bytes_consumed()); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, ConnectionFlowControlAccountingFinAfterRst) { | 
|  | CompleteHandshake(); | 
|  | // Test that when we RST the stream (and tear down stream state), and then | 
|  | // receive a FIN from the peer, we correctly adjust our connection level flow | 
|  | // control receive window. | 
|  |  | 
|  | // Connection starts with some non-zero highest received byte offset, | 
|  | // due to other active streams. | 
|  | const uint64_t kInitialConnectionBytesConsumed = 567; | 
|  | const uint64_t kInitialConnectionHighestReceivedOffset = 1234; | 
|  | EXPECT_LT(kInitialConnectionBytesConsumed, | 
|  | kInitialConnectionHighestReceivedOffset); | 
|  | session_.flow_controller()->UpdateHighestReceivedOffset( | 
|  | kInitialConnectionHighestReceivedOffset); | 
|  | session_.flow_controller()->AddBytesConsumed(kInitialConnectionBytesConsumed); | 
|  |  | 
|  | // Reset our stream: this results in the stream being closed locally. | 
|  | TestStream* stream = session_.CreateOutgoingBidirectionalStream(); | 
|  | EXPECT_CALL(*connection_, SendControlFrame(_)); | 
|  | EXPECT_CALL(*connection_, OnStreamReset(stream->id(), _)); | 
|  | stream->Reset(QUIC_STREAM_CANCELLED); | 
|  |  | 
|  | // Now receive a response from the peer with a FIN. We should handle this by | 
|  | // adjusting the connection level flow control receive window to take into | 
|  | // account the total number of bytes sent by the peer. | 
|  | const QuicStreamOffset kByteOffset = 5678; | 
|  | std::string body = "hello"; | 
|  | QuicStreamFrame frame(stream->id(), true, kByteOffset, | 
|  | absl::string_view(body)); | 
|  | session_.OnStreamFrame(frame); | 
|  |  | 
|  | QuicStreamOffset total_stream_bytes_sent_by_peer = | 
|  | kByteOffset + body.length(); | 
|  | EXPECT_EQ(kInitialConnectionBytesConsumed + total_stream_bytes_sent_by_peer, | 
|  | session_.flow_controller()->bytes_consumed()); | 
|  | EXPECT_EQ( | 
|  | kInitialConnectionHighestReceivedOffset + total_stream_bytes_sent_by_peer, | 
|  | session_.flow_controller()->highest_received_byte_offset()); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, ConnectionFlowControlAccountingRstAfterRst) { | 
|  | CompleteHandshake(); | 
|  | // Test that when we RST the stream (and tear down stream state), and then | 
|  | // receive a RST from the peer, we correctly adjust our connection level flow | 
|  | // control receive window. | 
|  |  | 
|  | // Connection starts with some non-zero highest received byte offset, | 
|  | // due to other active streams. | 
|  | const uint64_t kInitialConnectionBytesConsumed = 567; | 
|  | const uint64_t kInitialConnectionHighestReceivedOffset = 1234; | 
|  | EXPECT_LT(kInitialConnectionBytesConsumed, | 
|  | kInitialConnectionHighestReceivedOffset); | 
|  | session_.flow_controller()->UpdateHighestReceivedOffset( | 
|  | kInitialConnectionHighestReceivedOffset); | 
|  | session_.flow_controller()->AddBytesConsumed(kInitialConnectionBytesConsumed); | 
|  |  | 
|  | // Reset our stream: this results in the stream being closed locally. | 
|  | TestStream* stream = session_.CreateOutgoingBidirectionalStream(); | 
|  | EXPECT_CALL(*connection_, SendControlFrame(_)); | 
|  | EXPECT_CALL(*connection_, OnStreamReset(stream->id(), _)); | 
|  | stream->Reset(QUIC_STREAM_CANCELLED); | 
|  | EXPECT_TRUE(QuicStreamPeer::read_side_closed(stream)); | 
|  |  | 
|  | // Now receive a RST from the peer. We should handle this by adjusting the | 
|  | // connection level flow control receive window to take into account the total | 
|  | // number of bytes sent by the peer. | 
|  | const QuicStreamOffset kByteOffset = 5678; | 
|  | QuicRstStreamFrame rst_frame(kInvalidControlFrameId, stream->id(), | 
|  | QUIC_STREAM_CANCELLED, kByteOffset); | 
|  | session_.OnRstStream(rst_frame); | 
|  |  | 
|  | EXPECT_EQ(kInitialConnectionBytesConsumed + kByteOffset, | 
|  | session_.flow_controller()->bytes_consumed()); | 
|  | EXPECT_EQ(kInitialConnectionHighestReceivedOffset + kByteOffset, | 
|  | session_.flow_controller()->highest_received_byte_offset()); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, InvalidStreamFlowControlWindowInHandshake) { | 
|  | // Test that receipt of an invalid (< default) stream flow control window from | 
|  | // the peer results in the connection being torn down. | 
|  | const uint32_t kInvalidWindow = kMinimumFlowControlSendWindow - 1; | 
|  | QuicConfigPeer::SetReceivedInitialStreamFlowControlWindow(session_.config(), | 
|  | kInvalidWindow); | 
|  |  | 
|  | if (connection_->version().handshake_protocol != PROTOCOL_TLS1_3) { | 
|  | EXPECT_CALL(*connection_, | 
|  | CloseConnection(QUIC_FLOW_CONTROL_INVALID_WINDOW, _, _)); | 
|  | } else { | 
|  | EXPECT_CALL(*connection_, CloseConnection(_, _, _)).Times(0); | 
|  | } | 
|  | connection_->SetDefaultEncryptionLevel(ENCRYPTION_FORWARD_SECURE); | 
|  | session_.OnConfigNegotiated(); | 
|  | } | 
|  |  | 
|  | // Test negotiation of custom server initial flow control window. | 
|  | TEST_P(QuicSessionTestServer, CustomFlowControlWindow) { | 
|  | QuicTagVector copt; | 
|  | copt.push_back(kIFW7); | 
|  | QuicConfigPeer::SetReceivedConnectionOptions(session_.config(), copt); | 
|  |  | 
|  | connection_->SetDefaultEncryptionLevel(ENCRYPTION_FORWARD_SECURE); | 
|  | session_.OnConfigNegotiated(); | 
|  | EXPECT_EQ(192 * 1024u, QuicFlowControllerPeer::ReceiveWindowSize( | 
|  | session_.flow_controller())); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, FlowControlWithInvalidFinalOffset) { | 
|  | CompleteHandshake(); | 
|  | // Test that if we receive a stream RST with a highest byte offset that | 
|  | // violates flow control, that we close the connection. | 
|  | const uint64_t kLargeOffset = kInitialSessionFlowControlWindowForTest + 1; | 
|  | EXPECT_CALL(*connection_, | 
|  | CloseConnection(QUIC_FLOW_CONTROL_RECEIVED_TOO_MUCH_DATA, _, _)) | 
|  | .Times(2); | 
|  |  | 
|  | // Check that stream frame + FIN results in connection close. | 
|  | TestStream* stream = session_.CreateOutgoingBidirectionalStream(); | 
|  | EXPECT_CALL(*connection_, SendControlFrame(_)); | 
|  | EXPECT_CALL(*connection_, OnStreamReset(stream->id(), _)); | 
|  | stream->Reset(QUIC_STREAM_CANCELLED); | 
|  | QuicStreamFrame frame(stream->id(), true, kLargeOffset, absl::string_view()); | 
|  | session_.OnStreamFrame(frame); | 
|  |  | 
|  | // Check that RST results in connection close. | 
|  | QuicRstStreamFrame rst_frame(kInvalidControlFrameId, stream->id(), | 
|  | QUIC_STREAM_CANCELLED, kLargeOffset); | 
|  | session_.OnRstStream(rst_frame); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, TooManyUnfinishedStreamsCauseServerRejectStream) { | 
|  | CompleteHandshake(); | 
|  | // If a buggy/malicious peer creates too many streams that are not ended | 
|  | // with a FIN or RST then we send an RST to refuse streams. For IETF QUIC the | 
|  | // connection is closed. | 
|  | const QuicStreamId kMaxStreams = 5; | 
|  | if (VersionHasIetfQuicFrames(transport_version())) { | 
|  | QuicSessionPeer::SetMaxOpenIncomingBidirectionalStreams(&session_, | 
|  | kMaxStreams); | 
|  | } else { | 
|  | QuicSessionPeer::SetMaxOpenIncomingStreams(&session_, kMaxStreams); | 
|  | } | 
|  | const QuicStreamId kFirstStreamId = GetNthClientInitiatedBidirectionalId(0); | 
|  | const QuicStreamId kFinalStreamId = | 
|  | GetNthClientInitiatedBidirectionalId(kMaxStreams); | 
|  | // Create kMaxStreams data streams, and close them all without receiving a | 
|  | // FIN or a RST_STREAM from the client. | 
|  | for (QuicStreamId i = kFirstStreamId; i < kFinalStreamId; | 
|  | i += QuicUtils::StreamIdDelta(connection_->transport_version())) { | 
|  | QuicStreamFrame data1(i, false, 0, absl::string_view("HT")); | 
|  | session_.OnStreamFrame(data1); | 
|  | CloseStream(i); | 
|  | } | 
|  |  | 
|  | if (VersionHasIetfQuicFrames(transport_version())) { | 
|  | EXPECT_CALL( | 
|  | *connection_, | 
|  | CloseConnection(QUIC_INVALID_STREAM_ID, | 
|  | "Stream id 20 would exceed stream count limit 5", _)); | 
|  | } else { | 
|  | EXPECT_CALL(*connection_, SendControlFrame(_)).Times(1); | 
|  | EXPECT_CALL(*connection_, | 
|  | OnStreamReset(kFinalStreamId, QUIC_REFUSED_STREAM)) | 
|  | .Times(1); | 
|  | } | 
|  | // Create one more data streams to exceed limit of open stream. | 
|  | QuicStreamFrame data1(kFinalStreamId, false, 0, absl::string_view("HT")); | 
|  | session_.OnStreamFrame(data1); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, DrainingStreamsDoNotCountAsOpenedOutgoing) { | 
|  | // Verify that a draining stream (which has received a FIN but not consumed | 
|  | // it) does not count against the open quota (because it is closed from the | 
|  | // protocol point of view). | 
|  | CompleteHandshake(); | 
|  | TestStream* stream = session_.CreateOutgoingBidirectionalStream(); | 
|  | QuicStreamId stream_id = stream->id(); | 
|  | QuicStreamFrame data1(stream_id, true, 0, absl::string_view("HT")); | 
|  | session_.OnStreamFrame(data1); | 
|  | if (!VersionHasIetfQuicFrames(transport_version())) { | 
|  | EXPECT_CALL(session_, OnCanCreateNewOutgoingStream(false)).Times(1); | 
|  | } | 
|  | session_.StreamDraining(stream_id, /*unidirectional=*/false); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, NoPendingStreams) { | 
|  | session_.set_uses_pending_streams(false); | 
|  |  | 
|  | QuicStreamId stream_id = QuicUtils::GetFirstUnidirectionalStreamId( | 
|  | transport_version(), Perspective::IS_CLIENT); | 
|  | QuicStreamFrame data1(stream_id, true, 10, absl::string_view("HT")); | 
|  | session_.OnStreamFrame(data1); | 
|  | EXPECT_EQ(1, session_.num_incoming_streams_created()); | 
|  |  | 
|  | QuicStreamFrame data2(stream_id, false, 0, absl::string_view("HT")); | 
|  | session_.OnStreamFrame(data2); | 
|  | EXPECT_EQ(1, session_.num_incoming_streams_created()); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, PendingStreams) { | 
|  | if (!VersionUsesHttp3(transport_version())) { | 
|  | return; | 
|  | } | 
|  | session_.set_uses_pending_streams(true); | 
|  | session_.set_process_pending_stream_immediately(true); | 
|  |  | 
|  | QuicStreamId stream_id = QuicUtils::GetFirstUnidirectionalStreamId( | 
|  | transport_version(), Perspective::IS_CLIENT); | 
|  | QuicStreamFrame data1(stream_id, true, 10, absl::string_view("HT")); | 
|  | session_.OnStreamFrame(data1); | 
|  | EXPECT_TRUE(QuicSessionPeer::GetPendingStream(&session_, stream_id)); | 
|  | EXPECT_EQ(0, session_.num_incoming_streams_created()); | 
|  |  | 
|  | QuicStreamFrame data2(stream_id, false, 0, absl::string_view("HT")); | 
|  | session_.OnStreamFrame(data2); | 
|  | EXPECT_FALSE(QuicSessionPeer::GetPendingStream(&session_, stream_id)); | 
|  | EXPECT_EQ(1, session_.num_incoming_streams_created()); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, BufferAllIncomingStreams) { | 
|  | if (!VersionUsesHttp3(transport_version())) { | 
|  | return; | 
|  | } | 
|  | session_.set_uses_pending_streams(true); | 
|  | session_.set_process_pending_stream_immediately(false); | 
|  |  | 
|  | QuicStreamId stream_id = QuicUtils::GetFirstUnidirectionalStreamId( | 
|  | transport_version(), Perspective::IS_CLIENT); | 
|  | QuicStreamFrame data1(stream_id, true, 10, absl::string_view("HT")); | 
|  | session_.OnStreamFrame(data1); | 
|  | EXPECT_TRUE(QuicSessionPeer::GetPendingStream(&session_, stream_id)); | 
|  | EXPECT_EQ(0, session_.num_incoming_streams_created()); | 
|  | // Read unidirectional stream is still buffered when the first byte arrives. | 
|  | QuicStreamFrame data2(stream_id, false, 0, absl::string_view("HT")); | 
|  | session_.OnStreamFrame(data2); | 
|  | EXPECT_TRUE(QuicSessionPeer::GetPendingStream(&session_, stream_id)); | 
|  | EXPECT_EQ(0, session_.num_incoming_streams_created()); | 
|  |  | 
|  | // Bidirectional stream is buffered. | 
|  | QuicStreamId bidirectional_stream_id = | 
|  | QuicUtils::GetFirstBidirectionalStreamId(transport_version(), | 
|  | Perspective::IS_CLIENT); | 
|  | QuicStreamFrame data3(bidirectional_stream_id, false, 0, | 
|  | absl::string_view("HT")); | 
|  | session_.OnStreamFrame(data3); | 
|  | EXPECT_TRUE( | 
|  | QuicSessionPeer::GetPendingStream(&session_, bidirectional_stream_id)); | 
|  | EXPECT_EQ(0, session_.num_incoming_streams_created()); | 
|  |  | 
|  | session_.ProcessAllPendingStreams(); | 
|  | // Both bidirectional and read-unidirectional streams are unbuffered. | 
|  | EXPECT_FALSE(QuicSessionPeer::GetPendingStream(&session_, stream_id)); | 
|  | EXPECT_FALSE( | 
|  | QuicSessionPeer::GetPendingStream(&session_, bidirectional_stream_id)); | 
|  | EXPECT_EQ(2, session_.num_incoming_streams_created()); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, RstPendingStreams) { | 
|  | if (!VersionUsesHttp3(transport_version())) { | 
|  | return; | 
|  | } | 
|  | session_.set_uses_pending_streams(true); | 
|  | session_.set_process_pending_stream_immediately(false); | 
|  |  | 
|  | QuicStreamId stream_id = QuicUtils::GetFirstUnidirectionalStreamId( | 
|  | transport_version(), Perspective::IS_CLIENT); | 
|  | QuicStreamFrame data1(stream_id, true, 10, absl::string_view("HT")); | 
|  | session_.OnStreamFrame(data1); | 
|  | EXPECT_TRUE(QuicSessionPeer::GetPendingStream(&session_, stream_id)); | 
|  | EXPECT_EQ(0, session_.num_incoming_streams_created()); | 
|  | EXPECT_EQ(0u, QuicSessionPeer::GetNumOpenDynamicStreams(&session_)); | 
|  |  | 
|  | QuicRstStreamFrame rst1(kInvalidControlFrameId, stream_id, | 
|  | QUIC_ERROR_PROCESSING_STREAM, 12); | 
|  | session_.OnRstStream(rst1); | 
|  | EXPECT_FALSE(QuicSessionPeer::GetPendingStream(&session_, stream_id)); | 
|  | EXPECT_EQ(0, session_.num_incoming_streams_created()); | 
|  | EXPECT_EQ(0u, QuicSessionPeer::GetNumOpenDynamicStreams(&session_)); | 
|  |  | 
|  | QuicStreamFrame data2(stream_id, false, 0, absl::string_view("HT")); | 
|  | session_.OnStreamFrame(data2); | 
|  | EXPECT_FALSE(QuicSessionPeer::GetPendingStream(&session_, stream_id)); | 
|  | EXPECT_EQ(0, session_.num_incoming_streams_created()); | 
|  | EXPECT_EQ(0u, QuicSessionPeer::GetNumOpenDynamicStreams(&session_)); | 
|  |  | 
|  | session_.ProcessAllPendingStreams(); | 
|  | // Bidirectional stream is buffered. | 
|  | QuicStreamId bidirectional_stream_id = | 
|  | QuicUtils::GetFirstBidirectionalStreamId(transport_version(), | 
|  | Perspective::IS_CLIENT); | 
|  | QuicStreamFrame data3(bidirectional_stream_id, false, 0, | 
|  | absl::string_view("HT")); | 
|  | session_.OnStreamFrame(data3); | 
|  | EXPECT_TRUE( | 
|  | QuicSessionPeer::GetPendingStream(&session_, bidirectional_stream_id)); | 
|  | EXPECT_EQ(0, session_.num_incoming_streams_created()); | 
|  |  | 
|  | // Bidirectional pending stream is removed after RST_STREAM is received. | 
|  | QuicRstStreamFrame rst2(kInvalidControlFrameId, bidirectional_stream_id, | 
|  | QUIC_ERROR_PROCESSING_STREAM, 12); | 
|  | session_.OnRstStream(rst2); | 
|  | EXPECT_FALSE( | 
|  | QuicSessionPeer::GetPendingStream(&session_, bidirectional_stream_id)); | 
|  | EXPECT_EQ(0, session_.num_incoming_streams_created()); | 
|  | EXPECT_EQ(0u, QuicSessionPeer::GetNumOpenDynamicStreams(&session_)); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, OnFinPendingStreams) { | 
|  | if (!VersionUsesHttp3(transport_version())) { | 
|  | return; | 
|  | } | 
|  | session_.set_uses_pending_streams(true); | 
|  | session_.set_process_pending_stream_immediately(true); | 
|  |  | 
|  | QuicStreamId stream_id = QuicUtils::GetFirstUnidirectionalStreamId( | 
|  | transport_version(), Perspective::IS_CLIENT); | 
|  | QuicStreamFrame data(stream_id, true, 0, ""); | 
|  | session_.OnStreamFrame(data); | 
|  |  | 
|  | EXPECT_FALSE(QuicSessionPeer::GetPendingStream(&session_, stream_id)); | 
|  | EXPECT_EQ(0, session_.num_incoming_streams_created()); | 
|  | EXPECT_EQ(0u, QuicSessionPeer::GetNumOpenDynamicStreams(&session_)); | 
|  |  | 
|  | session_.set_process_pending_stream_immediately(false); | 
|  | // Bidirectional pending stream remains after Fin is received. | 
|  | // Bidirectional stream is buffered. | 
|  | QuicStreamId bidirectional_stream_id = | 
|  | QuicUtils::GetFirstBidirectionalStreamId(transport_version(), | 
|  | Perspective::IS_CLIENT); | 
|  | QuicStreamFrame data2(bidirectional_stream_id, true, 0, | 
|  | absl::string_view("HT")); | 
|  | session_.OnStreamFrame(data2); | 
|  | EXPECT_TRUE( | 
|  | QuicSessionPeer::GetPendingStream(&session_, bidirectional_stream_id)); | 
|  | EXPECT_EQ(0, session_.num_incoming_streams_created()); | 
|  |  | 
|  | session_.ProcessAllPendingStreams(); | 
|  | EXPECT_FALSE( | 
|  | QuicSessionPeer::GetPendingStream(&session_, bidirectional_stream_id)); | 
|  | EXPECT_EQ(1, session_.num_incoming_streams_created()); | 
|  | QuicStream* bidirectional_stream = | 
|  | QuicSessionPeer::GetStream(&session_, bidirectional_stream_id); | 
|  | EXPECT_TRUE(bidirectional_stream->fin_received()); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, UnidirectionalPendingStreamOnWindowUpdate) { | 
|  | if (!VersionUsesHttp3(transport_version())) { | 
|  | return; | 
|  | } | 
|  |  | 
|  | session_.set_uses_pending_streams(true); | 
|  | QuicStreamId stream_id = QuicUtils::GetFirstUnidirectionalStreamId( | 
|  | transport_version(), Perspective::IS_CLIENT); | 
|  | QuicStreamFrame data1(stream_id, true, 10, absl::string_view("HT")); | 
|  | session_.OnStreamFrame(data1); | 
|  | EXPECT_TRUE(QuicSessionPeer::GetPendingStream(&session_, stream_id)); | 
|  | EXPECT_EQ(0, session_.num_incoming_streams_created()); | 
|  | QuicWindowUpdateFrame window_update_frame(kInvalidControlFrameId, stream_id, | 
|  | 0); | 
|  | EXPECT_CALL( | 
|  | *connection_, | 
|  | CloseConnection( | 
|  | QUIC_WINDOW_UPDATE_RECEIVED_ON_READ_UNIDIRECTIONAL_STREAM, | 
|  | "WindowUpdateFrame received on READ_UNIDIRECTIONAL stream.", _)); | 
|  | session_.OnWindowUpdateFrame(window_update_frame); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, BidirectionalPendingStreamOnWindowUpdate) { | 
|  | if (!VersionUsesHttp3(transport_version())) { | 
|  | return; | 
|  | } | 
|  |  | 
|  | session_.set_uses_pending_streams(true); | 
|  | session_.set_process_pending_stream_immediately(false); | 
|  | QuicStreamId stream_id = QuicUtils::GetFirstBidirectionalStreamId( | 
|  | transport_version(), Perspective::IS_CLIENT); | 
|  | QuicStreamFrame data(stream_id, true, 10, absl::string_view("HT")); | 
|  | session_.OnStreamFrame(data); | 
|  | QuicWindowUpdateFrame window_update_frame(kInvalidControlFrameId, stream_id, | 
|  | kDefaultFlowControlSendWindow * 2); | 
|  | session_.OnWindowUpdateFrame(window_update_frame); | 
|  | EXPECT_TRUE(QuicSessionPeer::GetPendingStream(&session_, stream_id)); | 
|  | EXPECT_EQ(0, session_.num_incoming_streams_created()); | 
|  |  | 
|  | session_.ProcessAllPendingStreams(); | 
|  | EXPECT_FALSE(QuicSessionPeer::GetPendingStream(&session_, stream_id)); | 
|  | EXPECT_EQ(1, session_.num_incoming_streams_created()); | 
|  | QuicStream* bidirectional_stream = | 
|  | QuicSessionPeer::GetStream(&session_, stream_id); | 
|  | QuicByteCount send_window = | 
|  | QuicStreamPeer::SendWindowSize(bidirectional_stream); | 
|  | EXPECT_EQ(send_window, kDefaultFlowControlSendWindow * 2); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, UnidirectionalPendingStreamOnStopSending) { | 
|  | if (!VersionUsesHttp3(transport_version())) { | 
|  | return; | 
|  | } | 
|  |  | 
|  | session_.set_uses_pending_streams(true); | 
|  | QuicStreamId stream_id = QuicUtils::GetFirstUnidirectionalStreamId( | 
|  | transport_version(), Perspective::IS_CLIENT); | 
|  | QuicStreamFrame data1(stream_id, true, 10, absl::string_view("HT")); | 
|  | session_.OnStreamFrame(data1); | 
|  | EXPECT_TRUE(QuicSessionPeer::GetPendingStream(&session_, stream_id)); | 
|  | EXPECT_EQ(0, session_.num_incoming_streams_created()); | 
|  | QuicStopSendingFrame stop_sending_frame(kInvalidControlFrameId, stream_id, | 
|  | QUIC_STREAM_CANCELLED); | 
|  | EXPECT_CALL( | 
|  | *connection_, | 
|  | CloseConnection(QUIC_INVALID_STREAM_ID, | 
|  | "Received STOP_SENDING for a read-only stream", _)); | 
|  | session_.OnStopSendingFrame(stop_sending_frame); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, BidirectionalPendingStreamOnStopSending) { | 
|  | if (!VersionUsesHttp3(transport_version())) { | 
|  | return; | 
|  | } | 
|  |  | 
|  | session_.set_uses_pending_streams(true); | 
|  | session_.set_process_pending_stream_immediately(false); | 
|  | QuicStreamId stream_id = QuicUtils::GetFirstBidirectionalStreamId( | 
|  | transport_version(), Perspective::IS_CLIENT); | 
|  | QuicStreamFrame data(stream_id, true, 0, absl::string_view("HT")); | 
|  | session_.OnStreamFrame(data); | 
|  | QuicStopSendingFrame stop_sending_frame(kInvalidControlFrameId, stream_id, | 
|  | QUIC_STREAM_CANCELLED); | 
|  | session_.OnStopSendingFrame(stop_sending_frame); | 
|  | EXPECT_TRUE(QuicSessionPeer::GetPendingStream(&session_, stream_id)); | 
|  | EXPECT_EQ(0, session_.num_incoming_streams_created()); | 
|  |  | 
|  | EXPECT_CALL(*connection_, OnStreamReset(stream_id, _)); | 
|  | session_.ProcessAllPendingStreams(); | 
|  | EXPECT_FALSE(QuicSessionPeer::GetPendingStream(&session_, stream_id)); | 
|  | EXPECT_EQ(1, session_.num_incoming_streams_created()); | 
|  | QuicStream* bidirectional_stream = | 
|  | QuicSessionPeer::GetStream(&session_, stream_id); | 
|  | EXPECT_TRUE(bidirectional_stream->write_side_closed()); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, DrainingStreamsDoNotCountAsOpened) { | 
|  | // Verify that a draining stream (which has received a FIN but not consumed | 
|  | // it) does not count against the open quota (because it is closed from the | 
|  | // protocol point of view). | 
|  | CompleteHandshake(); | 
|  | if (VersionHasIetfQuicFrames(transport_version())) { | 
|  | // On IETF QUIC, we will expect to see a MAX_STREAMS go out when there are | 
|  | // not enough streams to create the next one. | 
|  | EXPECT_CALL(*connection_, SendControlFrame(_)).Times(1); | 
|  | } else { | 
|  | EXPECT_CALL(*connection_, SendControlFrame(_)).Times(0); | 
|  | } | 
|  | EXPECT_CALL(*connection_, OnStreamReset(_, QUIC_REFUSED_STREAM)).Times(0); | 
|  | const QuicStreamId kMaxStreams = 5; | 
|  | if (VersionHasIetfQuicFrames(transport_version())) { | 
|  | QuicSessionPeer::SetMaxOpenIncomingBidirectionalStreams(&session_, | 
|  | kMaxStreams); | 
|  | } else { | 
|  | QuicSessionPeer::SetMaxOpenIncomingStreams(&session_, kMaxStreams); | 
|  | } | 
|  |  | 
|  | // Create kMaxStreams + 1 data streams, and mark them draining. | 
|  | const QuicStreamId kFirstStreamId = GetNthClientInitiatedBidirectionalId(0); | 
|  | const QuicStreamId kFinalStreamId = | 
|  | GetNthClientInitiatedBidirectionalId(2 * kMaxStreams + 1); | 
|  | for (QuicStreamId i = kFirstStreamId; i < kFinalStreamId; | 
|  | i += QuicUtils::StreamIdDelta(connection_->transport_version())) { | 
|  | QuicStreamFrame data1(i, true, 0, absl::string_view("HT")); | 
|  | session_.OnStreamFrame(data1); | 
|  | EXPECT_EQ(1u, QuicSessionPeer::GetNumOpenDynamicStreams(&session_)); | 
|  | session_.StreamDraining(i, /*unidirectional=*/false); | 
|  | EXPECT_EQ(0u, QuicSessionPeer::GetNumOpenDynamicStreams(&session_)); | 
|  | } | 
|  | } | 
|  |  | 
|  | class QuicSessionTestClient : public QuicSessionTestBase { | 
|  | protected: | 
|  | QuicSessionTestClient() | 
|  | : QuicSessionTestBase(Perspective::IS_CLIENT, | 
|  | /*configure_session=*/true) {} | 
|  | }; | 
|  |  | 
|  | INSTANTIATE_TEST_SUITE_P(Tests, | 
|  | QuicSessionTestClient, | 
|  | ::testing::ValuesIn(AllSupportedVersions()), | 
|  | ::testing::PrintToStringParamName()); | 
|  |  | 
|  | TEST_P(QuicSessionTestClient, AvailableBidirectionalStreamsClient) { | 
|  | ASSERT_TRUE(session_.GetOrCreateStream( | 
|  | GetNthServerInitiatedBidirectionalId(2)) != nullptr); | 
|  | // Smaller bidirectional streams should be available. | 
|  | EXPECT_TRUE(QuicSessionPeer::IsStreamAvailable( | 
|  | &session_, GetNthServerInitiatedBidirectionalId(0))); | 
|  | EXPECT_TRUE(QuicSessionPeer::IsStreamAvailable( | 
|  | &session_, GetNthServerInitiatedBidirectionalId(1))); | 
|  | ASSERT_TRUE(session_.GetOrCreateStream( | 
|  | GetNthServerInitiatedBidirectionalId(0)) != nullptr); | 
|  | ASSERT_TRUE(session_.GetOrCreateStream( | 
|  | GetNthServerInitiatedBidirectionalId(1)) != nullptr); | 
|  | // And 5 should be not available. | 
|  | EXPECT_FALSE(QuicSessionPeer::IsStreamAvailable( | 
|  | &session_, GetNthClientInitiatedBidirectionalId(1))); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestClient, InvalidSessionFlowControlWindowInHandshake) { | 
|  | // Test that receipt of an invalid (< default for gQUIC, < current for TLS) | 
|  | // session flow control window from the peer results in the connection being | 
|  | // torn down. | 
|  | const uint32_t kInvalidWindow = kMinimumFlowControlSendWindow - 1; | 
|  | QuicConfigPeer::SetReceivedInitialSessionFlowControlWindow(session_.config(), | 
|  | kInvalidWindow); | 
|  | EXPECT_CALL( | 
|  | *connection_, | 
|  | CloseConnection(connection_->version().AllowsLowFlowControlLimits() | 
|  | ? QUIC_ZERO_RTT_RESUMPTION_LIMIT_REDUCED | 
|  | : QUIC_FLOW_CONTROL_INVALID_WINDOW, | 
|  | _, _)); | 
|  | connection_->SetDefaultEncryptionLevel(ENCRYPTION_FORWARD_SECURE); | 
|  | session_.OnConfigNegotiated(); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestClient, InvalidBidiStreamLimitInHandshake) { | 
|  | // IETF QUIC only feature. | 
|  | if (!VersionHasIetfQuicFrames(transport_version())) { | 
|  | return; | 
|  | } | 
|  | QuicConfigPeer::SetReceivedMaxBidirectionalStreams( | 
|  | session_.config(), kDefaultMaxStreamsPerConnection - 1); | 
|  | EXPECT_CALL(*connection_, | 
|  | CloseConnection(QUIC_ZERO_RTT_RESUMPTION_LIMIT_REDUCED, _, _)); | 
|  | connection_->SetDefaultEncryptionLevel(ENCRYPTION_FORWARD_SECURE); | 
|  | session_.OnConfigNegotiated(); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestClient, InvalidUniStreamLimitInHandshake) { | 
|  | // IETF QUIC only feature. | 
|  | if (!VersionHasIetfQuicFrames(transport_version())) { | 
|  | return; | 
|  | } | 
|  | QuicConfigPeer::SetReceivedMaxUnidirectionalStreams( | 
|  | session_.config(), kDefaultMaxStreamsPerConnection - 1); | 
|  | EXPECT_CALL(*connection_, | 
|  | CloseConnection(QUIC_ZERO_RTT_RESUMPTION_LIMIT_REDUCED, _, _)); | 
|  | connection_->SetDefaultEncryptionLevel(ENCRYPTION_FORWARD_SECURE); | 
|  | session_.OnConfigNegotiated(); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestClient, InvalidStreamFlowControlWindowInHandshake) { | 
|  | // IETF QUIC only feature. | 
|  | if (!VersionHasIetfQuicFrames(transport_version())) { | 
|  | return; | 
|  | } | 
|  | session_.CreateOutgoingBidirectionalStream(); | 
|  | session_.CreateOutgoingBidirectionalStream(); | 
|  | QuicConfigPeer::SetReceivedInitialMaxStreamDataBytesOutgoingBidirectional( | 
|  | session_.config(), kMinimumFlowControlSendWindow - 1); | 
|  |  | 
|  | EXPECT_CALL(*connection_, CloseConnection(_, _, _)) | 
|  | .WillOnce( | 
|  | Invoke(connection_, &MockQuicConnection::ReallyCloseConnection)); | 
|  | EXPECT_CALL(*connection_, SendConnectionClosePacket(_, _, _)); | 
|  |  | 
|  | connection_->SetDefaultEncryptionLevel(ENCRYPTION_FORWARD_SECURE); | 
|  | session_.OnConfigNegotiated(); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestClient, OnMaxStreamFrame) { | 
|  | if (!VersionUsesHttp3(transport_version())) { | 
|  | return; | 
|  | } | 
|  | QuicMaxStreamsFrame frame; | 
|  | frame.unidirectional = false; | 
|  | frame.stream_count = 120; | 
|  | EXPECT_CALL(session_, OnCanCreateNewOutgoingStream(false)).Times(1); | 
|  | session_.OnMaxStreamsFrame(frame); | 
|  |  | 
|  | QuicMaxStreamsFrame frame2; | 
|  | frame2.unidirectional = false; | 
|  | frame2.stream_count = 110; | 
|  | EXPECT_CALL(session_, OnCanCreateNewOutgoingStream(false)).Times(0); | 
|  | session_.OnMaxStreamsFrame(frame2); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestClient, AvailableUnidirectionalStreamsClient) { | 
|  | ASSERT_TRUE(session_.GetOrCreateStream( | 
|  | GetNthServerInitiatedUnidirectionalId(2)) != nullptr); | 
|  | // Smaller unidirectional streams should be available. | 
|  | EXPECT_TRUE(QuicSessionPeer::IsStreamAvailable( | 
|  | &session_, GetNthServerInitiatedUnidirectionalId(0))); | 
|  | EXPECT_TRUE(QuicSessionPeer::IsStreamAvailable( | 
|  | &session_, GetNthServerInitiatedUnidirectionalId(1))); | 
|  | ASSERT_TRUE(session_.GetOrCreateStream( | 
|  | GetNthServerInitiatedUnidirectionalId(0)) != nullptr); | 
|  | ASSERT_TRUE(session_.GetOrCreateStream( | 
|  | GetNthServerInitiatedUnidirectionalId(1)) != nullptr); | 
|  | // And 5 should be not available. | 
|  | EXPECT_FALSE(QuicSessionPeer::IsStreamAvailable( | 
|  | &session_, GetNthClientInitiatedUnidirectionalId(1))); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestClient, RecordFinAfterReadSideClosed) { | 
|  | CompleteHandshake(); | 
|  | // Verify that an incoming FIN is recorded in a stream object even if the read | 
|  | // side has been closed.  This prevents an entry from being made in | 
|  | // locally_closed_streams_highest_offset_ (which will never be deleted). | 
|  | TestStream* stream = session_.CreateOutgoingBidirectionalStream(); | 
|  | QuicStreamId stream_id = stream->id(); | 
|  |  | 
|  | // Close the read side manually. | 
|  | QuicStreamPeer::CloseReadSide(stream); | 
|  |  | 
|  | // Receive a stream data frame with FIN. | 
|  | QuicStreamFrame frame(stream_id, true, 0, absl::string_view()); | 
|  | session_.OnStreamFrame(frame); | 
|  | EXPECT_TRUE(stream->fin_received()); | 
|  |  | 
|  | // Reset stream locally. | 
|  | EXPECT_CALL(*connection_, SendControlFrame(_)); | 
|  | EXPECT_CALL(*connection_, OnStreamReset(stream->id(), _)); | 
|  | stream->Reset(QUIC_STREAM_CANCELLED); | 
|  | EXPECT_TRUE(QuicStreamPeer::read_side_closed(stream)); | 
|  |  | 
|  | EXPECT_TRUE(connection_->connected()); | 
|  | EXPECT_TRUE(QuicSessionPeer::IsStreamClosed(&session_, stream_id)); | 
|  | EXPECT_FALSE(QuicSessionPeer::IsStreamCreated(&session_, stream_id)); | 
|  |  | 
|  | // The stream is not waiting for the arrival of the peer's final offset as it | 
|  | // was received with the FIN earlier. | 
|  | EXPECT_EQ( | 
|  | 0u, | 
|  | QuicSessionPeer::GetLocallyClosedStreamsHighestOffset(&session_).size()); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestClient, IncomingStreamWithClientInitiatedStreamId) { | 
|  | const QuicErrorCode expected_error = | 
|  | VersionHasIetfQuicFrames(transport_version()) | 
|  | ? QUIC_HTTP_STREAM_WRONG_DIRECTION | 
|  | : QUIC_INVALID_STREAM_ID; | 
|  | EXPECT_CALL( | 
|  | *connection_, | 
|  | CloseConnection(expected_error, "Data for nonexistent stream", | 
|  | ConnectionCloseBehavior::SEND_CONNECTION_CLOSE_PACKET)); | 
|  |  | 
|  | QuicStreamFrame frame(GetNthClientInitiatedBidirectionalId(1), | 
|  | /* fin = */ false, /* offset = */ 0, | 
|  | absl::string_view("foo")); | 
|  | session_.OnStreamFrame(frame); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestClient, MinAckDelaySetOnTheClientQuicConfig) { | 
|  | if (!session_.version().HasIetfQuicFrames()) { | 
|  | return; | 
|  | } | 
|  | session_.config()->SetClientConnectionOptions({kAFFE}); | 
|  | session_.Initialize(); | 
|  | ASSERT_EQ(session_.config()->GetMinAckDelayToSendMs(), | 
|  | kDefaultMinAckDelayTimeMs); | 
|  | ASSERT_TRUE(session_.connection()->can_receive_ack_frequency_frame()); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestClient, KeyUpdateNotSupportedLocally) { | 
|  | EXPECT_CALL(*session_.GetMutableCryptoStream(), KeyUpdateSupportedLocally()) | 
|  | .WillOnce(Return(false)); | 
|  | session_.Initialize(); | 
|  | EXPECT_FALSE(session_.config()->KeyUpdateSupportedLocally()); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestClient, KeyUpdateSupportedLocally) { | 
|  | EXPECT_CALL(*session_.GetMutableCryptoStream(), KeyUpdateSupportedLocally()) | 
|  | .WillOnce(Return(true)); | 
|  | session_.Initialize(); | 
|  | EXPECT_TRUE(session_.config()->KeyUpdateSupportedLocally()); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestClient, FailedToCreateStreamIfTooCloseToIdleTimeout) { | 
|  | connection_->SetDefaultEncryptionLevel(ENCRYPTION_FORWARD_SECURE); | 
|  | EXPECT_TRUE(session_.CanOpenNextOutgoingBidirectionalStream()); | 
|  | QuicTime deadline = QuicConnectionPeer::GetIdleNetworkDeadline(connection_); | 
|  | ASSERT_TRUE(deadline.IsInitialized()); | 
|  | QuicTime::Delta timeout = deadline - helper_.GetClock()->ApproximateNow(); | 
|  | // Advance time to very close idle timeout. | 
|  | connection_->AdvanceTime(timeout - QuicTime::Delta::FromMilliseconds(1)); | 
|  | // Verify creation of new stream gets pushed back and connectivity probing | 
|  | // packet gets sent. | 
|  | EXPECT_CALL(*connection_, SendConnectivityProbingPacket(_, _)).Times(1); | 
|  | EXPECT_FALSE(session_.CanOpenNextOutgoingBidirectionalStream()); | 
|  |  | 
|  | // New packet gets received, idle deadline gets extended. | 
|  | EXPECT_CALL(session_, OnCanCreateNewOutgoingStream(false)); | 
|  | QuicConnectionPeer::GetIdleNetworkDetector(connection_) | 
|  | .OnPacketReceived(helper_.GetClock()->ApproximateNow()); | 
|  | session_.OnPacketDecrypted(ENCRYPTION_FORWARD_SECURE); | 
|  |  | 
|  | EXPECT_TRUE(session_.CanOpenNextOutgoingBidirectionalStream()); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, ZombieStreams) { | 
|  | CompleteHandshake(); | 
|  | TestStream* stream2 = session_.CreateOutgoingBidirectionalStream(); | 
|  | QuicStreamPeer::SetStreamBytesWritten(3, stream2); | 
|  | EXPECT_TRUE(stream2->IsWaitingForAcks()); | 
|  |  | 
|  | CloseStream(stream2->id()); | 
|  | ASSERT_EQ(1u, session_.closed_streams()->size()); | 
|  | EXPECT_EQ(stream2->id(), session_.closed_streams()->front()->id()); | 
|  | session_.MaybeCloseZombieStream(stream2->id()); | 
|  | EXPECT_EQ(1u, session_.closed_streams()->size()); | 
|  | EXPECT_EQ(stream2->id(), session_.closed_streams()->front()->id()); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, RstStreamReceivedAfterRstStreamSent) { | 
|  | CompleteHandshake(); | 
|  | TestStream* stream2 = session_.CreateOutgoingBidirectionalStream(); | 
|  | QuicStreamPeer::SetStreamBytesWritten(3, stream2); | 
|  | EXPECT_TRUE(stream2->IsWaitingForAcks()); | 
|  |  | 
|  | EXPECT_CALL(*connection_, SendControlFrame(_)); | 
|  | EXPECT_CALL(*connection_, OnStreamReset(stream2->id(), _)); | 
|  | EXPECT_CALL(session_, OnCanCreateNewOutgoingStream(false)).Times(0); | 
|  | stream2->Reset(quic::QUIC_STREAM_CANCELLED); | 
|  |  | 
|  | QuicRstStreamFrame rst1(kInvalidControlFrameId, stream2->id(), | 
|  | QUIC_ERROR_PROCESSING_STREAM, 0); | 
|  | if (!VersionHasIetfQuicFrames(transport_version())) { | 
|  | EXPECT_CALL(session_, OnCanCreateNewOutgoingStream(false)).Times(1); | 
|  | } | 
|  | session_.OnRstStream(rst1); | 
|  | } | 
|  |  | 
|  | // Regression test of b/71548958. | 
|  | TEST_P(QuicSessionTestServer, TestZombieStreams) { | 
|  | CompleteHandshake(); | 
|  | session_.set_writev_consumes_all_data(true); | 
|  |  | 
|  | TestStream* stream2 = session_.CreateOutgoingBidirectionalStream(); | 
|  | std::string body(100, '.'); | 
|  | stream2->WriteOrBufferData(body, false, nullptr); | 
|  | EXPECT_TRUE(stream2->IsWaitingForAcks()); | 
|  | EXPECT_EQ(1u, QuicStreamPeer::SendBuffer(stream2).size()); | 
|  |  | 
|  | QuicRstStreamFrame rst_frame(kInvalidControlFrameId, stream2->id(), | 
|  | QUIC_STREAM_CANCELLED, 1234); | 
|  | // Just for the RST_STREAM | 
|  | EXPECT_CALL(*connection_, SendControlFrame(_)) | 
|  | .WillOnce(Invoke(&ClearControlFrame)); | 
|  | if (VersionHasIetfQuicFrames(transport_version())) { | 
|  | EXPECT_CALL(*connection_, | 
|  | OnStreamReset(stream2->id(), QUIC_STREAM_CANCELLED)); | 
|  | } else { | 
|  | EXPECT_CALL(*connection_, | 
|  | OnStreamReset(stream2->id(), QUIC_RST_ACKNOWLEDGEMENT)); | 
|  | } | 
|  | stream2->OnStreamReset(rst_frame); | 
|  |  | 
|  | if (VersionHasIetfQuicFrames(transport_version())) { | 
|  | // The test requires the stream to be fully closed in both directions. For | 
|  | // IETF QUIC, the RST_STREAM only closes one side. | 
|  | QuicStopSendingFrame frame(kInvalidControlFrameId, stream2->id(), | 
|  | QUIC_STREAM_CANCELLED); | 
|  | EXPECT_CALL(*connection_, CloseConnection(_, _, _)).Times(0); | 
|  | session_.OnStopSendingFrame(frame); | 
|  | } | 
|  | ASSERT_EQ(1u, session_.closed_streams()->size()); | 
|  | EXPECT_EQ(stream2->id(), session_.closed_streams()->front()->id()); | 
|  |  | 
|  | TestStream* stream4 = session_.CreateOutgoingBidirectionalStream(); | 
|  | if (VersionHasIetfQuicFrames(transport_version())) { | 
|  | // Once for the RST_STREAM, once for the STOP_SENDING | 
|  | EXPECT_CALL(*connection_, SendControlFrame(_)) | 
|  | .Times(2) | 
|  | .WillRepeatedly(Invoke(&ClearControlFrame)); | 
|  | } else { | 
|  | // Just for the RST_STREAM | 
|  | EXPECT_CALL(*connection_, SendControlFrame(_)).Times(1); | 
|  | } | 
|  | EXPECT_CALL(*connection_, | 
|  | OnStreamReset(stream4->id(), QUIC_STREAM_CANCELLED)); | 
|  | stream4->WriteOrBufferData(body, false, nullptr); | 
|  | // Note well: Reset() actually closes the stream in both directions. For | 
|  | // GOOGLE QUIC it sends a RST_STREAM (which does a 2-way close), for IETF | 
|  | // QUIC it sends both a RST_STREAM and a STOP_SENDING (each of which | 
|  | // closes in only one direction). | 
|  | stream4->Reset(QUIC_STREAM_CANCELLED); | 
|  | EXPECT_EQ(2u, session_.closed_streams()->size()); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, OnStreamFrameLost) { | 
|  | CompleteHandshake(); | 
|  | InSequence s; | 
|  |  | 
|  | // Drive congestion control manually. | 
|  | MockSendAlgorithm* send_algorithm = new StrictMock<MockSendAlgorithm>; | 
|  | QuicConnectionPeer::SetSendAlgorithm(session_.connection(), send_algorithm); | 
|  |  | 
|  | TestCryptoStream* crypto_stream = session_.GetMutableCryptoStream(); | 
|  | TestStream* stream2 = session_.CreateOutgoingBidirectionalStream(); | 
|  | TestStream* stream4 = session_.CreateOutgoingBidirectionalStream(); | 
|  |  | 
|  | QuicStreamFrame frame1; | 
|  | if (!QuicVersionUsesCryptoFrames(connection_->transport_version())) { | 
|  | frame1 = QuicStreamFrame( | 
|  | QuicUtils::GetCryptoStreamId(connection_->transport_version()), false, | 
|  | 0, 1300); | 
|  | } | 
|  | QuicStreamFrame frame2(stream2->id(), false, 0, 9); | 
|  | QuicStreamFrame frame3(stream4->id(), false, 0, 9); | 
|  |  | 
|  | // Lost data on cryption stream, streams 2 and 4. | 
|  | EXPECT_CALL(*stream4, HasPendingRetransmission()).WillOnce(Return(true)); | 
|  | if (!QuicVersionUsesCryptoFrames(connection_->transport_version())) { | 
|  | EXPECT_CALL(*crypto_stream, HasPendingRetransmission()) | 
|  | .WillOnce(Return(true)); | 
|  | } | 
|  | EXPECT_CALL(*stream2, HasPendingRetransmission()).WillOnce(Return(true)); | 
|  | session_.OnFrameLost(QuicFrame(frame3)); | 
|  | if (!QuicVersionUsesCryptoFrames(connection_->transport_version())) { | 
|  | session_.OnFrameLost(QuicFrame(frame1)); | 
|  | } else { | 
|  | QuicCryptoFrame crypto_frame(ENCRYPTION_INITIAL, 0, 1300); | 
|  | session_.OnFrameLost(QuicFrame(&crypto_frame)); | 
|  | } | 
|  | session_.OnFrameLost(QuicFrame(frame2)); | 
|  | EXPECT_TRUE(session_.WillingAndAbleToWrite()); | 
|  |  | 
|  | // Mark streams 2 and 4 write blocked. | 
|  | session_.MarkConnectionLevelWriteBlocked(stream2->id()); | 
|  | session_.MarkConnectionLevelWriteBlocked(stream4->id()); | 
|  |  | 
|  | // Lost data is retransmitted before new data, and retransmissions for crypto | 
|  | // stream go first. | 
|  | // Do not check congestion window when crypto stream has lost data. | 
|  | EXPECT_CALL(*send_algorithm, CanSend(_)).Times(0); | 
|  | if (!QuicVersionUsesCryptoFrames(connection_->transport_version())) { | 
|  | EXPECT_CALL(*crypto_stream, OnCanWrite()); | 
|  | EXPECT_CALL(*crypto_stream, HasPendingRetransmission()) | 
|  | .WillOnce(Return(false)); | 
|  | } | 
|  | // Check congestion window for non crypto streams. | 
|  | EXPECT_CALL(*send_algorithm, CanSend(_)).WillOnce(Return(true)); | 
|  | EXPECT_CALL(*stream4, OnCanWrite()); | 
|  | EXPECT_CALL(*stream4, HasPendingRetransmission()).WillOnce(Return(false)); | 
|  | // Connection is blocked. | 
|  | EXPECT_CALL(*send_algorithm, CanSend(_)).WillRepeatedly(Return(false)); | 
|  |  | 
|  | session_.OnCanWrite(); | 
|  | EXPECT_TRUE(session_.WillingAndAbleToWrite()); | 
|  |  | 
|  | // Unblock connection. | 
|  | // Stream 2 retransmits lost data. | 
|  | EXPECT_CALL(*send_algorithm, CanSend(_)).WillOnce(Return(true)); | 
|  | EXPECT_CALL(*stream2, OnCanWrite()); | 
|  | EXPECT_CALL(*stream2, HasPendingRetransmission()).WillOnce(Return(false)); | 
|  | EXPECT_CALL(*send_algorithm, CanSend(_)).WillOnce(Return(true)); | 
|  | // Stream 2 sends new data. | 
|  | EXPECT_CALL(*stream2, OnCanWrite()); | 
|  | EXPECT_CALL(*send_algorithm, CanSend(_)).WillOnce(Return(true)); | 
|  | EXPECT_CALL(*stream4, OnCanWrite()); | 
|  | EXPECT_CALL(*send_algorithm, OnApplicationLimited(_)); | 
|  |  | 
|  | session_.OnCanWrite(); | 
|  | EXPECT_FALSE(session_.WillingAndAbleToWrite()); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, DonotRetransmitDataOfClosedStreams) { | 
|  | CompleteHandshake(); | 
|  | InSequence s; | 
|  |  | 
|  | TestStream* stream2 = session_.CreateOutgoingBidirectionalStream(); | 
|  | TestStream* stream4 = session_.CreateOutgoingBidirectionalStream(); | 
|  | TestStream* stream6 = session_.CreateOutgoingBidirectionalStream(); | 
|  |  | 
|  | QuicStreamFrame frame1(stream2->id(), false, 0, 9); | 
|  | QuicStreamFrame frame2(stream4->id(), false, 0, 9); | 
|  | QuicStreamFrame frame3(stream6->id(), false, 0, 9); | 
|  |  | 
|  | EXPECT_CALL(*stream6, HasPendingRetransmission()).WillOnce(Return(true)); | 
|  | EXPECT_CALL(*stream4, HasPendingRetransmission()).WillOnce(Return(true)); | 
|  | EXPECT_CALL(*stream2, HasPendingRetransmission()).WillOnce(Return(true)); | 
|  | session_.OnFrameLost(QuicFrame(frame3)); | 
|  | session_.OnFrameLost(QuicFrame(frame2)); | 
|  | session_.OnFrameLost(QuicFrame(frame1)); | 
|  |  | 
|  | session_.MarkConnectionLevelWriteBlocked(stream2->id()); | 
|  | session_.MarkConnectionLevelWriteBlocked(stream4->id()); | 
|  | session_.MarkConnectionLevelWriteBlocked(stream6->id()); | 
|  |  | 
|  | // Reset stream 4 locally. | 
|  | EXPECT_CALL(*connection_, SendControlFrame(_)); | 
|  | EXPECT_CALL(*connection_, OnStreamReset(stream4->id(), _)); | 
|  | stream4->Reset(QUIC_STREAM_CANCELLED); | 
|  |  | 
|  | // Verify stream 4 is removed from streams with lost data list. | 
|  | EXPECT_CALL(*stream6, OnCanWrite()); | 
|  | EXPECT_CALL(*stream6, HasPendingRetransmission()).WillOnce(Return(false)); | 
|  | EXPECT_CALL(*stream2, OnCanWrite()); | 
|  | EXPECT_CALL(*stream2, HasPendingRetransmission()).WillOnce(Return(false)); | 
|  | EXPECT_CALL(*connection_, SendControlFrame(_)) | 
|  | .WillRepeatedly(Invoke(&ClearControlFrame)); | 
|  | EXPECT_CALL(*stream2, OnCanWrite()); | 
|  | EXPECT_CALL(*stream6, OnCanWrite()); | 
|  | session_.OnCanWrite(); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, RetransmitFrames) { | 
|  | CompleteHandshake(); | 
|  | MockSendAlgorithm* send_algorithm = new StrictMock<MockSendAlgorithm>; | 
|  | QuicConnectionPeer::SetSendAlgorithm(session_.connection(), send_algorithm); | 
|  | InSequence s; | 
|  |  | 
|  | TestStream* stream2 = session_.CreateOutgoingBidirectionalStream(); | 
|  | TestStream* stream4 = session_.CreateOutgoingBidirectionalStream(); | 
|  | TestStream* stream6 = session_.CreateOutgoingBidirectionalStream(); | 
|  | EXPECT_CALL(*connection_, SendControlFrame(_)) | 
|  | .WillOnce(Invoke(&ClearControlFrame)); | 
|  | session_.SendWindowUpdate(stream2->id(), 9); | 
|  |  | 
|  | QuicStreamFrame frame1(stream2->id(), false, 0, 9); | 
|  | QuicStreamFrame frame2(stream4->id(), false, 0, 9); | 
|  | QuicStreamFrame frame3(stream6->id(), false, 0, 9); | 
|  | QuicWindowUpdateFrame window_update(1, stream2->id(), 9); | 
|  | QuicFrames frames; | 
|  | frames.push_back(QuicFrame(frame1)); | 
|  | frames.push_back(QuicFrame(&window_update)); | 
|  | frames.push_back(QuicFrame(frame2)); | 
|  | frames.push_back(QuicFrame(frame3)); | 
|  | EXPECT_FALSE(session_.WillingAndAbleToWrite()); | 
|  |  | 
|  | EXPECT_CALL(*stream2, RetransmitStreamData(_, _, _, _)) | 
|  | .WillOnce(Return(true)); | 
|  | EXPECT_CALL(*connection_, SendControlFrame(_)) | 
|  | .WillOnce(Invoke(&ClearControlFrame)); | 
|  | EXPECT_CALL(*stream4, RetransmitStreamData(_, _, _, _)) | 
|  | .WillOnce(Return(true)); | 
|  | EXPECT_CALL(*stream6, RetransmitStreamData(_, _, _, _)) | 
|  | .WillOnce(Return(true)); | 
|  | EXPECT_CALL(*send_algorithm, OnApplicationLimited(_)); | 
|  | session_.RetransmitFrames(frames, TLP_RETRANSMISSION); | 
|  | } | 
|  |  | 
|  | // Regression test of b/110082001. | 
|  | TEST_P(QuicSessionTestServer, RetransmitLostDataCausesConnectionClose) { | 
|  | CompleteHandshake(); | 
|  | // This test mimics the scenario when a dynamic stream retransmits lost data | 
|  | // and causes connection close. | 
|  | TestStream* stream = session_.CreateOutgoingBidirectionalStream(); | 
|  | QuicStreamFrame frame(stream->id(), false, 0, 9); | 
|  |  | 
|  | EXPECT_CALL(*stream, HasPendingRetransmission()) | 
|  | .Times(2) | 
|  | .WillOnce(Return(true)) | 
|  | .WillOnce(Return(false)); | 
|  | session_.OnFrameLost(QuicFrame(frame)); | 
|  | // Retransmit stream data causes connection close. Stream has not sent fin | 
|  | // yet, so an RST is sent. | 
|  | EXPECT_CALL(*stream, OnCanWrite()).WillOnce(Invoke([this, stream]() { | 
|  | session_.ResetStream(stream->id(), QUIC_STREAM_CANCELLED); | 
|  | })); | 
|  | if (VersionHasIetfQuicFrames(transport_version())) { | 
|  | // Once for the RST_STREAM, once for the STOP_SENDING | 
|  | EXPECT_CALL(*connection_, SendControlFrame(_)) | 
|  | .Times(2) | 
|  | .WillRepeatedly(Invoke(&session_, &TestSession::SaveFrame)); | 
|  | } else { | 
|  | // Just for the RST_STREAM | 
|  | EXPECT_CALL(*connection_, SendControlFrame(_)) | 
|  | .WillOnce(Invoke(&session_, &TestSession::SaveFrame)); | 
|  | } | 
|  | EXPECT_CALL(*connection_, OnStreamReset(stream->id(), _)); | 
|  | session_.OnCanWrite(); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, SendMessage) { | 
|  | // Cannot send message when encryption is not established. | 
|  | EXPECT_FALSE(session_.OneRttKeysAvailable()); | 
|  | EXPECT_EQ(MessageResult(MESSAGE_STATUS_ENCRYPTION_NOT_ESTABLISHED, 0), | 
|  | session_.SendMessage(MemSliceFromString(""))); | 
|  |  | 
|  | CompleteHandshake(); | 
|  | EXPECT_TRUE(session_.OneRttKeysAvailable()); | 
|  |  | 
|  | EXPECT_CALL(*connection_, SendMessage(1, _, false)) | 
|  | .WillOnce(Return(MESSAGE_STATUS_SUCCESS)); | 
|  | EXPECT_EQ(MessageResult(MESSAGE_STATUS_SUCCESS, 1), | 
|  | session_.SendMessage(MemSliceFromString(""))); | 
|  | // Verify message_id increases. | 
|  | EXPECT_CALL(*connection_, SendMessage(2, _, false)) | 
|  | .WillOnce(Return(MESSAGE_STATUS_TOO_LARGE)); | 
|  | EXPECT_EQ(MessageResult(MESSAGE_STATUS_TOO_LARGE, 0), | 
|  | session_.SendMessage(MemSliceFromString(""))); | 
|  | // Verify unsent message does not consume a message_id. | 
|  | EXPECT_CALL(*connection_, SendMessage(2, _, false)) | 
|  | .WillOnce(Return(MESSAGE_STATUS_SUCCESS)); | 
|  | EXPECT_EQ(MessageResult(MESSAGE_STATUS_SUCCESS, 2), | 
|  | session_.SendMessage(MemSliceFromString(""))); | 
|  |  | 
|  | QuicMessageFrame frame(1); | 
|  | QuicMessageFrame frame2(2); | 
|  | EXPECT_FALSE(session_.IsFrameOutstanding(QuicFrame(&frame))); | 
|  | EXPECT_FALSE(session_.IsFrameOutstanding(QuicFrame(&frame2))); | 
|  |  | 
|  | // Lost message 2. | 
|  | session_.OnMessageLost(2); | 
|  | EXPECT_FALSE(session_.IsFrameOutstanding(QuicFrame(&frame2))); | 
|  |  | 
|  | // message 1 gets acked. | 
|  | session_.OnMessageAcked(1, QuicTime::Zero()); | 
|  | EXPECT_FALSE(session_.IsFrameOutstanding(QuicFrame(&frame))); | 
|  | } | 
|  |  | 
|  | // Regression test of b/115323618. | 
|  | TEST_P(QuicSessionTestServer, LocallyResetZombieStreams) { | 
|  | CompleteHandshake(); | 
|  | session_.set_writev_consumes_all_data(true); | 
|  | TestStream* stream2 = session_.CreateOutgoingBidirectionalStream(); | 
|  | std::string body(100, '.'); | 
|  | QuicStreamPeer::CloseReadSide(stream2); | 
|  | stream2->WriteOrBufferData(body, true, nullptr); | 
|  | EXPECT_TRUE(stream2->IsWaitingForAcks()); | 
|  | // Verify stream2 is a zombie streams. | 
|  | auto& stream_map = QuicSessionPeer::stream_map(&session_); | 
|  | ASSERT_TRUE(stream_map.contains(stream2->id())); | 
|  | auto* stream = stream_map.find(stream2->id())->second.get(); | 
|  | EXPECT_TRUE(stream->IsZombie()); | 
|  |  | 
|  | QuicStreamFrame frame(stream2->id(), true, 0, 100); | 
|  | EXPECT_CALL(*stream2, HasPendingRetransmission()) | 
|  | .WillRepeatedly(Return(true)); | 
|  | session_.OnFrameLost(QuicFrame(frame)); | 
|  |  | 
|  | // Reset stream2 locally. | 
|  | EXPECT_CALL(*connection_, SendControlFrame(_)) | 
|  | .WillRepeatedly(Invoke(&ClearControlFrame)); | 
|  | EXPECT_CALL(*connection_, OnStreamReset(stream2->id(), _)); | 
|  | stream2->Reset(QUIC_STREAM_CANCELLED); | 
|  |  | 
|  | // Verify stream 2 gets closed. | 
|  | EXPECT_TRUE(session_.IsClosedStream(stream2->id())); | 
|  | EXPECT_CALL(*stream2, OnCanWrite()).Times(0); | 
|  | session_.OnCanWrite(); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, CleanUpClosedStreamsAlarm) { | 
|  | CompleteHandshake(); | 
|  | EXPECT_FALSE( | 
|  | QuicSessionPeer::GetCleanUpClosedStreamsAlarm(&session_)->IsSet()); | 
|  |  | 
|  | session_.set_writev_consumes_all_data(true); | 
|  | TestStream* stream2 = session_.CreateOutgoingBidirectionalStream(); | 
|  | EXPECT_FALSE(stream2->IsWaitingForAcks()); | 
|  |  | 
|  | CloseStream(stream2->id()); | 
|  | EXPECT_EQ(1u, session_.closed_streams()->size()); | 
|  | EXPECT_TRUE( | 
|  | QuicSessionPeer::GetCleanUpClosedStreamsAlarm(&session_)->IsSet()); | 
|  |  | 
|  | alarm_factory_.FireAlarm( | 
|  | QuicSessionPeer::GetCleanUpClosedStreamsAlarm(&session_)); | 
|  | EXPECT_TRUE(session_.closed_streams()->empty()); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, WriteUnidirectionalStream) { | 
|  | session_.set_writev_consumes_all_data(true); | 
|  | TestStream* stream4 = new TestStream(GetNthServerInitiatedUnidirectionalId(1), | 
|  | &session_, WRITE_UNIDIRECTIONAL); | 
|  | session_.ActivateStream(absl::WrapUnique(stream4)); | 
|  | std::string body(100, '.'); | 
|  | stream4->WriteOrBufferData(body, false, nullptr); | 
|  | stream4->WriteOrBufferData(body, true, nullptr); | 
|  | auto& stream_map = QuicSessionPeer::stream_map(&session_); | 
|  | ASSERT_TRUE(stream_map.contains(stream4->id())); | 
|  | auto* stream = stream_map.find(stream4->id())->second.get(); | 
|  | EXPECT_TRUE(stream->IsZombie()); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, ReceivedDataOnWriteUnidirectionalStream) { | 
|  | TestStream* stream4 = new TestStream(GetNthServerInitiatedUnidirectionalId(1), | 
|  | &session_, WRITE_UNIDIRECTIONAL); | 
|  | session_.ActivateStream(absl::WrapUnique(stream4)); | 
|  |  | 
|  | EXPECT_CALL( | 
|  | *connection_, | 
|  | CloseConnection(QUIC_DATA_RECEIVED_ON_WRITE_UNIDIRECTIONAL_STREAM, _, _)) | 
|  | .Times(1); | 
|  | QuicStreamFrame stream_frame(GetNthServerInitiatedUnidirectionalId(1), false, | 
|  | 0, 2); | 
|  | session_.OnStreamFrame(stream_frame); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, ReadUnidirectionalStream) { | 
|  | TestStream* stream4 = new TestStream(GetNthClientInitiatedUnidirectionalId(1), | 
|  | &session_, READ_UNIDIRECTIONAL); | 
|  | session_.ActivateStream(absl::WrapUnique(stream4)); | 
|  | EXPECT_FALSE(stream4->IsWaitingForAcks()); | 
|  | // Discard all incoming data. | 
|  | stream4->StopReading(); | 
|  |  | 
|  | std::string data(100, '.'); | 
|  | QuicStreamFrame stream_frame(GetNthClientInitiatedUnidirectionalId(1), false, | 
|  | 0, data); | 
|  | stream4->OnStreamFrame(stream_frame); | 
|  | EXPECT_TRUE(session_.closed_streams()->empty()); | 
|  |  | 
|  | QuicStreamFrame stream_frame2(GetNthClientInitiatedUnidirectionalId(1), true, | 
|  | 100, data); | 
|  | stream4->OnStreamFrame(stream_frame2); | 
|  | EXPECT_EQ(1u, session_.closed_streams()->size()); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, WriteOrBufferDataOnReadUnidirectionalStream) { | 
|  | TestStream* stream4 = new TestStream(GetNthClientInitiatedUnidirectionalId(1), | 
|  | &session_, READ_UNIDIRECTIONAL); | 
|  | session_.ActivateStream(absl::WrapUnique(stream4)); | 
|  |  | 
|  | EXPECT_CALL(*connection_, | 
|  | CloseConnection( | 
|  | QUIC_TRY_TO_WRITE_DATA_ON_READ_UNIDIRECTIONAL_STREAM, _, _)) | 
|  | .Times(1); | 
|  | std::string body(100, '.'); | 
|  | stream4->WriteOrBufferData(body, false, nullptr); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, WritevDataOnReadUnidirectionalStream) { | 
|  | TestStream* stream4 = new TestStream(GetNthClientInitiatedUnidirectionalId(1), | 
|  | &session_, READ_UNIDIRECTIONAL); | 
|  | session_.ActivateStream(absl::WrapUnique(stream4)); | 
|  |  | 
|  | EXPECT_CALL(*connection_, | 
|  | CloseConnection( | 
|  | QUIC_TRY_TO_WRITE_DATA_ON_READ_UNIDIRECTIONAL_STREAM, _, _)) | 
|  | .Times(1); | 
|  | std::string body(100, '.'); | 
|  | struct iovec iov = {const_cast<char*>(body.data()), body.length()}; | 
|  | QuicMemSliceStorage storage( | 
|  | &iov, 1, session_.connection()->helper()->GetStreamSendBufferAllocator(), | 
|  | 1024); | 
|  | stream4->WriteMemSlices(storage.ToSpan(), false); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, WriteMemSlicesOnReadUnidirectionalStream) { | 
|  | TestStream* stream4 = new TestStream(GetNthClientInitiatedUnidirectionalId(1), | 
|  | &session_, READ_UNIDIRECTIONAL); | 
|  | session_.ActivateStream(absl::WrapUnique(stream4)); | 
|  |  | 
|  | EXPECT_CALL(*connection_, | 
|  | CloseConnection( | 
|  | QUIC_TRY_TO_WRITE_DATA_ON_READ_UNIDIRECTIONAL_STREAM, _, _)) | 
|  | .Times(1); | 
|  | std::string data(1024, 'a'); | 
|  | std::vector<QuicMemSlice> buffers; | 
|  | buffers.push_back(MemSliceFromString(data)); | 
|  | buffers.push_back(MemSliceFromString(data)); | 
|  | stream4->WriteMemSlices(absl::MakeSpan(buffers), false); | 
|  | } | 
|  |  | 
|  | // Test code that tests that an incoming stream frame with a new (not previously | 
|  | // seen) stream id is acceptable. The ID must not be larger than has been | 
|  | // advertised. It may be equal to what has been advertised.  These tests | 
|  | // invoke QuicStreamIdManager::MaybeIncreaseLargestPeerStreamId by calling | 
|  | // QuicSession::OnStreamFrame in order to check that all the steps are connected | 
|  | // properly and that nothing in the call path interferes with the check. | 
|  | // First test make sure that streams with ids below the limit are accepted. | 
|  | TEST_P(QuicSessionTestServer, NewStreamIdBelowLimit) { | 
|  | if (!VersionHasIetfQuicFrames(transport_version())) { | 
|  | // Applicable only to IETF QUIC | 
|  | return; | 
|  | } | 
|  | QuicStreamId bidirectional_stream_id = StreamCountToId( | 
|  | QuicSessionPeer::ietf_streamid_manager(&session_) | 
|  | ->advertised_max_incoming_bidirectional_streams() - | 
|  | 1, | 
|  | Perspective::IS_CLIENT, | 
|  | /*bidirectional=*/true); | 
|  |  | 
|  | QuicStreamFrame bidirectional_stream_frame(bidirectional_stream_id, false, 0, | 
|  | "Random String"); | 
|  | EXPECT_CALL(*connection_, CloseConnection(_, _, _)).Times(0); | 
|  | session_.OnStreamFrame(bidirectional_stream_frame); | 
|  |  | 
|  | QuicStreamId unidirectional_stream_id = StreamCountToId( | 
|  | QuicSessionPeer::ietf_streamid_manager(&session_) | 
|  | ->advertised_max_incoming_unidirectional_streams() - | 
|  | 1, | 
|  | Perspective::IS_CLIENT, | 
|  | /*bidirectional=*/false); | 
|  | QuicStreamFrame unidirectional_stream_frame(unidirectional_stream_id, false, | 
|  | 0, "Random String"); | 
|  | EXPECT_CALL(*connection_, CloseConnection(_, _, _)).Times(0); | 
|  | session_.OnStreamFrame(unidirectional_stream_frame); | 
|  | } | 
|  |  | 
|  | // Accept a stream with an ID that equals the limit. | 
|  | TEST_P(QuicSessionTestServer, NewStreamIdAtLimit) { | 
|  | if (!VersionHasIetfQuicFrames(transport_version())) { | 
|  | // Applicable only to IETF QUIC | 
|  | return; | 
|  | } | 
|  | QuicStreamId bidirectional_stream_id = | 
|  | StreamCountToId(QuicSessionPeer::ietf_streamid_manager(&session_) | 
|  | ->advertised_max_incoming_bidirectional_streams(), | 
|  | Perspective::IS_CLIENT, /*bidirectional=*/true); | 
|  | QuicStreamFrame bidirectional_stream_frame(bidirectional_stream_id, false, 0, | 
|  | "Random String"); | 
|  | EXPECT_CALL(*connection_, CloseConnection(_, _, _)).Times(0); | 
|  | session_.OnStreamFrame(bidirectional_stream_frame); | 
|  |  | 
|  | QuicStreamId unidirectional_stream_id = | 
|  | StreamCountToId(QuicSessionPeer::ietf_streamid_manager(&session_) | 
|  | ->advertised_max_incoming_unidirectional_streams(), | 
|  | Perspective::IS_CLIENT, /*bidirectional=*/false); | 
|  | QuicStreamFrame unidirectional_stream_frame(unidirectional_stream_id, false, | 
|  | 0, "Random String"); | 
|  | EXPECT_CALL(*connection_, CloseConnection(_, _, _)).Times(0); | 
|  | session_.OnStreamFrame(unidirectional_stream_frame); | 
|  | } | 
|  |  | 
|  | // Close the connection if the id exceeds the limit. | 
|  | TEST_P(QuicSessionTestServer, NewStreamIdAboveLimit) { | 
|  | if (!VersionHasIetfQuicFrames(transport_version())) { | 
|  | // Applicable only to IETF QUIC | 
|  | return; | 
|  | } | 
|  |  | 
|  | QuicStreamId bidirectional_stream_id = StreamCountToId( | 
|  | QuicSessionPeer::ietf_streamid_manager(&session_) | 
|  | ->advertised_max_incoming_bidirectional_streams() + | 
|  | 1, | 
|  | Perspective::IS_CLIENT, /*bidirectional=*/true); | 
|  | QuicStreamFrame bidirectional_stream_frame(bidirectional_stream_id, false, 0, | 
|  | "Random String"); | 
|  | EXPECT_CALL( | 
|  | *connection_, | 
|  | CloseConnection(QUIC_INVALID_STREAM_ID, | 
|  | "Stream id 400 would exceed stream count limit 100", _)); | 
|  | session_.OnStreamFrame(bidirectional_stream_frame); | 
|  |  | 
|  | QuicStreamId unidirectional_stream_id = StreamCountToId( | 
|  | QuicSessionPeer::ietf_streamid_manager(&session_) | 
|  | ->advertised_max_incoming_unidirectional_streams() + | 
|  | 1, | 
|  | Perspective::IS_CLIENT, /*bidirectional=*/false); | 
|  | QuicStreamFrame unidirectional_stream_frame(unidirectional_stream_id, false, | 
|  | 0, "Random String"); | 
|  | EXPECT_CALL( | 
|  | *connection_, | 
|  | CloseConnection(QUIC_INVALID_STREAM_ID, | 
|  | "Stream id 402 would exceed stream count limit 100", _)); | 
|  | session_.OnStreamFrame(unidirectional_stream_frame); | 
|  | } | 
|  |  | 
|  | // Checks that invalid stream ids are handled. | 
|  | TEST_P(QuicSessionTestServer, OnStopSendingInvalidStreamId) { | 
|  | if (!VersionHasIetfQuicFrames(transport_version())) { | 
|  | return; | 
|  | } | 
|  | // Check that "invalid" stream ids are rejected. | 
|  | QuicStopSendingFrame frame(1, -1, QUIC_STREAM_CANCELLED); | 
|  | EXPECT_CALL( | 
|  | *connection_, | 
|  | CloseConnection(QUIC_INVALID_STREAM_ID, | 
|  | "Received STOP_SENDING for an invalid stream", _)); | 
|  | session_.OnStopSendingFrame(frame); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, OnStopSendingReadUnidirectional) { | 
|  | if (!VersionHasIetfQuicFrames(transport_version())) { | 
|  | return; | 
|  | } | 
|  | // It's illegal to send STOP_SENDING with a stream ID that is read-only. | 
|  | QuicStopSendingFrame frame(1, GetNthClientInitiatedUnidirectionalId(1), | 
|  | QUIC_STREAM_CANCELLED); | 
|  | EXPECT_CALL( | 
|  | *connection_, | 
|  | CloseConnection(QUIC_INVALID_STREAM_ID, | 
|  | "Received STOP_SENDING for a read-only stream", _)); | 
|  | session_.OnStopSendingFrame(frame); | 
|  | } | 
|  |  | 
|  | // Static streams ignore STOP_SENDING. | 
|  | TEST_P(QuicSessionTestServer, OnStopSendingStaticStreams) { | 
|  | if (!VersionHasIetfQuicFrames(transport_version())) { | 
|  | return; | 
|  | } | 
|  | QuicStreamId stream_id = 0; | 
|  | std::unique_ptr<TestStream> fake_static_stream = std::make_unique<TestStream>( | 
|  | stream_id, &session_, /*is_static*/ true, BIDIRECTIONAL); | 
|  | QuicSessionPeer::ActivateStream(&session_, std::move(fake_static_stream)); | 
|  | // Check that a stream id in the static stream map is ignored. | 
|  | QuicStopSendingFrame frame(1, stream_id, QUIC_STREAM_CANCELLED); | 
|  | EXPECT_CALL(*connection_, | 
|  | CloseConnection(QUIC_INVALID_STREAM_ID, | 
|  | "Received STOP_SENDING for a static stream", _)); | 
|  | session_.OnStopSendingFrame(frame); | 
|  | } | 
|  |  | 
|  | // If stream is write closed, do not send a RESET_STREAM frame. | 
|  | TEST_P(QuicSessionTestServer, OnStopSendingForWriteClosedStream) { | 
|  | if (!VersionHasIetfQuicFrames(transport_version())) { | 
|  | return; | 
|  | } | 
|  |  | 
|  | TestStream* stream = session_.CreateOutgoingBidirectionalStream(); | 
|  | QuicStreamId stream_id = stream->id(); | 
|  | QuicStreamPeer::SetFinSent(stream); | 
|  | stream->CloseWriteSide(); | 
|  | EXPECT_TRUE(stream->write_side_closed()); | 
|  | QuicStopSendingFrame frame(1, stream_id, QUIC_STREAM_CANCELLED); | 
|  | EXPECT_CALL(*connection_, CloseConnection(_, _, _)).Times(0); | 
|  | session_.OnStopSendingFrame(frame); | 
|  | } | 
|  |  | 
|  | // If stream is closed, return true and do not close the connection. | 
|  | TEST_P(QuicSessionTestServer, OnStopSendingClosedStream) { | 
|  | if (!VersionHasIetfQuicFrames(transport_version())) { | 
|  | return; | 
|  | } | 
|  | CompleteHandshake(); | 
|  | TestStream* stream = session_.CreateOutgoingBidirectionalStream(); | 
|  | QuicStreamId stream_id = stream->id(); | 
|  | CloseStream(stream_id); | 
|  | QuicStopSendingFrame frame(1, stream_id, QUIC_STREAM_CANCELLED); | 
|  | EXPECT_CALL(*connection_, CloseConnection(_, _, _)).Times(0); | 
|  | session_.OnStopSendingFrame(frame); | 
|  | } | 
|  |  | 
|  | // If stream id is a nonexistent local stream, return false and close the | 
|  | // connection. | 
|  | TEST_P(QuicSessionTestServer, OnStopSendingInputNonExistentLocalStream) { | 
|  | if (!VersionHasIetfQuicFrames(transport_version())) { | 
|  | return; | 
|  | } | 
|  |  | 
|  | QuicStopSendingFrame frame(1, GetNthServerInitiatedBidirectionalId(123456), | 
|  | QUIC_STREAM_CANCELLED); | 
|  | EXPECT_CALL(*connection_, CloseConnection(QUIC_HTTP_STREAM_WRONG_DIRECTION, | 
|  | "Data for nonexistent stream", _)) | 
|  | .Times(1); | 
|  | session_.OnStopSendingFrame(frame); | 
|  | } | 
|  |  | 
|  | // If a STOP_SENDING is received for a peer initiated stream, the new stream | 
|  | // will be created. | 
|  | TEST_P(QuicSessionTestServer, OnStopSendingNewStream) { | 
|  | CompleteHandshake(); | 
|  | if (!VersionHasIetfQuicFrames(transport_version())) { | 
|  | return; | 
|  | } | 
|  | QuicStopSendingFrame frame(1, GetNthClientInitiatedBidirectionalId(1), | 
|  | QUIC_STREAM_CANCELLED); | 
|  |  | 
|  | // A Rst will be sent as a response for STOP_SENDING. | 
|  | EXPECT_CALL(*connection_, SendControlFrame(_)).Times(1); | 
|  | EXPECT_CALL(*connection_, OnStreamReset(_, _)).Times(1); | 
|  | session_.OnStopSendingFrame(frame); | 
|  |  | 
|  | QuicStream* stream = | 
|  | session_.GetOrCreateStream(GetNthClientInitiatedBidirectionalId(1)); | 
|  | EXPECT_TRUE(stream); | 
|  | EXPECT_TRUE(stream->write_side_closed()); | 
|  | } | 
|  |  | 
|  | // For a valid stream, ensure that all works | 
|  | TEST_P(QuicSessionTestServer, OnStopSendingInputValidStream) { | 
|  | CompleteHandshake(); | 
|  | if (!VersionHasIetfQuicFrames(transport_version())) { | 
|  | // Applicable only to IETF QUIC | 
|  | return; | 
|  | } | 
|  |  | 
|  | TestStream* stream = session_.CreateOutgoingBidirectionalStream(); | 
|  |  | 
|  | // Ensure that the stream starts out open in both directions. | 
|  | EXPECT_FALSE(stream->write_side_closed()); | 
|  | EXPECT_FALSE(QuicStreamPeer::read_side_closed(stream)); | 
|  |  | 
|  | QuicStreamId stream_id = stream->id(); | 
|  | QuicStopSendingFrame frame(1, stream_id, QUIC_STREAM_CANCELLED); | 
|  | // Expect a reset to come back out. | 
|  | EXPECT_CALL(*connection_, SendControlFrame(_)); | 
|  | EXPECT_CALL(*connection_, OnStreamReset(stream_id, QUIC_STREAM_CANCELLED)); | 
|  | EXPECT_CALL(*connection_, CloseConnection(_, _, _)).Times(0); | 
|  | session_.OnStopSendingFrame(frame); | 
|  |  | 
|  | EXPECT_FALSE(QuicStreamPeer::read_side_closed(stream)); | 
|  | EXPECT_TRUE(stream->write_side_closed()); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, WriteBufferedCryptoFrames) { | 
|  | if (!QuicVersionUsesCryptoFrames(connection_->transport_version())) { | 
|  | return; | 
|  | } | 
|  | std::string data(1350, 'a'); | 
|  | TestCryptoStream* crypto_stream = session_.GetMutableCryptoStream(); | 
|  | // Only consumed 1000 bytes. | 
|  | EXPECT_CALL(*connection_, SendCryptoData(ENCRYPTION_INITIAL, 1350, 0)) | 
|  | .WillOnce(Return(1000)); | 
|  | crypto_stream->WriteCryptoData(ENCRYPTION_INITIAL, data); | 
|  | EXPECT_TRUE(session_.HasPendingHandshake()); | 
|  | EXPECT_TRUE(session_.WillingAndAbleToWrite()); | 
|  |  | 
|  | EXPECT_CALL(*connection_, SendCryptoData(_, _, _)).Times(0); | 
|  | connection_->SetEncrypter( | 
|  | ENCRYPTION_ZERO_RTT, | 
|  | std::make_unique<NullEncrypter>(connection_->perspective())); | 
|  | crypto_stream->WriteCryptoData(ENCRYPTION_ZERO_RTT, data); | 
|  |  | 
|  | EXPECT_CALL(*connection_, SendCryptoData(ENCRYPTION_INITIAL, 350, 1000)) | 
|  | .WillOnce(Return(350)); | 
|  | EXPECT_CALL(*connection_, SendCryptoData(ENCRYPTION_ZERO_RTT, 1350, 0)) | 
|  | .WillOnce(Return(1350)); | 
|  | session_.OnCanWrite(); | 
|  | EXPECT_FALSE(session_.HasPendingHandshake()); | 
|  | EXPECT_FALSE(session_.WillingAndAbleToWrite()); | 
|  | } | 
|  |  | 
|  | // Regression test for | 
|  | // https://bugs.chromium.org/p/chromium/issues/detail?id=1002119 | 
|  | TEST_P(QuicSessionTestServer, StreamFrameReceivedAfterFin) { | 
|  | TestStream* stream = session_.CreateOutgoingBidirectionalStream(); | 
|  | QuicStreamFrame frame(stream->id(), true, 0, ","); | 
|  | session_.OnStreamFrame(frame); | 
|  |  | 
|  | QuicStreamFrame frame1(stream->id(), false, 1, ","); | 
|  | EXPECT_CALL(*connection_, | 
|  | CloseConnection(QUIC_STREAM_DATA_BEYOND_CLOSE_OFFSET, _, _)); | 
|  | session_.OnStreamFrame(frame1); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, ResetForIETFStreamTypes) { | 
|  | CompleteHandshake(); | 
|  | if (!VersionHasIetfQuicFrames(transport_version())) { | 
|  | return; | 
|  | } | 
|  |  | 
|  | QuicStreamId read_only = GetNthClientInitiatedUnidirectionalId(0); | 
|  |  | 
|  | EXPECT_CALL(*connection_, SendControlFrame(_)) | 
|  | .Times(1) | 
|  | .WillOnce(Invoke(&ClearControlFrame)); | 
|  | EXPECT_CALL(*connection_, OnStreamReset(read_only, _)); | 
|  | session_.ResetStream(read_only, QUIC_STREAM_CANCELLED); | 
|  |  | 
|  | QuicStreamId write_only = GetNthServerInitiatedUnidirectionalId(0); | 
|  | EXPECT_CALL(*connection_, SendControlFrame(_)) | 
|  | .Times(1) | 
|  | .WillOnce(Invoke(&ClearControlFrame)); | 
|  | EXPECT_CALL(*connection_, OnStreamReset(write_only, _)); | 
|  | session_.ResetStream(write_only, QUIC_STREAM_CANCELLED); | 
|  |  | 
|  | QuicStreamId bidirectional = GetNthClientInitiatedBidirectionalId(0); | 
|  | EXPECT_CALL(*connection_, SendControlFrame(_)) | 
|  | .Times(2) | 
|  | .WillRepeatedly(Invoke(&ClearControlFrame)); | 
|  | EXPECT_CALL(*connection_, OnStreamReset(bidirectional, _)); | 
|  | session_.ResetStream(bidirectional, QUIC_STREAM_CANCELLED); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, DecryptionKeyAvailableBeforeEncryptionKey) { | 
|  | if (connection_->version().handshake_protocol != PROTOCOL_TLS1_3) { | 
|  | return; | 
|  | } | 
|  | ASSERT_FALSE(connection_->framer().HasEncrypterOfEncryptionLevel( | 
|  | ENCRYPTION_HANDSHAKE)); | 
|  | EXPECT_FALSE(session_.OnNewDecryptionKeyAvailable( | 
|  | ENCRYPTION_HANDSHAKE, /*decrypter=*/nullptr, | 
|  | /*set_alternative_decrypter=*/false, /*latch_once_used=*/false)); | 
|  | } | 
|  |  | 
|  | TEST_P(QuicSessionTestServer, IncomingStreamWithServerInitiatedStreamId) { | 
|  | const QuicErrorCode expected_error = | 
|  | VersionHasIetfQuicFrames(transport_version()) | 
|  | ? QUIC_HTTP_STREAM_WRONG_DIRECTION | 
|  | : QUIC_INVALID_STREAM_ID; | 
|  | EXPECT_CALL( | 
|  | *connection_, | 
|  | CloseConnection(expected_error, "Data for nonexistent stream", | 
|  | ConnectionCloseBehavior::SEND_CONNECTION_CLOSE_PACKET)); | 
|  |  | 
|  | QuicStreamFrame frame(GetNthServerInitiatedBidirectionalId(1), | 
|  | /* fin = */ false, /* offset = */ 0, | 
|  | absl::string_view("foo")); | 
|  | session_.OnStreamFrame(frame); | 
|  | } | 
|  |  | 
|  | // A client test class that can be used when the automatic configuration is not | 
|  | // desired. | 
|  | class QuicSessionTestClientUnconfigured : public QuicSessionTestBase { | 
|  | protected: | 
|  | QuicSessionTestClientUnconfigured() | 
|  | : QuicSessionTestBase(Perspective::IS_CLIENT, | 
|  | /*configure_session=*/false) {} | 
|  | }; | 
|  |  | 
|  | INSTANTIATE_TEST_SUITE_P(Tests, | 
|  | QuicSessionTestClientUnconfigured, | 
|  | ::testing::ValuesIn(AllSupportedVersions()), | 
|  | ::testing::PrintToStringParamName()); | 
|  |  | 
|  | TEST_P(QuicSessionTestClientUnconfigured, StreamInitiallyBlockedThenUnblocked) { | 
|  | if (!connection_->version().AllowsLowFlowControlLimits()) { | 
|  | return; | 
|  | } | 
|  | // Create a stream before negotiating the config and verify it starts off | 
|  | // blocked. | 
|  | QuicSessionPeer::SetMaxOpenOutgoingBidirectionalStreams(&session_, 10); | 
|  | TestStream* stream2 = session_.CreateOutgoingBidirectionalStream(); | 
|  | EXPECT_TRUE(stream2->IsFlowControlBlocked()); | 
|  | EXPECT_TRUE(session_.IsConnectionFlowControlBlocked()); | 
|  | EXPECT_TRUE(session_.IsStreamFlowControlBlocked()); | 
|  |  | 
|  | // Negotiate the config with higher received limits. | 
|  | QuicConfigPeer::SetReceivedInitialMaxStreamDataBytesOutgoingBidirectional( | 
|  | session_.config(), kMinimumFlowControlSendWindow); | 
|  | QuicConfigPeer::SetReceivedInitialSessionFlowControlWindow( | 
|  | session_.config(), kMinimumFlowControlSendWindow); | 
|  | session_.OnConfigNegotiated(); | 
|  |  | 
|  | // Stream is now unblocked. | 
|  | EXPECT_FALSE(stream2->IsFlowControlBlocked()); | 
|  | EXPECT_FALSE(session_.IsConnectionFlowControlBlocked()); | 
|  | EXPECT_FALSE(session_.IsStreamFlowControlBlocked()); | 
|  | } | 
|  |  | 
|  | }  // namespace | 
|  | }  // namespace test | 
|  | }  // namespace quic |