Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(89)

Side by Side Diff: net/quic/core/quic_protocol.h

Issue 2516033003: Landing Recent QUIC changes until Mon Nov 14 04:43:50 2016 +0000 (Closed)
Patch Set: Remove unused UpdatePacketGapSentHistogram() function. Created 4 years, 1 month ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
« no previous file with comments | « net/quic/core/quic_packet_generator_test.cc ('k') | net/quic/core/quic_protocol.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #ifndef NET_QUIC_QUIC_PROTOCOL_H_ 5 #ifndef NET_QUIC_QUIC_PROTOCOL_H_
6 #define NET_QUIC_QUIC_PROTOCOL_H_ 6 #define NET_QUIC_QUIC_PROTOCOL_H_
7 7
8 #include <stddef.h> 8 #include <stddef.h>
9 #include <stdint.h> 9 #include <stdint.h>
10 10
(...skipping 11 matching lines...) Expand all
22 #include "base/logging.h" 22 #include "base/logging.h"
23 #include "base/macros.h" 23 #include "base/macros.h"
24 #include "base/memory/ref_counted.h" 24 #include "base/memory/ref_counted.h"
25 #include "base/strings/string_piece.h" 25 #include "base/strings/string_piece.h"
26 #include "net/base/int128.h" 26 #include "net/base/int128.h"
27 #include "net/base/iovec.h" 27 #include "net/base/iovec.h"
28 #include "net/base/ip_endpoint.h" 28 #include "net/base/ip_endpoint.h"
29 #include "net/base/net_export.h" 29 #include "net/base/net_export.h"
30 #include "net/quic/core/interval_set.h" 30 #include "net/quic/core/interval_set.h"
31 #include "net/quic/core/quic_bandwidth.h" 31 #include "net/quic/core/quic_bandwidth.h"
32 #include "net/quic/core/quic_buffer_allocator.h"
33 #include "net/quic/core/quic_constants.h"
34 #include "net/quic/core/quic_error_codes.h"
32 #include "net/quic/core/quic_time.h" 35 #include "net/quic/core/quic_time.h"
33 #include "net/quic/core/quic_types.h" 36 #include "net/quic/core/quic_types.h"
37 #include "net/quic/core/quic_versions.h"
34 38
35 namespace net { 39 namespace net {
36 40
37 class QuicPacket; 41 class QuicPacket;
38 struct QuicPacketHeader; 42 struct QuicPacketHeader;
39 class QuicAckListenerInterface;
40
41 typedef uint64_t QuicConnectionId;
42 typedef uint32_t QuicStreamId;
43 typedef uint64_t QuicStreamOffset;
44 typedef uint64_t QuicPacketNumber;
45 typedef uint8_t QuicPathId;
46 typedef uint64_t QuicPublicResetNonceProof;
47 typedef uint8_t QuicPacketEntropyHash;
48 typedef uint32_t QuicHeaderId;
49 // QuicTag is the type of a tag in the wire protocol.
50 typedef uint32_t QuicTag;
51 typedef std::vector<QuicTag> QuicTagVector;
52 typedef std::map<QuicTag, std::string> QuicTagValueMap;
53 typedef uint16_t QuicPacketLength;
54
55 // Default initial maximum size in bytes of a QUIC packet.
56 const QuicByteCount kDefaultMaxPacketSize = 1350;
57 // Default initial maximum size in bytes of a QUIC packet for servers.
58 const QuicByteCount kDefaultServerMaxPacketSize = 1000;
59 // The maximum packet size of any QUIC packet, based on ethernet's max size,
60 // minus the IP and UDP headers. IPv6 has a 40 byte header, UDP adds an
61 // additional 8 bytes. This is a total overhead of 48 bytes. Ethernet's
62 // max packet size is 1500 bytes, 1500 - 48 = 1452.
63 const QuicByteCount kMaxPacketSize = 1452;
64 // Default maximum packet size used in the Linux TCP implementation.
65 // Used in QUIC for congestion window computations in bytes.
66 const QuicByteCount kDefaultTCPMSS = 1460;
67
68 // We match SPDY's use of 32 (since we'd compete with SPDY).
69 const QuicPacketCount kInitialCongestionWindow = 32;
70
71 // Minimum size of initial flow control window, for both stream and session.
72 const uint32_t kMinimumFlowControlSendWindow = 16 * 1024; // 16 KB
73
74 // Maximum flow control receive window limits for connection and stream.
75 const QuicByteCount kStreamReceiveWindowLimit = 16 * 1024 * 1024; // 16 MB
76 const QuicByteCount kSessionReceiveWindowLimit = 24 * 1024 * 1024; // 24 MB
77
78 // Default limit on the size of uncompressed headers.
79 const QuicByteCount kDefaultMaxUncompressedHeaderSize = 16 * 1024; // 16 KB
80
81 // Minimum size of the CWND, in packets, when doing bandwidth resumption.
82 const QuicPacketCount kMinCongestionWindowForBandwidthResumption = 10;
83
84 // Maximum number of tracked packets.
85 const QuicPacketCount kMaxTrackedPackets = 10000;
86
87 // Default size of the socket receive buffer in bytes.
88 const QuicByteCount kDefaultSocketReceiveBuffer = 1024 * 1024;
89
90 // Don't allow a client to suggest an RTT shorter than 10ms.
91 const uint32_t kMinInitialRoundTripTimeUs = 10 * kNumMicrosPerMilli;
92
93 // Don't allow a client to suggest an RTT longer than 15 seconds.
94 const uint32_t kMaxInitialRoundTripTimeUs = 15 * kNumMicrosPerSecond;
95
96 // Maximum number of open streams per connection.
97 const size_t kDefaultMaxStreamsPerConnection = 100;
98
99 // Number of bytes reserved for public flags in the packet header.
100 const size_t kPublicFlagsSize = 1;
101 // Number of bytes reserved for version number in the packet header.
102 const size_t kQuicVersionSize = 4;
103 // Number of bytes reserved for path id in the packet header.
104 const size_t kQuicPathIdSize = 1;
105 // Number of bytes reserved for private flags in the packet header.
106 const size_t kPrivateFlagsSize = 1;
107
108 // Signifies that the QuicPacket will contain version of the protocol.
109 const bool kIncludeVersion = true;
110 // Signifies that the QuicPacket will contain path id.
111 const bool kIncludePathId = true;
112 // Signifies that the QuicPacket will include a diversification nonce.
113 const bool kIncludeDiversificationNonce = true;
114
115 // Stream ID is reserved to denote an invalid ID.
116 const QuicStreamId kInvalidStreamId = 0;
117
118 // Reserved ID for the crypto stream.
119 const QuicStreamId kCryptoStreamId = 1;
120
121 // Reserved ID for the headers stream.
122 const QuicStreamId kHeadersStreamId = 3;
123
124 // Header key used to identify final offset on data stream when sending HTTP/2
125 // trailing headers over QUIC.
126 NET_EXPORT_PRIVATE extern const char* const kFinalOffsetHeaderKey;
127
128 // Maximum delayed ack time, in ms.
129 const int64_t kMaxDelayedAckTimeMs = 25;
130
131 // Minimum tail loss probe time in ms.
132 static const int64_t kMinTailLossProbeTimeoutMs = 10;
133
134 // The timeout before the handshake succeeds.
135 const int64_t kInitialIdleTimeoutSecs = 5;
136 // The default idle timeout.
137 const int64_t kDefaultIdleTimeoutSecs = 30;
138 // The maximum idle timeout that can be negotiated.
139 const int64_t kMaximumIdleTimeoutSecs = 60 * 10; // 10 minutes.
140 // The default timeout for a connection until the crypto handshake succeeds.
141 const int64_t kMaxTimeForCryptoHandshakeSecs = 10; // 10 secs.
142
143 // Default limit on the number of undecryptable packets the connection buffers
144 // before the CHLO/SHLO arrive.
145 const size_t kDefaultMaxUndecryptablePackets = 10;
146
147 // Default ping timeout.
148 const int64_t kPingTimeoutSecs = 15; // 15 secs.
149
150 // Minimum number of RTTs between Server Config Updates (SCUP) sent to client.
151 const int kMinIntervalBetweenServerConfigUpdatesRTTs = 10;
152
153 // Minimum time between Server Config Updates (SCUP) sent to client.
154 const int kMinIntervalBetweenServerConfigUpdatesMs = 1000;
155
156 // Minimum number of packets between Server Config Updates (SCUP).
157 const int kMinPacketsBetweenServerConfigUpdates = 100;
158
159 // The number of open streams that a server will accept is set to be slightly
160 // larger than the negotiated limit. Immediately closing the connection if the
161 // client opens slightly too many streams is not ideal: the client may have sent
162 // a FIN that was lost, and simultaneously opened a new stream. The number of
163 // streams a server accepts is a fixed increment over the negotiated limit, or a
164 // percentage increase, whichever is larger.
165 const float kMaxStreamsMultiplier = 1.1f;
166 const int kMaxStreamsMinimumIncrement = 10;
167
168 // Available streams are ones with IDs less than the highest stream that has
169 // been opened which have neither been opened or reset. The limit on the number
170 // of available streams is 10 times the limit on the number of open streams.
171 const int kMaxAvailableStreamsMultiplier = 10;
172
173 // Track the number of promises that are not yet claimed by a
174 // corresponding get. This must be smaller than
175 // kMaxAvailableStreamsMultiplier, because RST on a promised stream my
176 // create available streams entries.
177 const int kMaxPromisedStreamsMultiplier = kMaxAvailableStreamsMultiplier - 1;
178
179 // TCP RFC calls for 1 second RTO however Linux differs from this default and
180 // define the minimum RTO to 200ms, we will use the same until we have data to
181 // support a higher or lower value.
182 static const int64_t kMinRetransmissionTimeMs = 200;
183
184 // We define an unsigned 16-bit floating point value, inspired by IEEE floats
185 // (http://en.wikipedia.org/wiki/Half_precision_floating-point_format),
186 // with 5-bit exponent (bias 1), 11-bit mantissa (effective 12 with hidden
187 // bit) and denormals, but without signs, transfinites or fractions. Wire format
188 // 16 bits (little-endian byte order) are split into exponent (high 5) and
189 // mantissa (low 11) and decoded as:
190 // uint64_t value;
191 // if (exponent == 0) value = mantissa;
192 // else value = (mantissa | 1 << 11) << (exponent - 1)
193 const int kUFloat16ExponentBits = 5;
194 const int kUFloat16MaxExponent = (1 << kUFloat16ExponentBits) - 2; // 30
195 const int kUFloat16MantissaBits = 16 - kUFloat16ExponentBits; // 11
196 const int kUFloat16MantissaEffectiveBits = kUFloat16MantissaBits + 1; // 12
197 const uint64_t kUFloat16MaxValue = // 0x3FFC0000000
198 ((UINT64_C(1) << kUFloat16MantissaEffectiveBits) - 1)
199 << kUFloat16MaxExponent;
200
201 // Default path ID.
202 const QuicPathId kDefaultPathId = 0;
203 // Invalid path ID.
204 const QuicPathId kInvalidPathId = 0xff;
205
206 // kDiversificationNonceSize is the size, in bytes, of the nonce that a server
207 // may set in the packet header to ensure that its INITIAL keys are not
208 // duplicated.
209 const size_t kDiversificationNonceSize = 32;
210
211 // The largest gap in packets we'll accept without closing the connection.
212 // This will likely have to be tuned.
213 const QuicPacketNumber kMaxPacketGap = 5000;
214
215 enum TransmissionType : int8_t {
216 NOT_RETRANSMISSION,
217 FIRST_TRANSMISSION_TYPE = NOT_RETRANSMISSION,
218 HANDSHAKE_RETRANSMISSION, // Retransmits due to handshake timeouts.
219 ALL_UNACKED_RETRANSMISSION, // Retransmits all unacked packets.
220 ALL_INITIAL_RETRANSMISSION, // Retransmits all initially encrypted packets.
221 LOSS_RETRANSMISSION, // Retransmits due to loss detection.
222 RTO_RETRANSMISSION, // Retransmits due to retransmit time out.
223 TLP_RETRANSMISSION, // Tail loss probes.
224 LAST_TRANSMISSION_TYPE = TLP_RETRANSMISSION,
225 };
226
227 enum HasRetransmittableData : int8_t {
228 NO_RETRANSMITTABLE_DATA,
229 HAS_RETRANSMITTABLE_DATA,
230 };
231
232 enum IsHandshake : int8_t { NOT_HANDSHAKE, IS_HANDSHAKE };
233
234 enum class Perspective { IS_SERVER, IS_CLIENT };
235
236 // Describes whether a ConnectionClose was originated by the peer.
237 enum class ConnectionCloseSource { FROM_PEER, FROM_SELF };
238
239 // Should a connection be closed silently or not.
240 enum class ConnectionCloseBehavior {
241 SILENT_CLOSE,
242 SEND_CONNECTION_CLOSE_PACKET,
243 SEND_CONNECTION_CLOSE_PACKET_WITH_NO_ACK
244 };
245
246 NET_EXPORT_PRIVATE std::ostream& operator<<(std::ostream& os,
247 const Perspective& s);
248 enum QuicFrameType {
249 // Regular frame types. The values set here cannot change without the
250 // introduction of a new QUIC version.
251 PADDING_FRAME = 0,
252 RST_STREAM_FRAME = 1,
253 CONNECTION_CLOSE_FRAME = 2,
254 GOAWAY_FRAME = 3,
255 WINDOW_UPDATE_FRAME = 4,
256 BLOCKED_FRAME = 5,
257 STOP_WAITING_FRAME = 6,
258 PING_FRAME = 7,
259 PATH_CLOSE_FRAME = 8,
260
261 // STREAM and ACK frames are special frames. They are encoded differently on
262 // the wire and their values do not need to be stable.
263 STREAM_FRAME,
264 ACK_FRAME,
265 // The path MTU discovery frame is encoded as a PING frame on the wire.
266 MTU_DISCOVERY_FRAME,
267 NUM_FRAME_TYPES
268 };
269
270 enum QuicConnectionIdLength {
271 PACKET_0BYTE_CONNECTION_ID = 0,
272 PACKET_8BYTE_CONNECTION_ID = 8
273 };
274
275 enum QuicPacketNumberLength : int8_t {
276 PACKET_1BYTE_PACKET_NUMBER = 1,
277 PACKET_2BYTE_PACKET_NUMBER = 2,
278 PACKET_4BYTE_PACKET_NUMBER = 4,
279 PACKET_6BYTE_PACKET_NUMBER = 6
280 };
281
282 // Used to indicate a QuicSequenceNumberLength using two flag bits.
283 enum QuicPacketNumberLengthFlags {
284 PACKET_FLAGS_1BYTE_PACKET = 0, // 00
285 PACKET_FLAGS_2BYTE_PACKET = 1, // 01
286 PACKET_FLAGS_4BYTE_PACKET = 1 << 1, // 10
287 PACKET_FLAGS_6BYTE_PACKET = 1 << 1 | 1, // 11
288 };
289
290 // The public flags are specified in one byte.
291 enum QuicPacketPublicFlags {
292 PACKET_PUBLIC_FLAGS_NONE = 0,
293
294 // Bit 0: Does the packet header contains version info?
295 PACKET_PUBLIC_FLAGS_VERSION = 1 << 0,
296
297 // Bit 1: Is this packet a public reset packet?
298 PACKET_PUBLIC_FLAGS_RST = 1 << 1,
299
300 // Bit 2: indicates the that public header includes a nonce.
301 PACKET_PUBLIC_FLAGS_NONCE = 1 << 2,
302
303 // Bit 3: indicates whether a ConnectionID is included.
304 PACKET_PUBLIC_FLAGS_0BYTE_CONNECTION_ID = 0,
305 PACKET_PUBLIC_FLAGS_8BYTE_CONNECTION_ID = 1 << 3,
306
307 // QUIC_VERSION_32 and earlier use two bits for an 8 byte
308 // connection id.
309 PACKET_PUBLIC_FLAGS_8BYTE_CONNECTION_ID_OLD = 1 << 3 | 1 << 2,
310
311 // Bits 4 and 5 describe the packet number length as follows:
312 // --00----: 1 byte
313 // --01----: 2 bytes
314 // --10----: 4 bytes
315 // --11----: 6 bytes
316 PACKET_PUBLIC_FLAGS_1BYTE_PACKET = PACKET_FLAGS_1BYTE_PACKET << 4,
317 PACKET_PUBLIC_FLAGS_2BYTE_PACKET = PACKET_FLAGS_2BYTE_PACKET << 4,
318 PACKET_PUBLIC_FLAGS_4BYTE_PACKET = PACKET_FLAGS_4BYTE_PACKET << 4,
319 PACKET_PUBLIC_FLAGS_6BYTE_PACKET = PACKET_FLAGS_6BYTE_PACKET << 4,
320
321 // Bit 6: Does the packet header contain a path id?
322 PACKET_PUBLIC_FLAGS_MULTIPATH = 1 << 6,
323
324 // Reserved, unimplemented flags:
325
326 // Bit 7: indicates the presence of a second flags byte.
327 PACKET_PUBLIC_FLAGS_TWO_OR_MORE_BYTES = 1 << 7,
328
329 // All bits set (bit 7 is not currently used): 01111111
330 PACKET_PUBLIC_FLAGS_MAX = (1 << 7) - 1,
331 };
332
333 // The private flags are specified in one byte.
334 enum QuicPacketPrivateFlags {
335 PACKET_PRIVATE_FLAGS_NONE = 0,
336
337 // Bit 0: Does this packet contain an entropy bit?
338 PACKET_PRIVATE_FLAGS_ENTROPY = 1 << 0,
339
340 // (bits 1-7 are not used): 00000001
341 PACKET_PRIVATE_FLAGS_MAX = (1 << 1) - 1
342 };
343
344 // The available versions of QUIC. Guaranteed that the integer value of the enum
345 // will match the version number.
346 // When adding a new version to this enum you should add it to
347 // kSupportedQuicVersions (if appropriate), and also add a new case to the
348 // helper methods QuicVersionToQuicTag, QuicTagToQuicVersion, and
349 // QuicVersionToString.
350 enum QuicVersion {
351 // Special case to indicate unknown/unsupported QUIC version.
352 QUIC_VERSION_UNSUPPORTED = 0,
353
354 QUIC_VERSION_32 = 32, // FEC related fields are removed from wire format.
355 QUIC_VERSION_33 = 33, // Adds diversification nonces.
356 QUIC_VERSION_34 = 34, // Deprecates entropy, removes private flag from packet
357 // header, uses new ack and stop waiting wire format.
358 QUIC_VERSION_35 = 35, // Allows endpoints to independently set stream limit.
359 QUIC_VERSION_36 = 36, // Add support to force HOL blocking.
360
361 // IMPORTANT: if you are adding to this std::list, follow the instructions at
362 // http://sites/quic/adding-and-removing-versions
363 };
364
365 // This vector contains QUIC versions which we currently support.
366 // This should be ordered such that the highest supported version is the first
367 // element, with subsequent elements in descending order (versions can be
368 // skipped as necessary).
369 //
370 // IMPORTANT: if you are adding to this list, follow the instructions at
371 // http://sites/quic/adding-and-removing-versions
372 static const QuicVersion kSupportedQuicVersions[] = {
373 QUIC_VERSION_36, QUIC_VERSION_35, QUIC_VERSION_34, QUIC_VERSION_33,
374 QUIC_VERSION_32};
375
376 typedef std::vector<QuicVersion> QuicVersionVector;
377
378 // Returns a vector of QUIC versions in kSupportedQuicVersions.
379 NET_EXPORT_PRIVATE QuicVersionVector AllSupportedVersions();
380
381 // Returns a vector of QUIC versions from kSupportedQuicVersions which exclude
382 // any versions which are disabled by flags.
383 NET_EXPORT_PRIVATE QuicVersionVector CurrentSupportedVersions();
384
385 // Returns a vector of QUIC versions from |versions| which exclude any versions
386 // which are disabled by flags.
387 NET_EXPORT_PRIVATE QuicVersionVector
388 FilterSupportedVersions(QuicVersionVector versions);
389
390 // Returns QUIC version of |index| in result of |versions|. Returns
391 // QUIC_VERSION_UNSUPPORTED if |index| is out of bounds.
392 NET_EXPORT_PRIVATE QuicVersionVector
393 VersionOfIndex(const QuicVersionVector& versions, int index);
394
395 // QuicTag is written to and read from the wire, but we prefer to use
396 // the more readable QuicVersion at other levels.
397 // Helper function which translates from a QuicVersion to a QuicTag. Returns 0
398 // if QuicVersion is unsupported.
399 NET_EXPORT_PRIVATE QuicTag QuicVersionToQuicTag(const QuicVersion version);
400
401 // Returns appropriate QuicVersion from a QuicTag.
402 // Returns QUIC_VERSION_UNSUPPORTED if version_tag cannot be understood.
403 NET_EXPORT_PRIVATE QuicVersion QuicTagToQuicVersion(const QuicTag version_tag);
404
405 // Helper function which translates from a QuicVersion to a string.
406 // Returns strings corresponding to enum names (e.g. QUIC_VERSION_6).
407 NET_EXPORT_PRIVATE std::string QuicVersionToString(const QuicVersion version);
408
409 // Returns comma separated list of string representations of QuicVersion enum
410 // values in the supplied |versions| vector.
411 NET_EXPORT_PRIVATE std::string QuicVersionVectorToString(
412 const QuicVersionVector& versions);
413
414 // Version and Crypto tags are written to the wire with a big-endian
415 // representation of the name of the tag. For example
416 // the client hello tag (CHLO) will be written as the
417 // following 4 bytes: 'C' 'H' 'L' 'O'. Since it is
418 // stored in memory as a little endian uint32_t, we need
419 // to reverse the order of the bytes.
420
421 // MakeQuicTag returns a value given the four bytes. For example:
422 // MakeQuicTag('C', 'H', 'L', 'O');
423 NET_EXPORT_PRIVATE QuicTag MakeQuicTag(char a, char b, char c, char d);
424
425 // Returns true if the tag vector contains the specified tag.
426 NET_EXPORT_PRIVATE bool ContainsQuicTag(const QuicTagVector& tag_vector,
427 QuicTag tag);
428 43
429 // Size in bytes of the data packet header. 44 // Size in bytes of the data packet header.
430 NET_EXPORT_PRIVATE size_t GetPacketHeaderSize(QuicVersion version, 45 NET_EXPORT_PRIVATE size_t GetPacketHeaderSize(QuicVersion version,
431 const QuicPacketHeader& header); 46 const QuicPacketHeader& header);
432 47
433 NET_EXPORT_PRIVATE size_t 48 NET_EXPORT_PRIVATE size_t
434 GetPacketHeaderSize(QuicVersion version, 49 GetPacketHeaderSize(QuicVersion version,
435 QuicConnectionIdLength connection_id_length, 50 QuicConnectionIdLength connection_id_length,
436 bool include_version, 51 bool include_version,
437 bool include_path_id, 52 bool include_path_id,
438 bool include_diversification_nonce, 53 bool include_diversification_nonce,
439 QuicPacketNumberLength packet_number_length); 54 QuicPacketNumberLength packet_number_length);
440 55
441 // Index of the first byte in a QUIC packet of encrypted data. 56 // Index of the first byte in a QUIC packet of encrypted data.
442 NET_EXPORT_PRIVATE size_t 57 NET_EXPORT_PRIVATE size_t
443 GetStartOfEncryptedData(QuicVersion version, const QuicPacketHeader& header); 58 GetStartOfEncryptedData(QuicVersion version, const QuicPacketHeader& header);
444 59
445 NET_EXPORT_PRIVATE size_t 60 NET_EXPORT_PRIVATE size_t
446 GetStartOfEncryptedData(QuicVersion version, 61 GetStartOfEncryptedData(QuicVersion version,
447 QuicConnectionIdLength connection_id_length, 62 QuicConnectionIdLength connection_id_length,
448 bool include_version, 63 bool include_version,
449 bool include_path_id, 64 bool include_path_id,
450 bool include_diversification_nonce, 65 bool include_diversification_nonce,
451 QuicPacketNumberLength packet_number_length); 66 QuicPacketNumberLength packet_number_length);
452 67
453 enum QuicRstStreamErrorCode {
454 // Complete response has been sent, sending a RST to ask the other endpoint
455 // to stop sending request data without discarding the response.
456 QUIC_STREAM_NO_ERROR = 0,
457
458 // There was some error which halted stream processing.
459 QUIC_ERROR_PROCESSING_STREAM,
460 // We got two fin or reset offsets which did not match.
461 QUIC_MULTIPLE_TERMINATION_OFFSETS,
462 // We got bad payload and can not respond to it at the protocol level.
463 QUIC_BAD_APPLICATION_PAYLOAD,
464 // Stream closed due to connection error. No reset frame is sent when this
465 // happens.
466 QUIC_STREAM_CONNECTION_ERROR,
467 // GoAway frame sent. No more stream can be created.
468 QUIC_STREAM_PEER_GOING_AWAY,
469 // The stream has been cancelled.
470 QUIC_STREAM_CANCELLED,
471 // Closing stream locally, sending a RST to allow for proper flow control
472 // accounting. Sent in response to a RST from the peer.
473 QUIC_RST_ACKNOWLEDGEMENT,
474 // Receiver refused to create the stream (because its limit on open streams
475 // has been reached). The sender should retry the request later (using
476 // another stream).
477 QUIC_REFUSED_STREAM,
478 // Invalid URL in PUSH_PROMISE request header.
479 QUIC_INVALID_PROMISE_URL,
480 // Server is not authoritative for this URL.
481 QUIC_UNAUTHORIZED_PROMISE_URL,
482 // Can't have more than one active PUSH_PROMISE per URL.
483 QUIC_DUPLICATE_PROMISE_URL,
484 // Vary check failed.
485 QUIC_PROMISE_VARY_MISMATCH,
486 // Only GET and HEAD methods allowed.
487 QUIC_INVALID_PROMISE_METHOD,
488 // The push stream is unclaimed and timed out.
489 QUIC_PUSH_STREAM_TIMED_OUT,
490 // Received headers were too large.
491 QUIC_HEADERS_TOO_LARGE,
492 // No error. Used as bound while iterating.
493 QUIC_STREAM_LAST_ERROR,
494 };
495 // QUIC error codes are encoded to a single octet on-the-wire.
496 static_assert(static_cast<int>(QUIC_STREAM_LAST_ERROR) <=
497 std::numeric_limits<uint8_t>::max(),
498 "QuicErrorCode exceeds single octet");
499
500 // These values must remain stable as they are uploaded to UMA histograms.
501 // To add a new error code, use the current value of QUIC_LAST_ERROR and
502 // increment QUIC_LAST_ERROR.
503 enum QuicErrorCode {
504 QUIC_NO_ERROR = 0,
505
506 // Connection has reached an invalid state.
507 QUIC_INTERNAL_ERROR = 1,
508 // There were data frames after the a fin or reset.
509 QUIC_STREAM_DATA_AFTER_TERMINATION = 2,
510 // Control frame is malformed.
511 QUIC_INVALID_PACKET_HEADER = 3,
512 // Frame data is malformed.
513 QUIC_INVALID_FRAME_DATA = 4,
514 // The packet contained no payload.
515 QUIC_MISSING_PAYLOAD = 48,
516 // FEC data is malformed.
517 QUIC_INVALID_FEC_DATA = 5,
518 // STREAM frame data is malformed.
519 QUIC_INVALID_STREAM_DATA = 46,
520 // STREAM frame data overlaps with buffered data.
521 QUIC_OVERLAPPING_STREAM_DATA = 87,
522 // Received STREAM frame data is not encrypted.
523 QUIC_UNENCRYPTED_STREAM_DATA = 61,
524 // Attempt to send unencrypted STREAM frame.
525 QUIC_ATTEMPT_TO_SEND_UNENCRYPTED_STREAM_DATA = 88,
526 // Received a frame which is likely the result of memory corruption.
527 QUIC_MAYBE_CORRUPTED_MEMORY = 89,
528 // FEC frame data is not encrypted.
529 QUIC_UNENCRYPTED_FEC_DATA = 77,
530 // RST_STREAM frame data is malformed.
531 QUIC_INVALID_RST_STREAM_DATA = 6,
532 // CONNECTION_CLOSE frame data is malformed.
533 QUIC_INVALID_CONNECTION_CLOSE_DATA = 7,
534 // GOAWAY frame data is malformed.
535 QUIC_INVALID_GOAWAY_DATA = 8,
536 // WINDOW_UPDATE frame data is malformed.
537 QUIC_INVALID_WINDOW_UPDATE_DATA = 57,
538 // BLOCKED frame data is malformed.
539 QUIC_INVALID_BLOCKED_DATA = 58,
540 // STOP_WAITING frame data is malformed.
541 QUIC_INVALID_STOP_WAITING_DATA = 60,
542 // PATH_CLOSE frame data is malformed.
543 QUIC_INVALID_PATH_CLOSE_DATA = 78,
544 // ACK frame data is malformed.
545 QUIC_INVALID_ACK_DATA = 9,
546
547 // Version negotiation packet is malformed.
548 QUIC_INVALID_VERSION_NEGOTIATION_PACKET = 10,
549 // Public RST packet is malformed.
550 QUIC_INVALID_PUBLIC_RST_PACKET = 11,
551 // There was an error decrypting.
552 QUIC_DECRYPTION_FAILURE = 12,
553 // There was an error encrypting.
554 QUIC_ENCRYPTION_FAILURE = 13,
555 // The packet exceeded kMaxPacketSize.
556 QUIC_PACKET_TOO_LARGE = 14,
557 // The peer is going away. May be a client or server.
558 QUIC_PEER_GOING_AWAY = 16,
559 // A stream ID was invalid.
560 QUIC_INVALID_STREAM_ID = 17,
561 // A priority was invalid.
562 QUIC_INVALID_PRIORITY = 49,
563 // Too many streams already open.
564 QUIC_TOO_MANY_OPEN_STREAMS = 18,
565 // The peer created too many available streams.
566 QUIC_TOO_MANY_AVAILABLE_STREAMS = 76,
567 // Received public reset for this connection.
568 QUIC_PUBLIC_RESET = 19,
569 // Invalid protocol version.
570 QUIC_INVALID_VERSION = 20,
571
572 // The Header ID for a stream was too far from the previous.
573 QUIC_INVALID_HEADER_ID = 22,
574 // Negotiable parameter received during handshake had invalid value.
575 QUIC_INVALID_NEGOTIATED_VALUE = 23,
576 // There was an error decompressing data.
577 QUIC_DECOMPRESSION_FAILURE = 24,
578 // The connection timed out due to no network activity.
579 QUIC_NETWORK_IDLE_TIMEOUT = 25,
580 // The connection timed out waiting for the handshake to complete.
581 QUIC_HANDSHAKE_TIMEOUT = 67,
582 // There was an error encountered migrating addresses.
583 QUIC_ERROR_MIGRATING_ADDRESS = 26,
584 // There was an error encountered migrating port only.
585 QUIC_ERROR_MIGRATING_PORT = 86,
586 // There was an error while writing to the socket.
587 QUIC_PACKET_WRITE_ERROR = 27,
588 // There was an error while reading from the socket.
589 QUIC_PACKET_READ_ERROR = 51,
590 // We received a STREAM_FRAME with no data and no fin flag set.
591 QUIC_EMPTY_STREAM_FRAME_NO_FIN = 50,
592 // We received invalid data on the headers stream.
593 QUIC_INVALID_HEADERS_STREAM_DATA = 56,
594 // The peer received too much data, violating flow control.
595 QUIC_FLOW_CONTROL_RECEIVED_TOO_MUCH_DATA = 59,
596 // The peer sent too much data, violating flow control.
597 QUIC_FLOW_CONTROL_SENT_TOO_MUCH_DATA = 63,
598 // The peer received an invalid flow control window.
599 QUIC_FLOW_CONTROL_INVALID_WINDOW = 64,
600 // The connection has been IP pooled into an existing connection.
601 QUIC_CONNECTION_IP_POOLED = 62,
602 // The connection has too many outstanding sent packets.
603 QUIC_TOO_MANY_OUTSTANDING_SENT_PACKETS = 68,
604 // The connection has too many outstanding received packets.
605 QUIC_TOO_MANY_OUTSTANDING_RECEIVED_PACKETS = 69,
606 // The quic connection has been cancelled.
607 QUIC_CONNECTION_CANCELLED = 70,
608 // Disabled QUIC because of high packet loss rate.
609 QUIC_BAD_PACKET_LOSS_RATE = 71,
610 // Disabled QUIC because of too many PUBLIC_RESETs post handshake.
611 QUIC_PUBLIC_RESETS_POST_HANDSHAKE = 73,
612 // Disabled QUIC because of too many timeouts with streams open.
613 QUIC_TIMEOUTS_WITH_OPEN_STREAMS = 74,
614 // Closed because we failed to serialize a packet.
615 QUIC_FAILED_TO_SERIALIZE_PACKET = 75,
616 // QUIC timed out after too many RTOs.
617 QUIC_TOO_MANY_RTOS = 85,
618
619 // Crypto errors.
620
621 // Hanshake failed.
622 QUIC_HANDSHAKE_FAILED = 28,
623 // Handshake message contained out of order tags.
624 QUIC_CRYPTO_TAGS_OUT_OF_ORDER = 29,
625 // Handshake message contained too many entries.
626 QUIC_CRYPTO_TOO_MANY_ENTRIES = 30,
627 // Handshake message contained an invalid value length.
628 QUIC_CRYPTO_INVALID_VALUE_LENGTH = 31,
629 // A crypto message was received after the handshake was complete.
630 QUIC_CRYPTO_MESSAGE_AFTER_HANDSHAKE_COMPLETE = 32,
631 // A crypto message was received with an illegal message tag.
632 QUIC_INVALID_CRYPTO_MESSAGE_TYPE = 33,
633 // A crypto message was received with an illegal parameter.
634 QUIC_INVALID_CRYPTO_MESSAGE_PARAMETER = 34,
635 // An invalid channel id signature was supplied.
636 QUIC_INVALID_CHANNEL_ID_SIGNATURE = 52,
637 // A crypto message was received with a mandatory parameter missing.
638 QUIC_CRYPTO_MESSAGE_PARAMETER_NOT_FOUND = 35,
639 // A crypto message was received with a parameter that has no overlap
640 // with the local parameter.
641 QUIC_CRYPTO_MESSAGE_PARAMETER_NO_OVERLAP = 36,
642 // A crypto message was received that contained a parameter with too few
643 // values.
644 QUIC_CRYPTO_MESSAGE_INDEX_NOT_FOUND = 37,
645 // A demand for an unsupport proof type was received.
646 QUIC_UNSUPPORTED_PROOF_DEMAND = 94,
647 // An internal error occured in crypto processing.
648 QUIC_CRYPTO_INTERNAL_ERROR = 38,
649 // A crypto handshake message specified an unsupported version.
650 QUIC_CRYPTO_VERSION_NOT_SUPPORTED = 39,
651 // A crypto handshake message resulted in a stateless reject.
652 QUIC_CRYPTO_HANDSHAKE_STATELESS_REJECT = 72,
653 // There was no intersection between the crypto primitives supported by the
654 // peer and ourselves.
655 QUIC_CRYPTO_NO_SUPPORT = 40,
656 // The server rejected our client hello messages too many times.
657 QUIC_CRYPTO_TOO_MANY_REJECTS = 41,
658 // The client rejected the server's certificate chain or signature.
659 QUIC_PROOF_INVALID = 42,
660 // A crypto message was received with a duplicate tag.
661 QUIC_CRYPTO_DUPLICATE_TAG = 43,
662 // A crypto message was received with the wrong encryption level (i.e. it
663 // should have been encrypted but was not.)
664 QUIC_CRYPTO_ENCRYPTION_LEVEL_INCORRECT = 44,
665 // The server config for a server has expired.
666 QUIC_CRYPTO_SERVER_CONFIG_EXPIRED = 45,
667 // We failed to setup the symmetric keys for a connection.
668 QUIC_CRYPTO_SYMMETRIC_KEY_SETUP_FAILED = 53,
669 // A handshake message arrived, but we are still validating the
670 // previous handshake message.
671 QUIC_CRYPTO_MESSAGE_WHILE_VALIDATING_CLIENT_HELLO = 54,
672 // A server config update arrived before the handshake is complete.
673 QUIC_CRYPTO_UPDATE_BEFORE_HANDSHAKE_COMPLETE = 65,
674 // CHLO cannot fit in one packet.
675 QUIC_CRYPTO_CHLO_TOO_LARGE = 90,
676 // This connection involved a version negotiation which appears to have been
677 // tampered with.
678 QUIC_VERSION_NEGOTIATION_MISMATCH = 55,
679
680 // Multipath errors.
681 // Multipath is not enabled, but a packet with multipath flag on is received.
682 QUIC_BAD_MULTIPATH_FLAG = 79,
683 // A path is supposed to exist but does not.
684 QUIC_MULTIPATH_PATH_DOES_NOT_EXIST = 91,
685 // A path is supposed to be active but is not.
686 QUIC_MULTIPATH_PATH_NOT_ACTIVE = 92,
687
688 // IP address changed causing connection close.
689 QUIC_IP_ADDRESS_CHANGED = 80,
690
691 // Connection migration errors.
692 // Network changed, but connection had no migratable streams.
693 QUIC_CONNECTION_MIGRATION_NO_MIGRATABLE_STREAMS = 81,
694 // Connection changed networks too many times.
695 QUIC_CONNECTION_MIGRATION_TOO_MANY_CHANGES = 82,
696 // Connection migration was attempted, but there was no new network to
697 // migrate to.
698 QUIC_CONNECTION_MIGRATION_NO_NEW_NETWORK = 83,
699 // Network changed, but connection had one or more non-migratable streams.
700 QUIC_CONNECTION_MIGRATION_NON_MIGRATABLE_STREAM = 84,
701
702 // Stream frames arrived too discontiguously so that stream sequencer buffer
703 // maintains too many gaps.
704 QUIC_TOO_MANY_FRAME_GAPS = 93,
705
706 // Sequencer buffer get into weird state where continuing read/write will lead
707 // to crash.
708 QUIC_STREAM_SEQUENCER_INVALID_STATE = 95,
709
710 // Connection closed because of server hits max number of sessions allowed.
711 // TODO(fayang): Add monitoring for QUIC_TOO_MANY_SESSIONS_ON_SERVER.
712 QUIC_TOO_MANY_SESSIONS_ON_SERVER = 96,
713
714 // No error. Used as bound while iterating.
715 QUIC_LAST_ERROR = 97,
716 };
717
718 typedef std::array<char, 32> DiversificationNonce;
719
720 struct NET_EXPORT_PRIVATE QuicPacketPublicHeader { 68 struct NET_EXPORT_PRIVATE QuicPacketPublicHeader {
721 QuicPacketPublicHeader(); 69 QuicPacketPublicHeader();
722 explicit QuicPacketPublicHeader(const QuicPacketPublicHeader& other); 70 explicit QuicPacketPublicHeader(const QuicPacketPublicHeader& other);
723 ~QuicPacketPublicHeader(); 71 ~QuicPacketPublicHeader();
724 72
725 // Universal header. All QuicPacket headers will have a connection_id and 73 // Universal header. All QuicPacket headers will have a connection_id and
726 // public flags. 74 // public flags.
727 QuicConnectionId connection_id; 75 QuicConnectionId connection_id;
728 QuicConnectionIdLength connection_id_length; 76 QuicConnectionIdLength connection_id_length;
729 bool multipath_flag; 77 bool multipath_flag;
730 bool reset_flag; 78 bool reset_flag;
731 bool version_flag; 79 bool version_flag;
732 QuicPacketNumberLength packet_number_length; 80 QuicPacketNumberLength packet_number_length;
733 QuicVersionVector versions; 81 QuicVersionVector versions;
734 // nonce contains an optional, 32-byte nonce value. If not included in the 82 // nonce contains an optional, 32-byte nonce value. If not included in the
735 // packet, |nonce| will be empty. 83 // packet, |nonce| will be empty.
736 DiversificationNonce* nonce; 84 DiversificationNonce* nonce;
737 }; 85 };
738 86
739 // An integer which cannot be a packet number.
740 const QuicPacketNumber kInvalidPacketNumber = 0;
741
742 // Header for Data packets. 87 // Header for Data packets.
743 struct NET_EXPORT_PRIVATE QuicPacketHeader { 88 struct NET_EXPORT_PRIVATE QuicPacketHeader {
744 QuicPacketHeader(); 89 QuicPacketHeader();
745 explicit QuicPacketHeader(const QuicPacketPublicHeader& header); 90 explicit QuicPacketHeader(const QuicPacketPublicHeader& header);
746 QuicPacketHeader(const QuicPacketHeader& other); 91 QuicPacketHeader(const QuicPacketHeader& other);
747 92
748 NET_EXPORT_PRIVATE friend std::ostream& operator<<(std::ostream& os, 93 NET_EXPORT_PRIVATE friend std::ostream& operator<<(std::ostream& os,
749 const QuicPacketHeader& s); 94 const QuicPacketHeader& s);
750 95
751 QuicPacketPublicHeader public_header; 96 QuicPacketPublicHeader public_header;
752 QuicPacketNumber packet_number; 97 QuicPacketNumber packet_number;
753 QuicPathId path_id; 98 QuicPathId path_id;
754 bool entropy_flag;
755 QuicPacketEntropyHash entropy_hash;
756 }; 99 };
757 100
758 struct NET_EXPORT_PRIVATE QuicPublicResetPacket { 101 struct NET_EXPORT_PRIVATE QuicPublicResetPacket {
759 QuicPublicResetPacket(); 102 QuicPublicResetPacket();
760 explicit QuicPublicResetPacket(const QuicPacketPublicHeader& header); 103 explicit QuicPublicResetPacket(const QuicPacketPublicHeader& header);
761 104
762 QuicPacketPublicHeader public_header; 105 QuicPacketPublicHeader public_header;
763 QuicPublicResetNonceProof nonce_proof; 106 QuicPublicResetNonceProof nonce_proof;
764 // TODO(fayang): remove rejected_packet_number when deprecating 107 // TODO(fayang): remove rejected_packet_number when deprecating
765 // FLAGS_quic_remove_packet_number_from_public_reset. 108 // FLAGS_quic_remove_packet_number_from_public_reset.
766 QuicPacketNumber rejected_packet_number; 109 QuicPacketNumber rejected_packet_number;
767 IPEndPoint client_address; 110 IPEndPoint client_address;
768 }; 111 };
769 112
770 enum QuicVersionNegotiationState {
771 START_NEGOTIATION = 0,
772 // Server-side this implies we've sent a version negotiation packet and are
773 // waiting on the client to select a compatible version. Client-side this
774 // implies we've gotten a version negotiation packet, are retransmitting the
775 // initial packets with a supported version and are waiting for our first
776 // packet from the server.
777 NEGOTIATION_IN_PROGRESS,
778 // This indicates this endpoint has received a packet from the peer with a
779 // version this endpoint supports. Version negotiation is complete, and the
780 // version number will no longer be sent with future packets.
781 NEGOTIATED_VERSION
782 };
783
784 typedef QuicPacketPublicHeader QuicVersionNegotiationPacket; 113 typedef QuicPacketPublicHeader QuicVersionNegotiationPacket;
785 114
786 // A padding frame contains no payload. 115 // A padding frame contains no payload.
787 struct NET_EXPORT_PRIVATE QuicPaddingFrame { 116 struct NET_EXPORT_PRIVATE QuicPaddingFrame {
788 QuicPaddingFrame() : num_padding_bytes(-1) {} 117 QuicPaddingFrame() : num_padding_bytes(-1) {}
789 explicit QuicPaddingFrame(int num_padding_bytes) 118 explicit QuicPaddingFrame(int num_padding_bytes)
790 : num_padding_bytes(num_padding_bytes) {} 119 : num_padding_bytes(num_padding_bytes) {}
791 120
792 NET_EXPORT_PRIVATE friend std::ostream& operator<<(std::ostream& os, 121 NET_EXPORT_PRIVATE friend std::ostream& operator<<(std::ostream& os,
793 const QuicPaddingFrame& s); 122 const QuicPaddingFrame& s);
794 123
795 // -1: full padding to the end of a max-sized packet 124 // -1: full padding to the end of a max-sized packet
796 // otherwise: only pad up to num_padding_bytes bytes 125 // otherwise: only pad up to num_padding_bytes bytes
797 int num_padding_bytes; 126 int num_padding_bytes;
798 }; 127 };
799 128
800 // A ping frame contains no payload, though it is retransmittable, 129 // A ping frame contains no payload, though it is retransmittable,
801 // and ACK'd just like other normal frames. 130 // and ACK'd just like other normal frames.
802 struct NET_EXPORT_PRIVATE QuicPingFrame {}; 131 struct NET_EXPORT_PRIVATE QuicPingFrame {};
803 132
804 // A path MTU discovery frame contains no payload and is serialized as a ping 133 // A path MTU discovery frame contains no payload and is serialized as a ping
805 // frame. 134 // frame.
806 struct NET_EXPORT_PRIVATE QuicMtuDiscoveryFrame {}; 135 struct NET_EXPORT_PRIVATE QuicMtuDiscoveryFrame {};
807 136
808 class NET_EXPORT_PRIVATE QuicBufferAllocator {
809 public:
810 virtual ~QuicBufferAllocator();
811
812 // Returns or allocates a new buffer of |size|. Never returns null.
813 virtual char* New(size_t size) = 0;
814
815 // Returns or allocates a new buffer of |size| if |flag_enable| is true.
816 // Otherwise, returns a buffer that is compatible with this class directly
817 // with operator new. Never returns null.
818 virtual char* New(size_t size, bool flag_enable) = 0;
819
820 // Releases a buffer.
821 virtual void Delete(char* buffer) = 0;
822
823 // Marks the allocator as being idle. Serves as a hint to notify the allocator
824 // that it should release any resources it's still holding on to.
825 virtual void MarkAllocatorIdle() {}
826 };
827
828 // Deleter for stream buffers. Copyable to support platforms where the deleter 137 // Deleter for stream buffers. Copyable to support platforms where the deleter
829 // of a unique_ptr must be copyable. Otherwise it would be nice for this to be 138 // of a unique_ptr must be copyable. Otherwise it would be nice for this to be
830 // move-only. 139 // move-only.
831 class NET_EXPORT_PRIVATE StreamBufferDeleter { 140 class NET_EXPORT_PRIVATE StreamBufferDeleter {
832 public: 141 public:
833 StreamBufferDeleter() : allocator_(nullptr) {} 142 StreamBufferDeleter() : allocator_(nullptr) {}
834 explicit StreamBufferDeleter(QuicBufferAllocator* allocator) 143 explicit StreamBufferDeleter(QuicBufferAllocator* allocator)
835 : allocator_(allocator) {} 144 : allocator_(allocator) {}
836 145
837 // Deletes |buffer| using |allocator_|. 146 // Deletes |buffer| using |allocator_|.
(...skipping 52 matching lines...) Expand 10 before | Expand all | Expand 10 after
890 199
891 struct NET_EXPORT_PRIVATE QuicStopWaitingFrame { 200 struct NET_EXPORT_PRIVATE QuicStopWaitingFrame {
892 QuicStopWaitingFrame(); 201 QuicStopWaitingFrame();
893 ~QuicStopWaitingFrame(); 202 ~QuicStopWaitingFrame();
894 203
895 NET_EXPORT_PRIVATE friend std::ostream& operator<<( 204 NET_EXPORT_PRIVATE friend std::ostream& operator<<(
896 std::ostream& os, 205 std::ostream& os,
897 const QuicStopWaitingFrame& s); 206 const QuicStopWaitingFrame& s);
898 // Path which this stop waiting frame belongs to. 207 // Path which this stop waiting frame belongs to.
899 QuicPathId path_id; 208 QuicPathId path_id;
900 // Entropy hash of all packets up to, but not including, the least unacked
901 // packet.
902 QuicPacketEntropyHash entropy_hash;
903 // The lowest packet we've sent which is unacked, and we expect an ack for. 209 // The lowest packet we've sent which is unacked, and we expect an ack for.
904 QuicPacketNumber least_unacked; 210 QuicPacketNumber least_unacked;
905 }; 211 };
906 212
907 // A sequence of packet numbers where each number is unique. Intended to be used 213 // A sequence of packet numbers where each number is unique. Intended to be used
908 // in a sliding window fashion, where smaller old packet numbers are removed and 214 // in a sliding window fashion, where smaller old packet numbers are removed and
909 // larger new packet numbers are added, with the occasional random access. 215 // larger new packet numbers are added, with the occasional random access.
910 class NET_EXPORT_PRIVATE PacketNumberQueue { 216 class NET_EXPORT_PRIVATE PacketNumberQueue {
911 public: 217 public:
912 using const_iterator = IntervalSet<QuicPacketNumber>::const_iterator; 218 using const_iterator = IntervalSet<QuicPacketNumber>::const_iterator;
(...skipping 74 matching lines...) Expand 10 before | Expand all | Expand 10 after
987 293
988 struct NET_EXPORT_PRIVATE QuicAckFrame { 294 struct NET_EXPORT_PRIVATE QuicAckFrame {
989 QuicAckFrame(); 295 QuicAckFrame();
990 QuicAckFrame(const QuicAckFrame& other); 296 QuicAckFrame(const QuicAckFrame& other);
991 ~QuicAckFrame(); 297 ~QuicAckFrame();
992 298
993 NET_EXPORT_PRIVATE friend std::ostream& operator<<(std::ostream& os, 299 NET_EXPORT_PRIVATE friend std::ostream& operator<<(std::ostream& os,
994 const QuicAckFrame& s); 300 const QuicAckFrame& s);
995 301
996 // The highest packet number we've observed from the peer. 302 // The highest packet number we've observed from the peer.
997 //
998 // In general, this should be the largest packet number we've received. In
999 // the case of truncated acks, we may have to advertise a lower "upper bound"
1000 // than largest received, to avoid implicitly acking missing packets that
1001 // don't fit in the missing packet list due to size limitations. In this
1002 // case, largest_observed may be a packet which is also in the missing packets
1003 // list.
1004 QuicPacketNumber largest_observed; 303 QuicPacketNumber largest_observed;
1005 304
1006 // Time elapsed since largest_observed was received until this Ack frame was 305 // Time elapsed since largest_observed was received until this Ack frame was
1007 // sent. 306 // sent.
1008 QuicTime::Delta ack_delay_time; 307 QuicTime::Delta ack_delay_time;
1009 308
1010 // Vector of <packet_number, time> for when packets arrived. 309 // Vector of <packet_number, time> for when packets arrived.
1011 PacketTimeVector received_packet_times; 310 PacketTimeVector received_packet_times;
1012 311
1013 // Set of packets. 312 // Set of packets.
1014 PacketNumberQueue packets; 313 PacketNumberQueue packets;
1015 314
1016 // Path which this ack belongs to. 315 // Path which this ack belongs to.
1017 QuicPathId path_id; 316 QuicPathId path_id;
1018
1019 // Entropy hash of all packets up to largest observed not including missing
1020 // packets.
1021 QuicPacketEntropyHash entropy_hash;
1022
1023 // Whether the ack had to be truncated when sent.
1024 bool is_truncated;
1025
1026 // If true, |packets| express missing packets. Otherwise, |packets| express
1027 // received packets.
1028 bool missing;
1029 }; 317 };
1030 318
1031 // True if the packet number is greater than largest_observed or is listed 319 // True if the packet number is greater than largest_observed or is listed
1032 // as missing. 320 // as missing.
1033 // Always returns false for packet numbers less than least_unacked. 321 // Always returns false for packet numbers less than least_unacked.
1034 bool NET_EXPORT_PRIVATE 322 bool NET_EXPORT_PRIVATE
1035 IsAwaitingPacket(const QuicAckFrame& ack_frame, 323 IsAwaitingPacket(const QuicAckFrame& ack_frame,
1036 QuicPacketNumber packet_number, 324 QuicPacketNumber packet_number,
1037 QuicPacketNumber peer_least_packet_awaiting_ack); 325 QuicPacketNumber peer_least_packet_awaiting_ack);
1038 326
1039 // Defines for all types of congestion control algorithms that can be used in
1040 // QUIC. Note that this is separate from the congestion feedback type -
1041 // some congestion control algorithms may use the same feedback type
1042 // (Reno and Cubic are the classic example for that).
1043 enum CongestionControlType {
1044 kCubic,
1045 kCubicBytes,
1046 kReno,
1047 kRenoBytes,
1048 kBBR,
1049 };
1050
1051 enum LossDetectionType {
1052 kNack, // Used to mimic TCP's loss detection.
1053 kTime, // Time based loss detection.
1054 kAdaptiveTime, // Adaptive time based loss detection.
1055 kLazyFack, // Nack based but with FACK disabled for the first ack.
1056 };
1057
1058 struct NET_EXPORT_PRIVATE QuicRstStreamFrame { 327 struct NET_EXPORT_PRIVATE QuicRstStreamFrame {
1059 QuicRstStreamFrame(); 328 QuicRstStreamFrame();
1060 QuicRstStreamFrame(QuicStreamId stream_id, 329 QuicRstStreamFrame(QuicStreamId stream_id,
1061 QuicRstStreamErrorCode error_code, 330 QuicRstStreamErrorCode error_code,
1062 QuicStreamOffset bytes_written); 331 QuicStreamOffset bytes_written);
1063 332
1064 NET_EXPORT_PRIVATE friend std::ostream& operator<<( 333 NET_EXPORT_PRIVATE friend std::ostream& operator<<(
1065 std::ostream& os, 334 std::ostream& os,
1066 const QuicRstStreamFrame& r); 335 const QuicRstStreamFrame& r);
1067 336
(...skipping 80 matching lines...) Expand 10 before | Expand all | Expand 10 after
1148 QuicPathCloseFrame() {} 417 QuicPathCloseFrame() {}
1149 explicit QuicPathCloseFrame(QuicPathId path_id); 418 explicit QuicPathCloseFrame(QuicPathId path_id);
1150 419
1151 NET_EXPORT_PRIVATE friend std::ostream& operator<<( 420 NET_EXPORT_PRIVATE friend std::ostream& operator<<(
1152 std::ostream& os, 421 std::ostream& os,
1153 const QuicPathCloseFrame& p); 422 const QuicPathCloseFrame& p);
1154 423
1155 QuicPathId path_id; 424 QuicPathId path_id;
1156 }; 425 };
1157 426
1158 // EncryptionLevel enumerates the stages of encryption that a QUIC connection
1159 // progresses through. When retransmitting a packet, the encryption level needs
1160 // to be specified so that it is retransmitted at a level which the peer can
1161 // understand.
1162 enum EncryptionLevel : int8_t {
1163 ENCRYPTION_NONE = 0,
1164 ENCRYPTION_INITIAL = 1,
1165 ENCRYPTION_FORWARD_SECURE = 2,
1166
1167 NUM_ENCRYPTION_LEVELS,
1168 };
1169
1170 enum PeerAddressChangeType {
1171 // IP address and port remain unchanged.
1172 NO_CHANGE,
1173 // Port changed, but IP address remains unchanged.
1174 PORT_CHANGE,
1175 // IPv4 address changed, but within the /24 subnet (port may have changed.)
1176 IPV4_SUBNET_CHANGE,
1177 // IPv4 address changed, excluding /24 subnet change (port may have changed.)
1178 IPV4_TO_IPV4_CHANGE,
1179 // IP address change from an IPv4 to an IPv6 address (port may have changed.)
1180 IPV4_TO_IPV6_CHANGE,
1181 // IP address change from an IPv6 to an IPv4 address (port may have changed.)
1182 IPV6_TO_IPV4_CHANGE,
1183 // IP address change from an IPv6 to an IPv6 address (port may have changed.)
1184 IPV6_TO_IPV6_CHANGE,
1185 };
1186
1187 struct NET_EXPORT_PRIVATE QuicFrame { 427 struct NET_EXPORT_PRIVATE QuicFrame {
1188 QuicFrame(); 428 QuicFrame();
1189 explicit QuicFrame(QuicPaddingFrame padding_frame); 429 explicit QuicFrame(QuicPaddingFrame padding_frame);
1190 explicit QuicFrame(QuicMtuDiscoveryFrame frame); 430 explicit QuicFrame(QuicMtuDiscoveryFrame frame);
1191 explicit QuicFrame(QuicPingFrame frame); 431 explicit QuicFrame(QuicPingFrame frame);
1192 432
1193 explicit QuicFrame(QuicStreamFrame* stream_frame); 433 explicit QuicFrame(QuicStreamFrame* stream_frame);
1194 explicit QuicFrame(QuicAckFrame* frame); 434 explicit QuicFrame(QuicAckFrame* frame);
1195 explicit QuicFrame(QuicRstStreamFrame* frame); 435 explicit QuicFrame(QuicRstStreamFrame* frame);
1196 explicit QuicFrame(QuicConnectionCloseFrame* frame); 436 explicit QuicFrame(QuicConnectionCloseFrame* frame);
(...skipping 172 matching lines...) Expand 10 before | Expand all | Expand 10 after
1369 // Called when an unrecoverable error is encountered. 609 // Called when an unrecoverable error is encountered.
1370 virtual void OnUnrecoverableError(QuicErrorCode error, 610 virtual void OnUnrecoverableError(QuicErrorCode error,
1371 const std::string& error_details, 611 const std::string& error_details,
1372 ConnectionCloseSource source) = 0; 612 ConnectionCloseSource source) = 0;
1373 }; 613 };
1374 614
1375 // Used to generate filtered supported versions based on flags. 615 // Used to generate filtered supported versions based on flags.
1376 class NET_EXPORT_PRIVATE QuicVersionManager { 616 class NET_EXPORT_PRIVATE QuicVersionManager {
1377 public: 617 public:
1378 explicit QuicVersionManager(QuicVersionVector supported_versions); 618 explicit QuicVersionManager(QuicVersionVector supported_versions);
1379 ~QuicVersionManager(); 619 virtual ~QuicVersionManager();
1380 620
1381 // Returns supported versions based on flags. 621 // Returns currently supported QUIC versions.
1382 const QuicVersionVector& GetSupportedVersions(); 622 const QuicVersionVector& GetSupportedVersions();
1383 623
624 protected:
625 // Maybe refilter filtered_supported_versions_ based on flags.
626 void MaybeRefilterSupportedVersions();
627
628 // Refilters filtered_supported_versions_.
629 virtual void RefilterSupportedVersions();
630
631 const QuicVersionVector& filtered_supported_versions() const {
632 return filtered_supported_versions_;
633 }
634
1384 private: 635 private:
1385 // FLAGS_quic_disable_pre_34 636 // FLAGS_quic_enable_version_36_v3
1386 bool disable_pre_34_;
1387 // FLAGS_quic_enable_version_35
1388 bool enable_version_35_;
1389 // FLAGS_quic_enable_version_36_v2
1390 bool enable_version_36_; 637 bool enable_version_36_;
1391 // The list of versions that may be supported. 638 // The list of versions that may be supported.
1392 QuicVersionVector allowed_supported_versions_; 639 QuicVersionVector allowed_supported_versions_;
1393 // This vector contains QUIC versions which are currently supported based 640 // This vector contains QUIC versions which are currently supported based
1394 // on flags. 641 // on flags.
1395 QuicVersionVector filtered_supported_versions_; 642 QuicVersionVector filtered_supported_versions_;
1396 }; 643 };
1397 644
1398 struct NET_EXPORT_PRIVATE AckListenerWrapper { 645 struct NET_EXPORT_PRIVATE AckListenerWrapper {
1399 AckListenerWrapper(QuicAckListenerInterface* listener, 646 AckListenerWrapper(QuicAckListenerInterface* listener,
1400 QuicPacketLength data_length); 647 QuicPacketLength data_length);
1401 AckListenerWrapper(const AckListenerWrapper& other); 648 AckListenerWrapper(const AckListenerWrapper& other);
1402 ~AckListenerWrapper(); 649 ~AckListenerWrapper();
1403 650
1404 scoped_refptr<QuicAckListenerInterface> ack_listener; 651 scoped_refptr<QuicAckListenerInterface> ack_listener;
1405 QuicPacketLength length; 652 QuicPacketLength length;
1406 }; 653 };
1407 654
1408 struct NET_EXPORT_PRIVATE SerializedPacket { 655 struct NET_EXPORT_PRIVATE SerializedPacket {
1409 SerializedPacket(QuicPathId path_id, 656 SerializedPacket(QuicPathId path_id,
1410 QuicPacketNumber packet_number, 657 QuicPacketNumber packet_number,
1411 QuicPacketNumberLength packet_number_length, 658 QuicPacketNumberLength packet_number_length,
1412 const char* encrypted_buffer, 659 const char* encrypted_buffer,
1413 QuicPacketLength encrypted_length, 660 QuicPacketLength encrypted_length,
1414 QuicPacketEntropyHash entropy_hash,
1415 bool has_ack, 661 bool has_ack,
1416 bool has_stop_waiting); 662 bool has_stop_waiting);
1417 SerializedPacket(const SerializedPacket& other); 663 SerializedPacket(const SerializedPacket& other);
1418 ~SerializedPacket(); 664 ~SerializedPacket();
1419 665
1420 // Not owned. 666 // Not owned.
1421 const char* encrypted_buffer; 667 const char* encrypted_buffer;
1422 QuicPacketLength encrypted_length; 668 QuicPacketLength encrypted_length;
1423 QuicFrames retransmittable_frames; 669 QuicFrames retransmittable_frames;
1424 IsHandshake has_crypto_handshake; 670 IsHandshake has_crypto_handshake;
1425 // -1: full padding to the end of a max-sized packet 671 // -1: full padding to the end of a max-sized packet
1426 // 0: no padding 672 // 0: no padding
1427 // otherwise: only pad up to num_padding_bytes bytes 673 // otherwise: only pad up to num_padding_bytes bytes
1428 int16_t num_padding_bytes; 674 int16_t num_padding_bytes;
1429 QuicPathId path_id; 675 QuicPathId path_id;
1430 QuicPacketNumber packet_number; 676 QuicPacketNumber packet_number;
1431 QuicPacketNumberLength packet_number_length; 677 QuicPacketNumberLength packet_number_length;
1432 EncryptionLevel encryption_level; 678 EncryptionLevel encryption_level;
1433 QuicPacketEntropyHash entropy_hash;
1434 bool has_ack; 679 bool has_ack;
1435 bool has_stop_waiting; 680 bool has_stop_waiting;
1436 TransmissionType transmission_type; 681 TransmissionType transmission_type;
1437 QuicPathId original_path_id; 682 QuicPathId original_path_id;
1438 QuicPacketNumber original_packet_number; 683 QuicPacketNumber original_packet_number;
1439 684
1440 // Optional notifiers which will be informed when this packet has been ACKed. 685 // Optional notifiers which will be informed when this packet has been ACKed.
1441 std::list<AckListenerWrapper> listeners; 686 std::list<AckListenerWrapper> listeners;
1442 }; 687 };
1443 688
(...skipping 61 matching lines...) Expand 10 before | Expand all | Expand 10 after
1505 QuicPacketNumber packet_number; 750 QuicPacketNumber packet_number;
1506 const QuicFrames& retransmittable_frames; 751 const QuicFrames& retransmittable_frames;
1507 TransmissionType transmission_type; 752 TransmissionType transmission_type;
1508 QuicPathId path_id; 753 QuicPathId path_id;
1509 bool has_crypto_handshake; 754 bool has_crypto_handshake;
1510 int num_padding_bytes; 755 int num_padding_bytes;
1511 EncryptionLevel encryption_level; 756 EncryptionLevel encryption_level;
1512 QuicPacketNumberLength packet_number_length; 757 QuicPacketNumberLength packet_number_length;
1513 }; 758 };
1514 759
1515 // Convenience wrapper to wrap an iovec array and the total length, which must
1516 // be less than or equal to the actual total length of the iovecs.
1517 struct NET_EXPORT_PRIVATE QuicIOVector {
1518 QuicIOVector(const struct iovec* iov, int iov_count, size_t total_length)
1519 : iov(iov), iov_count(iov_count), total_length(total_length) {}
1520
1521 const struct iovec* iov;
1522 const int iov_count;
1523 const size_t total_length;
1524 };
1525
1526 } // namespace net 760 } // namespace net
1527 761
1528 #endif // NET_QUIC_QUIC_PROTOCOL_H_ 762 #endif // NET_QUIC_QUIC_PROTOCOL_H_
OLDNEW
« no previous file with comments | « net/quic/core/quic_packet_generator_test.cc ('k') | net/quic/core/quic_protocol.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698