Basic HTTP pipelining support

net/http/http_pipelined_host.cc

Index: net/http/http_pipelined_host.cc
diff --git a/net/http/http_pipelined_host.cc b/net/http/http_pipelined_host.cc
new file mode 100644
index 0000000000000000000000000000000000000000..958c417cfff7c5c1d6257663fa8f1fa879190ca5
--- /dev/null
+++ b/net/http/http_pipelined_host.cc
@@ -0,0 +1,72 @@
+// Copyright (c) 2011 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/http/http_pipelined_host.h"
+
+#include "base/stl_util-inl.h"
+#include "net/http/http_pipelined_connection.h"
+#include "net/http/http_pipelined_host_pool.h"
+#include "net/http/http_pipelined_stream.h"
+
+namespace net {
+
+HttpPipelinedHost::HttpPipelinedHost(HttpPipelinedHostPool* pool,
+                                     const HostPortPair& origin)
+    : pool_(pool),
+      origin_(origin) {
+}
+
+HttpPipelinedHost::~HttpPipelinedHost() {
+  DCHECK(pipelines_.empty());
+}
+
+HttpPipelinedConnection* HttpPipelinedHost::CreateNewPipeline(
+    ClientSocketHandle* connection,
+    const SSLConfig& used_ssl_config,
+    const ProxyInfo& used_proxy_info,
+    const BoundNetLog& net_log,
+    bool was_npn_negotiated) {
+  HttpPipelinedConnection* pipeline = new HttpPipelinedConnection(
+      connection, this, used_ssl_config, used_proxy_info, net_log,
+      was_npn_negotiated);
+  pipelines_.insert(pipeline);
+  return pipeline;
+}
+
+HttpPipelinedConnection* HttpPipelinedHost::FindAvailablePipeline() {
+  HttpPipelinedConnection* available_pipeline = NULL;
+  for (std::set<HttpPipelinedConnection*>::iterator it = pipelines_.begin();
+       it != pipelines_.end(); ++it) {
+    if ((*it)->usable() &&
+        (*it)->active() &&
+        (*it)->depth() < max_pipeline_depth() &&
+        (!available_pipeline || (*it)->depth() < available_pipeline->depth())) {
+      available_pipeline = *it;
+    }
+  }
+  return available_pipeline;
+}
+
+void HttpPipelinedHost::OnPipelineEmpty(HttpPipelinedConnection* pipeline) {
+  DCHECK(ContainsKey(pipelines_, pipeline));
+  pipelines_.erase(pipeline);
+  delete pipeline;
+  if (pipelines_.empty()) {
+    pool_->OnHostIdle(this);
+    // WARNING: We'll probably be deleted here.
+  }
+}
+
+void HttpPipelinedHost::OnPipelineHasCapacity(
+    HttpPipelinedConnection* pipeline) {
+  if (pipeline->usable() && pipeline->depth() < max_pipeline_depth()) {
+    pool_->OnHostHasAdditionalCapacity(this);
+  }
+  if (!pipeline->depth()) {
+    OnPipelineEmpty(pipeline);
+    // WARNING: We'll probably be deleted here.
+  }
+}
+
+}  // namespace net