| 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_manager_impl.h" | 5 #include "net/socket/client_socket_pool_manager_impl.h" |
| 6 | 6 |
| 7 #include <algorithm> | 7 #include <algorithm> |
| 8 #include <utility> | 8 #include <utility> |
| 9 | 9 |
| 10 #include "base/logging.h" | 10 #include "base/logging.h" |
| (...skipping 194 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 205 } | 205 } |
| 206 | 206 |
| 207 SSLClientSocketPool* ClientSocketPoolManagerImpl::GetSSLSocketPool() { | 207 SSLClientSocketPool* ClientSocketPoolManagerImpl::GetSSLSocketPool() { |
| 208 return ssl_socket_pool_.get(); | 208 return ssl_socket_pool_.get(); |
| 209 } | 209 } |
| 210 | 210 |
| 211 SOCKSClientSocketPool* ClientSocketPoolManagerImpl::GetSocketPoolForSOCKSProxy( | 211 SOCKSClientSocketPool* ClientSocketPoolManagerImpl::GetSocketPoolForSOCKSProxy( |
| 212 const HostPortPair& socks_proxy) { | 212 const HostPortPair& socks_proxy) { |
| 213 SOCKSSocketPoolMap::const_iterator it = socks_socket_pools_.find(socks_proxy); | 213 SOCKSSocketPoolMap::const_iterator it = socks_socket_pools_.find(socks_proxy); |
| 214 if (it != socks_socket_pools_.end()) { | 214 if (it != socks_socket_pools_.end()) { |
| 215 DCHECK(ContainsKey(transport_socket_pools_for_socks_proxies_, socks_proxy)); | 215 DCHECK(base::ContainsKey(transport_socket_pools_for_socks_proxies_, |
| 216 socks_proxy)); |
| 216 return it->second; | 217 return it->second; |
| 217 } | 218 } |
| 218 | 219 |
| 219 DCHECK(!ContainsKey(transport_socket_pools_for_socks_proxies_, socks_proxy)); | 220 DCHECK(!base::ContainsKey(transport_socket_pools_for_socks_proxies_, |
| 221 socks_proxy)); |
| 220 int sockets_per_proxy_server = max_sockets_per_proxy_server(pool_type_); | 222 int sockets_per_proxy_server = max_sockets_per_proxy_server(pool_type_); |
| 221 int sockets_per_group = std::min(sockets_per_proxy_server, | 223 int sockets_per_group = std::min(sockets_per_proxy_server, |
| 222 max_sockets_per_group(pool_type_)); | 224 max_sockets_per_group(pool_type_)); |
| 223 | 225 |
| 224 std::pair<TransportSocketPoolMap::iterator, bool> tcp_ret = | 226 std::pair<TransportSocketPoolMap::iterator, bool> tcp_ret = |
| 225 transport_socket_pools_for_socks_proxies_.insert(std::make_pair( | 227 transport_socket_pools_for_socks_proxies_.insert(std::make_pair( |
| 226 socks_proxy, | 228 socks_proxy, |
| 227 new TransportClientSocketPool(sockets_per_proxy_server, | 229 new TransportClientSocketPool(sockets_per_proxy_server, |
| 228 sockets_per_group, host_resolver_, | 230 sockets_per_group, host_resolver_, |
| 229 socket_factory_, nullptr, net_log_))); | 231 socket_factory_, nullptr, net_log_))); |
| 230 DCHECK(tcp_ret.second); | 232 DCHECK(tcp_ret.second); |
| 231 | 233 |
| 232 std::pair<SOCKSSocketPoolMap::iterator, bool> ret = | 234 std::pair<SOCKSSocketPoolMap::iterator, bool> ret = |
| 233 socks_socket_pools_.insert(std::make_pair( | 235 socks_socket_pools_.insert(std::make_pair( |
| 234 socks_proxy, | 236 socks_proxy, |
| 235 new SOCKSClientSocketPool(sockets_per_proxy_server, sockets_per_group, | 237 new SOCKSClientSocketPool(sockets_per_proxy_server, sockets_per_group, |
| 236 host_resolver_, tcp_ret.first->second, | 238 host_resolver_, tcp_ret.first->second, |
| 237 nullptr, net_log_))); | 239 nullptr, net_log_))); |
| 238 | 240 |
| 239 return ret.first->second; | 241 return ret.first->second; |
| 240 } | 242 } |
| 241 | 243 |
| 242 HttpProxyClientSocketPool* | 244 HttpProxyClientSocketPool* |
| 243 ClientSocketPoolManagerImpl::GetSocketPoolForHTTPProxy( | 245 ClientSocketPoolManagerImpl::GetSocketPoolForHTTPProxy( |
| 244 const HostPortPair& http_proxy) { | 246 const HostPortPair& http_proxy) { |
| 245 HTTPProxySocketPoolMap::const_iterator it = | 247 HTTPProxySocketPoolMap::const_iterator it = |
| 246 http_proxy_socket_pools_.find(http_proxy); | 248 http_proxy_socket_pools_.find(http_proxy); |
| 247 if (it != http_proxy_socket_pools_.end()) { | 249 if (it != http_proxy_socket_pools_.end()) { |
| 248 DCHECK(ContainsKey(transport_socket_pools_for_http_proxies_, http_proxy)); | 250 DCHECK(base::ContainsKey(transport_socket_pools_for_http_proxies_, |
| 249 DCHECK(ContainsKey(transport_socket_pools_for_https_proxies_, http_proxy)); | 251 http_proxy)); |
| 250 DCHECK(ContainsKey(ssl_socket_pools_for_https_proxies_, http_proxy)); | 252 DCHECK(base::ContainsKey(transport_socket_pools_for_https_proxies_, |
| 253 http_proxy)); |
| 254 DCHECK(base::ContainsKey(ssl_socket_pools_for_https_proxies_, http_proxy)); |
| 251 return it->second; | 255 return it->second; |
| 252 } | 256 } |
| 253 | 257 |
| 254 DCHECK(!ContainsKey(transport_socket_pools_for_http_proxies_, http_proxy)); | 258 DCHECK( |
| 255 DCHECK(!ContainsKey(transport_socket_pools_for_https_proxies_, http_proxy)); | 259 !base::ContainsKey(transport_socket_pools_for_http_proxies_, http_proxy)); |
| 256 DCHECK(!ContainsKey(ssl_socket_pools_for_https_proxies_, http_proxy)); | 260 DCHECK(!base::ContainsKey(transport_socket_pools_for_https_proxies_, |
| 261 http_proxy)); |
| 262 DCHECK(!base::ContainsKey(ssl_socket_pools_for_https_proxies_, http_proxy)); |
| 257 | 263 |
| 258 int sockets_per_proxy_server = max_sockets_per_proxy_server(pool_type_); | 264 int sockets_per_proxy_server = max_sockets_per_proxy_server(pool_type_); |
| 259 int sockets_per_group = std::min(sockets_per_proxy_server, | 265 int sockets_per_group = std::min(sockets_per_proxy_server, |
| 260 max_sockets_per_group(pool_type_)); | 266 max_sockets_per_group(pool_type_)); |
| 261 | 267 |
| 262 std::pair<TransportSocketPoolMap::iterator, bool> tcp_http_ret = | 268 std::pair<TransportSocketPoolMap::iterator, bool> tcp_http_ret = |
| 263 transport_socket_pools_for_http_proxies_.insert(std::make_pair( | 269 transport_socket_pools_for_http_proxies_.insert(std::make_pair( |
| 264 http_proxy, | 270 http_proxy, |
| 265 new TransportClientSocketPool( | 271 new TransportClientSocketPool( |
| 266 sockets_per_proxy_server, sockets_per_group, host_resolver_, | 272 sockets_per_proxy_server, sockets_per_group, host_resolver_, |
| (...skipping 100 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 367 // We should not flush the socket pools if we added trust to a | 373 // We should not flush the socket pools if we added trust to a |
| 368 // cert. | 374 // cert. |
| 369 // | 375 // |
| 370 // Since the OnCACertChanged method doesn't tell us what | 376 // Since the OnCACertChanged method doesn't tell us what |
| 371 // kind of change it is, we have to flush the socket | 377 // kind of change it is, we have to flush the socket |
| 372 // pools to be safe. | 378 // pools to be safe. |
| 373 FlushSocketPoolsWithError(ERR_NETWORK_CHANGED); | 379 FlushSocketPoolsWithError(ERR_NETWORK_CHANGED); |
| 374 } | 380 } |
| 375 | 381 |
| 376 } // namespace net | 382 } // namespace net |
| OLD | NEW |