| 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 2531 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2542 } | 2542 } |
| 2543 | 2543 |
| 2544 TEST_P(EndToEndTest, LargePostEarlyResponse) { | 2544 TEST_P(EndToEndTest, LargePostEarlyResponse) { |
| 2545 const uint32_t kWindowSize = 65536; | 2545 const uint32_t kWindowSize = 65536; |
| 2546 set_client_initial_stream_flow_control_receive_window(kWindowSize); | 2546 set_client_initial_stream_flow_control_receive_window(kWindowSize); |
| 2547 set_client_initial_session_flow_control_receive_window(kWindowSize); | 2547 set_client_initial_session_flow_control_receive_window(kWindowSize); |
| 2548 set_server_initial_stream_flow_control_receive_window(kWindowSize); | 2548 set_server_initial_stream_flow_control_receive_window(kWindowSize); |
| 2549 set_server_initial_session_flow_control_receive_window(kWindowSize); | 2549 set_server_initial_session_flow_control_receive_window(kWindowSize); |
| 2550 | 2550 |
| 2551 ASSERT_TRUE(Initialize()); | 2551 ASSERT_TRUE(Initialize()); |
| 2552 if (FLAGS_quic_reloadable_flag_quic_always_enable_bidi_streaming) { |
| 2553 // This test is testing the same behavior as |
| 2554 // EarlyResponseWithQuicStreamNoError, except for the additional final check |
| 2555 // that the stream is reset on early response. Once this flag is deprecated |
| 2556 // the tests will be the same and this one can be removed. |
| 2557 return; |
| 2558 } |
| 2552 | 2559 |
| 2553 EXPECT_TRUE(client_->client()->WaitForCryptoHandshakeConfirmed()); | 2560 EXPECT_TRUE(client_->client()->WaitForCryptoHandshakeConfirmed()); |
| 2554 | 2561 |
| 2555 // POST to a URL that gets an early error response, after the headers are | 2562 // POST to a URL that gets an early error response, after the headers are |
| 2556 // received and before the body is received. | 2563 // received and before the body is received. |
| 2557 SpdyHeaderBlock headers; | 2564 SpdyHeaderBlock headers; |
| 2558 headers[":method"] = "POST"; | 2565 headers[":method"] = "POST"; |
| 2559 headers[":path"] = "/foo"; | 2566 headers[":path"] = "/foo"; |
| 2560 headers[":scheme"] = "https"; | 2567 headers[":scheme"] = "https"; |
| 2561 headers[":authority"] = server_hostname_; | 2568 headers[":authority"] = server_hostname_; |
| (...skipping 501 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3063 client_->WaitForResponse(); | 3070 client_->WaitForResponse(); |
| 3064 EXPECT_EQ(kBarResponseBody, client_->response_body()); | 3071 EXPECT_EQ(kBarResponseBody, client_->response_body()); |
| 3065 QuicConnectionStats client_stats = | 3072 QuicConnectionStats client_stats = |
| 3066 client_->client()->session()->connection()->GetStats(); | 3073 client_->client()->session()->connection()->GetStats(); |
| 3067 EXPECT_EQ(0u, client_stats.packets_lost); | 3074 EXPECT_EQ(0u, client_stats.packets_lost); |
| 3068 EXPECT_EQ(1, client_->client()->GetNumSentClientHellos()); | 3075 EXPECT_EQ(1, client_->client()->GetNumSentClientHellos()); |
| 3069 } | 3076 } |
| 3070 } // namespace | 3077 } // namespace |
| 3071 } // namespace test | 3078 } // namespace test |
| 3072 } // namespace net | 3079 } // namespace net |
| OLD | NEW |