| 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 <list> | 8 #include <list> |
| 9 #include <memory> | 9 #include <memory> |
| 10 #include <string> | 10 #include <string> |
| (...skipping 1800 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1811 | 1811 |
| 1812 ASSERT_TRUE(Initialize()); | 1812 ASSERT_TRUE(Initialize()); |
| 1813 | 1813 |
| 1814 client_->client()->WaitForCryptoHandshakeConfirmed(); | 1814 client_->client()->WaitForCryptoHandshakeConfirmed(); |
| 1815 server_thread_->WaitForCryptoHandshakeConfirmed(); | 1815 server_thread_->WaitForCryptoHandshakeConfirmed(); |
| 1816 | 1816 |
| 1817 server_thread_->Pause(); | 1817 server_thread_->Pause(); |
| 1818 QuicSpdySession* const client_session = client_->client()->session(); | 1818 QuicSpdySession* const client_session = client_->client()->session(); |
| 1819 QuicDispatcher* dispatcher = | 1819 QuicDispatcher* dispatcher = |
| 1820 QuicServerPeer::GetDispatcher(server_thread_->server()); | 1820 QuicServerPeer::GetDispatcher(server_thread_->server()); |
| 1821 QuicSpdySession* server_session = | 1821 auto server_session = static_cast<QuicSpdySession*>( |
| 1822 dispatcher->session_map().begin()->second.get(); | 1822 dispatcher->session_map().begin()->second.get()); |
| 1823 | 1823 |
| 1824 ExpectFlowControlsSynced(client_session->flow_controller(), | 1824 ExpectFlowControlsSynced(client_session->flow_controller(), |
| 1825 server_session->flow_controller()); | 1825 server_session->flow_controller()); |
| 1826 ExpectFlowControlsSynced( | 1826 ExpectFlowControlsSynced( |
| 1827 QuicSessionPeer::GetCryptoStream(client_session)->flow_controller(), | 1827 QuicSessionPeer::GetCryptoStream(client_session)->flow_controller(), |
| 1828 QuicSessionPeer::GetCryptoStream(server_session)->flow_controller()); | 1828 QuicSessionPeer::GetCryptoStream(server_session)->flow_controller()); |
| 1829 ExpectFlowControlsSynced( | 1829 ExpectFlowControlsSynced( |
| 1830 QuicSpdySessionPeer::GetHeadersStream(client_session)->flow_controller(), | 1830 QuicSpdySessionPeer::GetHeadersStream(client_session)->flow_controller(), |
| 1831 QuicSpdySessionPeer::GetHeadersStream(server_session)->flow_controller()); | 1831 QuicSpdySessionPeer::GetHeadersStream(server_session)->flow_controller()); |
| 1832 | 1832 |
| (...skipping 620 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2453 | 2453 |
| 2454 // Pause the server so we can access the server's internals without races. | 2454 // Pause the server so we can access the server's internals without races. |
| 2455 server_thread_->Pause(); | 2455 server_thread_->Pause(); |
| 2456 | 2456 |
| 2457 QuicDispatcher* dispatcher = | 2457 QuicDispatcher* dispatcher = |
| 2458 QuicServerPeer::GetDispatcher(server_thread_->server()); | 2458 QuicServerPeer::GetDispatcher(server_thread_->server()); |
| 2459 QuicDispatcher::SessionMap const& map = | 2459 QuicDispatcher::SessionMap const& map = |
| 2460 QuicDispatcherPeer::session_map(dispatcher); | 2460 QuicDispatcherPeer::session_map(dispatcher); |
| 2461 QuicDispatcher::SessionMap::const_iterator it = map.begin(); | 2461 QuicDispatcher::SessionMap::const_iterator it = map.begin(); |
| 2462 EXPECT_TRUE(it != map.end()); | 2462 EXPECT_TRUE(it != map.end()); |
| 2463 QuicServerSessionBase* server_session = it->second.get(); | 2463 QuicSession* server_session = it->second.get(); |
| 2464 | 2464 |
| 2465 // The stream is not waiting for the arrival of the peer's final offset. | 2465 // The stream is not waiting for the arrival of the peer's final offset. |
| 2466 EXPECT_EQ( | 2466 EXPECT_EQ( |
| 2467 0u, QuicSessionPeer::GetLocallyClosedStreamsHighestOffset(server_session) | 2467 0u, QuicSessionPeer::GetLocallyClosedStreamsHighestOffset(server_session) |
| 2468 .size()); | 2468 .size()); |
| 2469 | 2469 |
| 2470 server_thread_->Resume(); | 2470 server_thread_->Resume(); |
| 2471 } | 2471 } |
| 2472 | 2472 |
| 2473 TEST_P(EndToEndTest, LargePostEarlyResponse) { | 2473 TEST_P(EndToEndTest, LargePostEarlyResponse) { |
| (...skipping 510 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2984 client_->WaitForResponse(); | 2984 client_->WaitForResponse(); |
| 2985 EXPECT_EQ(kBarResponseBody, client_->response_body()); | 2985 EXPECT_EQ(kBarResponseBody, client_->response_body()); |
| 2986 QuicConnectionStats client_stats = | 2986 QuicConnectionStats client_stats = |
| 2987 client_->client()->session()->connection()->GetStats(); | 2987 client_->client()->session()->connection()->GetStats(); |
| 2988 EXPECT_EQ(0u, client_stats.packets_lost); | 2988 EXPECT_EQ(0u, client_stats.packets_lost); |
| 2989 EXPECT_EQ(1, client_->client()->GetNumSentClientHellos()); | 2989 EXPECT_EQ(1, client_->client()->GetNumSentClientHellos()); |
| 2990 } | 2990 } |
| 2991 } // namespace | 2991 } // namespace |
| 2992 } // namespace test | 2992 } // namespace test |
| 2993 } // namespace net | 2993 } // namespace net |
| OLD | NEW |