OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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 <stddef.h> | 5 #include <stddef.h> |
6 #include <sys/epoll.h> | 6 #include <sys/epoll.h> |
7 | 7 |
8 #include <cstdint> | 8 #include <cstdint> |
9 #include <list> | 9 #include <list> |
10 #include <memory> | 10 #include <memory> |
(...skipping 421 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
432 void TearDown() override { | 432 void TearDown() override { |
433 ASSERT_TRUE(initialized_) << "You must call Initialize() in every test " | 433 ASSERT_TRUE(initialized_) << "You must call Initialize() in every test " |
434 << "case. Otherwise, your test will leak memory."; | 434 << "case. Otherwise, your test will leak memory."; |
435 StopServer(); | 435 StopServer(); |
436 } | 436 } |
437 | 437 |
438 void StartServer() { | 438 void StartServer() { |
439 FLAGS_quic_reloadable_flag_quic_use_cheap_stateless_rejects = | 439 FLAGS_quic_reloadable_flag_quic_use_cheap_stateless_rejects = |
440 GetParam().use_cheap_stateless_reject; | 440 GetParam().use_cheap_stateless_reject; |
441 | 441 |
442 auto test_server = new QuicTestServer( | 442 auto* test_server = new QuicTestServer( |
443 crypto_test_utils::ProofSourceForTesting(), server_config_, | 443 crypto_test_utils::ProofSourceForTesting(), server_config_, |
444 server_supported_versions_, &response_cache_); | 444 server_supported_versions_, &response_cache_); |
445 server_thread_.reset(new ServerThread(test_server, server_address_)); | 445 server_thread_.reset(new ServerThread(test_server, server_address_)); |
446 if (chlo_multiplier_ != 0) { | 446 if (chlo_multiplier_ != 0) { |
447 server_thread_->server()->SetChloMultiplier(chlo_multiplier_); | 447 server_thread_->server()->SetChloMultiplier(chlo_multiplier_); |
448 } | 448 } |
449 server_thread_->Initialize(); | 449 server_thread_->Initialize(); |
450 server_address_ = | 450 server_address_ = |
451 QuicSocketAddress(server_address_.host(), server_thread_->GetPort()); | 451 QuicSocketAddress(server_address_.host(), server_thread_->GetPort()); |
452 QuicDispatcher* dispatcher = | 452 QuicDispatcher* dispatcher = |
(...skipping 1364 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1817 | 1817 |
1818 ASSERT_TRUE(Initialize()); | 1818 ASSERT_TRUE(Initialize()); |
1819 | 1819 |
1820 EXPECT_TRUE(client_->client()->WaitForCryptoHandshakeConfirmed()); | 1820 EXPECT_TRUE(client_->client()->WaitForCryptoHandshakeConfirmed()); |
1821 server_thread_->WaitForCryptoHandshakeConfirmed(); | 1821 server_thread_->WaitForCryptoHandshakeConfirmed(); |
1822 | 1822 |
1823 server_thread_->Pause(); | 1823 server_thread_->Pause(); |
1824 QuicSpdySession* const client_session = client_->client()->session(); | 1824 QuicSpdySession* const client_session = client_->client()->session(); |
1825 QuicDispatcher* dispatcher = | 1825 QuicDispatcher* dispatcher = |
1826 QuicServerPeer::GetDispatcher(server_thread_->server()); | 1826 QuicServerPeer::GetDispatcher(server_thread_->server()); |
1827 auto server_session = static_cast<QuicSpdySession*>( | 1827 auto* server_session = static_cast<QuicSpdySession*>( |
1828 dispatcher->session_map().begin()->second.get()); | 1828 dispatcher->session_map().begin()->second.get()); |
1829 ExpectFlowControlsSynced(client_session->flow_controller(), | 1829 ExpectFlowControlsSynced(client_session->flow_controller(), |
1830 server_session->flow_controller()); | 1830 server_session->flow_controller()); |
1831 ExpectFlowControlsSynced( | 1831 ExpectFlowControlsSynced( |
1832 QuicSessionPeer::GetCryptoStream(client_session)->flow_controller(), | 1832 QuicSessionPeer::GetCryptoStream(client_session)->flow_controller(), |
1833 QuicSessionPeer::GetCryptoStream(server_session)->flow_controller()); | 1833 QuicSessionPeer::GetCryptoStream(server_session)->flow_controller()); |
1834 SpdyFramer spdy_framer(SpdyFramer::ENABLE_COMPRESSION); | 1834 SpdyFramer spdy_framer(SpdyFramer::ENABLE_COMPRESSION); |
1835 SpdySettingsIR settings_frame; | 1835 SpdySettingsIR settings_frame; |
1836 settings_frame.AddSetting(SETTINGS_MAX_HEADER_LIST_SIZE, | 1836 settings_frame.AddSetting(SETTINGS_MAX_HEADER_LIST_SIZE, |
1837 kDefaultMaxUncompressedHeaderSize); | 1837 kDefaultMaxUncompressedHeaderSize); |
(...skipping 1225 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
3063 client_->WaitForResponse(); | 3063 client_->WaitForResponse(); |
3064 EXPECT_EQ(kBarResponseBody, client_->response_body()); | 3064 EXPECT_EQ(kBarResponseBody, client_->response_body()); |
3065 QuicConnectionStats client_stats = | 3065 QuicConnectionStats client_stats = |
3066 client_->client()->session()->connection()->GetStats(); | 3066 client_->client()->session()->connection()->GetStats(); |
3067 EXPECT_EQ(0u, client_stats.packets_lost); | 3067 EXPECT_EQ(0u, client_stats.packets_lost); |
3068 EXPECT_EQ(1, client_->client()->GetNumSentClientHellos()); | 3068 EXPECT_EQ(1, client_->client()->GetNumSentClientHellos()); |
3069 } | 3069 } |
3070 } // namespace | 3070 } // namespace |
3071 } // namespace test | 3071 } // namespace test |
3072 } // namespace net | 3072 } // namespace net |
OLD | NEW |