Introduce a policy to control the maximal number of connections per proxy server.

net/socket/client_socket_pool_manager.cc

 // Copyright (c) 2011 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.
 //
 // ClientSocketPoolManager manages access to all ClientSocketPools.  It's a
 // simple container for all of them.  Most importantly, it handles the lifetime
 // and destruction order properly.
 
 #include "net/socket/client_socket_pool_manager.h"
 
 #include <string>
 
 #include "base/logging.h"
 #include "base/stringprintf.h"
 #include "base/values.h"
 #include "net/base/ssl_config_service.h"
 #include "net/http/http_network_session.h"
 #include "net/http/http_proxy_client_socket_pool.h"
 #include "net/http/http_request_info.h"
 #include "net/proxy/proxy_service.h"
 #include "net/socket/client_socket_factory.h"
 #include "net/socket/client_socket_handle.h"
 #include "net/socket/client_socket_pool_histograms.h"
 #include "net/socket/socks_client_socket_pool.h"
 #include "net/socket/ssl_client_socket_pool.h"
 #include "net/socket/transport_client_socket_pool.h"
 
 namespace net {
 
+const int kDefaultMaxSocketsPerProxyServer = 32;
+
 namespace {
 
 // Total limit of sockets.
 int g_max_sockets = 256;
 
 // Default to allow up to 6 connections per host. Experiment and tuning may
 // try other values (greater than 0).  Too large may cause many problems, such
 // as home routers blocking the connections!?!?  See http://crbug.com/12066.
 int g_max_sockets_per_group = 6;
 
 // The max number of sockets to allow per proxy server.  This applies both to
 // http and SOCKS proxies.  See http://crbug.com/12066 and
 // http://crbug.com/44501 for details about proxy server connection limits.
-int g_max_sockets_per_proxy_server = 32;
+int g_max_sockets_per_proxy_server = kDefaultMaxSocketsPerProxyServer;
 
 // Appends information about all |socket_pools| to the end of |list|.
 template <class MapType>
 static void AddSocketPoolsToList(ListValue* list,
                                  const MapType& socket_pools,
                                  const std::string& type,
                                  bool include_nested_pools) {
   for (typename MapType::const_iterator it = socket_pools.begin();
        it != socket_pools.end(); it++) {
     list->Append(it->second->GetInfoAsValue(it->first.ToString(),
@@ skipping 506 matching lines @@
 
 // static
 void ClientSocketPoolManager::set_max_sockets_per_proxy_server(
     int socket_count) {
   DCHECK_LT(0, socket_count);
   DCHECK_GT(100, socket_count);  // Sanity check.
   // Assert this case early on. The max number of sockets per group cannot
   // exceed the max number of sockets per proxy server.
   DCHECK_LE(g_max_sockets_per_group, socket_count);
   g_max_sockets_per_proxy_server = socket_count;
+  LOG(ERROR) << "### Set the count to : " << socket_count;

[willchan no longer on Chromium, 2011/07/07 17:22:04]

I presume this is for debugging. If so, please kill it.

[pastarmovj, 2011/07/08 10:49:39]

Done.

 }
 
 Value* ClientSocketPoolManager::SocketPoolInfoToValue() const {
   ListValue* list = new ListValue();
   list->Append(transport_socket_pool_->GetInfoAsValue("transport_socket_pool",
                                                 "transport_socket_pool",
                                                 false));
   // Third parameter is false because |ssl_socket_pool_| uses
   // |transport_socket_pool_| internally, and do not want to add it a second
   // time.
@@ skipping 129 matching lines @@
                               ssl_config_for_proxy,
                               false,
                               net_log,
                               num_preconnect_streams,
                               NULL,
                               NULL);
 }
 
 
 }  // namespace net