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 0e111e1e24ab3b16612d7ad48d45bd9ff73222b7..f757686ea72cc2e57253cb6c113adc070f470c23 100644 |
--- a/net/tools/quic/end_to_end_test.cc |
+++ b/net/tools/quic/end_to_end_test.cc |
@@ -96,16 +96,14 @@ struct TestParams { |
QuicVersion negotiated_version, |
bool client_supports_stateless_rejects, |
bool server_uses_stateless_rejects_if_peer_supported, |
- QuicTag congestion_control_tag, |
- bool auto_tune_flow_control_window) |
+ QuicTag congestion_control_tag) |
: client_supported_versions(client_supported_versions), |
server_supported_versions(server_supported_versions), |
negotiated_version(negotiated_version), |
client_supports_stateless_rejects(client_supports_stateless_rejects), |
server_uses_stateless_rejects_if_peer_supported( |
server_uses_stateless_rejects_if_peer_supported), |
- congestion_control_tag(congestion_control_tag), |
- auto_tune_flow_control_window(auto_tune_flow_control_window) {} |
+ congestion_control_tag(congestion_control_tag) {} |
friend ostream& operator<<(ostream& os, const TestParams& p) { |
os << "{ server_supported_versions: " |
@@ -118,9 +116,7 @@ struct TestParams { |
os << " server_uses_stateless_rejects_if_peer_supported: " |
<< p.server_uses_stateless_rejects_if_peer_supported; |
os << " congestion_control_tag: " |
- << QuicUtils::TagToString(p.congestion_control_tag); |
- os << " auto_tune_flow_control_window: " << p.auto_tune_flow_control_window |
- << " }"; |
+ << QuicUtils::TagToString(p.congestion_control_tag) << " }"; |
return os; |
} |
@@ -130,7 +126,6 @@ struct TestParams { |
bool client_supports_stateless_rejects; |
bool server_uses_stateless_rejects_if_peer_supported; |
QuicTag congestion_control_tag; |
- bool auto_tune_flow_control_window; |
}; |
// Constructs various test permutations. |
@@ -161,58 +156,53 @@ vector<TestParams> GetTestParams() { |
for (bool client_supports_stateless_rejects : {true, false}) { |
// TODO(rtenneti): Add kTBBR after BBR code is checked in. |
for (const QuicTag congestion_control_tag : {kRENO, kQBIC}) { |
- for (bool auto_tune_flow_control_window : {true, false}) { |
- const int kMaxEnabledOptions = 5; |
- int enabled_options = 0; |
- if (congestion_control_tag != kQBIC) { |
- ++enabled_options; |
- } |
- if (auto_tune_flow_control_window) { |
- ++enabled_options; |
- } |
- if (client_supports_stateless_rejects) { |
- ++enabled_options; |
- } |
- if (server_uses_stateless_rejects_if_peer_supported) { |
- ++enabled_options; |
- } |
- CHECK_GE(kMaxEnabledOptions, enabled_options); |
+ const int kMaxEnabledOptions = 4; |
+ int enabled_options = 0; |
+ if (congestion_control_tag != kQBIC) { |
+ ++enabled_options; |
+ } |
+ if (client_supports_stateless_rejects) { |
+ ++enabled_options; |
+ } |
+ if (server_uses_stateless_rejects_if_peer_supported) { |
+ ++enabled_options; |
+ } |
+ CHECK_GE(kMaxEnabledOptions, enabled_options); |
- // Run tests with no options, a single option, or all the options |
- // enabled to avoid a combinatorial explosion. |
- if (enabled_options > 1 && enabled_options < kMaxEnabledOptions) { |
+ // Run tests with no options, a single option, or all the options |
+ // enabled to avoid a combinatorial explosion. |
+ if (enabled_options > 1 && enabled_options < kMaxEnabledOptions) { |
+ continue; |
+ } |
+ |
+ for (const QuicVersionVector& client_versions : version_buckets) { |
+ CHECK(!client_versions.empty()); |
+ // Add an entry for server and client supporting all versions. |
+ params.push_back(TestParams( |
+ client_versions, all_supported_versions, client_versions.front(), |
+ client_supports_stateless_rejects, |
+ server_uses_stateless_rejects_if_peer_supported, |
+ congestion_control_tag)); |
+ |
+ // Run version negotiation tests tests with no options, or all |
+ // the options enabled to avoid a combinatorial explosion. |
+ if (enabled_options > 0 && enabled_options < kMaxEnabledOptions) { |
continue; |
} |
- for (const QuicVersionVector& client_versions : version_buckets) { |
- CHECK(!client_versions.empty()); |
- // Add an entry for server and client supporting all versions. |
- params.push_back(TestParams( |
- client_versions, all_supported_versions, |
- client_versions.front(), client_supports_stateless_rejects, |
- server_uses_stateless_rejects_if_peer_supported, |
- congestion_control_tag, auto_tune_flow_control_window)); |
- |
- // Run version negotiation tests tests with no options, or all |
- // the options enabled to avoid a combinatorial explosion. |
- if (enabled_options > 0 && enabled_options < kMaxEnabledOptions) { |
- continue; |
- } |
- |
- // Test client supporting all versions and server supporting 1 |
- // version. Simulate an old server and exercise version downgrade |
- // in the client. Protocol negotiation should occur. Skip the i = |
- // 0 case because it is essentially the same as the default case. |
- for (size_t i = 1; i < client_versions.size(); ++i) { |
- QuicVersionVector server_supported_versions; |
- server_supported_versions.push_back(client_versions[i]); |
- params.push_back(TestParams( |
- client_versions, server_supported_versions, |
- server_supported_versions.front(), |
- client_supports_stateless_rejects, |
- server_uses_stateless_rejects_if_peer_supported, |
- congestion_control_tag, auto_tune_flow_control_window)); |
- } |
+ // Test client supporting all versions and server supporting 1 |
+ // version. Simulate an old server and exercise version downgrade |
+ // in the client. Protocol negotiation should occur. Skip the i = |
+ // 0 case because it is essentially the same as the default case. |
+ for (size_t i = 1; i < client_versions.size(); ++i) { |
+ QuicVersionVector server_supported_versions; |
+ server_supported_versions.push_back(client_versions[i]); |
+ params.push_back( |
+ TestParams(client_versions, server_supported_versions, |
+ server_supported_versions.front(), |
+ client_supports_stateless_rejects, |
+ server_uses_stateless_rejects_if_peer_supported, |
+ congestion_control_tag)); |
} |
} |
} |
@@ -348,10 +338,6 @@ class EndToEndTest : public ::testing::TestWithParam<TestParams> { |
if (GetParam().client_supports_stateless_rejects) { |
copt.push_back(kSREJ); |
} |
- if (GetParam().auto_tune_flow_control_window) { |
- copt.push_back(kAFCW); |
- copt.push_back(kIFW5); |
- } |
client_config_.SetConnectionOptionsToSend(copt); |
// Start the server first, because CreateQuicClient() attempts |
@@ -1491,10 +1477,8 @@ TEST_P(EndToEndTest, DifferentFlowControlWindows) { |
set_client_initial_stream_flow_control_receive_window(kClientStreamIFCW); |
set_client_initial_session_flow_control_receive_window(kClientSessionIFCW); |
- uint32_t kServerStreamIFCW = |
- GetParam().auto_tune_flow_control_window ? 32 * 1024 : 654321; |
- uint32_t kServerSessionIFCW = |
- GetParam().auto_tune_flow_control_window ? 48 * 1024 : 765432; |
+ uint32_t kServerStreamIFCW = 32 * 1024; |
+ uint32_t kServerSessionIFCW = 48 * 1024; |
set_server_initial_stream_flow_control_receive_window(kServerStreamIFCW); |
set_server_initial_session_flow_control_receive_window(kServerSessionIFCW); |
@@ -1542,10 +1526,8 @@ TEST_P(EndToEndTest, DifferentFlowControlWindows) { |
TEST_P(EndToEndTest, HeadersAndCryptoStreamsNoConnectionFlowControl) { |
// The special headers and crypto streams should be subject to per-stream flow |
// control limits, but should not be subject to connection level flow control. |
- const uint32_t kStreamIFCW = |
- GetParam().auto_tune_flow_control_window ? 32 * 1024 : 123456; |
- const uint32_t kSessionIFCW = |
- GetParam().auto_tune_flow_control_window ? 48 * 1024 : 234567; |
+ const uint32_t kStreamIFCW = 32 * 1024; |
+ const uint32_t kSessionIFCW = 48 * 1024; |
set_client_initial_stream_flow_control_receive_window(kStreamIFCW); |
set_client_initial_session_flow_control_receive_window(kSessionIFCW); |
set_server_initial_stream_flow_control_receive_window(kStreamIFCW); |