| Index: net/quic/core/quic_protocol.h
|
| diff --git a/net/quic/core/quic_protocol.h b/net/quic/core/quic_protocol.h
|
| deleted file mode 100644
|
| index adb9d8f840b1d4e3b8b3cc1b30daf4f032eb523c..0000000000000000000000000000000000000000
|
| --- a/net/quic/core/quic_protocol.h
|
| +++ /dev/null
|
| @@ -1,766 +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.
|
| -
|
| -#ifndef NET_QUIC_QUIC_PROTOCOL_H_
|
| -#define NET_QUIC_QUIC_PROTOCOL_H_
|
| -
|
| -#include <stddef.h>
|
| -#include <stdint.h>
|
| -
|
| -#include <array>
|
| -#include <limits>
|
| -#include <list>
|
| -#include <map>
|
| -#include <memory>
|
| -#include <ostream>
|
| -#include <set>
|
| -#include <string>
|
| -#include <utility>
|
| -#include <vector>
|
| -
|
| -#include "base/logging.h"
|
| -#include "base/macros.h"
|
| -#include "base/memory/ref_counted.h"
|
| -#include "base/strings/string_piece.h"
|
| -#include "net/base/int128.h"
|
| -#include "net/base/iovec.h"
|
| -#include "net/base/net_export.h"
|
| -#include "net/quic/core/interval_set.h"
|
| -#include "net/quic/core/quic_bandwidth.h"
|
| -#include "net/quic/core/quic_buffer_allocator.h"
|
| -#include "net/quic/core/quic_constants.h"
|
| -#include "net/quic/core/quic_error_codes.h"
|
| -#include "net/quic/core/quic_time.h"
|
| -#include "net/quic/core/quic_types.h"
|
| -#include "net/quic/core/quic_versions.h"
|
| -#include "net/quic/platform/api/quic_socket_address.h"
|
| -
|
| -namespace net {
|
| -
|
| -class QuicPacket;
|
| -struct QuicPacketHeader;
|
| -
|
| -// Size in bytes of the data packet header.
|
| -NET_EXPORT_PRIVATE size_t GetPacketHeaderSize(QuicVersion version,
|
| - const QuicPacketHeader& header);
|
| -
|
| -NET_EXPORT_PRIVATE size_t
|
| -GetPacketHeaderSize(QuicVersion version,
|
| - QuicConnectionIdLength connection_id_length,
|
| - bool include_version,
|
| - bool include_path_id,
|
| - bool include_diversification_nonce,
|
| - QuicPacketNumberLength packet_number_length);
|
| -
|
| -// Index of the first byte in a QUIC packet of encrypted data.
|
| -NET_EXPORT_PRIVATE size_t
|
| -GetStartOfEncryptedData(QuicVersion version, const QuicPacketHeader& header);
|
| -
|
| -NET_EXPORT_PRIVATE size_t
|
| -GetStartOfEncryptedData(QuicVersion version,
|
| - QuicConnectionIdLength connection_id_length,
|
| - bool include_version,
|
| - bool include_path_id,
|
| - bool include_diversification_nonce,
|
| - QuicPacketNumberLength packet_number_length);
|
| -
|
| -struct NET_EXPORT_PRIVATE QuicPacketPublicHeader {
|
| - QuicPacketPublicHeader();
|
| - explicit QuicPacketPublicHeader(const QuicPacketPublicHeader& other);
|
| - ~QuicPacketPublicHeader();
|
| -
|
| - // Universal header. All QuicPacket headers will have a connection_id and
|
| - // public flags.
|
| - QuicConnectionId connection_id;
|
| - QuicConnectionIdLength connection_id_length;
|
| - bool multipath_flag;
|
| - bool reset_flag;
|
| - bool version_flag;
|
| - QuicPacketNumberLength packet_number_length;
|
| - QuicVersionVector versions;
|
| - // nonce contains an optional, 32-byte nonce value. If not included in the
|
| - // packet, |nonce| will be empty.
|
| - DiversificationNonce* nonce;
|
| -};
|
| -
|
| -// Header for Data packets.
|
| -struct NET_EXPORT_PRIVATE QuicPacketHeader {
|
| - QuicPacketHeader();
|
| - explicit QuicPacketHeader(const QuicPacketPublicHeader& header);
|
| - QuicPacketHeader(const QuicPacketHeader& other);
|
| -
|
| - NET_EXPORT_PRIVATE friend std::ostream& operator<<(std::ostream& os,
|
| - const QuicPacketHeader& s);
|
| -
|
| - QuicPacketPublicHeader public_header;
|
| - QuicPacketNumber packet_number;
|
| - QuicPathId path_id;
|
| -};
|
| -
|
| -struct NET_EXPORT_PRIVATE QuicPublicResetPacket {
|
| - QuicPublicResetPacket();
|
| - explicit QuicPublicResetPacket(const QuicPacketPublicHeader& header);
|
| -
|
| - QuicPacketPublicHeader public_header;
|
| - QuicPublicResetNonceProof nonce_proof;
|
| - // TODO(fayang): remove rejected_packet_number when deprecating
|
| - // FLAGS_quic_remove_packet_number_from_public_reset.
|
| - QuicPacketNumber rejected_packet_number;
|
| - QuicSocketAddress client_address;
|
| -};
|
| -
|
| -typedef QuicPacketPublicHeader QuicVersionNegotiationPacket;
|
| -
|
| -// A padding frame contains no payload.
|
| -struct NET_EXPORT_PRIVATE QuicPaddingFrame {
|
| - QuicPaddingFrame() : num_padding_bytes(-1) {}
|
| - explicit QuicPaddingFrame(int num_padding_bytes)
|
| - : num_padding_bytes(num_padding_bytes) {}
|
| -
|
| - NET_EXPORT_PRIVATE friend std::ostream& operator<<(std::ostream& os,
|
| - const QuicPaddingFrame& s);
|
| -
|
| - // -1: full padding to the end of a max-sized packet
|
| - // otherwise: only pad up to num_padding_bytes bytes
|
| - int num_padding_bytes;
|
| -};
|
| -
|
| -// A ping frame contains no payload, though it is retransmittable,
|
| -// and ACK'd just like other normal frames.
|
| -struct NET_EXPORT_PRIVATE QuicPingFrame {};
|
| -
|
| -// A path MTU discovery frame contains no payload and is serialized as a ping
|
| -// frame.
|
| -struct NET_EXPORT_PRIVATE QuicMtuDiscoveryFrame {};
|
| -
|
| -// Deleter for stream buffers. Copyable to support platforms where the deleter
|
| -// of a unique_ptr must be copyable. Otherwise it would be nice for this to be
|
| -// move-only.
|
| -class NET_EXPORT_PRIVATE StreamBufferDeleter {
|
| - public:
|
| - StreamBufferDeleter() : allocator_(nullptr) {}
|
| - explicit StreamBufferDeleter(QuicBufferAllocator* allocator)
|
| - : allocator_(allocator) {}
|
| -
|
| - // Deletes |buffer| using |allocator_|.
|
| - void operator()(char* buffer) const;
|
| -
|
| - private:
|
| - // Not owned; must be valid so long as the buffer stored in the unique_ptr
|
| - // that owns |this| is valid.
|
| - QuicBufferAllocator* allocator_;
|
| -};
|
| -
|
| -using UniqueStreamBuffer = std::unique_ptr<char[], StreamBufferDeleter>;
|
| -
|
| -// Allocates memory of size |size| using |allocator| for a QUIC stream buffer.
|
| -NET_EXPORT_PRIVATE UniqueStreamBuffer
|
| -NewStreamBuffer(QuicBufferAllocator* allocator, size_t size);
|
| -
|
| -struct NET_EXPORT_PRIVATE QuicStreamFrame {
|
| - QuicStreamFrame();
|
| - QuicStreamFrame(QuicStreamId stream_id,
|
| - bool fin,
|
| - QuicStreamOffset offset,
|
| - base::StringPiece data);
|
| - QuicStreamFrame(QuicStreamId stream_id,
|
| - bool fin,
|
| - QuicStreamOffset offset,
|
| - QuicPacketLength data_length,
|
| - UniqueStreamBuffer buffer);
|
| - ~QuicStreamFrame();
|
| -
|
| - NET_EXPORT_PRIVATE friend std::ostream& operator<<(std::ostream& os,
|
| - const QuicStreamFrame& s);
|
| -
|
| - QuicStreamId stream_id;
|
| - bool fin;
|
| - QuicPacketLength data_length;
|
| - const char* data_buffer;
|
| - QuicStreamOffset offset; // Location of this data in the stream.
|
| - // nullptr when the QuicStreamFrame is received, and non-null when sent.
|
| - UniqueStreamBuffer buffer;
|
| -
|
| - private:
|
| - QuicStreamFrame(QuicStreamId stream_id,
|
| - bool fin,
|
| - QuicStreamOffset offset,
|
| - const char* data_buffer,
|
| - QuicPacketLength data_length,
|
| - UniqueStreamBuffer buffer);
|
| -
|
| - DISALLOW_COPY_AND_ASSIGN(QuicStreamFrame);
|
| -};
|
| -static_assert(sizeof(QuicStreamFrame) <= 64,
|
| - "Keep the QuicStreamFrame size to a cacheline.");
|
| -
|
| -typedef std::vector<std::pair<QuicPacketNumber, QuicTime>> PacketTimeVector;
|
| -
|
| -struct NET_EXPORT_PRIVATE QuicStopWaitingFrame {
|
| - QuicStopWaitingFrame();
|
| - ~QuicStopWaitingFrame();
|
| -
|
| - NET_EXPORT_PRIVATE friend std::ostream& operator<<(
|
| - std::ostream& os,
|
| - const QuicStopWaitingFrame& s);
|
| - // Path which this stop waiting frame belongs to.
|
| - QuicPathId path_id;
|
| - // The lowest packet we've sent which is unacked, and we expect an ack for.
|
| - QuicPacketNumber least_unacked;
|
| -};
|
| -
|
| -// A sequence of packet numbers where each number is unique. Intended to be used
|
| -// in a sliding window fashion, where smaller old packet numbers are removed and
|
| -// larger new packet numbers are added, with the occasional random access.
|
| -class NET_EXPORT_PRIVATE PacketNumberQueue {
|
| - public:
|
| - using const_iterator = IntervalSet<QuicPacketNumber>::const_iterator;
|
| - using const_reverse_iterator =
|
| - IntervalSet<QuicPacketNumber>::const_reverse_iterator;
|
| -
|
| - PacketNumberQueue();
|
| - PacketNumberQueue(const PacketNumberQueue& other);
|
| - // TODO(rtenneti): on windows RValue reference gives errors.
|
| - // PacketNumberQueue(PacketNumberQueue&& other);
|
| - ~PacketNumberQueue();
|
| -
|
| - PacketNumberQueue& operator=(const PacketNumberQueue& other);
|
| - // PacketNumberQueue& operator=(PacketNumberQueue&& other);
|
| -
|
| - // Adds |packet_number| to the set of packets in the queue.
|
| - void Add(QuicPacketNumber packet_number);
|
| -
|
| - // Adds packets between [lower, higher) to the set of packets in the queue. It
|
| - // is undefined behavior to call this with |higher| < |lower|.
|
| - void Add(QuicPacketNumber lower, QuicPacketNumber higher);
|
| -
|
| - // Removes |packet_number| from the set of packets in the queue.
|
| - void Remove(QuicPacketNumber packet_number);
|
| -
|
| - // Removes packets numbers between [lower, higher) to the set of packets in
|
| - // the queue. It is undefined behavior to call this with |higher| < |lower|.
|
| - void Remove(QuicPacketNumber lower, QuicPacketNumber higher);
|
| -
|
| - // Removes packets with values less than |higher| from the set of packets in
|
| - // the queue. Returns true if packets were removed.
|
| - bool RemoveUpTo(QuicPacketNumber higher);
|
| -
|
| - // Mutates packet number set so that it contains only those packet numbers
|
| - // from minimum to maximum packet number not currently in the set. Do nothing
|
| - // if packet number set is empty.
|
| - void Complement();
|
| -
|
| - // Returns true if the queue contains |packet_number|.
|
| - bool Contains(QuicPacketNumber packet_number) const;
|
| -
|
| - // Returns true if the queue is empty.
|
| - bool Empty() const;
|
| -
|
| - // Returns the minimum packet number stored in the queue. It is undefined
|
| - // behavior to call this if the queue is empty.
|
| - QuicPacketNumber Min() const;
|
| -
|
| - // Returns the maximum packet number stored in the queue. It is undefined
|
| - // behavior to call this if the queue is empty.
|
| - QuicPacketNumber Max() const;
|
| -
|
| - // Returns the number of unique packets stored in the queue. Inefficient; only
|
| - // exposed for testing.
|
| - size_t NumPacketsSlow() const;
|
| -
|
| - // Returns the number of disjoint packet number intervals contained in the
|
| - // queue.
|
| - size_t NumIntervals() const;
|
| -
|
| - // Returns the length of last interval.
|
| - QuicPacketNumber LastIntervalLength() const;
|
| -
|
| - // Returns iterators over the packet number intervals.
|
| - const_iterator begin() const;
|
| - const_iterator end() const;
|
| - const_reverse_iterator rbegin() const;
|
| - const_reverse_iterator rend() const;
|
| - const_iterator lower_bound(QuicPacketNumber packet_number) const;
|
| -
|
| - NET_EXPORT_PRIVATE friend std::ostream& operator<<(
|
| - std::ostream& os,
|
| - const PacketNumberQueue& q);
|
| -
|
| - private:
|
| - IntervalSet<QuicPacketNumber> packet_number_intervals_;
|
| -};
|
| -
|
| -struct NET_EXPORT_PRIVATE QuicAckFrame {
|
| - QuicAckFrame();
|
| - QuicAckFrame(const QuicAckFrame& other);
|
| - ~QuicAckFrame();
|
| -
|
| - NET_EXPORT_PRIVATE friend std::ostream& operator<<(std::ostream& os,
|
| - const QuicAckFrame& s);
|
| -
|
| - // The highest packet number we've observed from the peer.
|
| - QuicPacketNumber largest_observed;
|
| -
|
| - // Time elapsed since largest_observed was received until this Ack frame was
|
| - // sent.
|
| - QuicTime::Delta ack_delay_time;
|
| -
|
| - // Vector of <packet_number, time> for when packets arrived.
|
| - PacketTimeVector received_packet_times;
|
| -
|
| - // Set of packets.
|
| - PacketNumberQueue packets;
|
| -
|
| - // Path which this ack belongs to.
|
| - QuicPathId path_id;
|
| -};
|
| -
|
| -// True if the packet number is greater than largest_observed or is listed
|
| -// as missing.
|
| -// Always returns false for packet numbers less than least_unacked.
|
| -bool NET_EXPORT_PRIVATE
|
| -IsAwaitingPacket(const QuicAckFrame& ack_frame,
|
| - QuicPacketNumber packet_number,
|
| - QuicPacketNumber peer_least_packet_awaiting_ack);
|
| -
|
| -struct NET_EXPORT_PRIVATE QuicRstStreamFrame {
|
| - QuicRstStreamFrame();
|
| - QuicRstStreamFrame(QuicStreamId stream_id,
|
| - QuicRstStreamErrorCode error_code,
|
| - QuicStreamOffset bytes_written);
|
| -
|
| - NET_EXPORT_PRIVATE friend std::ostream& operator<<(
|
| - std::ostream& os,
|
| - const QuicRstStreamFrame& r);
|
| -
|
| - QuicStreamId stream_id;
|
| - QuicRstStreamErrorCode error_code;
|
| -
|
| - // Used to update flow control windows. On termination of a stream, both
|
| - // endpoints must inform the peer of the number of bytes they have sent on
|
| - // that stream. This can be done through normal termination (data packet with
|
| - // FIN) or through a RST.
|
| - QuicStreamOffset byte_offset;
|
| -};
|
| -
|
| -struct NET_EXPORT_PRIVATE QuicConnectionCloseFrame {
|
| - QuicConnectionCloseFrame();
|
| -
|
| - NET_EXPORT_PRIVATE friend std::ostream& operator<<(
|
| - std::ostream& os,
|
| - const QuicConnectionCloseFrame& c);
|
| -
|
| - QuicErrorCode error_code;
|
| - std::string error_details;
|
| -};
|
| -
|
| -struct NET_EXPORT_PRIVATE QuicGoAwayFrame {
|
| - QuicGoAwayFrame();
|
| - QuicGoAwayFrame(QuicErrorCode error_code,
|
| - QuicStreamId last_good_stream_id,
|
| - const std::string& reason);
|
| -
|
| - NET_EXPORT_PRIVATE friend std::ostream& operator<<(std::ostream& os,
|
| - const QuicGoAwayFrame& g);
|
| -
|
| - QuicErrorCode error_code;
|
| - QuicStreamId last_good_stream_id;
|
| - std::string reason_phrase;
|
| -};
|
| -
|
| -// Flow control updates per-stream and at the connection levoel.
|
| -// Based on SPDY's WINDOW_UPDATE frame, but uses an absolute byte offset rather
|
| -// than a window delta.
|
| -// TODO(rjshade): A possible future optimization is to make stream_id and
|
| -// byte_offset variable length, similar to stream frames.
|
| -struct NET_EXPORT_PRIVATE QuicWindowUpdateFrame {
|
| - QuicWindowUpdateFrame() {}
|
| - QuicWindowUpdateFrame(QuicStreamId stream_id, QuicStreamOffset byte_offset);
|
| -
|
| - NET_EXPORT_PRIVATE friend std::ostream& operator<<(
|
| - std::ostream& os,
|
| - const QuicWindowUpdateFrame& w);
|
| -
|
| - // The stream this frame applies to. 0 is a special case meaning the overall
|
| - // connection rather than a specific stream.
|
| - QuicStreamId stream_id;
|
| -
|
| - // Byte offset in the stream or connection. The receiver of this frame must
|
| - // not send data which would result in this offset being exceeded.
|
| - QuicStreamOffset byte_offset;
|
| -};
|
| -
|
| -// The BLOCKED frame is used to indicate to the remote endpoint that this
|
| -// endpoint believes itself to be flow-control blocked but otherwise ready to
|
| -// send data. The BLOCKED frame is purely advisory and optional.
|
| -// Based on SPDY's BLOCKED frame (undocumented as of 2014-01-28).
|
| -struct NET_EXPORT_PRIVATE QuicBlockedFrame {
|
| - QuicBlockedFrame() {}
|
| - explicit QuicBlockedFrame(QuicStreamId stream_id);
|
| -
|
| - NET_EXPORT_PRIVATE friend std::ostream& operator<<(std::ostream& os,
|
| - const QuicBlockedFrame& b);
|
| -
|
| - // The stream this frame applies to. 0 is a special case meaning the overall
|
| - // connection rather than a specific stream.
|
| - QuicStreamId stream_id;
|
| -};
|
| -
|
| -// The PATH_CLOSE frame is used to explicitly close a path. Both endpoints can
|
| -// send a PATH_CLOSE frame to initiate a path termination. A path is considered
|
| -// to be closed either a PATH_CLOSE frame is sent or received. An endpoint drops
|
| -// receive side of a closed path, and packets with retransmittable frames on a
|
| -// closed path are marked as retransmissions which will be transmitted on other
|
| -// paths.
|
| -struct NET_EXPORT_PRIVATE QuicPathCloseFrame {
|
| - QuicPathCloseFrame() {}
|
| - explicit QuicPathCloseFrame(QuicPathId path_id);
|
| -
|
| - NET_EXPORT_PRIVATE friend std::ostream& operator<<(
|
| - std::ostream& os,
|
| - const QuicPathCloseFrame& p);
|
| -
|
| - QuicPathId path_id;
|
| -};
|
| -
|
| -struct NET_EXPORT_PRIVATE QuicFrame {
|
| - QuicFrame();
|
| - explicit QuicFrame(QuicPaddingFrame padding_frame);
|
| - explicit QuicFrame(QuicMtuDiscoveryFrame frame);
|
| - explicit QuicFrame(QuicPingFrame frame);
|
| -
|
| - explicit QuicFrame(QuicStreamFrame* stream_frame);
|
| - explicit QuicFrame(QuicAckFrame* frame);
|
| - explicit QuicFrame(QuicRstStreamFrame* frame);
|
| - explicit QuicFrame(QuicConnectionCloseFrame* frame);
|
| - explicit QuicFrame(QuicStopWaitingFrame* frame);
|
| - explicit QuicFrame(QuicGoAwayFrame* frame);
|
| - explicit QuicFrame(QuicWindowUpdateFrame* frame);
|
| - explicit QuicFrame(QuicBlockedFrame* frame);
|
| - explicit QuicFrame(QuicPathCloseFrame* frame);
|
| -
|
| - NET_EXPORT_PRIVATE friend std::ostream& operator<<(std::ostream& os,
|
| - const QuicFrame& frame);
|
| -
|
| - QuicFrameType type;
|
| - union {
|
| - // Frames smaller than a pointer are inline.
|
| - QuicPaddingFrame padding_frame;
|
| - QuicMtuDiscoveryFrame mtu_discovery_frame;
|
| - QuicPingFrame ping_frame;
|
| -
|
| - // Frames larger than a pointer.
|
| - QuicStreamFrame* stream_frame;
|
| - QuicAckFrame* ack_frame;
|
| - QuicStopWaitingFrame* stop_waiting_frame;
|
| - QuicRstStreamFrame* rst_stream_frame;
|
| - QuicConnectionCloseFrame* connection_close_frame;
|
| - QuicGoAwayFrame* goaway_frame;
|
| - QuicWindowUpdateFrame* window_update_frame;
|
| - QuicBlockedFrame* blocked_frame;
|
| - QuicPathCloseFrame* path_close_frame;
|
| - };
|
| -};
|
| -// QuicFrameType consumes 8 bytes with padding.
|
| -static_assert(sizeof(QuicFrame) <= 16,
|
| - "Frames larger than 8 bytes should be referenced by pointer.");
|
| -
|
| -typedef std::vector<QuicFrame> QuicFrames;
|
| -
|
| -// Deletes all the sub-frames contained in |frames|.
|
| -NET_EXPORT_PRIVATE void DeleteFrames(QuicFrames* frames);
|
| -
|
| -// Deletes all the QuicStreamFrames for the specified |stream_id|.
|
| -NET_EXPORT_PRIVATE void RemoveFramesForStream(QuicFrames* frames,
|
| - QuicStreamId stream_id);
|
| -
|
| -class NET_EXPORT_PRIVATE QuicData {
|
| - public:
|
| - QuicData(const char* buffer, size_t length);
|
| - QuicData(const char* buffer, size_t length, bool owns_buffer);
|
| - virtual ~QuicData();
|
| -
|
| - base::StringPiece AsStringPiece() const {
|
| - return base::StringPiece(data(), length());
|
| - }
|
| -
|
| - const char* data() const { return buffer_; }
|
| - size_t length() const { return length_; }
|
| - bool owns_buffer() const { return owns_buffer_; }
|
| -
|
| - private:
|
| - const char* buffer_;
|
| - size_t length_;
|
| - bool owns_buffer_;
|
| -
|
| - DISALLOW_COPY_AND_ASSIGN(QuicData);
|
| -};
|
| -
|
| -class NET_EXPORT_PRIVATE QuicPacket : public QuicData {
|
| - public:
|
| - // TODO(fayang): 4 fields from public header are passed in as arguments.
|
| - // Consider to add a convenience method which directly accepts the entire
|
| - // public header.
|
| - QuicPacket(char* buffer,
|
| - size_t length,
|
| - bool owns_buffer,
|
| - QuicConnectionIdLength connection_id_length,
|
| - bool includes_version,
|
| - bool includes_path_id,
|
| - bool includes_diversification_nonce,
|
| - QuicPacketNumberLength packet_number_length);
|
| -
|
| - base::StringPiece AssociatedData(QuicVersion version) const;
|
| - base::StringPiece Plaintext(QuicVersion version) const;
|
| -
|
| - char* mutable_data() { return buffer_; }
|
| -
|
| - private:
|
| - char* buffer_;
|
| - const QuicConnectionIdLength connection_id_length_;
|
| - const bool includes_version_;
|
| - const bool includes_path_id_;
|
| - const bool includes_diversification_nonce_;
|
| - const QuicPacketNumberLength packet_number_length_;
|
| -
|
| - DISALLOW_COPY_AND_ASSIGN(QuicPacket);
|
| -};
|
| -
|
| -class NET_EXPORT_PRIVATE QuicEncryptedPacket : public QuicData {
|
| - public:
|
| - QuicEncryptedPacket(const char* buffer, size_t length);
|
| - QuicEncryptedPacket(const char* buffer, size_t length, bool owns_buffer);
|
| -
|
| - // Clones the packet into a new packet which owns the buffer.
|
| - std::unique_ptr<QuicEncryptedPacket> Clone() const;
|
| -
|
| - // By default, gtest prints the raw bytes of an object. The bool data
|
| - // member (in the base class QuicData) causes this object to have padding
|
| - // bytes, which causes the default gtest object printer to read
|
| - // uninitialize memory. So we need to teach gtest how to print this object.
|
| - NET_EXPORT_PRIVATE friend std::ostream& operator<<(
|
| - std::ostream& os,
|
| - const QuicEncryptedPacket& s);
|
| -
|
| - private:
|
| - DISALLOW_COPY_AND_ASSIGN(QuicEncryptedPacket);
|
| -};
|
| -
|
| -// A received encrypted QUIC packet, with a recorded time of receipt.
|
| -class NET_EXPORT_PRIVATE QuicReceivedPacket : public QuicEncryptedPacket {
|
| - public:
|
| - QuicReceivedPacket(const char* buffer, size_t length, QuicTime receipt_time);
|
| - QuicReceivedPacket(const char* buffer,
|
| - size_t length,
|
| - QuicTime receipt_time,
|
| - bool owns_buffer);
|
| - QuicReceivedPacket(const char* buffer,
|
| - size_t length,
|
| - QuicTime receipt_time,
|
| - bool owns_buffer,
|
| - int ttl,
|
| - bool ttl_valid);
|
| -
|
| - // Clones the packet into a new packet which owns the buffer.
|
| - std::unique_ptr<QuicReceivedPacket> Clone() const;
|
| -
|
| - // Returns the time at which the packet was received.
|
| - QuicTime receipt_time() const { return receipt_time_; }
|
| -
|
| - // This is the TTL of the packet, assuming ttl_vaild_ is true.
|
| - int ttl() const { return ttl_; }
|
| -
|
| - // By default, gtest prints the raw bytes of an object. The bool data
|
| - // member (in the base class QuicData) causes this object to have padding
|
| - // bytes, which causes the default gtest object printer to read
|
| - // uninitialize memory. So we need to teach gtest how to print this object.
|
| - NET_EXPORT_PRIVATE friend std::ostream& operator<<(
|
| - std::ostream& os,
|
| - const QuicReceivedPacket& s);
|
| -
|
| - private:
|
| - const QuicTime receipt_time_;
|
| - int ttl_;
|
| -
|
| - DISALLOW_COPY_AND_ASSIGN(QuicReceivedPacket);
|
| -};
|
| -
|
| -// Pure virtual class to listen for packet acknowledgements.
|
| -class NET_EXPORT_PRIVATE QuicAckListenerInterface
|
| - : public base::RefCounted<QuicAckListenerInterface> {
|
| - public:
|
| - QuicAckListenerInterface() {}
|
| -
|
| - // Called when a packet is acked. Called once per packet.
|
| - // |acked_bytes| is the number of data bytes acked.
|
| - virtual void OnPacketAcked(int acked_bytes,
|
| - QuicTime::Delta ack_delay_time) = 0;
|
| -
|
| - // Called when a packet is retransmitted. Called once per packet.
|
| - // |retransmitted_bytes| is the number of data bytes retransmitted.
|
| - virtual void OnPacketRetransmitted(int retransmitted_bytes) = 0;
|
| -
|
| - protected:
|
| - friend class base::RefCounted<QuicAckListenerInterface>;
|
| -
|
| - // Delegates are ref counted.
|
| - virtual ~QuicAckListenerInterface() {}
|
| -};
|
| -
|
| -// Used to generate filtered supported versions based on flags.
|
| -class NET_EXPORT_PRIVATE QuicVersionManager {
|
| - public:
|
| - explicit QuicVersionManager(QuicVersionVector supported_versions);
|
| - virtual ~QuicVersionManager();
|
| -
|
| - // Returns currently supported QUIC versions.
|
| - const QuicVersionVector& GetSupportedVersions();
|
| -
|
| - protected:
|
| - // Maybe refilter filtered_supported_versions_ based on flags.
|
| - void MaybeRefilterSupportedVersions();
|
| -
|
| - // Refilters filtered_supported_versions_.
|
| - virtual void RefilterSupportedVersions();
|
| -
|
| - const QuicVersionVector& filtered_supported_versions() const {
|
| - return filtered_supported_versions_;
|
| - }
|
| -
|
| - private:
|
| - // FLAGS_quic_enable_version_36_v3
|
| - bool enable_version_36_;
|
| - // The list of versions that may be supported.
|
| - QuicVersionVector allowed_supported_versions_;
|
| - // This vector contains QUIC versions which are currently supported based
|
| - // on flags.
|
| - QuicVersionVector filtered_supported_versions_;
|
| -};
|
| -
|
| -struct NET_EXPORT_PRIVATE AckListenerWrapper {
|
| - AckListenerWrapper(QuicAckListenerInterface* listener,
|
| - QuicPacketLength data_length);
|
| - AckListenerWrapper(const AckListenerWrapper& other);
|
| - ~AckListenerWrapper();
|
| -
|
| - scoped_refptr<QuicAckListenerInterface> ack_listener;
|
| - QuicPacketLength length;
|
| -};
|
| -
|
| -struct NET_EXPORT_PRIVATE SerializedPacket {
|
| - SerializedPacket(QuicPathId path_id,
|
| - QuicPacketNumber packet_number,
|
| - QuicPacketNumberLength packet_number_length,
|
| - const char* encrypted_buffer,
|
| - QuicPacketLength encrypted_length,
|
| - bool has_ack,
|
| - bool has_stop_waiting);
|
| - SerializedPacket(const SerializedPacket& other);
|
| - ~SerializedPacket();
|
| -
|
| - // Not owned.
|
| - const char* encrypted_buffer;
|
| - QuicPacketLength encrypted_length;
|
| - QuicFrames retransmittable_frames;
|
| - IsHandshake has_crypto_handshake;
|
| - // -1: full padding to the end of a max-sized packet
|
| - // 0: no padding
|
| - // otherwise: only pad up to num_padding_bytes bytes
|
| - int16_t num_padding_bytes;
|
| - QuicPathId path_id;
|
| - QuicPacketNumber packet_number;
|
| - QuicPacketNumberLength packet_number_length;
|
| - EncryptionLevel encryption_level;
|
| - bool has_ack;
|
| - bool has_stop_waiting;
|
| - TransmissionType transmission_type;
|
| - QuicPathId original_path_id;
|
| - QuicPacketNumber original_packet_number;
|
| -
|
| - // Optional notifiers which will be informed when this packet has been ACKed.
|
| - std::list<AckListenerWrapper> listeners;
|
| -};
|
| -
|
| -// Deletes and clears all the frames and the packet from serialized packet.
|
| -NET_EXPORT_PRIVATE void ClearSerializedPacket(
|
| - SerializedPacket* serialized_packet);
|
| -
|
| -// Allocates a new char[] of size |packet.encrypted_length| and copies in
|
| -// |packet.encrypted_buffer|.
|
| -NET_EXPORT_PRIVATE char* CopyBuffer(const SerializedPacket& packet);
|
| -
|
| -struct NET_EXPORT_PRIVATE TransmissionInfo {
|
| - // Used by STL when assigning into a map.
|
| - TransmissionInfo();
|
| -
|
| - // Constructs a Transmission with a new all_transmissions set
|
| - // containing |packet_number|.
|
| - TransmissionInfo(EncryptionLevel level,
|
| - QuicPacketNumberLength packet_number_length,
|
| - TransmissionType transmission_type,
|
| - QuicTime sent_time,
|
| - QuicPacketLength bytes_sent,
|
| - bool has_crypto_handshake,
|
| - int num_padding_bytes);
|
| -
|
| - TransmissionInfo(const TransmissionInfo& other);
|
| -
|
| - ~TransmissionInfo();
|
| -
|
| - QuicFrames retransmittable_frames;
|
| - EncryptionLevel encryption_level;
|
| - QuicPacketNumberLength packet_number_length;
|
| - QuicPacketLength bytes_sent;
|
| - QuicTime sent_time;
|
| - // Reason why this packet was transmitted.
|
| - TransmissionType transmission_type;
|
| - // In flight packets have not been abandoned or lost.
|
| - bool in_flight;
|
| - // True if the packet can never be acked, so it can be removed. Occurs when
|
| - // a packet is never sent, after it is acknowledged once, or if it's a crypto
|
| - // packet we never expect to receive an ack for.
|
| - bool is_unackable;
|
| - // True if the packet contains stream data from the crypto stream.
|
| - bool has_crypto_handshake;
|
| - // Non-zero if the packet needs padding if it's retransmitted.
|
| - int16_t num_padding_bytes;
|
| - // Stores the packet number of the next retransmission of this packet.
|
| - // Zero if the packet has not been retransmitted.
|
| - QuicPacketNumber retransmission;
|
| - // Non-empty if there is a std::listener for this packet.
|
| - std::list<AckListenerWrapper> ack_listeners;
|
| -};
|
| -
|
| -// Struct to store the pending retransmission information.
|
| -struct PendingRetransmission {
|
| - PendingRetransmission(QuicPathId path_id,
|
| - QuicPacketNumber packet_number,
|
| - TransmissionType transmission_type,
|
| - const QuicFrames& retransmittable_frames,
|
| - bool has_crypto_handshake,
|
| - int num_padding_bytes,
|
| - EncryptionLevel encryption_level,
|
| - QuicPacketNumberLength packet_number_length)
|
| - : packet_number(packet_number),
|
| - retransmittable_frames(retransmittable_frames),
|
| - transmission_type(transmission_type),
|
| - path_id(path_id),
|
| - has_crypto_handshake(has_crypto_handshake),
|
| - num_padding_bytes(num_padding_bytes),
|
| - encryption_level(encryption_level),
|
| - packet_number_length(packet_number_length) {}
|
| -
|
| - QuicPacketNumber packet_number;
|
| - const QuicFrames& retransmittable_frames;
|
| - TransmissionType transmission_type;
|
| - QuicPathId path_id;
|
| - bool has_crypto_handshake;
|
| - int num_padding_bytes;
|
| - EncryptionLevel encryption_level;
|
| - QuicPacketNumberLength packet_number_length;
|
| -};
|
| -
|
| -} // namespace net
|
| -
|
| -#endif // NET_QUIC_QUIC_PROTOCOL_H_
|
|
|