summaryrefslogtreecommitdiffstats
path: root/chromium/net/http/http_pipelined_host_forced.cc
diff options
context:
space:
mode:
Diffstat (limited to 'chromium/net/http/http_pipelined_host_forced.cc')
-rw-r--r--chromium/net/http/http_pipelined_host_forced.cc103
1 files changed, 0 insertions, 103 deletions
diff --git a/chromium/net/http/http_pipelined_host_forced.cc b/chromium/net/http/http_pipelined_host_forced.cc
deleted file mode 100644
index 8059d848d73..00000000000
--- a/chromium/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