Basic HTTP pipelining support

net/http/http_stream_factory_impl.cc

Index: net/http/http_stream_factory_impl.cc
diff --git a/net/http/http_stream_factory_impl.cc b/net/http/http_stream_factory_impl.cc
index 63db4569e4dc904bac904b3b990443c9450c7e67..60ae0193f92f725b1d5dcde20b2416218714ac69 100644
--- a/net/http/http_stream_factory_impl.cc
+++ b/net/http/http_stream_factory_impl.cc
@@ -10,6 +10,9 @@
 #include "net/base/net_log.h"
 #include "net/base/net_util.h"
 #include "net/http/http_network_session.h"
+#include "net/http/http_pipelined_connection.h"
+#include "net/http/http_pipelined_host.h"
+#include "net/http/http_pipelined_stream.h"
 #include "net/http/http_stream_factory_impl_job.h"
 #include "net/http/http_stream_factory_impl_request.h"
 #include "net/spdy/spdy_http_stream.h"
@@ -205,4 +208,23 @@ void HttpStreamFactoryImpl::OnPreconnectsComplete(const Job* job) {
   OnPreconnectsCompleteInternal();
 }
 
+void HttpStreamFactoryImpl::OnHttpPipelinedHostHasAdditionalCapacity(
+    HttpPipelinedHost* host) {
+  const HostPortPair& origin = host->origin();
+  HttpPipelinedConnection* pipeline;
+  while ((pipeline = host->FindAvailablePipeline())) {
+    if (!ContainsKey(http_pipelining_request_map_, origin)) {
+      break;
+    }
+    Request* request = *http_pipelining_request_map_[origin].begin();
+    request->Complete(pipeline->was_npn_negotiated(),
+                      false,  // not using_spdy
+                      pipeline->source());
+    request->OnStreamReady(NULL,
+                           pipeline->used_ssl_config(),
+                           pipeline->used_proxy_info(),
+                           new HttpPipelinedStream(pipeline));
+  }
+}
+
 }  // namespace net