OLD | NEW |
1 // Copyright (c) 2011 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_handle.h" | 5 #include "net/socket/client_socket_handle.h" |
6 | 6 |
7 #include "base/compiler_specific.h" | 7 #include "base/compiler_specific.h" |
8 #include "base/metrics/histogram.h" | 8 #include "base/metrics/histogram.h" |
9 #include "base/logging.h" | 9 #include "base/logging.h" |
10 #include "net/base/net_errors.h" | 10 #include "net/base/net_errors.h" |
11 #include "net/socket/client_socket_pool.h" | 11 #include "net/socket/client_socket_pool.h" |
12 #include "net/socket/client_socket_pool_histograms.h" | 12 #include "net/socket/client_socket_pool_histograms.h" |
13 | 13 |
14 namespace net { | 14 namespace net { |
15 | 15 |
16 ClientSocketHandle::ClientSocketHandle() | 16 ClientSocketHandle::ClientSocketHandle() |
17 : is_initialized_(false), | 17 : is_initialized_(false), |
18 pool_(NULL), | |
19 layered_pool_(NULL), | |
20 is_reused_(false), | 18 is_reused_(false), |
21 ALLOW_THIS_IN_INITIALIZER_LIST( | 19 ALLOW_THIS_IN_INITIALIZER_LIST( |
22 callback_(this, &ClientSocketHandle::OnIOComplete)), | 20 callback_(this, &ClientSocketHandle::OnIOComplete)), |
23 is_ssl_error_(false) {} | 21 is_ssl_error_(false) {} |
24 | 22 |
25 ClientSocketHandle::~ClientSocketHandle() { | 23 ClientSocketHandle::~ClientSocketHandle() { |
26 Reset(); | 24 Reset(); |
27 } | 25 } |
28 | 26 |
29 void ClientSocketHandle::Reset() { | 27 void ClientSocketHandle::Reset() { |
(...skipping 14 matching lines...) Expand all Loading... |
44 pool_->ReleaseSocket(group_name_, release_socket(), pool_id_); | 42 pool_->ReleaseSocket(group_name_, release_socket(), pool_id_); |
45 } else if (cancel) { | 43 } else if (cancel) { |
46 // If we did not get initialized yet, we've got a socket request pending. | 44 // If we did not get initialized yet, we've got a socket request pending. |
47 // Cancel it. | 45 // Cancel it. |
48 pool_->CancelRequest(group_name_, this); | 46 pool_->CancelRequest(group_name_, this); |
49 } | 47 } |
50 is_initialized_ = false; | 48 is_initialized_ = false; |
51 group_name_.clear(); | 49 group_name_.clear(); |
52 is_reused_ = false; | 50 is_reused_ = false; |
53 user_callback_ = NULL; | 51 user_callback_ = NULL; |
54 if (layered_pool_) { | |
55 pool_->RemoveLayeredPool(layered_pool_); | |
56 layered_pool_ = NULL; | |
57 } | |
58 pool_ = NULL; | 52 pool_ = NULL; |
59 idle_time_ = base::TimeDelta(); | 53 idle_time_ = base::TimeDelta(); |
60 init_time_ = base::TimeTicks(); | 54 init_time_ = base::TimeTicks(); |
61 setup_time_ = base::TimeDelta(); | 55 setup_time_ = base::TimeDelta(); |
62 pool_id_ = -1; | 56 pool_id_ = -1; |
63 } | 57 } |
64 | 58 |
65 void ClientSocketHandle::ResetErrorState() { | 59 void ClientSocketHandle::ResetErrorState() { |
66 is_ssl_error_ = false; | 60 is_ssl_error_ = false; |
67 ssl_error_response_info_ = HttpResponseInfo(); | 61 ssl_error_response_info_ = HttpResponseInfo(); |
68 pending_http_proxy_connection_.reset(); | 62 pending_http_proxy_connection_.reset(); |
69 } | 63 } |
70 | 64 |
71 LoadState ClientSocketHandle::GetLoadState() const { | 65 LoadState ClientSocketHandle::GetLoadState() const { |
72 CHECK(!is_initialized()); | 66 CHECK(!is_initialized()); |
73 CHECK(!group_name_.empty()); | 67 CHECK(!group_name_.empty()); |
74 // Because of http://crbug.com/37810 we may not have a pool, but have | 68 // Because of http://crbug.com/37810 we may not have a pool, but have |
75 // just a raw socket. | 69 // just a raw socket. |
76 if (!pool_) | 70 if (!pool_) |
77 return LOAD_STATE_IDLE; | 71 return LOAD_STATE_IDLE; |
78 return pool_->GetLoadState(group_name_, this); | 72 return pool_->GetLoadState(group_name_, this); |
79 } | 73 } |
80 | 74 |
81 bool ClientSocketHandle::IsPoolStalled() const { | |
82 return pool_->IsStalled(); | |
83 } | |
84 | |
85 void ClientSocketHandle::AddLayeredPool(LayeredPool* layered_pool) { | |
86 CHECK(layered_pool); | |
87 CHECK(!layered_pool_); | |
88 if (pool_) { | |
89 pool_->AddLayeredPool(layered_pool); | |
90 layered_pool_ = layered_pool; | |
91 } | |
92 } | |
93 | |
94 void ClientSocketHandle::OnIOComplete(int result) { | 75 void ClientSocketHandle::OnIOComplete(int result) { |
95 OldCompletionCallback* callback = user_callback_; | 76 OldCompletionCallback* callback = user_callback_; |
96 user_callback_ = NULL; | 77 user_callback_ = NULL; |
97 HandleInitCompletion(result); | 78 HandleInitCompletion(result); |
98 callback->Run(result); | 79 callback->Run(result); |
99 } | 80 } |
100 | 81 |
101 void ClientSocketHandle::HandleInitCompletion(int result) { | 82 void ClientSocketHandle::HandleInitCompletion(int result) { |
102 CHECK_NE(ERR_IO_PENDING, result); | 83 CHECK_NE(ERR_IO_PENDING, result); |
103 if (result != OK) { | 84 if (result != OK) { |
(...skipping 29 matching lines...) Expand all Loading... |
133 // release() socket. It ends up working though, since those methods are being | 114 // release() socket. It ends up working though, since those methods are being |
134 // used to layer sockets (and the destination sources are the same). | 115 // used to layer sockets (and the destination sources are the same). |
135 DCHECK(socket_.get()); | 116 DCHECK(socket_.get()); |
136 socket_->NetLog().BeginEvent( | 117 socket_->NetLog().BeginEvent( |
137 NetLog::TYPE_SOCKET_IN_USE, | 118 NetLog::TYPE_SOCKET_IN_USE, |
138 make_scoped_refptr(new NetLogSourceParameter( | 119 make_scoped_refptr(new NetLogSourceParameter( |
139 "source_dependency", requesting_source_))); | 120 "source_dependency", requesting_source_))); |
140 } | 121 } |
141 | 122 |
142 } // namespace net | 123 } // namespace net |
OLD | NEW |