| 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 #ifndef NET_SOCKET_CLIENT_SOCKET_POOL_MANAGER_IMPL_H_ | 5 #ifndef NET_SOCKET_CLIENT_SOCKET_POOL_MANAGER_IMPL_H_ |
| 6 #define NET_SOCKET_CLIENT_SOCKET_POOL_MANAGER_IMPL_H_ | 6 #define NET_SOCKET_CLIENT_SOCKET_POOL_MANAGER_IMPL_H_ |
| 7 | 7 |
| 8 #include <map> | 8 #include <map> |
| 9 #include <type_traits> | 9 #include <type_traits> |
| 10 | 10 |
| 11 #include "base/compiler_specific.h" | 11 #include "base/compiler_specific.h" |
| 12 #include "base/macros.h" | 12 #include "base/macros.h" |
| 13 #include "base/memory/ref_counted.h" | 13 #include "base/memory/ref_counted.h" |
| 14 #include "base/memory/scoped_ptr.h" | 14 #include "base/memory/scoped_ptr.h" |
| 15 #include "base/stl_util.h" | 15 #include "base/stl_util.h" |
| 16 #include "base/threading/non_thread_safe.h" | 16 #include "base/threading/non_thread_safe.h" |
| 17 #include "net/cert/cert_database.h" | 17 #include "net/cert/cert_database.h" |
| 18 #include "net/http/http_network_session.h" | 18 #include "net/http/http_network_session.h" |
| 19 #include "net/socket/client_socket_pool_manager.h" | 19 #include "net/socket/client_socket_pool_manager.h" |
| 20 | 20 |
| 21 namespace net { | 21 namespace net { |
| 22 | 22 |
| 23 class CertVerifier; | 23 class CertVerifier; |
| 24 class ChannelIDService; | 24 class ChannelIDService; |
| 25 class ClientSocketFactory; | 25 class ClientSocketFactory; |
| 26 class CTVerifier; | 26 class CTVerifier; |
| 27 class HttpProxyClientSocketPool; | 27 class HttpProxyClientSocketPool; |
| 28 class HostResolver; | 28 class HostResolver; |
| 29 class NetLog; | 29 class NetLog; |
| 30 class SocketPerformanceWatcherFactory; |
| 30 class SOCKSClientSocketPool; | 31 class SOCKSClientSocketPool; |
| 31 class SSLClientSocketPool; | 32 class SSLClientSocketPool; |
| 32 class SSLConfigService; | 33 class SSLConfigService; |
| 33 class TransportClientSocketPool; | 34 class TransportClientSocketPool; |
| 34 class TransportSecurityState; | 35 class TransportSecurityState; |
| 35 | 36 |
| 36 namespace internal { | 37 namespace internal { |
| 37 | 38 |
| 38 // A helper class for auto-deleting Values in the destructor. | 39 // A helper class for auto-deleting Values in the destructor. |
| 39 template <typename Key, typename Value> | 40 template <typename Key, typename Value> |
| 40 class OwnedPoolMap : public std::map<Key, Value> { | 41 class OwnedPoolMap : public std::map<Key, Value> { |
| 41 public: | 42 public: |
| 42 OwnedPoolMap() { | 43 OwnedPoolMap() { |
| 43 static_assert(std::is_pointer<Value>::value, "value must be a pointer"); | 44 static_assert(std::is_pointer<Value>::value, "value must be a pointer"); |
| 44 } | 45 } |
| 45 | 46 |
| 46 ~OwnedPoolMap() { | 47 ~OwnedPoolMap() { |
| 47 STLDeleteValues(this); | 48 STLDeleteValues(this); |
| 48 } | 49 } |
| 49 }; | 50 }; |
| 50 | 51 |
| 51 } // namespace internal | 52 } // namespace internal |
| 52 | 53 |
| 53 class ClientSocketPoolManagerImpl : public base::NonThreadSafe, | 54 class ClientSocketPoolManagerImpl : public base::NonThreadSafe, |
| 54 public ClientSocketPoolManager, | 55 public ClientSocketPoolManager, |
| 55 public CertDatabase::Observer { | 56 public CertDatabase::Observer { |
| 56 public: | 57 public: |
| 57 ClientSocketPoolManagerImpl(NetLog* net_log, | 58 ClientSocketPoolManagerImpl( |
| 58 ClientSocketFactory* socket_factory, | 59 NetLog* net_log, |
| 59 HostResolver* host_resolver, | 60 ClientSocketFactory* socket_factory, |
| 60 CertVerifier* cert_verifier, | 61 SocketPerformanceWatcherFactory* socket_performance_watcher_factory, |
| 61 ChannelIDService* channel_id_service, | 62 HostResolver* host_resolver, |
| 62 TransportSecurityState* transport_security_state, | 63 CertVerifier* cert_verifier, |
| 63 CTVerifier* cert_transparency_verifier, | 64 ChannelIDService* channel_id_service, |
| 64 CTPolicyEnforcer* ct_policy_enforcer, | 65 TransportSecurityState* transport_security_state, |
| 65 const std::string& ssl_session_cache_shard, | 66 CTVerifier* cert_transparency_verifier, |
| 66 SSLConfigService* ssl_config_service, | 67 CTPolicyEnforcer* ct_policy_enforcer, |
| 67 HttpNetworkSession::SocketPoolType pool_type); | 68 const std::string& ssl_session_cache_shard, |
| 69 SSLConfigService* ssl_config_service, |
| 70 HttpNetworkSession::SocketPoolType pool_type); |
| 68 ~ClientSocketPoolManagerImpl() override; | 71 ~ClientSocketPoolManagerImpl() override; |
| 69 | 72 |
| 70 void FlushSocketPoolsWithError(int error) override; | 73 void FlushSocketPoolsWithError(int error) override; |
| 71 void CloseIdleSockets() override; | 74 void CloseIdleSockets() override; |
| 72 | 75 |
| 73 TransportClientSocketPool* GetTransportSocketPool() override; | 76 TransportClientSocketPool* GetTransportSocketPool() override; |
| 74 | 77 |
| 75 SSLClientSocketPool* GetSSLSocketPool() override; | 78 SSLClientSocketPool* GetSSLSocketPool() override; |
| 76 | 79 |
| 77 SOCKSClientSocketPool* GetSocketPoolForSOCKSProxy( | 80 SOCKSClientSocketPool* GetSocketPoolForSOCKSProxy( |
| (...skipping 17 matching lines...) Expand all Loading... |
| 95 TransportSocketPoolMap; | 98 TransportSocketPoolMap; |
| 96 typedef internal::OwnedPoolMap<HostPortPair, SOCKSClientSocketPool*> | 99 typedef internal::OwnedPoolMap<HostPortPair, SOCKSClientSocketPool*> |
| 97 SOCKSSocketPoolMap; | 100 SOCKSSocketPoolMap; |
| 98 typedef internal::OwnedPoolMap<HostPortPair, HttpProxyClientSocketPool*> | 101 typedef internal::OwnedPoolMap<HostPortPair, HttpProxyClientSocketPool*> |
| 99 HTTPProxySocketPoolMap; | 102 HTTPProxySocketPoolMap; |
| 100 typedef internal::OwnedPoolMap<HostPortPair, SSLClientSocketPool*> | 103 typedef internal::OwnedPoolMap<HostPortPair, SSLClientSocketPool*> |
| 101 SSLSocketPoolMap; | 104 SSLSocketPoolMap; |
| 102 | 105 |
| 103 NetLog* const net_log_; | 106 NetLog* const net_log_; |
| 104 ClientSocketFactory* const socket_factory_; | 107 ClientSocketFactory* const socket_factory_; |
| 108 SocketPerformanceWatcherFactory* socket_performance_watcher_factory_; |
| 105 HostResolver* const host_resolver_; | 109 HostResolver* const host_resolver_; |
| 106 CertVerifier* const cert_verifier_; | 110 CertVerifier* const cert_verifier_; |
| 107 ChannelIDService* const channel_id_service_; | 111 ChannelIDService* const channel_id_service_; |
| 108 TransportSecurityState* const transport_security_state_; | 112 TransportSecurityState* const transport_security_state_; |
| 109 CTVerifier* const cert_transparency_verifier_; | 113 CTVerifier* const cert_transparency_verifier_; |
| 110 CTPolicyEnforcer* const ct_policy_enforcer_; | 114 CTPolicyEnforcer* const ct_policy_enforcer_; |
| 111 const std::string ssl_session_cache_shard_; | 115 const std::string ssl_session_cache_shard_; |
| 112 const scoped_refptr<SSLConfigService> ssl_config_service_; | 116 const scoped_refptr<SSLConfigService> ssl_config_service_; |
| 113 const HttpNetworkSession::SocketPoolType pool_type_; | 117 const HttpNetworkSession::SocketPoolType pool_type_; |
| 114 | 118 |
| 115 // Note: this ordering is important. | 119 // Note: this ordering is important. |
| 116 | 120 |
| 117 scoped_ptr<TransportClientSocketPool> transport_socket_pool_; | 121 scoped_ptr<TransportClientSocketPool> transport_socket_pool_; |
| 118 scoped_ptr<SSLClientSocketPool> ssl_socket_pool_; | 122 scoped_ptr<SSLClientSocketPool> ssl_socket_pool_; |
| 119 TransportSocketPoolMap transport_socket_pools_for_socks_proxies_; | 123 TransportSocketPoolMap transport_socket_pools_for_socks_proxies_; |
| 120 SOCKSSocketPoolMap socks_socket_pools_; | 124 SOCKSSocketPoolMap socks_socket_pools_; |
| 121 TransportSocketPoolMap transport_socket_pools_for_http_proxies_; | 125 TransportSocketPoolMap transport_socket_pools_for_http_proxies_; |
| 122 TransportSocketPoolMap transport_socket_pools_for_https_proxies_; | 126 TransportSocketPoolMap transport_socket_pools_for_https_proxies_; |
| 123 SSLSocketPoolMap ssl_socket_pools_for_https_proxies_; | 127 SSLSocketPoolMap ssl_socket_pools_for_https_proxies_; |
| 124 HTTPProxySocketPoolMap http_proxy_socket_pools_; | 128 HTTPProxySocketPoolMap http_proxy_socket_pools_; |
| 125 SSLSocketPoolMap ssl_socket_pools_for_proxies_; | 129 SSLSocketPoolMap ssl_socket_pools_for_proxies_; |
| 126 | 130 |
| 127 DISALLOW_COPY_AND_ASSIGN(ClientSocketPoolManagerImpl); | 131 DISALLOW_COPY_AND_ASSIGN(ClientSocketPoolManagerImpl); |
| 128 }; | 132 }; |
| 129 | 133 |
| 130 } // namespace net | 134 } // namespace net |
| 131 | 135 |
| 132 #endif // NET_SOCKET_CLIENT_SOCKET_POOL_MANAGER_IMPL_H_ | 136 #endif // NET_SOCKET_CLIENT_SOCKET_POOL_MANAGER_IMPL_H_ |
| OLD | NEW |