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 38d2ed10b478fbc0d4288406b226cd9b5292bb4a..c9a0a94d70f12e3809d22b4bb94458a1fe2bf3e6 100644 |
--- a/net/tools/quic/end_to_end_test.cc |
+++ b/net/tools/quic/end_to_end_test.cc |
@@ -153,30 +153,26 @@ vector<TestParams> GetTestParams() { |
// to do 0-RTT across incompatible versions. Chromium only supports |
// a single version at a time anyway. :) |
QuicVersionVector all_supported_versions = QuicSupportedVersions(); |
- QuicVersionVector version_buckets[5]; |
+ QuicVersionVector version_buckets[4]; |
for (const QuicVersion version : all_supported_versions) { |
- if (version <= QUIC_VERSION_25) { |
- // Versions: 25 |
- // SPDY/4 |
- version_buckets[0].push_back(version); |
- } else if (version <= QUIC_VERSION_30) { |
- // Versions: 26-30 |
+ if (version <= QUIC_VERSION_30) { |
+ // Versions: 30 |
// v26 adds a hash of the expected leaf cert in the XLCT tag. |
- version_buckets[1].push_back(version); |
+ version_buckets[0].push_back(version); |
} else if (version <= QUIC_VERSION_32) { |
// Versions: 31-32 |
// v31 adds a hash of the CHLO into the proof signature. |
- version_buckets[2].push_back(version); |
+ version_buckets[1].push_back(version); |
} else if (version <= QUIC_VERSION_33) { |
// Versions: 33 |
// v33 adds a diversification nonce into the hkdf. |
- version_buckets[3].push_back(version); |
+ version_buckets[2].push_back(version); |
} else { |
// Versions: 34+ |
// QUIC_VERSION_34 deprecates entropy and uses new ack and stop waiting |
// wire formats. |
- version_buckets[4].push_back(version); |
+ version_buckets[3].push_back(version); |
} |
} |
@@ -222,10 +218,6 @@ vector<TestParams> GetTestParams() { |
} |
for (const QuicVersionVector& client_versions : version_buckets) { |
- if (client_versions.front() < QUIC_VERSION_30 && |
- FLAGS_quic_disable_pre_30) { |
- continue; |
- } |
CHECK(!client_versions.empty()); |
// Add an entry for server and client supporting all versions. |
params.push_back(TestParams( |
@@ -249,10 +241,6 @@ vector<TestParams> GetTestParams() { |
// because it is essentially the same as the default |
// case. |
for (size_t i = 1; i < client_versions.size(); ++i) { |
- if (client_versions[i] < QUIC_VERSION_30 && |
- FLAGS_quic_disable_pre_30) { |
- continue; |
- } |
QuicVersionVector server_supported_versions; |
server_supported_versions.push_back(client_versions[i]); |
params.push_back(TestParams( |
@@ -1224,15 +1212,9 @@ TEST_P(EndToEndTest, NegotiateMaxOpenStreams) { |
} |
client_->WaitForResponse(); |
- if (negotiated_version_ <= QUIC_VERSION_27) { |
- EXPECT_FALSE(client_->connected()); |
- EXPECT_EQ(QUIC_STREAM_CONNECTION_ERROR, client_->stream_error()); |
- EXPECT_EQ(QUIC_TOO_MANY_OPEN_STREAMS, client_->connection_error()); |
- } else { |
- EXPECT_TRUE(client_->connected()); |
- EXPECT_EQ(QUIC_REFUSED_STREAM, client_->stream_error()); |
- EXPECT_EQ(QUIC_NO_ERROR, client_->connection_error()); |
- } |
+ EXPECT_TRUE(client_->connected()); |
+ EXPECT_EQ(QUIC_REFUSED_STREAM, client_->stream_error()); |
+ EXPECT_EQ(QUIC_NO_ERROR, client_->connection_error()); |
} |
TEST_P(EndToEndTest, MaxIncomingDynamicStreamsLimitRespected) { |
@@ -2411,7 +2393,6 @@ TEST_P(EndToEndTest, LargePostEarlyResponse) { |
// POST to a URL that gets an early error response, after the headers are |
// received and before the body is received. |
HTTPMessage request(HttpConstants::HTTP_1_1, HttpConstants::POST, "/garbage"); |
- const uint32_t kBodySize = 2 * kWindowSize; |
// Invalid content-length so the request will receive an early 500 response. |
request.AddHeader("content-length", "-1"); |
request.set_skip_message_validation(true); |
@@ -2425,28 +2406,11 @@ TEST_P(EndToEndTest, LargePostEarlyResponse) { |
client_->WaitForInitialResponse(); |
EXPECT_EQ(500u, client_->response_headers()->parsed_response_code()); |
- if (negotiated_version_ > QUIC_VERSION_28) { |
- // Receive the reset stream from server on early response. |
- client_->WaitForResponseForMs(100); |
- ReliableQuicStream* stream = |
- client_->client()->session()->GetOrCreateStream(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); |
- |
- // 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. |
+ // Receive the reset stream from server on early response. |
ReliableQuicStream* stream = |
client_->client()->session()->GetOrCreateStream(kClientDataStreamId1); |
- EXPECT_FALSE(stream != nullptr && stream->HasBufferedData()); |
+ // The stream is reset by server's reset stream. |
+ EXPECT_EQ(stream, nullptr); |
} |
TEST_P(EndToEndTest, Trailers) { |