| 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 "net/socket/client_socket_pool_base.h" | 5 #include "net/socket/client_socket_pool_base.h" |
| 6 | 6 |
| 7 #include <vector> | 7 #include <vector> |
| 8 | 8 |
| 9 #include "base/bind.h" | 9 #include "base/bind.h" |
| 10 #include "base/bind_helpers.h" | 10 #include "base/bind_helpers.h" |
| (...skipping 649 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 660 ClientSocketPoolBaseTest() | 660 ClientSocketPoolBaseTest() |
| 661 : params_(new TestSocketParams(false /* ignore_limits */)), | 661 : params_(new TestSocketParams(false /* ignore_limits */)), |
| 662 histograms_("ClientSocketPoolTest") { | 662 histograms_("ClientSocketPoolTest") { |
| 663 connect_backup_jobs_enabled_ = | 663 connect_backup_jobs_enabled_ = |
| 664 internal::ClientSocketPoolBaseHelper::connect_backup_jobs_enabled(); | 664 internal::ClientSocketPoolBaseHelper::connect_backup_jobs_enabled(); |
| 665 internal::ClientSocketPoolBaseHelper::set_connect_backup_jobs_enabled(true); | 665 internal::ClientSocketPoolBaseHelper::set_connect_backup_jobs_enabled(true); |
| 666 cleanup_timer_enabled_ = | 666 cleanup_timer_enabled_ = |
| 667 internal::ClientSocketPoolBaseHelper::cleanup_timer_enabled(); | 667 internal::ClientSocketPoolBaseHelper::cleanup_timer_enabled(); |
| 668 } | 668 } |
| 669 | 669 |
| 670 virtual ~ClientSocketPoolBaseTest() { | 670 ~ClientSocketPoolBaseTest() override { |
| 671 internal::ClientSocketPoolBaseHelper::set_connect_backup_jobs_enabled( | 671 internal::ClientSocketPoolBaseHelper::set_connect_backup_jobs_enabled( |
| 672 connect_backup_jobs_enabled_); | 672 connect_backup_jobs_enabled_); |
| 673 internal::ClientSocketPoolBaseHelper::set_cleanup_timer_enabled( | 673 internal::ClientSocketPoolBaseHelper::set_cleanup_timer_enabled( |
| 674 cleanup_timer_enabled_); | 674 cleanup_timer_enabled_); |
| 675 } | 675 } |
| 676 | 676 |
| 677 void CreatePool(int max_sockets, int max_sockets_per_group) { | 677 void CreatePool(int max_sockets, int max_sockets_per_group) { |
| 678 CreatePoolWithIdleTimeouts( | 678 CreatePoolWithIdleTimeouts( |
| 679 max_sockets, | 679 max_sockets, |
| 680 max_sockets_per_group, | 680 max_sockets_per_group, |
| (...skipping 3413 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 4094 request(1)->handle()->Reset(); | 4094 request(1)->handle()->Reset(); |
| 4095 ASSERT_EQ(1, pool_->NumConnectJobsInGroup("a")); | 4095 ASSERT_EQ(1, pool_->NumConnectJobsInGroup("a")); |
| 4096 | 4096 |
| 4097 EXPECT_EQ(OK, request(2)->WaitForResult()); | 4097 EXPECT_EQ(OK, request(2)->WaitForResult()); |
| 4098 EXPECT_FALSE(request(1)->have_result()); | 4098 EXPECT_FALSE(request(1)->have_result()); |
| 4099 } | 4099 } |
| 4100 | 4100 |
| 4101 } // namespace | 4101 } // namespace |
| 4102 | 4102 |
| 4103 } // namespace net | 4103 } // namespace net |
| OLD | NEW |