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