blob: 431d498f042ed16d1cb3d3f53e68a9250c154a0a [file] [log] [blame]
// 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 <stddef.h>
#include <stdint.h>
#include <list>
#include <string>
#include <vector>
#include "base/macros.h"
#include "base/memory/weak_ptr.h"
#include "net/base/io_buffer.h"
#include "net/base/load_timing_info.h"
#include "net/base/net_export.h"
#include "net/http/http_response_info.h"
#include "net/http/http_stream.h"
#include "net/log/net_log_with_source.h"
#include "net/quic/chromium/quic_chromium_client_session.h"
#include "net/quic/chromium/quic_chromium_client_stream.h"
#include "net/quic/core/quic_client_push_promise_index.h"
#include "net/quic/core/quic_packets.h"
namespace net {
namespace test {
class QuicHttpStreamPeer;
} // namespace test
// The QuicHttpStream is a QUIC-specific HttpStream subclass. It holds a
// non-owning pointer to a QuicChromiumClientStream which it uses to
// send and receive data.
class NET_EXPORT_PRIVATE QuicHttpStream
: public QuicChromiumClientSession::Observer,
public QuicChromiumClientStream::Delegate,
public QuicClientPushPromiseIndex::Delegate,
public HttpStream {
explicit QuicHttpStream(
const base::WeakPtr<QuicChromiumClientSession>& session);
~QuicHttpStream() override;
// HttpStream implementation.
int InitializeStream(const HttpRequestInfo* request_info,
RequestPriority priority,
const NetLogWithSource& net_log,
const CompletionCallback& callback) override;
int SendRequest(const HttpRequestHeaders& request_headers,
HttpResponseInfo* response,
const CompletionCallback& callback) override;
int ReadResponseHeaders(const CompletionCallback& callback) override;
int ReadResponseBody(IOBuffer* buf,
int buf_len,
const CompletionCallback& callback) override;
void Close(bool not_reusable) override;
HttpStream* RenewStreamForAuth() override;
bool IsResponseBodyComplete() const override;
bool IsConnectionReused() const override;
void SetConnectionReused() override;
bool CanReuseConnection() const override;
int64_t GetTotalReceivedBytes() const override;
int64_t GetTotalSentBytes() const override;
bool GetLoadTimingInfo(LoadTimingInfo* load_timing_info) const override;
void GetSSLInfo(SSLInfo* ssl_info) override;
void GetSSLCertRequestInfo(SSLCertRequestInfo* cert_request_info) override;
bool GetRemoteEndpoint(IPEndPoint* endpoint) override;
Error GetTokenBindingSignature(crypto::ECPrivateKey* key,
TokenBindingType tb_type,
std::vector<uint8_t>* out) override;
void Drain(HttpNetworkSession* session) override;
void PopulateNetErrorDetails(NetErrorDetails* details) override;
void SetPriority(RequestPriority priority) override;
// QuicChromiumClientStream::Delegate implementation
void OnHeadersAvailable(const SpdyHeaderBlock& headers,
size_t frame_len) override;
void OnDataAvailable() override;
void OnClose() override;
void OnError(int error) override;
bool HasSendHeadersComplete() override;
// QuicChromiumClientSession::Observer implementation
void OnCryptoHandshakeConfirmed() override;
void OnSuccessfulVersionNegotiation(const QuicVersion& version) override;
void OnSessionClosed(int error, bool port_migration_detected) override;
// QuicClientPushPromiseIndex::Delegate implementation
bool CheckVary(const SpdyHeaderBlock& client_request,
const SpdyHeaderBlock& promise_request,
const SpdyHeaderBlock& promise_response) override;
void OnRendezvousResult(QuicSpdyStream* stream) override;
static HttpResponseInfo::ConnectionInfo ConnectionInfoFromQuicVersion(
QuicVersion quic_version);
friend class test::QuicHttpStreamPeer;
enum State {
void OnIOComplete(int rv);
void DoCallback(int rv);
int DoLoop(int rv);
int DoHandlePromise();
int DoHandlePromiseComplete(int rv);
int DoRequestStream();
int DoRequestStreamComplete(int rv);
int DoSetRequestPriority();
int DoWaitForConfirmation();
int DoWaitForConfirmationComplete(int rv);
int DoSendHeaders();
int DoSendHeadersComplete(int rv);
int DoReadRequestBody();
int DoReadRequestBodyComplete(int rv);
int DoSendBody();
int DoSendBodyComplete(int rv);
int ProcessResponseHeaders(const SpdyHeaderBlock& headers);
int ReadAvailableData(IOBuffer* buf, int buf_len);
void EnterStateSendHeaders();
void ResetStream();
State next_state_;
base::WeakPtr<QuicChromiumClientSession> session_;
QuicVersion quic_version_;
int session_error_; // Error code from the connection shutdown.
bool was_handshake_confirmed_; // True if the crypto handshake succeeded.
QuicChromiumClientSession::StreamRequest stream_request_;
QuicChromiumClientStream* stream_; // Non-owning.
// The following three fields are all owned by the caller and must
// outlive this object, according to the HttpStream contract.
// The request to send.
// Only valid before the response body is read.
const HttpRequestInfo* request_info_;
// The request body to send, if any, owned by the caller.
UploadDataStream* request_body_stream_;
// Time the request was issued.
base::Time request_time_;
// The priority of the request.
RequestPriority priority_;
// |response_info_| is the HTTP response data object which is filled in
// when a the response headers are read. It is not owned by this stream.
HttpResponseInfo* response_info_;
// Because response data is buffered, also buffer the response status if the
// stream is explicitly closed via OnError or OnClose with an error.
// Once all buffered data has been returned, this will be used as the final
// response.
int response_status_;
// Serialized request headers.
SpdyHeaderBlock request_headers_;
bool response_headers_received_;
// Serialized HTTP request.
std::string request_;
// Number of bytes received by the headers stream on behalf of this stream.
int64_t headers_bytes_received_;
// Number of bytes sent by the headers stream on behalf of this stream.
int64_t headers_bytes_sent_;
// Number of bytes received when the stream was closed.
int64_t closed_stream_received_bytes_;
// Number of bytes sent when the stream was closed.
int64_t closed_stream_sent_bytes_;
// True if the stream is the first stream negotiated on the session. Set when
// the stream was closed. If |stream_| is failed to be created, this takes on
// the default value of false.
bool closed_is_first_stream_;
// The caller's callback to be used for asynchronous operations.
CompletionCallback callback_;
// Caller provided buffer for the ReadResponseBody() response.
scoped_refptr<IOBuffer> user_buffer_;
int user_buffer_len_;
// Temporary buffer used to read the request body from UploadDataStream.
scoped_refptr<IOBufferWithSize> raw_request_body_buf_;
// Wraps raw_request_body_buf_ to read the remaining data progressively.
scoped_refptr<DrainableIOBuffer> request_body_buf_;
NetLogWithSource stream_net_log_;
QuicErrorCode quic_connection_error_;
// SSLInfo from the underlying QuicSession.
SSLInfo ssl_info_;
// True when this stream receives a go away from server due to port migration.
bool port_migration_detected_;
bool found_promise_;
// |QuicClientPromisedInfo| owns this. It will be set when |Try()|
// is asynchronous, i.e. it returned QUIC_PENDING, and remains valid
// until |OnRendezvouResult()| fires or |push_handle_->Cancel()| is
// invoked.
QuicClientPushPromiseIndex::TryHandle* push_handle_;
// Set to true when DoLoop() is being executed, false otherwise.
bool in_loop_;
// Session connect timing info.
LoadTimingInfo::ConnectTiming connect_timing_;
base::WeakPtrFactory<QuicHttpStream> weak_factory_;
} // namespace net