| Index: net/http/http_pipelined_host_pool.cc
|
| diff --git a/net/http/http_pipelined_host_pool.cc b/net/http/http_pipelined_host_pool.cc
|
| deleted file mode 100644
|
| index ee37e74c29d273792f789fb3c4a00945a9e1bc69..0000000000000000000000000000000000000000
|
| --- a/net/http/http_pipelined_host_pool.cc
|
| +++ /dev/null
|
| @@ -1,145 +0,0 @@
|
| -// 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/http/http_pipelined_host_pool.h"
|
| -
|
| -#include "base/logging.h"
|
| -#include "base/stl_util.h"
|
| -#include "base/values.h"
|
| -#include "net/http/http_pipelined_host_capability.h"
|
| -#include "net/http/http_pipelined_host_forced.h"
|
| -#include "net/http/http_pipelined_host_impl.h"
|
| -#include "net/http/http_server_properties.h"
|
| -
|
| -namespace net {
|
| -
|
| -class HttpPipelinedHostImplFactory : public HttpPipelinedHost::Factory {
|
| - public:
|
| - virtual HttpPipelinedHost* CreateNewHost(
|
| - HttpPipelinedHost::Delegate* delegate,
|
| - const HttpPipelinedHost::Key& key,
|
| - HttpPipelinedConnection::Factory* factory,
|
| - HttpPipelinedHostCapability capability,
|
| - bool force_pipelining) OVERRIDE {
|
| - if (force_pipelining) {
|
| - return new HttpPipelinedHostForced(delegate, key, factory);
|
| - } else {
|
| - return new HttpPipelinedHostImpl(delegate, key, factory, capability);
|
| - }
|
| - }
|
| -};
|
| -
|
| -HttpPipelinedHostPool::HttpPipelinedHostPool(
|
| - Delegate* delegate,
|
| - HttpPipelinedHost::Factory* factory,
|
| - const base::WeakPtr<HttpServerProperties>& http_server_properties,
|
| - bool force_pipelining)
|
| - : delegate_(delegate),
|
| - factory_(factory),
|
| - http_server_properties_(http_server_properties),
|
| - force_pipelining_(force_pipelining) {
|
| - if (!factory) {
|
| - factory_.reset(new HttpPipelinedHostImplFactory);
|
| - }
|
| -}
|
| -
|
| -HttpPipelinedHostPool::~HttpPipelinedHostPool() {
|
| - CHECK(host_map_.empty());
|
| -}
|
| -
|
| -bool HttpPipelinedHostPool::IsKeyEligibleForPipelining(
|
| - const HttpPipelinedHost::Key& key) {
|
| - HttpPipelinedHostCapability capability =
|
| - http_server_properties_->GetPipelineCapability(key.origin());
|
| - return capability != PIPELINE_INCAPABLE;
|
| -}
|
| -
|
| -HttpPipelinedStream* HttpPipelinedHostPool::CreateStreamOnNewPipeline(
|
| - const HttpPipelinedHost::Key& key,
|
| - ClientSocketHandle* connection,
|
| - const SSLConfig& used_ssl_config,
|
| - const ProxyInfo& used_proxy_info,
|
| - const BoundNetLog& net_log,
|
| - bool was_npn_negotiated,
|
| - NextProto protocol_negotiated) {
|
| - HttpPipelinedHost* host = GetPipelinedHost(key, true);
|
| - if (!host) {
|
| - return NULL;
|
| - }
|
| - return host->CreateStreamOnNewPipeline(connection, used_ssl_config,
|
| - used_proxy_info, net_log,
|
| - was_npn_negotiated,
|
| - protocol_negotiated);
|
| -}
|
| -
|
| -HttpPipelinedStream* HttpPipelinedHostPool::CreateStreamOnExistingPipeline(
|
| - const HttpPipelinedHost::Key& key) {
|
| - HttpPipelinedHost* host = GetPipelinedHost(key, false);
|
| - if (!host) {
|
| - return NULL;
|
| - }
|
| - return host->CreateStreamOnExistingPipeline();
|
| -}
|
| -
|
| -bool HttpPipelinedHostPool::IsExistingPipelineAvailableForKey(
|
| - const HttpPipelinedHost::Key& key) {
|
| - HttpPipelinedHost* host = GetPipelinedHost(key, false);
|
| - if (!host) {
|
| - return false;
|
| - }
|
| - return host->IsExistingPipelineAvailable();
|
| -}
|
| -
|
| -HttpPipelinedHost* HttpPipelinedHostPool::GetPipelinedHost(
|
| - const HttpPipelinedHost::Key& key, bool create_if_not_found) {
|
| - HostMap::iterator host_it = host_map_.find(key);
|
| - if (host_it != host_map_.end()) {
|
| - CHECK(host_it->second);
|
| - return host_it->second;
|
| - } else if (!create_if_not_found) {
|
| - return NULL;
|
| - }
|
| -
|
| - HttpPipelinedHostCapability capability =
|
| - http_server_properties_->GetPipelineCapability(key.origin());
|
| - if (capability == PIPELINE_INCAPABLE) {
|
| - return NULL;
|
| - }
|
| -
|
| - HttpPipelinedHost* host = factory_->CreateNewHost(
|
| - this, key, NULL, capability, force_pipelining_);
|
| - host_map_[key] = host;
|
| - return host;
|
| -}
|
| -
|
| -void HttpPipelinedHostPool::OnHostIdle(HttpPipelinedHost* host) {
|
| - const HttpPipelinedHost::Key& key = host->GetKey();
|
| - CHECK(ContainsKey(host_map_, key));
|
| - host_map_.erase(key);
|
| - delete host;
|
| -}
|
| -
|
| -void HttpPipelinedHostPool::OnHostHasAdditionalCapacity(
|
| - HttpPipelinedHost* host) {
|
| - delegate_->OnHttpPipelinedHostHasAdditionalCapacity(host);
|
| -}
|
| -
|
| -void HttpPipelinedHostPool::OnHostDeterminedCapability(
|
| - HttpPipelinedHost* host,
|
| - HttpPipelinedHostCapability capability) {
|
| - http_server_properties_->SetPipelineCapability(host->GetKey().origin(),
|
| - capability);
|
| -}
|
| -
|
| -base::Value* HttpPipelinedHostPool::PipelineInfoToValue() const {
|
| - base::ListValue* list = new base::ListValue();
|
| - for (HostMap::const_iterator it = host_map_.begin();
|
| - it != host_map_.end(); ++it) {
|
| - base::Value* value = it->second->PipelineInfoToValue();
|
| - list->Append(value);
|
| - }
|
| - return list;
|
| -}
|
| -
|
| -} // namespace net
|
|
|