| Index: net/quic/quic_connection.h
|
| diff --git a/net/quic/quic_connection.h b/net/quic/quic_connection.h
|
| deleted file mode 100644
|
| index e944aea51951a473b7b1dafc5f6bc21e86a2dbb2..0000000000000000000000000000000000000000
|
| --- a/net/quic/quic_connection.h
|
| +++ /dev/null
|
| @@ -1,845 +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.
|
| -//
|
| -// The entity that handles framing writes for a Quic client or server.
|
| -// Each QuicSession will have a connection associated with it.
|
| -//
|
| -// On the server side, the Dispatcher handles the raw reads, and hands off
|
| -// packets via ProcessUdpPacket for framing and processing.
|
| -//
|
| -// On the client side, the Connection handles the raw reads, as well as the
|
| -// processing.
|
| -//
|
| -// Note: this class is not thread-safe.
|
| -
|
| -#ifndef NET_QUIC_QUIC_CONNECTION_H_
|
| -#define NET_QUIC_QUIC_CONNECTION_H_
|
| -
|
| -#include <stddef.h>
|
| -#include <deque>
|
| -#include <list>
|
| -#include <map>
|
| -#include <queue>
|
| -#include <string>
|
| -#include <vector>
|
| -
|
| -#include "base/basictypes.h"
|
| -#include "base/logging.h"
|
| -#include "net/base/iovec.h"
|
| -#include "net/base/ip_endpoint.h"
|
| -#include "net/quic/iovector.h"
|
| -#include "net/quic/quic_ack_notifier.h"
|
| -#include "net/quic/quic_ack_notifier_manager.h"
|
| -#include "net/quic/quic_alarm.h"
|
| -#include "net/quic/quic_blocked_writer_interface.h"
|
| -#include "net/quic/quic_connection_stats.h"
|
| -#include "net/quic/quic_packet_creator.h"
|
| -#include "net/quic/quic_packet_generator.h"
|
| -#include "net/quic/quic_packet_writer.h"
|
| -#include "net/quic/quic_protocol.h"
|
| -#include "net/quic/quic_received_packet_manager.h"
|
| -#include "net/quic/quic_sent_entropy_manager.h"
|
| -#include "net/quic/quic_sent_packet_manager.h"
|
| -#include "net/quic/quic_time.h"
|
| -#include "net/quic/quic_types.h"
|
| -
|
| -namespace net {
|
| -
|
| -class QuicClock;
|
| -class QuicConfig;
|
| -class QuicConnection;
|
| -class QuicDecrypter;
|
| -class QuicEncrypter;
|
| -class QuicFecGroup;
|
| -class QuicRandom;
|
| -
|
| -namespace test {
|
| -class PacketSavingConnection;
|
| -class QuicConnectionPeer;
|
| -} // namespace test
|
| -
|
| -// Class that receives callbacks from the connection when frames are received
|
| -// and when other interesting events happen.
|
| -class NET_EXPORT_PRIVATE QuicConnectionVisitorInterface {
|
| - public:
|
| - virtual ~QuicConnectionVisitorInterface() {}
|
| -
|
| - // A simple visitor interface for dealing with data frames.
|
| - virtual void OnStreamFrames(const std::vector<QuicStreamFrame>& frames) = 0;
|
| -
|
| - // The session should process all WINDOW_UPDATE frames, adjusting both stream
|
| - // and connection level flow control windows.
|
| - virtual void OnWindowUpdateFrames(
|
| - const std::vector<QuicWindowUpdateFrame>& frames) = 0;
|
| -
|
| - // BLOCKED frames tell us that the peer believes it is flow control blocked on
|
| - // a specified stream. If the session at this end disagrees, something has
|
| - // gone wrong with our flow control accounting.
|
| - virtual void OnBlockedFrames(const std::vector<QuicBlockedFrame>& frames) = 0;
|
| -
|
| - // Called when the stream is reset by the peer.
|
| - virtual void OnRstStream(const QuicRstStreamFrame& frame) = 0;
|
| -
|
| - // Called when the connection is going away according to the peer.
|
| - virtual void OnGoAway(const QuicGoAwayFrame& frame) = 0;
|
| -
|
| - // Called when the connection is closed either locally by the framer, or
|
| - // remotely by the peer.
|
| - virtual void OnConnectionClosed(QuicErrorCode error, bool from_peer) = 0;
|
| -
|
| - // Called when the connection failed to write because the socket was blocked.
|
| - virtual void OnWriteBlocked() = 0;
|
| -
|
| - // Called once a specific QUIC version is agreed by both endpoints.
|
| - virtual void OnSuccessfulVersionNegotiation(const QuicVersion& version) = 0;
|
| -
|
| - // Called when a blocked socket becomes writable.
|
| - virtual void OnCanWrite() = 0;
|
| -
|
| - // Called when the connection experiences a change in congestion window.
|
| - virtual void OnCongestionWindowChange(QuicTime now) = 0;
|
| -
|
| - // Called to ask if the visitor wants to schedule write resumption as it both
|
| - // has pending data to write, and is able to write (e.g. based on flow control
|
| - // limits).
|
| - // Writes may be pending because they were write-blocked, congestion-throttled
|
| - // or yielded to other connections.
|
| - virtual bool WillingAndAbleToWrite() const = 0;
|
| -
|
| - // Called to ask if any handshake messages are pending in this visitor.
|
| - virtual bool HasPendingHandshake() const = 0;
|
| -
|
| - // Called to ask if any streams are open in this visitor, excluding the
|
| - // reserved crypto and headers stream.
|
| - virtual bool HasOpenDataStreams() const = 0;
|
| -};
|
| -
|
| -// Interface which gets callbacks from the QuicConnection at interesting
|
| -// points. Implementations must not mutate the state of the connection
|
| -// as a result of these callbacks.
|
| -class NET_EXPORT_PRIVATE QuicConnectionDebugVisitor
|
| - : public QuicPacketGenerator::DebugDelegate,
|
| - public QuicSentPacketManager::DebugDelegate {
|
| - public:
|
| - ~QuicConnectionDebugVisitor() override {}
|
| -
|
| - // Called when a packet has been sent.
|
| - virtual void OnPacketSent(const SerializedPacket& serialized_packet,
|
| - QuicPacketSequenceNumber original_sequence_number,
|
| - EncryptionLevel level,
|
| - TransmissionType transmission_type,
|
| - const QuicEncryptedPacket& packet,
|
| - QuicTime sent_time) {}
|
| -
|
| - // Called when a packet has been received, but before it is
|
| - // validated or parsed.
|
| - virtual void OnPacketReceived(const IPEndPoint& self_address,
|
| - const IPEndPoint& peer_address,
|
| - const QuicEncryptedPacket& packet) {}
|
| -
|
| - // Called when a packet is received with a connection id that does not
|
| - // match the ID of this connection.
|
| - virtual void OnIncorrectConnectionId(
|
| - QuicConnectionId connection_id) {}
|
| -
|
| - // Called when an undecryptable packet has been received.
|
| - virtual void OnUndecryptablePacket() {}
|
| -
|
| - // Called when a duplicate packet has been received.
|
| - virtual void OnDuplicatePacket(QuicPacketSequenceNumber sequence_number) {}
|
| -
|
| - // Called when the protocol version on the received packet doensn't match
|
| - // current protocol version of the connection.
|
| - virtual void OnProtocolVersionMismatch(QuicVersion version) {}
|
| -
|
| - // Called when the complete header of a packet has been parsed.
|
| - virtual void OnPacketHeader(const QuicPacketHeader& header) {}
|
| -
|
| - // Called when a StreamFrame has been parsed.
|
| - virtual void OnStreamFrame(const QuicStreamFrame& frame) {}
|
| -
|
| - // Called when a AckFrame has been parsed.
|
| - virtual void OnAckFrame(const QuicAckFrame& frame) {}
|
| -
|
| - // Called when a StopWaitingFrame has been parsed.
|
| - virtual void OnStopWaitingFrame(const QuicStopWaitingFrame& frame) {}
|
| -
|
| - // Called when a Ping has been parsed.
|
| - virtual void OnPingFrame(const QuicPingFrame& frame) {}
|
| -
|
| - // Called when a GoAway has been parsed.
|
| - virtual void OnGoAwayFrame(const QuicGoAwayFrame& frame) {}
|
| -
|
| - // Called when a RstStreamFrame has been parsed.
|
| - virtual void OnRstStreamFrame(const QuicRstStreamFrame& frame) {}
|
| -
|
| - // Called when a ConnectionCloseFrame has been parsed.
|
| - virtual void OnConnectionCloseFrame(
|
| - const QuicConnectionCloseFrame& frame) {}
|
| -
|
| - // Called when a WindowUpdate has been parsed.
|
| - virtual void OnWindowUpdateFrame(const QuicWindowUpdateFrame& frame) {}
|
| -
|
| - // Called when a BlockedFrame has been parsed.
|
| - virtual void OnBlockedFrame(const QuicBlockedFrame& frame) {}
|
| -
|
| - // Called when a public reset packet has been received.
|
| - virtual void OnPublicResetPacket(const QuicPublicResetPacket& packet) {}
|
| -
|
| - // Called when a version negotiation packet has been received.
|
| - virtual void OnVersionNegotiationPacket(
|
| - const QuicVersionNegotiationPacket& packet) {}
|
| -
|
| - // Called after a packet has been successfully parsed which results
|
| - // in the revival of a packet via FEC.
|
| - virtual void OnRevivedPacket(const QuicPacketHeader& revived_header,
|
| - base::StringPiece payload) {}
|
| -
|
| - // Called when the connection is closed.
|
| - virtual void OnConnectionClosed(QuicErrorCode error, bool from_peer) {}
|
| -
|
| - // Called when the version negotiation is successful.
|
| - virtual void OnSuccessfulVersionNegotiation(const QuicVersion& version) {}
|
| -};
|
| -
|
| -class NET_EXPORT_PRIVATE QuicConnectionHelperInterface {
|
| - public:
|
| - virtual ~QuicConnectionHelperInterface() {}
|
| -
|
| - // Returns a QuicClock to be used for all time related functions.
|
| - virtual const QuicClock* GetClock() const = 0;
|
| -
|
| - // Returns a QuicRandom to be used for all random number related functions.
|
| - virtual QuicRandom* GetRandomGenerator() = 0;
|
| -
|
| - // Creates a new platform-specific alarm which will be configured to
|
| - // notify |delegate| when the alarm fires. Caller takes ownership
|
| - // of the new alarm, which will not yet be "set" to fire.
|
| - virtual QuicAlarm* CreateAlarm(QuicAlarm::Delegate* delegate) = 0;
|
| -};
|
| -
|
| -class NET_EXPORT_PRIVATE QuicConnection
|
| - : public QuicFramerVisitorInterface,
|
| - public QuicBlockedWriterInterface,
|
| - public QuicPacketGenerator::DelegateInterface,
|
| - public QuicSentPacketManager::NetworkChangeVisitor {
|
| - public:
|
| - enum AckBundling {
|
| - NO_ACK = 0,
|
| - SEND_ACK = 1,
|
| - BUNDLE_PENDING_ACK = 2,
|
| - };
|
| -
|
| - class PacketWriterFactory {
|
| - public:
|
| - virtual ~PacketWriterFactory() {}
|
| -
|
| - virtual QuicPacketWriter* Create(QuicConnection* connection) const = 0;
|
| - };
|
| -
|
| - // Constructs a new QuicConnection for |connection_id| and |address|. Invokes
|
| - // writer_factory->Create() to get a writer; |owns_writer| specifies whether
|
| - // the connection takes ownership of the returned writer. |helper| must
|
| - // outlive this connection.
|
| - QuicConnection(QuicConnectionId connection_id,
|
| - IPEndPoint address,
|
| - QuicConnectionHelperInterface* helper,
|
| - const PacketWriterFactory& writer_factory,
|
| - bool owns_writer,
|
| - bool is_server,
|
| - bool is_secure,
|
| - const QuicVersionVector& supported_versions);
|
| - ~QuicConnection() override;
|
| -
|
| - // Sets connection parameters from the supplied |config|.
|
| - void SetFromConfig(const QuicConfig& config);
|
| -
|
| - // Called by the Session when the client has provided CachedNetworkParameters.
|
| - // Returns true if this changes the initial connection state.
|
| - virtual bool ResumeConnectionState(
|
| - const CachedNetworkParameters& cached_network_params);
|
| -
|
| - // Sets the number of active streams on the connection for congestion control.
|
| - void SetNumOpenStreams(size_t num_streams);
|
| -
|
| - // Send the data in |data| to the peer in as few packets as possible.
|
| - // Returns a pair with the number of bytes consumed from data, and a boolean
|
| - // indicating if the fin bit was consumed. This does not indicate the data
|
| - // has been sent on the wire: it may have been turned into a packet and queued
|
| - // if the socket was unexpectedly blocked. |fec_protection| indicates if
|
| - // data is to be FEC protected. Note that data that is sent immediately
|
| - // following MUST_FEC_PROTECT data may get protected by falling within the
|
| - // same FEC group.
|
| - // If |delegate| is provided, then it will be informed once ACKs have been
|
| - // received for all the packets written in this call.
|
| - // The |delegate| is not owned by the QuicConnection and must outlive it.
|
| - QuicConsumedData SendStreamData(QuicStreamId id,
|
| - const IOVector& data,
|
| - QuicStreamOffset offset,
|
| - bool fin,
|
| - FecProtection fec_protection,
|
| - QuicAckNotifier::DelegateInterface* delegate);
|
| -
|
| - // Send a RST_STREAM frame to the peer.
|
| - virtual void SendRstStream(QuicStreamId id,
|
| - QuicRstStreamErrorCode error,
|
| - QuicStreamOffset bytes_written);
|
| -
|
| - // Send a BLOCKED frame to the peer.
|
| - virtual void SendBlocked(QuicStreamId id);
|
| -
|
| - // Send a WINDOW_UPDATE frame to the peer.
|
| - virtual void SendWindowUpdate(QuicStreamId id,
|
| - QuicStreamOffset byte_offset);
|
| -
|
| - // Sends the connection close packet without affecting the state of the
|
| - // connection. This should only be called if the session is actively being
|
| - // destroyed: otherwise call SendConnectionCloseWithDetails instead.
|
| - virtual void SendConnectionClosePacket(QuicErrorCode error,
|
| - const std::string& details);
|
| -
|
| - // Sends a connection close frame to the peer, and closes the connection by
|
| - // calling CloseConnection(notifying the visitor as it does so).
|
| - virtual void SendConnectionClose(QuicErrorCode error);
|
| - virtual void SendConnectionCloseWithDetails(QuicErrorCode error,
|
| - const std::string& details);
|
| - // Notifies the visitor of the close and marks the connection as disconnected.
|
| - void CloseConnection(QuicErrorCode error, bool from_peer) override;
|
| - virtual void SendGoAway(QuicErrorCode error,
|
| - QuicStreamId last_good_stream_id,
|
| - const std::string& reason);
|
| -
|
| - // Returns statistics tracked for this connection.
|
| - const QuicConnectionStats& GetStats();
|
| -
|
| - // Processes an incoming UDP packet (consisting of a QuicEncryptedPacket) from
|
| - // the peer. If processing this packet permits a packet to be revived from
|
| - // its FEC group that packet will be revived and processed.
|
| - virtual void ProcessUdpPacket(const IPEndPoint& self_address,
|
| - const IPEndPoint& peer_address,
|
| - const QuicEncryptedPacket& packet);
|
| -
|
| - // QuicBlockedWriterInterface
|
| - // Called when the underlying connection becomes writable to allow queued
|
| - // writes to happen.
|
| - void OnCanWrite() override;
|
| -
|
| - // Called when an error occurs while attempting to write a packet to the
|
| - // network.
|
| - void OnWriteError(int error_code);
|
| -
|
| - // If the socket is not blocked, writes queued packets.
|
| - void WriteIfNotBlocked();
|
| -
|
| - // The version of the protocol this connection is using.
|
| - QuicVersion version() const { return framer_.version(); }
|
| -
|
| - // The versions of the protocol that this connection supports.
|
| - const QuicVersionVector& supported_versions() const {
|
| - return framer_.supported_versions();
|
| - }
|
| -
|
| - // From QuicFramerVisitorInterface
|
| - void OnError(QuicFramer* framer) override;
|
| - bool OnProtocolVersionMismatch(QuicVersion received_version) override;
|
| - void OnPacket() override;
|
| - void OnPublicResetPacket(const QuicPublicResetPacket& packet) override;
|
| - void OnVersionNegotiationPacket(
|
| - const QuicVersionNegotiationPacket& packet) override;
|
| - void OnRevivedPacket() override;
|
| - bool OnUnauthenticatedPublicHeader(
|
| - const QuicPacketPublicHeader& header) override;
|
| - bool OnUnauthenticatedHeader(const QuicPacketHeader& header) override;
|
| - void OnDecryptedPacket(EncryptionLevel level) override;
|
| - bool OnPacketHeader(const QuicPacketHeader& header) override;
|
| - void OnFecProtectedPayload(base::StringPiece payload) override;
|
| - bool OnStreamFrame(const QuicStreamFrame& frame) override;
|
| - bool OnAckFrame(const QuicAckFrame& frame) override;
|
| - bool OnStopWaitingFrame(const QuicStopWaitingFrame& frame) override;
|
| - bool OnPingFrame(const QuicPingFrame& frame) override;
|
| - bool OnRstStreamFrame(const QuicRstStreamFrame& frame) override;
|
| - bool OnConnectionCloseFrame(const QuicConnectionCloseFrame& frame) override;
|
| - bool OnGoAwayFrame(const QuicGoAwayFrame& frame) override;
|
| - bool OnWindowUpdateFrame(const QuicWindowUpdateFrame& frame) override;
|
| - bool OnBlockedFrame(const QuicBlockedFrame& frame) override;
|
| - void OnFecData(const QuicFecData& fec) override;
|
| - void OnPacketComplete() override;
|
| -
|
| - // QuicPacketGenerator::DelegateInterface
|
| - bool ShouldGeneratePacket(TransmissionType transmission_type,
|
| - HasRetransmittableData retransmittable,
|
| - IsHandshake handshake) override;
|
| - void PopulateAckFrame(QuicAckFrame* ack) override;
|
| - void PopulateStopWaitingFrame(QuicStopWaitingFrame* stop_waiting) override;
|
| - void OnSerializedPacket(const SerializedPacket& packet) override;
|
| -
|
| - // QuicSentPacketManager::NetworkChangeVisitor
|
| - void OnCongestionWindowChange() override;
|
| - void OnRttChange() override;
|
| -
|
| - // Called by the crypto stream when the handshake completes. In the server's
|
| - // case this is when the SHLO has been ACKed. Clients call this on receipt of
|
| - // the SHLO.
|
| - void OnHandshakeComplete();
|
| -
|
| - // Accessors
|
| - void set_visitor(QuicConnectionVisitorInterface* visitor) {
|
| - visitor_ = visitor;
|
| - }
|
| - // This method takes ownership of |debug_visitor|.
|
| - void set_debug_visitor(QuicConnectionDebugVisitor* debug_visitor) {
|
| - debug_visitor_.reset(debug_visitor);
|
| - packet_generator_.set_debug_delegate(debug_visitor);
|
| - sent_packet_manager_.set_debug_delegate(debug_visitor);
|
| - }
|
| - const IPEndPoint& self_address() const { return self_address_; }
|
| - const IPEndPoint& peer_address() const { return peer_address_; }
|
| - QuicConnectionId connection_id() const { return connection_id_; }
|
| - const QuicClock* clock() const { return clock_; }
|
| - QuicRandom* random_generator() const { return random_generator_; }
|
| - QuicByteCount max_packet_length() const;
|
| - void set_max_packet_length(QuicByteCount length);
|
| -
|
| - bool connected() const { return connected_; }
|
| -
|
| - // Must only be called on client connections.
|
| - const QuicVersionVector& server_supported_versions() const {
|
| - DCHECK(!is_server_);
|
| - return server_supported_versions_;
|
| - }
|
| -
|
| - size_t NumFecGroups() const { return group_map_.size(); }
|
| -
|
| - // Testing only.
|
| - size_t NumQueuedPackets() const { return queued_packets_.size(); }
|
| -
|
| - QuicEncryptedPacket* ReleaseConnectionClosePacket() {
|
| - return connection_close_packet_.release();
|
| - }
|
| -
|
| - // Returns true if the underlying UDP socket is writable, there is
|
| - // no queued data and the connection is not congestion-control
|
| - // blocked.
|
| - bool CanWriteStreamData();
|
| -
|
| - // Returns true if the connection has queued packets or frames.
|
| - bool HasQueuedData() const;
|
| -
|
| - // Sets the overall and idle state connection timeouts.
|
| - void SetNetworkTimeouts(QuicTime::Delta overall_timeout,
|
| - QuicTime::Delta idle_timeout);
|
| -
|
| - // If the connection has timed out, this will close the connection.
|
| - // Otherwise, it will reschedule the timeout alarm.
|
| - void CheckForTimeout();
|
| -
|
| - // Sends a ping, and resets the ping alarm.
|
| - void SendPing();
|
| -
|
| - // Sets up a packet with an QuicAckFrame and sends it out.
|
| - void SendAck();
|
| -
|
| - // Called when an RTO fires. Resets the retransmission alarm if there are
|
| - // remaining unacked packets.
|
| - void OnRetransmissionTimeout();
|
| -
|
| - // Called when a data packet is sent. Starts an alarm if the data sent in
|
| - // |sequence_number| was FEC protected.
|
| - void MaybeSetFecAlarm(QuicPacketSequenceNumber sequence_number);
|
| -
|
| - // Retransmits all unacked packets with retransmittable frames if
|
| - // |retransmission_type| is ALL_UNACKED_PACKETS, otherwise retransmits only
|
| - // initially encrypted packets. Used when the negotiated protocol version is
|
| - // different from what was initially assumed and when the initial encryption
|
| - // changes.
|
| - void RetransmitUnackedPackets(TransmissionType retransmission_type);
|
| -
|
| - // Calls |sent_packet_manager_|'s NeuterUnencryptedPackets. Used when the
|
| - // connection becomes forward secure and hasn't received acks for all packets.
|
| - void NeuterUnencryptedPackets();
|
| -
|
| - // Changes the encrypter used for level |level| to |encrypter|. The function
|
| - // takes ownership of |encrypter|.
|
| - void SetEncrypter(EncryptionLevel level, QuicEncrypter* encrypter);
|
| - const QuicEncrypter* encrypter(EncryptionLevel level) const;
|
| -
|
| - // SetDefaultEncryptionLevel sets the encryption level that will be applied
|
| - // to new packets.
|
| - void SetDefaultEncryptionLevel(EncryptionLevel level);
|
| -
|
| - // 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(QuicDecrypter* decrypter, EncryptionLevel level);
|
| -
|
| - // 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(QuicDecrypter* decrypter,
|
| - EncryptionLevel level,
|
| - bool latch_once_used);
|
| -
|
| - const QuicDecrypter* decrypter() const;
|
| - const QuicDecrypter* alternative_decrypter() const;
|
| -
|
| - bool is_server() const { return is_server_; }
|
| -
|
| - // Allow easy overriding of truncated connection IDs.
|
| - void set_can_truncate_connection_ids(bool can) {
|
| - can_truncate_connection_ids_ = can;
|
| - }
|
| -
|
| - // Returns the underlying sent packet manager.
|
| - const QuicSentPacketManager& sent_packet_manager() const {
|
| - return sent_packet_manager_;
|
| - }
|
| -
|
| - bool CanWrite(HasRetransmittableData retransmittable);
|
| -
|
| - // Stores current batch state for connection, puts the connection
|
| - // into batch mode, and destruction restores the stored batch state.
|
| - // While the bundler is in scope, any generated frames are bundled
|
| - // as densely as possible into packets. In addition, this bundler
|
| - // can be configured to ensure that an ACK frame is included in the
|
| - // first packet created, if there's new ack information to be sent.
|
| - class ScopedPacketBundler {
|
| - public:
|
| - // In addition to all outgoing frames being bundled when the
|
| - // bundler is in scope, setting |include_ack| to true ensures that
|
| - // an ACK frame is opportunistically bundled with the first
|
| - // outgoing packet.
|
| - ScopedPacketBundler(QuicConnection* connection, AckBundling send_ack);
|
| - ~ScopedPacketBundler();
|
| -
|
| - private:
|
| - QuicConnection* connection_;
|
| - bool already_in_batch_mode_;
|
| - };
|
| -
|
| - QuicPacketSequenceNumber sequence_number_of_last_sent_packet() const {
|
| - return sequence_number_of_last_sent_packet_;
|
| - }
|
| - const QuicPacketWriter* writer() const { return writer_; }
|
| -
|
| - bool is_secure() const { return is_secure_; }
|
| -
|
| - protected:
|
| - // Packets which have not been written to the wire.
|
| - // Owns the QuicPacket* packet.
|
| - struct QueuedPacket {
|
| - QueuedPacket(SerializedPacket packet,
|
| - EncryptionLevel level);
|
| - QueuedPacket(SerializedPacket packet,
|
| - EncryptionLevel level,
|
| - TransmissionType transmission_type,
|
| - QuicPacketSequenceNumber original_sequence_number);
|
| -
|
| - SerializedPacket serialized_packet;
|
| - const EncryptionLevel encryption_level;
|
| - TransmissionType transmission_type;
|
| - // The packet's original sequence number if it is a retransmission.
|
| - // Otherwise it must be 0.
|
| - QuicPacketSequenceNumber original_sequence_number;
|
| - };
|
| -
|
| - // Do any work which logically would be done in OnPacket but can not be
|
| - // safely done until the packet is validated. Returns true if the packet
|
| - // can be handled, false otherwise.
|
| - virtual bool ProcessValidatedPacket();
|
| -
|
| - // Send a packet to the peer, and takes ownership of the packet if the packet
|
| - // cannot be written immediately.
|
| - virtual void SendOrQueuePacket(QueuedPacket packet);
|
| -
|
| - QuicConnectionHelperInterface* helper() { return helper_; }
|
| -
|
| - // Selects and updates the version of the protocol being used by selecting a
|
| - // version from |available_versions| which is also supported. Returns true if
|
| - // such a version exists, false otherwise.
|
| - bool SelectMutualVersion(const QuicVersionVector& available_versions);
|
| -
|
| - QuicPacketWriter* writer() { return writer_; }
|
| -
|
| - bool peer_port_changed() const { return peer_port_changed_; }
|
| -
|
| - private:
|
| - friend class test::QuicConnectionPeer;
|
| - friend class test::PacketSavingConnection;
|
| -
|
| - typedef std::list<QueuedPacket> QueuedPacketList;
|
| - typedef std::map<QuicFecGroupNumber, QuicFecGroup*> FecGroupMap;
|
| -
|
| - // Writes the given packet to socket, encrypted with packet's
|
| - // encryption_level. Returns true on successful write, and false if the writer
|
| - // was blocked and the write needs to be tried again. Notifies the
|
| - // SentPacketManager when the write is successful and sets
|
| - // retransmittable frames to nullptr.
|
| - // Saves the connection close packet for later transmission, even if the
|
| - // writer is write blocked.
|
| - bool WritePacket(QueuedPacket* packet);
|
| -
|
| - // Does the main work of WritePacket, but does not delete the packet or
|
| - // retransmittable frames upon success.
|
| - bool WritePacketInner(QueuedPacket* packet);
|
| -
|
| - // Make sure an ack we got from our peer is sane.
|
| - bool ValidateAckFrame(const QuicAckFrame& incoming_ack);
|
| -
|
| - // Make sure a stop waiting we got from our peer is sane.
|
| - bool ValidateStopWaitingFrame(const QuicStopWaitingFrame& stop_waiting);
|
| -
|
| - // Sends a version negotiation packet to the peer.
|
| - void SendVersionNegotiationPacket();
|
| -
|
| - // Clears any accumulated frames from the last received packet.
|
| - void ClearLastFrames();
|
| -
|
| - // Closes the connection if the sent or received packet manager are tracking
|
| - // too many outstanding packets.
|
| - void MaybeCloseIfTooManyOutstandingPackets();
|
| -
|
| - // Writes as many queued packets as possible. The connection must not be
|
| - // blocked when this is called.
|
| - void WriteQueuedPackets();
|
| -
|
| - // Writes as many pending retransmissions as possible.
|
| - void WritePendingRetransmissions();
|
| -
|
| - // Returns true if the packet should be discarded and not sent.
|
| - bool ShouldDiscardPacket(const QueuedPacket& packet);
|
| -
|
| - // Queues |packet| in the hopes that it can be decrypted in the
|
| - // future, when a new key is installed.
|
| - void QueueUndecryptablePacket(const QuicEncryptedPacket& packet);
|
| -
|
| - // Attempts to process any queued undecryptable packets.
|
| - void MaybeProcessUndecryptablePackets();
|
| -
|
| - // If a packet can be revived from the current FEC group, then
|
| - // revive and process the packet.
|
| - void MaybeProcessRevivedPacket();
|
| -
|
| - void ProcessAckFrame(const QuicAckFrame& incoming_ack);
|
| -
|
| - void ProcessStopWaitingFrame(const QuicStopWaitingFrame& stop_waiting);
|
| -
|
| - // Queues an ack or sets the ack alarm when an incoming packet arrives that
|
| - // should be acked.
|
| - void MaybeQueueAck();
|
| -
|
| - // Checks if the last packet should instigate an ack.
|
| - bool ShouldLastPacketInstigateAck() const;
|
| -
|
| - // Checks if the peer is waiting for packets that have been given up on, and
|
| - // therefore an ack frame should be sent with a larger least_unacked.
|
| - void UpdateStopWaitingCount();
|
| -
|
| - // Sends any packets which are a response to the last packet, including both
|
| - // acks and pending writes if an ack opened the congestion window.
|
| - void MaybeSendInResponseToPacket();
|
| -
|
| - // Gets the least unacked sequence number, which is the next sequence number
|
| - // to be sent if there are no outstanding packets.
|
| - QuicPacketSequenceNumber GetLeastUnacked() const;
|
| -
|
| - // Get the FEC group associate with the last processed packet or nullptr, if
|
| - // the group has already been deleted.
|
| - QuicFecGroup* GetFecGroup();
|
| -
|
| - // Closes any FEC groups protecting packets before |sequence_number|.
|
| - void CloseFecGroupsBefore(QuicPacketSequenceNumber sequence_number);
|
| -
|
| - // Sets the timeout alarm to the appropriate value, if any.
|
| - void SetTimeoutAlarm();
|
| -
|
| - // Sets the ping alarm to the appropriate value, if any.
|
| - void SetPingAlarm();
|
| -
|
| - // On arrival of a new packet, checks to see if the socket addresses have
|
| - // changed since the last packet we saw on this connection.
|
| - void CheckForAddressMigration(const IPEndPoint& self_address,
|
| - const IPEndPoint& peer_address);
|
| -
|
| - HasRetransmittableData IsRetransmittable(const QueuedPacket& packet);
|
| - bool IsConnectionClose(const QueuedPacket& packet);
|
| -
|
| - QuicFramer framer_;
|
| - QuicConnectionHelperInterface* helper_; // Not owned.
|
| - QuicPacketWriter* writer_; // Owned or not depending on |owns_writer_|.
|
| - bool owns_writer_;
|
| - // Encryption level for new packets. Should only be changed via
|
| - // SetDefaultEncryptionLevel().
|
| - EncryptionLevel encryption_level_;
|
| - bool has_forward_secure_encrypter_;
|
| - // The sequence number of the first packet which will be encrypted with the
|
| - // foward-secure encrypter, even if the peer has not started sending
|
| - // forward-secure packets.
|
| - QuicPacketSequenceNumber first_required_forward_secure_packet_;
|
| - const QuicClock* clock_;
|
| - QuicRandom* random_generator_;
|
| -
|
| - const QuicConnectionId connection_id_;
|
| - // Address on the last successfully processed packet received from the
|
| - // client.
|
| - IPEndPoint self_address_;
|
| - IPEndPoint peer_address_;
|
| - // Used to store latest peer port to possibly migrate to later.
|
| - uint16 migrating_peer_port_;
|
| -
|
| - // True if the last packet has gotten far enough in the framer to be
|
| - // decrypted.
|
| - bool last_packet_decrypted_;
|
| - bool last_packet_revived_; // True if the last packet was revived from FEC.
|
| - QuicByteCount last_size_; // Size of the last received packet.
|
| - EncryptionLevel last_decrypted_packet_level_;
|
| - QuicPacketHeader last_header_;
|
| - std::vector<QuicStreamFrame> last_stream_frames_;
|
| - std::vector<QuicAckFrame> last_ack_frames_;
|
| - std::vector<QuicStopWaitingFrame> last_stop_waiting_frames_;
|
| - std::vector<QuicRstStreamFrame> last_rst_frames_;
|
| - std::vector<QuicGoAwayFrame> last_goaway_frames_;
|
| - std::vector<QuicWindowUpdateFrame> last_window_update_frames_;
|
| - std::vector<QuicBlockedFrame> last_blocked_frames_;
|
| - std::vector<QuicPingFrame> last_ping_frames_;
|
| - std::vector<QuicConnectionCloseFrame> last_close_frames_;
|
| -
|
| - // Track some peer state so we can do less bookkeeping
|
| - // Largest sequence sent by the peer which had an ack frame (latest ack info).
|
| - QuicPacketSequenceNumber largest_seen_packet_with_ack_;
|
| -
|
| - // Largest sequence number sent by the peer which had a stop waiting frame.
|
| - QuicPacketSequenceNumber largest_seen_packet_with_stop_waiting_;
|
| -
|
| - // Collection of packets which were received before encryption was
|
| - // established, but which could not be decrypted. We buffer these on
|
| - // the assumption that they could not be processed because they were
|
| - // sent with the INITIAL encryption and the CHLO message was lost.
|
| - std::deque<QuicEncryptedPacket*> undecryptable_packets_;
|
| -
|
| - // Maximum number of undecryptable packets the connection will store.
|
| - size_t max_undecryptable_packets_;
|
| -
|
| - // When the version negotiation packet could not be sent because the socket
|
| - // was not writable, this is set to true.
|
| - bool pending_version_negotiation_packet_;
|
| -
|
| - // When packets could not be sent because the socket was not writable,
|
| - // they are added to this list. All corresponding frames are in
|
| - // unacked_packets_ if they are to be retransmitted.
|
| - QueuedPacketList queued_packets_;
|
| -
|
| - // Contains the connection close packet if the connection has been closed.
|
| - scoped_ptr<QuicEncryptedPacket> connection_close_packet_;
|
| -
|
| - // When true, the connection does not send a close packet on timeout.
|
| - bool silent_close_enabled_;
|
| -
|
| - FecGroupMap group_map_;
|
| -
|
| - QuicReceivedPacketManager received_packet_manager_;
|
| - QuicSentEntropyManager sent_entropy_manager_;
|
| -
|
| - // Indicates whether an ack should be sent the next time we try to write.
|
| - bool ack_queued_;
|
| - // Indicates how many consecutive packets have arrived without sending an ack.
|
| - QuicPacketCount num_packets_received_since_last_ack_sent_;
|
| - // Indicates how many consecutive times an ack has arrived which indicates
|
| - // the peer needs to stop waiting for some packets.
|
| - int stop_waiting_count_;
|
| -
|
| - // An alarm that fires when an ACK should be sent to the peer.
|
| - scoped_ptr<QuicAlarm> ack_alarm_;
|
| - // An alarm that fires when a packet needs to be retransmitted.
|
| - scoped_ptr<QuicAlarm> retransmission_alarm_;
|
| - // An alarm that is scheduled when the sent scheduler requires a
|
| - // a delay before sending packets and fires when the packet may be sent.
|
| - scoped_ptr<QuicAlarm> send_alarm_;
|
| - // An alarm that is scheduled when the connection can still write and there
|
| - // may be more data to send.
|
| - scoped_ptr<QuicAlarm> resume_writes_alarm_;
|
| - // An alarm that fires when the connection may have timed out.
|
| - scoped_ptr<QuicAlarm> timeout_alarm_;
|
| - // An alarm that fires when a ping should be sent.
|
| - scoped_ptr<QuicAlarm> ping_alarm_;
|
| -
|
| - QuicConnectionVisitorInterface* visitor_;
|
| - scoped_ptr<QuicConnectionDebugVisitor> debug_visitor_;
|
| - QuicPacketGenerator packet_generator_;
|
| -
|
| - // An alarm that fires when an FEC packet should be sent.
|
| - scoped_ptr<QuicAlarm> fec_alarm_;
|
| -
|
| - // Network idle time before we kill of this connection.
|
| - QuicTime::Delta idle_network_timeout_;
|
| - // Overall connection timeout.
|
| - QuicTime::Delta overall_connection_timeout_;
|
| -
|
| - // Statistics for this session.
|
| - QuicConnectionStats stats_;
|
| -
|
| - // The time that we got a packet for this connection.
|
| - // This is used for timeouts, and does not indicate the packet was processed.
|
| - QuicTime time_of_last_received_packet_;
|
| -
|
| - // The last time this connection began sending a new (non-retransmitted)
|
| - // packet.
|
| - QuicTime time_of_last_sent_new_packet_;
|
| -
|
| - // Sequence number of the last sent packet. Packets are guaranteed to be sent
|
| - // in sequence number order.
|
| - QuicPacketSequenceNumber sequence_number_of_last_sent_packet_;
|
| -
|
| - // Sent packet manager which tracks the status of packets sent by this
|
| - // connection and contains the send and receive algorithms to determine when
|
| - // to send packets.
|
| - QuicSentPacketManager sent_packet_manager_;
|
| -
|
| - // The state of connection in version negotiation finite state machine.
|
| - QuicVersionNegotiationState version_negotiation_state_;
|
| -
|
| - // Tracks if the connection was created by the server.
|
| - bool is_server_;
|
| -
|
| - // True by default. False if we've received or sent an explicit connection
|
| - // close.
|
| - bool connected_;
|
| -
|
| - // Set to true if the UDP packet headers have a new IP address for the peer.
|
| - // If true, do not perform connection migration.
|
| - bool peer_ip_changed_;
|
| -
|
| - // Set to true if the UDP packet headers have a new port for the peer.
|
| - // If true, and the IP has not changed, then we can migrate the connection.
|
| - bool peer_port_changed_;
|
| -
|
| - // Set to true if the UDP packet headers are addressed to a different IP.
|
| - // We do not support connection migration when the self IP changed.
|
| - bool self_ip_changed_;
|
| -
|
| - // Set to true if the UDP packet headers are addressed to a different port.
|
| - // We do not support connection migration when the self port changed.
|
| - bool self_port_changed_;
|
| -
|
| - // Set to false if the connection should not send truncated connection IDs to
|
| - // the peer, even if the peer supports it.
|
| - bool can_truncate_connection_ids_;
|
| -
|
| - // If non-empty this contains the set of versions received in a
|
| - // version negotiation packet.
|
| - QuicVersionVector server_supported_versions_;
|
| -
|
| - // True if this is a secure QUIC connection.
|
| - bool is_secure_;
|
| -
|
| - DISALLOW_COPY_AND_ASSIGN(QuicConnection);
|
| -};
|
| -
|
| -} // namespace net
|
| -
|
| -#endif // NET_QUIC_QUIC_CONNECTION_H_
|
|
|