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

net/spdy/spdy_session.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.h"
 
 #include <algorithm>
 #include <map>
 
 #include "base/basictypes.h"
@@ skipping 499 matching lines @@
 
   net_log_.AddEvent(
       NetLog::TYPE_SPDY_SESSION_INITIALIZED,
       connection_->socket()->NetLog().source().ToEventParametersCallback());
 
   int error = DoReadLoop(READ_STATE_DO_READ, OK);
   if (error == ERR_IO_PENDING)
     error = OK;
   if (error == OK) {
     DCHECK_NE(availability_state_, STATE_CLOSED);
-    connection_->AddLayeredPool(this);
+    connection_->AddHigherLayeredPool(this);
     if (enable_sending_initial_data_)
       SendInitialData();
     pool_ = pool;
   } else {
     DcheckClosed();
   }
   return static_cast<Error>(error);
 }
 
 bool SpdySession::VerifyDomainAuthentication(const std::string& domain) {
@@ skipping 510 matching lines @@
   active_streams_.erase(it);
 
   // TODO(akalin): When SpdyStream was ref-counted (and
   // |unclaimed_pushed_streams_| held scoped_refptr<SpdyStream>), this
   // was only done when status was not OK. This meant that pushed
   // streams can still be claimed after they're closed. This is
   // probably something that we still want to support, although server
   // push is hardly used. Write tests for this and fix this. (See
   // http://crbug.com/261712 .)
   if (owned_stream->type() == SPDY_PUSH_STREAM)
-      unclaimed_pushed_streams_.erase(owned_stream->url());
+    unclaimed_pushed_streams_.erase(owned_stream->url());
+
+  base::WeakPtr<SpdySession> weak_this = GetWeakPtr();
 
   DeleteStream(owned_stream.Pass(), status);
+
+  if (!weak_this)
+    return;
+
+  if (availability_state_ == STATE_CLOSED)
+    return;
+
+  // If there are no active streams and the socket pool is stalled, close the
+  // session to free up a socket slot.
+  if (active_streams_.empty() && connection_->IsPoolStalled()) {
+    CloseSessionResult result =
+        DoCloseSession(ERR_CONNECTION_CLOSED, "Closing idle connection.");
+    DCHECK_NE(result, SESSION_ALREADY_CLOSED);
+  }
 }
 
 void SpdySession::CloseCreatedStreamIterator(CreatedStreamSet::iterator it,
                                              int status) {
   scoped_ptr<SpdyStream> owned_stream(*it);
   created_streams_.erase(it);
   DeleteStream(owned_stream.Pass(), status);
 }
 
 void SpdySession::ResetStreamIterator(ActiveStreamMap::iterator it,
@@ skipping 1855 matching lines @@
     if (!queue->empty()) {
       SpdyStreamId stream_id = queue->front();
       queue->pop_front();
       return stream_id;
     }
   }
   return 0;
 }
 
 }  // namespace net