| OLD | NEW |
| 1 // Copyright (c) 2010 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2010 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 "base/callback.h" | 7 #include "base/callback.h" |
| 8 #include "base/compiler_specific.h" | 8 #include "base/compiler_specific.h" |
| 9 #include "base/message_loop.h" | 9 #include "base/message_loop.h" |
| 10 #include "base/platform_thread.h" | 10 #include "base/platform_thread.h" |
| (...skipping 2907 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2918 } | 2918 } |
| 2919 | 2919 |
| 2920 TEST_F(ClientSocketPoolBaseTest, RequestSocketsSynchronousError) { | 2920 TEST_F(ClientSocketPoolBaseTest, RequestSocketsSynchronousError) { |
| 2921 CreatePool(kDefaultMaxSockets, kDefaultMaxSocketsPerGroup); | 2921 CreatePool(kDefaultMaxSockets, kDefaultMaxSocketsPerGroup); |
| 2922 connect_job_factory_->set_job_type(TestConnectJob::kMockFailingJob); | 2922 connect_job_factory_->set_job_type(TestConnectJob::kMockFailingJob); |
| 2923 | 2923 |
| 2924 pool_->RequestSockets("a", ¶ms_, kDefaultMaxSocketsPerGroup, | 2924 pool_->RequestSockets("a", ¶ms_, kDefaultMaxSocketsPerGroup, |
| 2925 BoundNetLog()); | 2925 BoundNetLog()); |
| 2926 | 2926 |
| 2927 ASSERT_FALSE(pool_->HasGroup("a")); | 2927 ASSERT_FALSE(pool_->HasGroup("a")); |
| 2928 |
| 2929 connect_job_factory_->set_job_type( |
| 2930 TestConnectJob::kMockAdditionalErrorStateJob); |
| 2931 pool_->RequestSockets("a", ¶ms_, kDefaultMaxSocketsPerGroup, |
| 2932 BoundNetLog()); |
| 2933 |
| 2934 ASSERT_FALSE(pool_->HasGroup("a")); |
| 2928 } | 2935 } |
| 2929 | 2936 |
| 2930 TEST_F(ClientSocketPoolBaseTest, RequestSocketsMultipleTimesDoesNothing) { | 2937 TEST_F(ClientSocketPoolBaseTest, RequestSocketsMultipleTimesDoesNothing) { |
| 2931 CreatePool(4, 4); | 2938 CreatePool(4, 4); |
| 2932 connect_job_factory_->set_job_type(TestConnectJob::kMockPendingJob); | 2939 connect_job_factory_->set_job_type(TestConnectJob::kMockPendingJob); |
| 2933 | 2940 |
| 2934 pool_->RequestSockets("a", ¶ms_, 2, BoundNetLog()); | 2941 pool_->RequestSockets("a", ¶ms_, 2, BoundNetLog()); |
| 2935 | 2942 |
| 2936 ASSERT_TRUE(pool_->HasGroup("a")); | 2943 ASSERT_TRUE(pool_->HasGroup("a")); |
| 2937 EXPECT_EQ(2, pool_->NumConnectJobsInGroup("a")); | 2944 EXPECT_EQ(2, pool_->NumConnectJobsInGroup("a")); |
| (...skipping 159 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3097 EXPECT_EQ(1, pool_->IdleSocketCountInGroup("a")); | 3104 EXPECT_EQ(1, pool_->IdleSocketCountInGroup("a")); |
| 3098 EXPECT_EQ(0, pool_->NumActiveSocketsInGroup("a")); | 3105 EXPECT_EQ(0, pool_->NumActiveSocketsInGroup("a")); |
| 3099 EXPECT_EQ(0, pool_->NumConnectJobsInGroup("b")); | 3106 EXPECT_EQ(0, pool_->NumConnectJobsInGroup("b")); |
| 3100 EXPECT_EQ(1, pool_->IdleSocketCountInGroup("b")); | 3107 EXPECT_EQ(1, pool_->IdleSocketCountInGroup("b")); |
| 3101 EXPECT_EQ(0, pool_->NumActiveSocketsInGroup("b")); | 3108 EXPECT_EQ(0, pool_->NumActiveSocketsInGroup("b")); |
| 3102 } | 3109 } |
| 3103 | 3110 |
| 3104 } // namespace | 3111 } // namespace |
| 3105 | 3112 |
| 3106 } // namespace net | 3113 } // namespace net |
| OLD | NEW |