| 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 |