| Index: net/tools/quic/end_to_end_test.cc
|
| diff --git a/net/tools/quic/end_to_end_test.cc b/net/tools/quic/end_to_end_test.cc
|
| index 31fc98ba6e31b8470926043ab1891c1b6ae40f03..8d519794697e85c6eaecd0f9d796e65b498d914c 100644
|
| --- a/net/tools/quic/end_to_end_test.cc
|
| +++ b/net/tools/quic/end_to_end_test.cc
|
| @@ -2105,32 +2105,37 @@ TEST_P(EndToEndTest, LargePostEarlyResponse) {
|
| client_->WaitForInitialResponse();
|
| EXPECT_EQ(500u, client_->response_headers()->parsed_response_code());
|
|
|
| - if (negotiated_version_ <= QUIC_VERSION_28) {
|
| - // Send a body larger than the stream flow control window.
|
| - string body;
|
| - GenerateBody(&body, kBodySize);
|
| - client_->SendData(body, true);
|
| -
|
| - if (FLAGS_quic_implement_stop_reading) {
|
| - // Run the client to let any buffered data be sent.
|
| - // (This is OK despite already waiting for a response.)
|
| - client_->WaitForResponse();
|
| - // There should be no buffered data to write in the client's stream.
|
| - ReliableQuicStream* stream = client_->client()->session()->GetStream(5);
|
| - EXPECT_FALSE(stream != nullptr && stream->HasBufferedData());
|
| - } else {
|
| - // Run the client for 0.1 second to let any buffered data be sent.
|
| - // Must have a timeout, as the stream will not close and cause a return.
|
| - // (This is OK despite already waiting for a response.)
|
| - client_->WaitForResponseForMs(100);
|
| - // There will be buffered data to write in the client's stream.
|
| - ReliableQuicStream* stream = client_->client()->session()->GetStream(5);
|
| - EXPECT_TRUE(stream != nullptr && stream->HasBufferedData());
|
| - }
|
| + if (negotiated_version_ > QUIC_VERSION_28) {
|
| + // Receive the reset stream from server on early response.
|
| + client_->WaitForResponseForMs(100);
|
| + ReliableQuicStream* stream =
|
| + client_->client()->session()->GetStream(kClientDataStreamId1);
|
| + // The stream is reset by server's reset stream.
|
| + EXPECT_EQ(stream, nullptr);
|
| + return;
|
| + }
|
| +
|
| + // Send a body larger than the stream flow control window.
|
| + string body;
|
| + GenerateBody(&body, kBodySize);
|
| + client_->SendData(body, true);
|
| +
|
| + if (FLAGS_quic_implement_stop_reading) {
|
| + // Run the client to let any buffered data be sent.
|
| + // (This is OK despite already waiting for a response.)
|
| + client_->WaitForResponse();
|
| + // There should be no buffered data to write in the client's stream.
|
| + ReliableQuicStream* stream =
|
| + client_->client()->session()->GetStream(kClientDataStreamId1);
|
| + EXPECT_FALSE(stream != nullptr && stream->HasBufferedData());
|
| } else {
|
| + // Run the client for 0.1 second to let any buffered data be sent.
|
| + // Must have a timeout, as the stream will not close and cause a return.
|
| + // (This is OK despite already waiting for a response.)
|
| client_->WaitForResponseForMs(100);
|
| + // There will be buffered data to write in the client's stream.
|
| ReliableQuicStream* stream = client_->client()->session()->GetStream(5);
|
| - EXPECT_TRUE(stream == nullptr);
|
| + EXPECT_TRUE(stream != nullptr && stream->HasBufferedData());
|
| }
|
| }
|
|
|
|
|