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 |