Index: net/quic/quic_framer.h |
diff --git a/net/quic/quic_framer.h b/net/quic/quic_framer.h |
deleted file mode 100644 |
index 6ac0518d34b86ebb11da84fd8f3cbf138e002e29..0000000000000000000000000000000000000000 |
--- a/net/quic/quic_framer.h |
+++ /dev/null |
@@ -1,625 +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_FRAMER_H_ |
-#define NET_QUIC_QUIC_FRAMER_H_ |
- |
-#include <stddef.h> |
-#include <stdint.h> |
- |
-#include <memory> |
-#include <string> |
-#include <unordered_map> |
-#include <unordered_set> |
-#include <vector> |
- |
-#include "base/logging.h" |
-#include "base/macros.h" |
-#include "base/strings/string_piece.h" |
-#include "net/base/net_export.h" |
-#include "net/quic/quic_protocol.h" |
- |
-namespace net { |
- |
-namespace test { |
-class QuicFramerPeer; |
-} // namespace test |
- |
-class QuicDataReader; |
-class QuicDataWriter; |
-class QuicDecrypter; |
-class QuicEncrypter; |
-class QuicFramer; |
- |
-// Number of bytes reserved for the frame type preceding each frame. |
-const size_t kQuicFrameTypeSize = 1; |
-// Number of bytes reserved for error code. |
-const size_t kQuicErrorCodeSize = 4; |
-// Number of bytes reserved to denote the length of error details field. |
-const size_t kQuicErrorDetailsLengthSize = 2; |
- |
-// Maximum number of bytes reserved for stream id. |
-const size_t kQuicMaxStreamIdSize = 4; |
-// Maximum number of bytes reserved for byte offset in stream frame. |
-const size_t kQuicMaxStreamOffsetSize = 8; |
-// Number of bytes reserved to store payload length in stream frame. |
-const size_t kQuicStreamPayloadLengthSize = 2; |
- |
-// Size in bytes of the entropy hash sent in ack frames. |
-const size_t kQuicEntropyHashSize = 1; |
-// Size in bytes reserved for the delta time of the largest observed |
-// packet number in ack frames. |
-const size_t kQuicDeltaTimeLargestObservedSize = 2; |
-// Size in bytes reserved for the number of received packets with timestamps. |
-const size_t kQuicNumTimestampsSize = 1; |
-// Size in bytes reserved for the number of missing packets in ack frames. |
-const size_t kNumberOfNackRangesSize = 1; |
-// Size in bytes reserved for the number of ack blocks in ack frames. |
-const size_t kNumberOfAckBlocksSize = 1; |
-// Maximum number of missing packet ranges that can fit within an ack frame. |
-const size_t kMaxNackRanges = (1 << (kNumberOfNackRangesSize * 8)) - 1; |
-// Maximum number of ack blocks that can fit within an ack frame. |
-const size_t kMaxAckBlocks = (1 << (kNumberOfAckBlocksSize * 8)) - 1; |
-// Size in bytes reserved for the number of revived packets in ack frames. |
-const size_t kNumberOfRevivedPacketsSize = 1; |
- |
-// This class receives callbacks from the framer when packets |
-// are processed. |
-class NET_EXPORT_PRIVATE QuicFramerVisitorInterface { |
- public: |
- virtual ~QuicFramerVisitorInterface() {} |
- |
- // Called if an error is detected in the QUIC protocol. |
- virtual void OnError(QuicFramer* framer) = 0; |
- |
- // Called only when |perspective_| is IS_SERVER and the the framer gets a |
- // packet with version flag true and the version on the packet doesn't match |
- // |quic_version_|. The visitor should return true after it updates the |
- // version of the |framer_| to |received_version| or false to stop processing |
- // this packet. |
- virtual bool OnProtocolVersionMismatch(QuicVersion received_version) = 0; |
- |
- // Called when a new packet has been received, before it |
- // has been validated or processed. |
- virtual void OnPacket() = 0; |
- |
- // Called when a public reset packet has been parsed but has not yet |
- // been validated. |
- virtual void OnPublicResetPacket(const QuicPublicResetPacket& packet) = 0; |
- |
- // Called only when |perspective_| is IS_CLIENT and a version negotiation |
- // packet has been parsed. |
- virtual void OnVersionNegotiationPacket( |
- const QuicVersionNegotiationPacket& packet) = 0; |
- |
- // Called when the public header has been parsed, but has not been |
- // authenticated. If it returns false, framing for this packet will cease. |
- virtual bool OnUnauthenticatedPublicHeader( |
- const QuicPacketPublicHeader& header) = 0; |
- |
- // Called when the unauthenticated portion of the header has been parsed. |
- // If OnUnauthenticatedHeader returns false, framing for this packet will |
- // cease. |
- virtual bool OnUnauthenticatedHeader(const QuicPacketHeader& header) = 0; |
- |
- // Called when a packet has been decrypted. |level| is the encryption level |
- // of the packet. |
- virtual void OnDecryptedPacket(EncryptionLevel level) = 0; |
- |
- // Called when the complete header of a packet had been parsed. |
- // If OnPacketHeader returns false, framing for this packet will cease. |
- virtual bool OnPacketHeader(const QuicPacketHeader& header) = 0; |
- |
- // Called when a StreamFrame has been parsed. |
- virtual bool OnStreamFrame(const QuicStreamFrame& frame) = 0; |
- |
- // Called when a AckFrame has been parsed. If OnAckFrame returns false, |
- // the framer will stop parsing the current packet. |
- virtual bool OnAckFrame(const QuicAckFrame& frame) = 0; |
- |
- // Called when a StopWaitingFrame has been parsed. |
- virtual bool OnStopWaitingFrame(const QuicStopWaitingFrame& frame) = 0; |
- |
- // Called when a QuicPaddingFrame has been parsed. |
- virtual bool OnPaddingFrame(const QuicPaddingFrame& frame) = 0; |
- |
- // Called when a PingFrame has been parsed. |
- virtual bool OnPingFrame(const QuicPingFrame& frame) = 0; |
- |
- // Called when a RstStreamFrame has been parsed. |
- virtual bool OnRstStreamFrame(const QuicRstStreamFrame& frame) = 0; |
- |
- // Called when a ConnectionCloseFrame has been parsed. |
- virtual bool OnConnectionCloseFrame( |
- const QuicConnectionCloseFrame& frame) = 0; |
- |
- // Called when a GoAwayFrame has been parsed. |
- virtual bool OnGoAwayFrame(const QuicGoAwayFrame& frame) = 0; |
- |
- // Called when a WindowUpdateFrame has been parsed. |
- virtual bool OnWindowUpdateFrame(const QuicWindowUpdateFrame& frame) = 0; |
- |
- // Called when a BlockedFrame has been parsed. |
- virtual bool OnBlockedFrame(const QuicBlockedFrame& frame) = 0; |
- |
- // Called when a PathCloseFrame has been parsed. |
- virtual bool OnPathCloseFrame(const QuicPathCloseFrame& frame) = 0; |
- |
- // Called when a packet has been completely processed. |
- virtual void OnPacketComplete() = 0; |
-}; |
- |
-// This class calculates the received entropy of the ack packet being |
-// framed, should it get truncated. |
-class NET_EXPORT_PRIVATE QuicReceivedEntropyHashCalculatorInterface { |
- public: |
- virtual ~QuicReceivedEntropyHashCalculatorInterface() {} |
- |
- // When an ack frame gets truncated while being framed the received |
- // entropy of the ack frame needs to be calculated since the some of the |
- // missing packets are not added and the largest observed might be lowered. |
- // This should return the received entropy hash of the packets received up to |
- // and including |packet_number|. |
- virtual QuicPacketEntropyHash EntropyHash( |
- QuicPacketNumber packet_number) const = 0; |
-}; |
- |
-// Class for parsing and constructing QUIC packets. It has a |
-// QuicFramerVisitorInterface that is called when packets are parsed. |
-class NET_EXPORT_PRIVATE QuicFramer { |
- public: |
- // Constructs a new framer that installs a kNULL QuicEncrypter and |
- // QuicDecrypter for level ENCRYPTION_NONE. |supported_versions| specifies the |
- // list of supported QUIC versions. |quic_version_| is set to the maximum |
- // version in |supported_versions|. |
- QuicFramer(const QuicVersionVector& supported_versions, |
- QuicTime creation_time, |
- Perspective perspective); |
- |
- virtual ~QuicFramer(); |
- |
- // Returns true if |version| is a supported protocol version. |
- bool IsSupportedVersion(const QuicVersion version) const; |
- |
- // Set callbacks to be called from the framer. A visitor must be set, or |
- // else the framer will likely crash. It is acceptable for the visitor |
- // to do nothing. If this is called multiple times, only the last visitor |
- // will be used. |
- void set_visitor(QuicFramerVisitorInterface* visitor) { visitor_ = visitor; } |
- |
- const QuicVersionVector& supported_versions() const { |
- return supported_versions_; |
- } |
- |
- QuicVersion version() const { return quic_version_; } |
- |
- void set_version(const QuicVersion version); |
- |
- // Does not DCHECK for supported version. Used by tests to set unsupported |
- // version to trigger version negotiation. |
- void set_version_for_tests(const QuicVersion version) { |
- quic_version_ = version; |
- } |
- |
- // Set entropy calculator to be called from the framer when it needs the |
- // entropy of a truncated ack frame. An entropy calculator must be set or else |
- // the framer will likely crash. If this is called multiple times, only the |
- // last calculator will be used. |
- void set_received_entropy_calculator( |
- QuicReceivedEntropyHashCalculatorInterface* entropy_calculator) { |
- entropy_calculator_ = entropy_calculator; |
- } |
- |
- QuicErrorCode error() const { return error_; } |
- |
- // Pass a UDP packet into the framer for parsing. |
- // Return true if the packet was processed succesfully. |packet| must be a |
- // single, complete UDP packet (not a frame of a packet). This packet |
- // might be null padded past the end of the payload, which will be correctly |
- // ignored. |
- bool ProcessPacket(const QuicEncryptedPacket& packet); |
- |
- // Largest size in bytes of all stream frame fields without the payload. |
- static size_t GetMinStreamFrameSize(QuicStreamId stream_id, |
- QuicStreamOffset offset, |
- bool last_frame_in_packet); |
- // Size in bytes of all ack frame fields without the missing packets or ack |
- // blocks. |
- static size_t GetMinAckFrameSize( |
- QuicVersion version, |
- QuicPacketNumberLength largest_observed_length); |
- // Size in bytes of a stop waiting frame. |
- static size_t GetStopWaitingFrameSize( |
- QuicVersion version, |
- QuicPacketNumberLength packet_number_length); |
- // Size in bytes of all reset stream frame fields. |
- static size_t GetRstStreamFrameSize(); |
- // Size in bytes of all connection close frame fields without the error |
- // details and the missing packets from the enclosed ack frame. |
- static size_t GetMinConnectionCloseFrameSize(); |
- // Size in bytes of all GoAway frame fields without the reason phrase. |
- static size_t GetMinGoAwayFrameSize(); |
- // Size in bytes of all WindowUpdate frame fields. |
- static size_t GetWindowUpdateFrameSize(); |
- // Size in bytes of all Blocked frame fields. |
- static size_t GetBlockedFrameSize(); |
- // Size in bytes of all PathClose frame fields. |
- static size_t GetPathCloseFrameSize(); |
- // Size in bytes required to serialize the stream id. |
- static size_t GetStreamIdSize(QuicStreamId stream_id); |
- // Size in bytes required to serialize the stream offset. |
- static size_t GetStreamOffsetSize(QuicStreamOffset offset); |
- // Size in bytes required for a serialized version negotiation packet |
- static size_t GetVersionNegotiationPacketSize(size_t number_versions); |
- |
- // Returns the number of bytes added to the packet for the specified frame, |
- // and 0 if the frame doesn't fit. Includes the header size for the first |
- // frame. |
- size_t GetSerializedFrameLength(const QuicFrame& frame, |
- size_t free_bytes, |
- bool first_frame_in_packet, |
- bool last_frame_in_packet, |
- QuicPacketNumberLength packet_number_length); |
- |
- // Returns the associated data from the encrypted packet |encrypted| as a |
- // stringpiece. |
- static base::StringPiece GetAssociatedDataFromEncryptedPacket( |
- QuicVersion version, |
- const QuicEncryptedPacket& encrypted, |
- QuicConnectionIdLength connection_id_length, |
- bool includes_version, |
- bool includes_path_id, |
- bool includes_diversification_nonce, |
- QuicPacketNumberLength packet_number_length); |
- |
- // Serializes a packet containing |frames| into |buffer|. |
- // Returns the length of the packet, which must not be longer than |
- // |packet_length|. Returns 0 if it fails to serialize. |
- size_t BuildDataPacket(const QuicPacketHeader& header, |
- const QuicFrames& frames, |
- char* buffer, |
- size_t packet_length); |
- |
- // Returns a new public reset packet, owned by the caller. |
- static QuicEncryptedPacket* BuildPublicResetPacket( |
- const QuicPublicResetPacket& packet); |
- |
- // Returns a new version negotiation packet, owned by the caller. |
- static QuicEncryptedPacket* BuildVersionNegotiationPacket( |
- QuicConnectionId connection_id, |
- const QuicVersionVector& versions); |
- |
- // If header.public_header.version_flag is set, the version in the |
- // packet will be set -- but it will be set from quic_version_ not |
- // header.public_header.versions. |
- bool AppendPacketHeader(const QuicPacketHeader& header, |
- QuicDataWriter* writer); |
- bool AppendTypeByte(const QuicFrame& frame, |
- bool last_frame_in_packet, |
- QuicDataWriter* writer); |
- bool AppendStreamFrame(const QuicStreamFrame& frame, |
- bool last_frame_in_packet, |
- QuicDataWriter* builder); |
- |
- // SetDecrypter sets the primary decrypter, replacing any that already exists, |
- // and takes ownership. If an alternative decrypter is in place then the |
- // function DCHECKs. This is intended for cases where one knows that future |
- // packets will be using the new decrypter and the previous decrypter is now |
- // obsolete. |level| indicates the encryption level of the new decrypter. |
- void SetDecrypter(EncryptionLevel level, QuicDecrypter* decrypter); |
- |
- // SetAlternativeDecrypter sets a decrypter that may be used to decrypt |
- // future packets and takes ownership of it. |level| indicates the encryption |
- // level of the decrypter. If |latch_once_used| is true, then the first time |
- // that the decrypter is successful it will replace the primary decrypter. |
- // Otherwise both decrypters will remain active and the primary decrypter |
- // will be the one last used. |
- void SetAlternativeDecrypter(EncryptionLevel level, |
- QuicDecrypter* decrypter, |
- bool latch_once_used); |
- |
- const QuicDecrypter* decrypter() const; |
- const QuicDecrypter* alternative_decrypter() const; |
- |
- // Changes the encrypter used for level |level| to |encrypter|. The function |
- // takes ownership of |encrypter|. |
- void SetEncrypter(EncryptionLevel level, QuicEncrypter* encrypter); |
- |
- // Encrypts a payload in |buffer|. |ad_len| is the length of the associated |
- // data. |total_len| is the length of the associated data plus plaintext. |
- // |buffer_len| is the full length of the allocated buffer. |
- size_t EncryptInPlace(EncryptionLevel level, |
- QuicPathId path_id, |
- QuicPacketNumber packet_number, |
- size_t ad_len, |
- size_t total_len, |
- size_t buffer_len, |
- char* buffer); |
- |
- // Returns the length of the data encrypted into |buffer| if |buffer_len| is |
- // long enough, and otherwise 0. |
- size_t EncryptPayload(EncryptionLevel level, |
- QuicPathId path_id, |
- QuicPacketNumber packet_number, |
- const QuicPacket& packet, |
- char* buffer, |
- size_t buffer_len); |
- |
- // Returns the maximum length of plaintext that can be encrypted |
- // to ciphertext no larger than |ciphertext_size|. |
- size_t GetMaxPlaintextSize(size_t ciphertext_size); |
- |
- const std::string& detailed_error() { return detailed_error_; } |
- |
- // The minimum packet number length required to represent |packet_number|. |
- static QuicPacketNumberLength GetMinSequenceNumberLength( |
- QuicPacketNumber packet_number); |
- |
- void SetSupportedVersions(const QuicVersionVector& versions) { |
- supported_versions_ = versions; |
- quic_version_ = versions[0]; |
- } |
- |
- void set_validate_flags(bool value) { validate_flags_ = value; } |
- |
- Perspective perspective() const { return perspective_; } |
- |
- static QuicPacketEntropyHash GetPacketEntropyHash( |
- const QuicPacketHeader& header); |
- |
- // Called when a PATH_CLOSED frame has been sent/received on |path_id|. |
- void OnPathClosed(QuicPathId path_id); |
- |
- QuicTag last_version_tag() { return last_version_tag_; } |
- |
- private: |
- friend class test::QuicFramerPeer; |
- |
- typedef std::map<QuicPacketNumber, uint8_t> NackRangeMap; |
- |
- struct AckFrameInfo { |
- AckFrameInfo(); |
- AckFrameInfo(const AckFrameInfo& other); |
- ~AckFrameInfo(); |
- |
- // The maximum delta between ranges. |
- QuicPacketNumber max_delta; |
- // Nack ranges starting with start packet numbers and lengths. |
- NackRangeMap nack_ranges; |
- }; |
- |
- struct AckBlock { |
- AckBlock(uint8_t gap, QuicPacketNumber length); |
- AckBlock(const AckBlock& other); |
- ~AckBlock(); |
- |
- // Gap to the next ack block. |
- uint8_t gap; |
- // Length of this ack block. |
- QuicPacketNumber length; |
- }; |
- |
- struct NewAckFrameInfo { |
- NewAckFrameInfo(); |
- NewAckFrameInfo(const NewAckFrameInfo& other); |
- ~NewAckFrameInfo(); |
- |
- // The maximum ack block length. |
- QuicPacketNumber max_block_length; |
- // Length of first ack block. |
- QuicPacketNumber first_block_length; |
- // Ack blocks starting with gaps to next block and ack block lengths. |
- std::vector<AckBlock> ack_blocks; |
- // Number of ACK blocks. If |ack_blocks| is generated, must equal |
- // |ack_blocks.size()|. |
- size_t num_ack_blocks; |
- }; |
- |
- bool ProcessDataPacket(QuicDataReader* reader, |
- const QuicPacketPublicHeader& public_header, |
- const QuicEncryptedPacket& packet, |
- char* decrypted_buffer, |
- size_t buffer_length); |
- |
- bool ProcessPublicResetPacket(QuicDataReader* reader, |
- const QuicPacketPublicHeader& public_header); |
- |
- bool ProcessVersionNegotiationPacket(QuicDataReader* reader, |
- QuicPacketPublicHeader* public_header); |
- |
- bool ProcessPublicHeader(QuicDataReader* reader, |
- QuicPacketPublicHeader* header); |
- |
- // Processes the unauthenticated portion of the header into |header| from |
- // the current QuicDataReader. Returns true on success, false on failure. |
- bool ProcessUnauthenticatedHeader(QuicDataReader* encrypted_reader, |
- QuicPacketHeader* header); |
- |
- // Processes the authenticated portion of the header into |header| from |
- // the current QuicDataReader. Returns true on success, false on failure. |
- bool ProcessAuthenticatedHeader(QuicDataReader* reader, |
- QuicPacketHeader* header); |
- |
- bool ProcessPathId(QuicDataReader* reader, QuicPathId* path_id); |
- bool ProcessPacketSequenceNumber(QuicDataReader* reader, |
- QuicPacketNumberLength packet_number_length, |
- QuicPacketNumber last_packet_number, |
- QuicPacketNumber* packet_number); |
- bool ProcessFrameData(QuicDataReader* reader, const QuicPacketHeader& header); |
- bool ProcessStreamFrame(QuicDataReader* reader, |
- uint8_t frame_type, |
- QuicStreamFrame* frame); |
- bool ProcessAckFrame(QuicDataReader* reader, |
- uint8_t frame_type, |
- QuicAckFrame* frame); |
- bool ProcessNewAckFrame(QuicDataReader* reader, |
- uint8_t frame_type, |
- QuicAckFrame* frame); |
- bool ProcessTimestampsInAckFrame(QuicDataReader* reader, QuicAckFrame* frame); |
- bool ProcessStopWaitingFrame(QuicDataReader* reader, |
- const QuicPacketHeader& public_header, |
- QuicStopWaitingFrame* stop_waiting); |
- bool ProcessRstStreamFrame(QuicDataReader* reader, QuicRstStreamFrame* frame); |
- bool ProcessConnectionCloseFrame(QuicDataReader* reader, |
- QuicConnectionCloseFrame* frame); |
- bool ProcessGoAwayFrame(QuicDataReader* reader, QuicGoAwayFrame* frame); |
- bool ProcessWindowUpdateFrame(QuicDataReader* reader, |
- QuicWindowUpdateFrame* frame); |
- bool ProcessBlockedFrame(QuicDataReader* reader, QuicBlockedFrame* frame); |
- bool ProcessPathCloseFrame(QuicDataReader* reader, QuicPathCloseFrame* frame); |
- |
- bool DecryptPayload(QuicDataReader* encrypted_reader, |
- const QuicPacketHeader& header, |
- const QuicEncryptedPacket& packet, |
- char* decrypted_buffer, |
- size_t buffer_length, |
- size_t* decrypted_length); |
- |
- // Checks if |path_id| is a viable path to receive packets on. Returns true |
- // and sets |last_packet_number| if the path is not closed. Returns false |
- // otherwise. |
- bool IsValidPath(QuicPathId path_id, QuicPacketNumber* last_packet_number); |
- |
- // Sets last_packet_number_. This can only be called after the packet is |
- // successfully decrypted. |
- void SetLastPacketNumber(const QuicPacketHeader& header); |
- |
- // Returns the full packet number from the truncated |
- // wire format version and the last seen packet number. |
- QuicPacketNumber CalculatePacketNumberFromWire( |
- QuicPacketNumberLength packet_number_length, |
- QuicPacketNumber last_packet_number, |
- QuicPacketNumber packet_number) const; |
- |
- // Returns the QuicTime::Delta corresponding to the time from when the framer |
- // was created. |
- const QuicTime::Delta CalculateTimestampFromWire(uint32_t time_delta_us); |
- |
- // Computes the wire size in bytes of time stamps in |ack|. |
- size_t GetAckFrameTimeStampSize(const QuicAckFrame& ack); |
- |
- // Computes the wire size in bytes of the |ack| frame, assuming no truncation. |
- size_t GetAckFrameSize(const QuicAckFrame& ack, |
- QuicPacketNumberLength packet_number_length); |
- |
- // Computes the wire size in bytes of the |ack| frame. |
- size_t GetNewAckFrameSize(const QuicAckFrame& ack); |
- |
- // Computes the wire size in bytes of the payload of |frame|. |
- size_t ComputeFrameLength(const QuicFrame& frame, |
- bool last_frame_in_packet, |
- QuicPacketNumberLength packet_number_length); |
- |
- static bool AppendPacketSequenceNumber( |
- QuicPacketNumberLength packet_number_length, |
- QuicPacketNumber packet_number, |
- QuicDataWriter* writer); |
- |
- // Appends a single ACK block to |writer| and returns true if the block was |
- // successfully appended. |
- static bool AppendAckBlock(uint8_t gap, |
- QuicPacketNumberLength length_length, |
- QuicPacketNumber length, |
- QuicDataWriter* writer); |
- |
- static uint8_t GetSequenceNumberFlags( |
- QuicPacketNumberLength packet_number_length); |
- |
- static AckFrameInfo GetAckFrameInfo(const QuicAckFrame& frame); |
- |
- static NewAckFrameInfo GetNewAckFrameInfo(const QuicAckFrame& frame, |
- bool construct_blocks); |
- |
- // The Append* methods attempt to write the provided header or frame using the |
- // |writer|, and return true if successful. |
- |
- bool AppendAckFrameAndTypeByte(const QuicPacketHeader& header, |
- const QuicAckFrame& frame, |
- QuicDataWriter* builder); |
- bool AppendNewAckFrameAndTypeByte(const QuicAckFrame& frame, |
- QuicDataWriter* builder); |
- bool AppendTimestampToAckFrame(const QuicAckFrame& frame, |
- QuicDataWriter* builder); |
- bool AppendStopWaitingFrame(const QuicPacketHeader& header, |
- const QuicStopWaitingFrame& frame, |
- QuicDataWriter* builder); |
- bool AppendRstStreamFrame(const QuicRstStreamFrame& frame, |
- QuicDataWriter* builder); |
- bool AppendConnectionCloseFrame(const QuicConnectionCloseFrame& frame, |
- QuicDataWriter* builder); |
- bool AppendGoAwayFrame(const QuicGoAwayFrame& frame, QuicDataWriter* writer); |
- bool AppendWindowUpdateFrame(const QuicWindowUpdateFrame& frame, |
- QuicDataWriter* writer); |
- bool AppendBlockedFrame(const QuicBlockedFrame& frame, |
- QuicDataWriter* writer); |
- bool AppendPathCloseFrame(const QuicPathCloseFrame& frame, |
- QuicDataWriter* writer); |
- |
- bool RaiseError(QuicErrorCode error); |
- |
- void set_error(QuicErrorCode error) { error_ = error; } |
- |
- void set_detailed_error(const char* error) { detailed_error_ = error; } |
- |
- std::string detailed_error_; |
- QuicFramerVisitorInterface* visitor_; |
- QuicReceivedEntropyHashCalculatorInterface* entropy_calculator_; |
- QuicErrorCode error_; |
- // Set of closed paths. A path is considered as closed if a PATH_CLOSED frame |
- // has been sent/received. |
- // TODO(fayang): this set is never cleaned up. A possible improvement is to |
- // use intervals. |
- std::unordered_set<QuicPathId> closed_paths_; |
- // Map mapping path id to packet number of last successfully decrypted |
- // received packet. |
- std::unordered_map<QuicPathId, QuicPacketNumber> last_packet_numbers_; |
- // Updated by ProcessPacketHeader when it succeeds. |
- QuicPacketNumber last_packet_number_; |
- // The path on which last successfully decrypted packet was received. |
- QuicPathId last_path_id_; |
- // Updated by WritePacketHeader. |
- QuicConnectionId last_serialized_connection_id_; |
- // The last QUIC version tag received. |
- QuicTag last_version_tag_; |
- // Version of the protocol being used. |
- QuicVersion quic_version_; |
- // This vector contains QUIC versions which we currently support. |
- // This should be ordered such that the highest supported version is the first |
- // element, with subsequent elements in descending order (versions can be |
- // skipped as necessary). |
- QuicVersionVector supported_versions_; |
- // Primary decrypter used to decrypt packets during parsing. |
- std::unique_ptr<QuicDecrypter> decrypter_; |
- // Alternative decrypter that can also be used to decrypt packets. |
- std::unique_ptr<QuicDecrypter> alternative_decrypter_; |
- // The encryption level of |decrypter_|. |
- EncryptionLevel decrypter_level_; |
- // The encryption level of |alternative_decrypter_|. |
- EncryptionLevel alternative_decrypter_level_; |
- // |alternative_decrypter_latch_| is true if, when |alternative_decrypter_| |
- // successfully decrypts a packet, we should install it as the only |
- // decrypter. |
- bool alternative_decrypter_latch_; |
- // Encrypters used to encrypt packets via EncryptPayload(). |
- std::unique_ptr<QuicEncrypter> encrypter_[NUM_ENCRYPTION_LEVELS]; |
- // Tracks if the framer is being used by the entity that received the |
- // connection or the entity that initiated it. |
- Perspective perspective_; |
- // If false, skip validation that the public flags are set to legal values. |
- bool validate_flags_; |
- // The time this framer was created. Time written to the wire will be |
- // written as a delta from this value. |
- QuicTime creation_time_; |
- // The time delta computed for the last timestamp frame. This is relative to |
- // the creation_time. |
- QuicTime::Delta last_timestamp_; |
- // The diversification nonce from the last received packet. |
- DiversificationNonce last_nonce_; |
- |
- DISALLOW_COPY_AND_ASSIGN(QuicFramer); |
-}; |
- |
-} // namespace net |
- |
-#endif // NET_QUIC_QUIC_FRAMER_H_ |