| 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 366 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 377 } | 377 } |
| 378 | 378 |
| 379 bool Initialize() { | 379 bool Initialize() { |
| 380 QuicTagVector copt; | 380 QuicTagVector copt; |
| 381 server_config_.SetConnectionOptionsToSend(copt); | 381 server_config_.SetConnectionOptionsToSend(copt); |
| 382 copt = client_extra_copts_; | 382 copt = client_extra_copts_; |
| 383 | 383 |
| 384 // TODO(nimia): Consider setting the congestion control algorithm for the | 384 // TODO(nimia): Consider setting the congestion control algorithm for the |
| 385 // client as well according to the test parameter. | 385 // client as well according to the test parameter. |
| 386 copt.push_back(GetParam().congestion_control_tag); | 386 copt.push_back(GetParam().congestion_control_tag); |
| 387 if (GetParam().congestion_control_tag == kQBIC && | 387 if (GetParam().congestion_control_tag == kQBIC) { |
| 388 FLAGS_quic_reloadable_flag_quic_fix_cubic_convex_mode) { | |
| 389 copt.push_back(kCCVX); | 388 copt.push_back(kCCVX); |
| 390 } | 389 } |
| 391 if (GetParam().congestion_control_tag == kQBIC && | 390 if (GetParam().congestion_control_tag == kQBIC) { |
| 392 FLAGS_quic_reloadable_flag_quic_fix_cubic_bytes_quantization) { | |
| 393 copt.push_back(kCBQT); | 391 copt.push_back(kCBQT); |
| 394 } | 392 } |
| 395 if (GetParam().congestion_control_tag == kQBIC && | 393 if (GetParam().congestion_control_tag == kQBIC) { |
| 396 FLAGS_quic_reloadable_flag_quic_enable_cubic_per_ack_updates) { | |
| 397 copt.push_back(kCPAU); | 394 copt.push_back(kCPAU); |
| 398 } | 395 } |
| 399 if (GetParam().congestion_control_tag == kTPCC && | 396 if (GetParam().congestion_control_tag == kTPCC && |
| 400 FLAGS_quic_reloadable_flag_quic_enable_pcc) { | 397 FLAGS_quic_reloadable_flag_quic_enable_pcc) { |
| 401 copt.push_back(kTPCC); | 398 copt.push_back(kTPCC); |
| 402 } | 399 } |
| 403 | 400 |
| 404 if (support_server_push_) { | 401 if (support_server_push_) { |
| 405 copt.push_back(kSPSH); | 402 copt.push_back(kSPSH); |
| 406 } | 403 } |
| (...skipping 2672 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3079 client_->WaitForResponse(); | 3076 client_->WaitForResponse(); |
| 3080 EXPECT_EQ(kBarResponseBody, client_->response_body()); | 3077 EXPECT_EQ(kBarResponseBody, client_->response_body()); |
| 3081 QuicConnectionStats client_stats = | 3078 QuicConnectionStats client_stats = |
| 3082 client_->client()->session()->connection()->GetStats(); | 3079 client_->client()->session()->connection()->GetStats(); |
| 3083 EXPECT_EQ(0u, client_stats.packets_lost); | 3080 EXPECT_EQ(0u, client_stats.packets_lost); |
| 3084 EXPECT_EQ(1, client_->client()->GetNumSentClientHellos()); | 3081 EXPECT_EQ(1, client_->client()->GetNumSentClientHellos()); |
| 3085 } | 3082 } |
| 3086 } // namespace | 3083 } // namespace |
| 3087 } // namespace test | 3084 } // namespace test |
| 3088 } // namespace net | 3085 } // namespace net |
| OLD | NEW |