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 1746 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1757 session->config()->ReceivedInitialStreamFlowControlWindowBytes()); | 1757 session->config()->ReceivedInitialStreamFlowControlWindowBytes()); |
1758 EXPECT_EQ(kClientSessionIFCW, | 1758 EXPECT_EQ(kClientSessionIFCW, |
1759 session->config()->ReceivedInitialSessionFlowControlWindowBytes()); | 1759 session->config()->ReceivedInitialSessionFlowControlWindowBytes()); |
1760 EXPECT_EQ(kClientSessionIFCW, QuicFlowControllerPeer::SendWindowOffset( | 1760 EXPECT_EQ(kClientSessionIFCW, QuicFlowControllerPeer::SendWindowOffset( |
1761 session->flow_controller())); | 1761 session->flow_controller())); |
1762 server_thread_->Resume(); | 1762 server_thread_->Resume(); |
1763 } | 1763 } |
1764 | 1764 |
1765 // Test negotiation of IFWA connection option. | 1765 // Test negotiation of IFWA connection option. |
1766 TEST_P(EndToEndTest, NegotiatedServerInitialFlowControlWindow) { | 1766 TEST_P(EndToEndTest, NegotiatedServerInitialFlowControlWindow) { |
1767 FLAGS_quic_reloadable_flag_quic_large_ifw_options = true; | |
1768 | |
1769 const uint32_t kClientStreamIFCW = 123456; | 1767 const uint32_t kClientStreamIFCW = 123456; |
1770 const uint32_t kClientSessionIFCW = 234567; | 1768 const uint32_t kClientSessionIFCW = 234567; |
1771 set_client_initial_stream_flow_control_receive_window(kClientStreamIFCW); | 1769 set_client_initial_stream_flow_control_receive_window(kClientStreamIFCW); |
1772 set_client_initial_session_flow_control_receive_window(kClientSessionIFCW); | 1770 set_client_initial_session_flow_control_receive_window(kClientSessionIFCW); |
1773 | 1771 |
1774 uint32_t kServerStreamIFCW = 32 * 1024; | 1772 uint32_t kServerStreamIFCW = 32 * 1024; |
1775 uint32_t kServerSessionIFCW = 48 * 1024; | 1773 uint32_t kServerSessionIFCW = 48 * 1024; |
1776 set_server_initial_stream_flow_control_receive_window(kServerStreamIFCW); | 1774 set_server_initial_stream_flow_control_receive_window(kServerStreamIFCW); |
1777 set_server_initial_session_flow_control_receive_window(kServerSessionIFCW); | 1775 set_server_initial_session_flow_control_receive_window(kServerSessionIFCW); |
1778 | 1776 |
(...skipping 1353 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
3132 client_->WaitForResponse(); | 3130 client_->WaitForResponse(); |
3133 EXPECT_EQ(kBarResponseBody, client_->response_body()); | 3131 EXPECT_EQ(kBarResponseBody, client_->response_body()); |
3134 QuicConnectionStats client_stats = | 3132 QuicConnectionStats client_stats = |
3135 client_->client()->session()->connection()->GetStats(); | 3133 client_->client()->session()->connection()->GetStats(); |
3136 EXPECT_EQ(0u, client_stats.packets_lost); | 3134 EXPECT_EQ(0u, client_stats.packets_lost); |
3137 EXPECT_EQ(1, client_->client()->GetNumSentClientHellos()); | 3135 EXPECT_EQ(1, client_->client()->GetNumSentClientHellos()); |
3138 } | 3136 } |
3139 } // namespace | 3137 } // namespace |
3140 } // namespace test | 3138 } // namespace test |
3141 } // namespace net | 3139 } // namespace net |
OLD | NEW |