Close idle H2 sockets when SpdySession is initialized.

net/socket/client_socket_pool_manager_impl.cc

 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "net/socket/client_socket_pool_manager_impl.h"
 
 #include <algorithm>
 #include <utility>
 
 #include "base/logging.h"
@@ skipping 136 matching lines @@
        ++it)
     it->second->FlushWithError(error);
 
   ssl_socket_pool_->FlushWithError(error);
   transport_socket_pool_->FlushWithError(error);
 }
 
 void ClientSocketPoolManagerImpl::CloseIdleSockets() {
   // Close sockets in the highest level pools first, since higher level pools'
   // sockets may release stuff to the lower level pools.
-  for (SSLSocketPoolMap::const_iterator it =
-       ssl_socket_pools_for_proxies_.begin();
-       it != ssl_socket_pools_for_proxies_.end();
-       ++it)
-    it->second->CloseIdleSockets();
+  for (const auto& it : ssl_socket_pools_for_proxies_)
+    it.second->CloseIdleSockets();
 
-  for (HTTPProxySocketPoolMap::const_iterator it =
-       http_proxy_socket_pools_.begin();
-       it != http_proxy_socket_pools_.end();
-       ++it)
-    it->second->CloseIdleSockets();
+  for (const auto& it : http_proxy_socket_pools_)
+    it.second->CloseIdleSockets();
 
-  for (SSLSocketPoolMap::const_iterator it =
-       ssl_socket_pools_for_https_proxies_.begin();
-       it != ssl_socket_pools_for_https_proxies_.end();
-       ++it)
-    it->second->CloseIdleSockets();
+  for (const auto& it : ssl_socket_pools_for_https_proxies_)
+    it.second->CloseIdleSockets();
 
-  for (TransportSocketPoolMap::const_iterator it =
-       transport_socket_pools_for_https_proxies_.begin();
-       it != transport_socket_pools_for_https_proxies_.end();
-       ++it)
-    it->second->CloseIdleSockets();
+  for (const auto& it : transport_socket_pools_for_https_proxies_)
+    it.second->CloseIdleSockets();
 
-  for (TransportSocketPoolMap::const_iterator it =
-       transport_socket_pools_for_http_proxies_.begin();
-       it != transport_socket_pools_for_http_proxies_.end();
-       ++it)
-    it->second->CloseIdleSockets();
+  for (const auto& it : transport_socket_pools_for_http_proxies_)
+    it.second->CloseIdleSockets();
 
-  for (SOCKSSocketPoolMap::const_iterator it =
-       socks_socket_pools_.begin();
-       it != socks_socket_pools_.end();
-       ++it)
-    it->second->CloseIdleSockets();
+  for (const auto& it : socks_socket_pools_)
+    it.second->CloseIdleSockets();
 
-  for (TransportSocketPoolMap::const_iterator it =
-       transport_socket_pools_for_socks_proxies_.begin();
-       it != transport_socket_pools_for_socks_proxies_.end();
-       ++it)
-    it->second->CloseIdleSockets();
+  for (const auto& it : transport_socket_pools_for_socks_proxies_)
+    it.second->CloseIdleSockets();
 
   ssl_socket_pool_->CloseIdleSockets();
   transport_socket_pool_->CloseIdleSockets();
 }
 
+void ClientSocketPoolManagerImpl::CloseIdleSocketsInGroup(
+    const std::string& group_name) {
+  // Close sockets in the highest level pools first, since higher level pools'
+  // sockets may release stuff to the lower level pools.
+  for (const auto& it : ssl_socket_pools_for_proxies_)
+    it.second->CloseIdleSocketsInGroup(group_name);
+
+  for (const auto& it : http_proxy_socket_pools_)
+    it.second->CloseIdleSocketsInGroup(group_name);
+
+  for (const auto& it : ssl_socket_pools_for_https_proxies_)
+    it.second->CloseIdleSocketsInGroup(group_name);
+
+  for (const auto& it : transport_socket_pools_for_https_proxies_)
+    it.second->CloseIdleSocketsInGroup(group_name);
+
+  for (const auto& it : transport_socket_pools_for_http_proxies_)
+    it.second->CloseIdleSocketsInGroup(group_name);
+
+  for (const auto& it : socks_socket_pools_)
+    it.second->CloseIdleSocketsInGroup(group_name);
+
+  for (const auto& it : transport_socket_pools_for_socks_proxies_)
+    it.second->CloseIdleSocketsInGroup(group_name);
+
+  ssl_socket_pool_->CloseIdleSocketsInGroup(group_name);
+  transport_socket_pool_->CloseIdleSocketsInGroup(group_name);
+}
+
 TransportClientSocketPool*
 ClientSocketPoolManagerImpl::GetTransportSocketPool() {
   return transport_socket_pool_.get();
 }
 
 SSLClientSocketPool* ClientSocketPoolManagerImpl::GetSSLSocketPool() {
   return ssl_socket_pool_.get();
 }
 
 SOCKSClientSocketPool* ClientSocketPoolManagerImpl::GetSocketPoolForSOCKSProxy(
@@ skipping 147 matching lines @@
   FlushSocketPoolsWithError(ERR_NETWORK_CHANGED);
 }
 
 void ClientSocketPoolManagerImpl::DumpMemoryStats(
     base::trace_event::ProcessMemoryDump* pmd,
     const std::string& parent_dump_absolute_name) const {
   return ssl_socket_pool_->DumpMemoryStats(pmd, parent_dump_absolute_name);
 }
 
 }  // namespace net