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

net/spdy/spdy_session.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_SPDY_SPDY_SESSION_H_
 #define NET_SPDY_SPDY_SESSION_H_
 
 #include <deque>
 #include <map>
 #include <set>
@@ skipping 168 matching lines @@
   GURL url_;
   RequestPriority priority_;
   BoundNetLog net_log_;
   CompletionCallback callback_;
 
   DISALLOW_COPY_AND_ASSIGN(SpdyStreamRequest);
 };
 
 class NET_EXPORT SpdySession : public BufferedSpdyFramerVisitorInterface,
                                public SpdyFramerDebugVisitorInterface,
-                               public LayeredPool {
+                               public HigherLayeredPool {
  public:
   // TODO(akalin): Use base::TickClock when it becomes available.
   typedef base::TimeTicks (*TimeFunc)(void);
 
   // How we handle flow control (version-dependent).
   enum FlowControlState {
     FLOW_CONTROL_NONE,
     FLOW_CONTROL_STREAM,
     FLOW_CONTROL_STREAM_AND_SESSION
   };
@@ skipping 273 matching lines @@
     return buffered_spdy_framer_->GetFrameMaximumSize();
   }
 
   size_t GetDataFrameMaximumPayload() const {
     return buffered_spdy_framer_->GetDataFrameMaximumPayload();
   }
 
   // Must be used only by |pool_|.
   base::WeakPtr<SpdySession> GetWeakPtr();
 
-  // LayeredPool implementation:
+  // HigherLayeredPool implementation:
   virtual bool CloseOneIdleConnection() OVERRIDE;
 
  private:
   friend class base::RefCounted<SpdySession>;
   friend class SpdyStreamRequest;
   friend class SpdySessionTest;
 
   // Allow tests to access our innards for testing purposes.
   FRIEND_TEST_ALL_PREFIXES(SpdySessionTest, ClientPing);
   FRIEND_TEST_ALL_PREFIXES(SpdySessionTest, FailedPing);
@@ skipping 405 matching lines @@
   void QueueSendStalledStream(const SpdyStream& stream);
 
   // Go through the queue of send-stalled streams and try to resume as
   // many as possible.
   void ResumeSendStalledStreams();
 
   // Returns the next stream to possibly resume, or 0 if the queue is
   // empty.
   SpdyStreamId PopStreamToPossiblyResume();
 
+  // Closes the session if it's idle.  Much like CloseOneIdleConnection, but
+  // without the DCHECKs.
+  void CloseIfIdle();
+
   // --------------------------
   // Helper methods for testing
   // --------------------------
 
   void set_connection_at_risk_of_loss_time(base::TimeDelta duration) {
     connection_at_risk_of_loss_time_ = duration;
   }
 
   void set_hung_interval(base::TimeDelta duration) {
     hung_interval_ = duration;
@@ skipping 215 matching lines @@
   // This SPDY proxy is allowed to push resources from origins that are
   // different from those of their associated streams.
   HostPortPair trusted_spdy_proxy_;
 
   TimeFunc time_func_;
 };
 
 }  // namespace net
 
 #endif  // NET_SPDY_SPDY_SESSION_H_