Index: net/http/http_pipelined_stream.cc |
diff --git a/net/http/http_pipelined_stream.cc b/net/http/http_pipelined_stream.cc |
deleted file mode 100644 |
index cc267e2510ec78b07e10764ff4e616c649a9d67f..0000000000000000000000000000000000000000 |
--- a/net/http/http_pipelined_stream.cc |
+++ /dev/null |
@@ -1,153 +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_stream.h" |
- |
-#include "base/logging.h" |
-#include "base/strings/stringprintf.h" |
-#include "net/base/net_errors.h" |
-#include "net/http/http_pipelined_connection_impl.h" |
-#include "net/http/http_request_headers.h" |
-#include "net/http/http_request_info.h" |
-#include "net/http/http_util.h" |
- |
-namespace net { |
- |
-HttpPipelinedStream::HttpPipelinedStream(HttpPipelinedConnectionImpl* pipeline, |
- int pipeline_id) |
- : pipeline_(pipeline), |
- pipeline_id_(pipeline_id), |
- request_info_(NULL) { |
-} |
- |
-HttpPipelinedStream::~HttpPipelinedStream() { |
- pipeline_->OnStreamDeleted(pipeline_id_); |
-} |
- |
-int HttpPipelinedStream::InitializeStream( |
- const HttpRequestInfo* request_info, |
- RequestPriority priority, |
- const BoundNetLog& net_log, |
- const CompletionCallback& callback) { |
- request_info_ = request_info; |
- pipeline_->InitializeParser(pipeline_id_, request_info, net_log); |
- return OK; |
-} |
- |
- |
-int HttpPipelinedStream::SendRequest(const HttpRequestHeaders& headers, |
- HttpResponseInfo* response, |
- const CompletionCallback& callback) { |
- CHECK(pipeline_id_); |
- CHECK(request_info_); |
- // TODO(simonjam): Proxy support will be needed here. |
- const std::string path = HttpUtil::PathForRequest(request_info_->url); |
- std::string request_line_ = base::StringPrintf("%s %s HTTP/1.1\r\n", |
- request_info_->method.c_str(), |
- path.c_str()); |
- return pipeline_->SendRequest(pipeline_id_, request_line_, headers, response, |
- callback); |
-} |
- |
-UploadProgress HttpPipelinedStream::GetUploadProgress() const { |
- return pipeline_->GetUploadProgress(pipeline_id_); |
-} |
- |
-int HttpPipelinedStream::ReadResponseHeaders( |
- const CompletionCallback& callback) { |
- return pipeline_->ReadResponseHeaders(pipeline_id_, callback); |
-} |
- |
-const HttpResponseInfo* HttpPipelinedStream::GetResponseInfo() const { |
- return pipeline_->GetResponseInfo(pipeline_id_); |
-} |
- |
-int HttpPipelinedStream::ReadResponseBody(IOBuffer* buf, int buf_len, |
- const CompletionCallback& callback) { |
- return pipeline_->ReadResponseBody(pipeline_id_, buf, buf_len, callback); |
-} |
- |
-void HttpPipelinedStream::Close(bool not_reusable) { |
- pipeline_->Close(pipeline_id_, not_reusable); |
-} |
- |
-HttpStream* HttpPipelinedStream::RenewStreamForAuth() { |
- if (pipeline_->usable()) { |
- return pipeline_->CreateNewStream(); |
- } |
- return NULL; |
-} |
- |
-bool HttpPipelinedStream::IsResponseBodyComplete() const { |
- return pipeline_->IsResponseBodyComplete(pipeline_id_); |
-} |
- |
-bool HttpPipelinedStream::CanFindEndOfResponse() const { |
- return pipeline_->CanFindEndOfResponse(pipeline_id_); |
-} |
- |
-bool HttpPipelinedStream::IsConnectionReused() const { |
- return pipeline_->IsConnectionReused(pipeline_id_); |
-} |
- |
-void HttpPipelinedStream::SetConnectionReused() { |
- pipeline_->SetConnectionReused(pipeline_id_); |
-} |
- |
-bool HttpPipelinedStream::IsConnectionReusable() const { |
- return pipeline_->usable(); |
-} |
- |
-int64 HttpPipelinedStream::GetTotalReceivedBytes() const { |
- return pipeline_->GetTotalReceivedBytes(pipeline_id_); |
-} |
- |
-bool HttpPipelinedStream::GetLoadTimingInfo( |
- LoadTimingInfo* load_timing_info) const { |
- return pipeline_->GetLoadTimingInfo(pipeline_id_, load_timing_info); |
-} |
- |
-void HttpPipelinedStream::GetSSLInfo(SSLInfo* ssl_info) { |
- pipeline_->GetSSLInfo(pipeline_id_, ssl_info); |
-} |
- |
-void HttpPipelinedStream::GetSSLCertRequestInfo( |
- SSLCertRequestInfo* cert_request_info) { |
- pipeline_->GetSSLCertRequestInfo(pipeline_id_, cert_request_info); |
-} |
- |
-bool HttpPipelinedStream::IsSpdyHttpStream() const { |
- return false; |
-} |
- |
-void HttpPipelinedStream::Drain(HttpNetworkSession* session) { |
- pipeline_->Drain(this, session); |
-} |
- |
-void HttpPipelinedStream::SetPriority(RequestPriority priority) { |
- // TODO(akalin): Plumb this through to |pipeline_| and its |
- // underlying ClientSocketHandle. |
-} |
- |
-const SSLConfig& HttpPipelinedStream::used_ssl_config() const { |
- return pipeline_->used_ssl_config(); |
-} |
- |
-const ProxyInfo& HttpPipelinedStream::used_proxy_info() const { |
- return pipeline_->used_proxy_info(); |
-} |
- |
-const BoundNetLog& HttpPipelinedStream::net_log() const { |
- return pipeline_->net_log(); |
-} |
- |
-bool HttpPipelinedStream::was_npn_negotiated() const { |
- return pipeline_->was_npn_negotiated(); |
-} |
- |
-NextProto HttpPipelinedStream::protocol_negotiated() const { |
- return pipeline_->protocol_negotiated(); |
-} |
- |
-} // namespace net |