When an idle socket is added back to a socket pool, check for stalled jobs in lower pools

net/socket/client_socket_handle.h

 // 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.
 
 #ifndef NET_SOCKET_CLIENT_SOCKET_HANDLE_H_
 #define NET_SOCKET_CLIENT_SOCKET_HANDLE_H_
 
 #include <string>
 
 #include "base/logging.h"
@@ skipping 76 matching lines @@
   // Disconnect method.  This will result in the ClientSocketPool deleting the
   // StreamSocket.
   void Reset();
 
   // Used after Init() is called, but before the ClientSocketPool has
   // initialized the ClientSocketHandle.
   LoadState GetLoadState() const;
 
   bool IsPoolStalled() const;
 
-  void AddLayeredPool(LayeredPool* layered_pool);
+  // Adds a higher layered pool on top of the socket pool that |socket_| belongs
+  // to.  At most one higher layered pool can be added to a
+  // ClientSocketHandle at a time.  On destruction or reset, automatically
+  // removes the higher pool if RemoveHigherLayeredPool has not been called.
+  void AddHigherLayeredPool(HigherLayeredPool* higher_pool);
 
-  void RemoveLayeredPool(LayeredPool* layered_pool);
+  // Removes a higher layered pool from the socket pool that |socket_| belongs
+  // to.  |higher_pool| must have been added by the above function.
+  void RemoveHigherLayeredPool(HigherLayeredPool* higher_pool);
 
   // Returns true when Init() has completed successfully.
   bool is_initialized() const { return is_initialized_; }
 
   // Returns the time tick when Init() was called.
   base::TimeTicks init_time() const { return init_time_; }
 
   // Returns the time between Init() and when is_initialized() becomes true.
   base::TimeDelta setup_time() const { return setup_time_; }
 
@@ skipping 67 matching lines @@
   // Resets the state of the ClientSocketHandle.  |cancel| indicates whether or
   // not to try to cancel the request with the ClientSocketPool.  Does not
   // reset the supplemental error state.
   void ResetInternal(bool cancel);
 
   // Resets the supplemental error state.
   void ResetErrorState();
 
   bool is_initialized_;
   ClientSocketPool* pool_;
-  LayeredPool* layered_pool_;
+  HigherLayeredPool* higher_pool_;
   scoped_ptr<StreamSocket> socket_;
   std::string group_name_;
   bool is_reused_;
   CompletionCallback callback_;
   CompletionCallback user_callback_;
   base::TimeDelta idle_time_;
   int pool_id_;  // See ClientSocketPool::ReleaseSocket() for an explanation.
   bool is_ssl_error_;
   HttpResponseInfo ssl_error_response_info_;
   scoped_ptr<ClientSocketHandle> pending_http_proxy_connection_;
@@ skipping 31 matching lines @@
     user_callback_ = callback;
   } else {
     HandleInitCompletion(rv);
   }
   return rv;
 }
 
 }  // namespace net
 
 #endif  // NET_SOCKET_CLIENT_SOCKET_HANDLE_H_