Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(376)

Side by Side Diff: net/tools/quic/quic_simple_server_session_test.cc

Issue 2236973002: Landing Recent QUIC changes until 4AM, Aug 7, 2016 UTC-4 (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: flip quic_sequencer_buffer_retire_block_in_time to true Created 4 years, 4 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
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 208 matching lines...) Expand 10 before | Expand all | Expand 10 after
219 QuicCryptoServerConfig crypto_config_; 219 QuicCryptoServerConfig crypto_config_;
220 QuicCompressedCertsCache compressed_certs_cache_; 220 QuicCompressedCertsCache compressed_certs_cache_;
221 std::unique_ptr<QuicSimpleServerSession> session_; 221 std::unique_ptr<QuicSimpleServerSession> session_;
222 std::unique_ptr<CryptoHandshakeMessage> handshake_message_; 222 std::unique_ptr<CryptoHandshakeMessage> handshake_message_;
223 QuicConnectionVisitorInterface* visitor_; 223 QuicConnectionVisitorInterface* visitor_;
224 MockQuicHeadersStream* headers_stream_; 224 MockQuicHeadersStream* headers_stream_;
225 }; 225 };
226 226
227 INSTANTIATE_TEST_CASE_P(Tests, 227 INSTANTIATE_TEST_CASE_P(Tests,
228 QuicSimpleServerSessionTest, 228 QuicSimpleServerSessionTest,
229 ::testing::ValuesIn(QuicSupportedVersions())); 229 ::testing::ValuesIn(AllSupportedVersions()));
230 230
231 TEST_P(QuicSimpleServerSessionTest, CloseStreamDueToReset) { 231 TEST_P(QuicSimpleServerSessionTest, CloseStreamDueToReset) {
232 // Open a stream, then reset it. 232 // Open a stream, then reset it.
233 // Send two bytes of payload to open it. 233 // Send two bytes of payload to open it.
234 QuicStreamFrame data1(kClientDataStreamId1, false, 0, StringPiece("HT")); 234 QuicStreamFrame data1(kClientDataStreamId1, false, 0, StringPiece("HT"));
235 session_->OnStreamFrame(data1); 235 session_->OnStreamFrame(data1);
236 EXPECT_EQ(1u, session_->GetNumOpenIncomingStreams()); 236 EXPECT_EQ(1u, session_->GetNumOpenIncomingStreams());
237 237
238 // Receive a reset (and send a RST in response). 238 // Receive a reset (and send a RST in response).
239 QuicRstStreamFrame rst1(kClientDataStreamId1, QUIC_ERROR_PROCESSING_STREAM, 239 QuicRstStreamFrame rst1(kClientDataStreamId1, QUIC_ERROR_PROCESSING_STREAM,
(...skipping 273 matching lines...) Expand 10 before | Expand all | Expand 10 after
513 } 513 }
514 } 514 }
515 } 515 }
516 session_->PromisePushResources(request_url, push_resources, 516 session_->PromisePushResources(request_url, push_resources,
517 kClientDataStreamId1, request_headers); 517 kClientDataStreamId1, request_headers);
518 } 518 }
519 }; 519 };
520 520
521 INSTANTIATE_TEST_CASE_P(Tests, 521 INSTANTIATE_TEST_CASE_P(Tests,
522 QuicSimpleServerSessionServerPushTest, 522 QuicSimpleServerSessionServerPushTest,
523 ::testing::ValuesIn(QuicSupportedVersions())); 523 ::testing::ValuesIn(AllSupportedVersions()));
524 524
525 TEST_P(QuicSimpleServerSessionServerPushTest, TestPromisePushResources) { 525 TEST_P(QuicSimpleServerSessionServerPushTest, TestPromisePushResources) {
526 // Tests that given more than kMaxOpenStreamForTest resources, all their 526 // Tests that given more than kMaxOpenStreamForTest resources, all their
527 // PUSH_PROMISE's will be sent out and only |kMaxOpenStreamForTest| streams 527 // PUSH_PROMISE's will be sent out and only |kMaxOpenStreamForTest| streams
528 // will be opened and send push response. 528 // will be opened and send push response.
529 529
530 if (session_->force_hol_blocking()) { 530 if (session_->force_hol_blocking()) {
531 return; 531 return;
532 } 532 }
533 size_t num_resources = kMaxStreamsForTest + 5; 533 size_t num_resources = kMaxStreamsForTest + 5;
(...skipping 90 matching lines...) Expand 10 before | Expand all | Expand 10 after
624 .WillOnce(Return(QuicConsumedData(kStreamFlowControlWindowSize, false))); 624 .WillOnce(Return(QuicConsumedData(kStreamFlowControlWindowSize, false)));
625 625
626 EXPECT_CALL(*connection_, SendBlocked(stream_to_open)); 626 EXPECT_CALL(*connection_, SendBlocked(stream_to_open));
627 QuicRstStreamFrame rst(stream_got_reset, QUIC_STREAM_CANCELLED, 0); 627 QuicRstStreamFrame rst(stream_got_reset, QUIC_STREAM_CANCELLED, 0);
628 visitor_->OnRstStream(rst); 628 visitor_->OnRstStream(rst);
629 } 629 }
630 630
631 } // namespace 631 } // namespace
632 } // namespace test 632 } // namespace test
633 } // namespace net 633 } // namespace net
OLDNEW
« no previous file with comments | « net/tools/quic/quic_simple_server_session.cc ('k') | net/tools/quic/quic_simple_server_stream_test.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698