mirror of
https://github.com/klzgrad/naiveproxy.git
synced 2024-12-01 01:36:09 +03:00
94 lines
3.1 KiB
C++
94 lines
3.1 KiB
C++
// 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.
|
|
|
|
#ifndef NET_TOOLS_QUIC_QUIC_SPDY_CLIENT_STREAM_H_
|
|
#define NET_TOOLS_QUIC_QUIC_SPDY_CLIENT_STREAM_H_
|
|
|
|
#include <stddef.h>
|
|
#include <sys/types.h>
|
|
#include <string>
|
|
|
|
#include "base/macros.h"
|
|
#include "net/quic/core/quic_packets.h"
|
|
#include "net/quic/core/quic_spdy_stream.h"
|
|
#include "net/quic/platform/api/quic_string_piece.h"
|
|
#include "net/spdy/core/spdy_framer.h"
|
|
|
|
namespace net {
|
|
|
|
class QuicSpdyClientSession;
|
|
|
|
// All this does right now is send an SPDY request, and aggregate the
|
|
// SPDY response.
|
|
class QuicSpdyClientStream : public QuicSpdyStream {
|
|
public:
|
|
QuicSpdyClientStream(QuicStreamId id, QuicSpdyClientSession* session);
|
|
~QuicSpdyClientStream() override;
|
|
|
|
// Override the base class to parse and store headers.
|
|
void OnInitialHeadersComplete(bool fin,
|
|
size_t frame_len,
|
|
const QuicHeaderList& header_list) override;
|
|
|
|
// Override the base class to parse and store trailers.
|
|
void OnTrailingHeadersComplete(bool fin,
|
|
size_t frame_len,
|
|
const QuicHeaderList& header_list) override;
|
|
|
|
// Override the base class to handle creation of the push stream.
|
|
void OnPromiseHeaderList(QuicStreamId promised_id,
|
|
size_t frame_len,
|
|
const QuicHeaderList& header_list) override;
|
|
|
|
// QuicStream implementation called by the session when there's data for us.
|
|
void OnDataAvailable() override;
|
|
|
|
// Serializes the headers and body, sends it to the server, and
|
|
// returns the number of bytes sent.
|
|
size_t SendRequest(SpdyHeaderBlock headers, QuicStringPiece body, bool fin);
|
|
|
|
// Returns the response data.
|
|
const std::string& data() { return data_; }
|
|
|
|
// Returns whatever headers have been received for this stream.
|
|
const SpdyHeaderBlock& response_headers() { return response_headers_; }
|
|
|
|
const SpdyHeaderBlock& preliminary_headers() { return preliminary_headers_; }
|
|
|
|
size_t header_bytes_read() const { return header_bytes_read_; }
|
|
|
|
size_t header_bytes_written() const { return header_bytes_written_; }
|
|
|
|
int response_code() const { return response_code_; }
|
|
|
|
// While the server's SetPriority shouldn't be called externally, the creator
|
|
// of client-side streams should be able to set the priority.
|
|
using QuicSpdyStream::SetPriority;
|
|
|
|
private:
|
|
// The parsed headers received from the server.
|
|
SpdyHeaderBlock response_headers_;
|
|
|
|
// The parsed content-length, or -1 if none is specified.
|
|
int64_t content_length_;
|
|
int response_code_;
|
|
std::string data_;
|
|
size_t header_bytes_read_;
|
|
size_t header_bytes_written_;
|
|
|
|
QuicSpdyClientSession* session_;
|
|
|
|
// These preliminary headers are used for the 100 Continue headers
|
|
// that may arrive before the response headers when the request has
|
|
// Expect: 100-continue.
|
|
bool has_preliminary_headers_;
|
|
SpdyHeaderBlock preliminary_headers_;
|
|
|
|
DISALLOW_COPY_AND_ASSIGN(QuicSpdyClientStream);
|
|
};
|
|
|
|
} // namespace net
|
|
|
|
#endif // NET_TOOLS_QUIC_QUIC_SPDY_CLIENT_STREAM_H_
|