| 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 <list> | 8 #include <list> |
| 9 #include <memory> | 9 #include <memory> |
| 10 #include <string> | 10 #include <string> |
| (...skipping 411 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 422 copt.push_back(kSPSH); | 422 copt.push_back(kSPSH); |
| 423 } | 423 } |
| 424 if (GetParam().client_supports_stateless_rejects) { | 424 if (GetParam().client_supports_stateless_rejects) { |
| 425 copt.push_back(kSREJ); | 425 copt.push_back(kSREJ); |
| 426 } | 426 } |
| 427 if (GetParam().disable_hpack_dynamic_table) { | 427 if (GetParam().disable_hpack_dynamic_table) { |
| 428 copt.push_back(kDHDT); | 428 copt.push_back(kDHDT); |
| 429 } | 429 } |
| 430 if (GetParam().force_hol_blocking) { | 430 if (GetParam().force_hol_blocking) { |
| 431 client_config_.SetForceHolBlocking(); | 431 client_config_.SetForceHolBlocking(); |
| 432 QuicConfigPeer::SetReceivedForceHolBlocking(&server_config_); | |
| 433 } | 432 } |
| 434 client_config_.SetConnectionOptionsToSend(copt); | 433 client_config_.SetConnectionOptionsToSend(copt); |
| 435 | 434 |
| 436 // Start the server first, because CreateQuicClient() attempts | 435 // Start the server first, because CreateQuicClient() attempts |
| 437 // to connect to the server. | 436 // to connect to the server. |
| 438 StartServer(); | 437 StartServer(); |
| 439 | 438 |
| 440 CreateClientWithWriter(); | 439 CreateClientWithWriter(); |
| 441 static EpollEvent event(EPOLLOUT, false); | 440 static EpollEvent event(EPOLLOUT, false); |
| 442 if (client_writer_ != nullptr) { | 441 if (client_writer_ != nullptr) { |
| (...skipping 2434 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2877 EXPECT_EQ(kBarResponseBody, client_->response_body()); | 2876 EXPECT_EQ(kBarResponseBody, client_->response_body()); |
| 2878 QuicConnectionStats client_stats = | 2877 QuicConnectionStats client_stats = |
| 2879 client_->client()->session()->connection()->GetStats(); | 2878 client_->client()->session()->connection()->GetStats(); |
| 2880 EXPECT_EQ(0u, client_stats.packets_lost); | 2879 EXPECT_EQ(0u, client_stats.packets_lost); |
| 2881 EXPECT_EQ(1, client_->client()->GetNumSentClientHellos()); | 2880 EXPECT_EQ(1, client_->client()->GetNumSentClientHellos()); |
| 2882 } | 2881 } |
| 2883 | 2882 |
| 2884 } // namespace | 2883 } // namespace |
| 2885 } // namespace test | 2884 } // namespace test |
| 2886 } // namespace net | 2885 } // namespace net |
| OLD | NEW |