| OLD | NEW |
| 1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "net/tools/quic/quic_simple_server_session.h" | 5 #include "net/tools/quic/quic_simple_server_session.h" |
| 6 | 6 |
| 7 #include <algorithm> | 7 #include <algorithm> |
| 8 #include <memory> | 8 #include <memory> |
| 9 | 9 |
| 10 #include "base/macros.h" | 10 #include "base/macros.h" |
| (...skipping 163 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 174 const QuicReferenceCountedPointer<QuicAckListenerInterface>& | 174 const QuicReferenceCountedPointer<QuicAckListenerInterface>& |
| 175 ack_listener)); | 175 ack_listener)); |
| 176 }; | 176 }; |
| 177 | 177 |
| 178 class QuicSimpleServerSessionTest | 178 class QuicSimpleServerSessionTest |
| 179 : public ::testing::TestWithParam<QuicVersion> { | 179 : public ::testing::TestWithParam<QuicVersion> { |
| 180 protected: | 180 protected: |
| 181 QuicSimpleServerSessionTest() | 181 QuicSimpleServerSessionTest() |
| 182 : crypto_config_(QuicCryptoServerConfig::TESTING, | 182 : crypto_config_(QuicCryptoServerConfig::TESTING, |
| 183 QuicRandom::GetInstance(), | 183 QuicRandom::GetInstance(), |
| 184 CryptoTestUtils::ProofSourceForTesting()), | 184 crypto_test_utils::ProofSourceForTesting()), |
| 185 compressed_certs_cache_( | 185 compressed_certs_cache_( |
| 186 QuicCompressedCertsCache::kQuicCompressedCertsCacheSize) { | 186 QuicCompressedCertsCache::kQuicCompressedCertsCacheSize) { |
| 187 config_.SetMaxStreamsPerConnection(kMaxStreamsForTest, kMaxStreamsForTest); | 187 config_.SetMaxStreamsPerConnection(kMaxStreamsForTest, kMaxStreamsForTest); |
| 188 config_.SetMaxIncomingDynamicStreamsToSend(kMaxStreamsForTest); | 188 config_.SetMaxIncomingDynamicStreamsToSend(kMaxStreamsForTest); |
| 189 QuicConfigPeer::SetReceivedMaxIncomingDynamicStreams(&config_, | 189 QuicConfigPeer::SetReceivedMaxIncomingDynamicStreams(&config_, |
| 190 kMaxStreamsForTest); | 190 kMaxStreamsForTest); |
| 191 config_.SetInitialStreamFlowControlWindowToSend( | 191 config_.SetInitialStreamFlowControlWindowToSend( |
| 192 kInitialStreamFlowControlWindowForTest); | 192 kInitialStreamFlowControlWindowForTest); |
| 193 config_.SetInitialSessionFlowControlWindowToSend( | 193 config_.SetInitialSessionFlowControlWindowToSend( |
| 194 kInitialSessionFlowControlWindowForTest); | 194 kInitialSessionFlowControlWindowForTest); |
| (...skipping 420 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 615 .WillOnce(Return(QuicConsumedData(kStreamFlowControlWindowSize, false))); | 615 .WillOnce(Return(QuicConsumedData(kStreamFlowControlWindowSize, false))); |
| 616 | 616 |
| 617 EXPECT_CALL(*connection_, SendBlocked(stream_to_open)); | 617 EXPECT_CALL(*connection_, SendBlocked(stream_to_open)); |
| 618 QuicRstStreamFrame rst(stream_got_reset, QUIC_STREAM_CANCELLED, 0); | 618 QuicRstStreamFrame rst(stream_got_reset, QUIC_STREAM_CANCELLED, 0); |
| 619 visitor_->OnRstStream(rst); | 619 visitor_->OnRstStream(rst); |
| 620 } | 620 } |
| 621 | 621 |
| 622 } // namespace | 622 } // namespace |
| 623 } // namespace test | 623 } // namespace test |
| 624 } // namespace net | 624 } // namespace net |
| OLD | NEW |