| Index: net/http/http_pipelined_host_forced.cc
|
| diff --git a/net/http/http_pipelined_host_forced.cc b/net/http/http_pipelined_host_forced.cc
|
| deleted file mode 100644
|
| index 8059d848d73904bde01b0d2df4b7e1df09b8a09d..0000000000000000000000000000000000000000
|
| --- a/net/http/http_pipelined_host_forced.cc
|
| +++ /dev/null
|
| @@ -1,103 +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_forced.h"
|
| -
|
| -#include "base/values.h"
|
| -#include "net/http/http_pipelined_connection_impl.h"
|
| -#include "net/http/http_pipelined_stream.h"
|
| -#include "net/socket/buffered_write_stream_socket.h"
|
| -#include "net/socket/client_socket_handle.h"
|
| -
|
| -namespace net {
|
| -
|
| -HttpPipelinedHostForced::HttpPipelinedHostForced(
|
| - HttpPipelinedHost::Delegate* delegate,
|
| - const Key& key,
|
| - HttpPipelinedConnection::Factory* factory)
|
| - : delegate_(delegate),
|
| - key_(key),
|
| - factory_(factory) {
|
| - if (!factory) {
|
| - factory_.reset(new HttpPipelinedConnectionImpl::Factory());
|
| - }
|
| -}
|
| -
|
| -HttpPipelinedHostForced::~HttpPipelinedHostForced() {
|
| - CHECK(!pipeline_.get());
|
| -}
|
| -
|
| -HttpPipelinedStream* HttpPipelinedHostForced::CreateStreamOnNewPipeline(
|
| - ClientSocketHandle* connection,
|
| - const SSLConfig& used_ssl_config,
|
| - const ProxyInfo& used_proxy_info,
|
| - const BoundNetLog& net_log,
|
| - bool was_npn_negotiated,
|
| - NextProto protocol_negotiated) {
|
| - CHECK(!pipeline_.get());
|
| - scoped_ptr<BufferedWriteStreamSocket> buffered_socket(
|
| - new BufferedWriteStreamSocket(connection->PassSocket()));
|
| - connection->SetSocket(buffered_socket.PassAs<StreamSocket>());
|
| - pipeline_.reset(factory_->CreateNewPipeline(
|
| - connection, this, key_.origin(), used_ssl_config, used_proxy_info,
|
| - net_log, was_npn_negotiated, protocol_negotiated));
|
| - return pipeline_->CreateNewStream();
|
| -}
|
| -
|
| -HttpPipelinedStream* HttpPipelinedHostForced::CreateStreamOnExistingPipeline() {
|
| - if (!pipeline_.get()) {
|
| - return NULL;
|
| - }
|
| - return pipeline_->CreateNewStream();
|
| -}
|
| -
|
| -bool HttpPipelinedHostForced::IsExistingPipelineAvailable() const {
|
| - return pipeline_.get() != NULL;
|
| -}
|
| -
|
| -const HttpPipelinedHost::Key& HttpPipelinedHostForced::GetKey() const {
|
| - return key_;
|
| -}
|
| -
|
| -void HttpPipelinedHostForced::OnPipelineEmpty(
|
| - HttpPipelinedConnection* pipeline) {
|
| - CHECK_EQ(pipeline_.get(), pipeline);
|
| - pipeline_.reset();
|
| - delegate_->OnHostIdle(this);
|
| - // WARNING: We'll probably be deleted here.
|
| -}
|
| -
|
| -void HttpPipelinedHostForced::OnPipelineHasCapacity(
|
| - HttpPipelinedConnection* pipeline) {
|
| - CHECK_EQ(pipeline_.get(), pipeline);
|
| - delegate_->OnHostHasAdditionalCapacity(this);
|
| - if (!pipeline->depth()) {
|
| - OnPipelineEmpty(pipeline);
|
| - // WARNING: We might be deleted here.
|
| - }
|
| -}
|
| -
|
| -void HttpPipelinedHostForced::OnPipelineFeedback(
|
| - HttpPipelinedConnection* pipeline,
|
| - HttpPipelinedConnection::Feedback feedback) {
|
| - // We don't care. We always pipeline.
|
| -}
|
| -
|
| -base::Value* HttpPipelinedHostForced::PipelineInfoToValue() const {
|
| - base::ListValue* list_value = new base::ListValue();
|
| - if (pipeline_.get()) {
|
| - base::DictionaryValue* pipeline_dict = new base::DictionaryValue;
|
| - pipeline_dict->SetString("host", key_.origin().ToString());
|
| - pipeline_dict->SetBoolean("forced", true);
|
| - pipeline_dict->SetInteger("depth", pipeline_->depth());
|
| - pipeline_dict->SetInteger("capacity", 1000);
|
| - pipeline_dict->SetBoolean("usable", pipeline_->usable());
|
| - pipeline_dict->SetBoolean("active", pipeline_->active());
|
| - pipeline_dict->SetInteger("source_id", pipeline_->net_log().source().id);
|
| - list_value->Append(pipeline_dict);
|
| - }
|
| - return list_value;
|
| -}
|
| -
|
| -} // namespace net
|
|
|