Close idle H2 sockets when SpdySession is initialized.

net/spdy/spdy_session_pool.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/spdy/spdy_session_pool.h"
 
 #include <utility>
 
 #include "base/logging.h"
 #include "base/memory/ptr_util.h"
@@ skipping 26 matching lines @@
   SPDY_SESSION_GET_MAX        = 4
 };
 
 }  // namespace
 
 SpdySessionPool::SpdySessionPool(
     HostResolver* resolver,
     SSLConfigService* ssl_config_service,
     HttpServerProperties* http_server_properties,
     TransportSecurityState* transport_security_state,
+    HttpNetworkSession* http_network_session,
     bool enable_ping_based_connection_checking,
     size_t session_max_recv_window_size,
     const SettingsMap& initial_settings,
     SpdySessionPool::TimeFunc time_func,
     ProxyDelegate* proxy_delegate)
     : http_server_properties_(http_server_properties),
       transport_security_state_(transport_security_state),
+      http_network_session_(http_network_session),
       ssl_config_service_(ssl_config_service),
       resolver_(resolver),
       enable_sending_initial_data_(true),
       enable_ping_based_connection_checking_(
           enable_ping_based_connection_checking),
       session_max_recv_window_size_(session_max_recv_window_size),
       initial_settings_(initial_settings),
       time_func_(time_func),
       push_delegate_(nullptr),
       proxy_delegate_(proxy_delegate) {
@@ skipping 24 matching lines @@
     const NetLogWithSource& net_log,
     bool is_secure) {
   TRACE_EVENT0(kNetTracingCategory,
                "SpdySessionPool::CreateAvailableSessionFromSocket");
 
   UMA_HISTOGRAM_ENUMERATION(
       "Net.SpdySessionGet", IMPORTED_FROM_SOCKET, SPDY_SESSION_GET_MAX);
 
   auto new_session = base::MakeUnique<SpdySession>(
       key, http_server_properties_, transport_security_state_,
-      enable_sending_initial_data_, enable_ping_based_connection_checking_,
-      session_max_recv_window_size_, initial_settings_, time_func_,
-      push_delegate_, proxy_delegate_, net_log.net_log());
+      http_network_session_, enable_sending_initial_data_,
+      enable_ping_based_connection_checking_, session_max_recv_window_size_,
+      initial_settings_, time_func_, push_delegate_, proxy_delegate_,
+      net_log.net_log());
 
   new_session->InitializeWithSocket(std::move(connection), this, is_secure);
 
   base::WeakPtr<SpdySession> available_session = new_session->GetWeakPtr();
   sessions_.insert(new_session.release());
   MapKeyToAvailableSession(key, available_session);
 
   net_log.AddEvent(
       NetLogEventType::HTTP2_SESSION_POOL_IMPORTED_SESSION_FROM_SOCKET,
       available_session->net_log().source().ToEventParametersCallback());
@@ skipping 367 matching lines @@
 
     if (idle_only && (*it)->is_active())
       continue;
 
     (*it)->CloseSessionOnError(error, description);
     DCHECK(!IsSessionAvailable(*it));
   }
 }
 
 }  // namespace net