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

Side by Side Diff: net/quic/core/quic_framer.cc

Issue 2464683002: adds std:: to stl types (#049) (Closed)
Patch Set: remove dead using std::foo declarations. 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_data_writer.cc ('k') | net/quic/core/quic_packet_creator_test.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 #include "net/quic/core/quic_framer.h" 5 #include "net/quic/core/quic_framer.h"
6 6
7 #include <cstdint> 7 #include <cstdint>
8 #include <memory> 8 #include <memory>
9 #include <vector> 9 #include <vector>
10 10
11 #include "base/compiler_specific.h" 11 #include "base/compiler_specific.h"
12 #include "base/logging.h" 12 #include "base/logging.h"
13 #include "base/memory/ptr_util.h" 13 #include "base/memory/ptr_util.h"
14 #include "base/stl_util.h" 14 #include "base/stl_util.h"
15 #include "net/quic/core/crypto/crypto_framer.h" 15 #include "net/quic/core/crypto/crypto_framer.h"
16 #include "net/quic/core/crypto/crypto_handshake_message.h" 16 #include "net/quic/core/crypto/crypto_handshake_message.h"
17 #include "net/quic/core/crypto/crypto_protocol.h" 17 #include "net/quic/core/crypto/crypto_protocol.h"
18 #include "net/quic/core/crypto/quic_decrypter.h" 18 #include "net/quic/core/crypto/quic_decrypter.h"
19 #include "net/quic/core/crypto/quic_encrypter.h" 19 #include "net/quic/core/crypto/quic_encrypter.h"
20 #include "net/quic/core/quic_bug_tracker.h" 20 #include "net/quic/core/quic_bug_tracker.h"
21 #include "net/quic/core/quic_data_reader.h" 21 #include "net/quic/core/quic_data_reader.h"
22 #include "net/quic/core/quic_data_writer.h" 22 #include "net/quic/core/quic_data_writer.h"
23 #include "net/quic/core/quic_flags.h" 23 #include "net/quic/core/quic_flags.h"
24 #include "net/quic/core/quic_socket_address_coder.h" 24 #include "net/quic/core/quic_socket_address_coder.h"
25 #include "net/quic/core/quic_utils.h" 25 #include "net/quic/core/quic_utils.h"
26 26
27 using base::ContainsKey; 27 using base::ContainsKey;
28 using base::StringPiece; 28 using base::StringPiece;
29 using std::map;
30 using std::max; 29 using std::max;
31 using std::min; 30 using std::min;
32 using std::numeric_limits;
33 using std::string; 31 using std::string;
34 using std::vector;
35 #define PREDICT_FALSE(x) (x) 32 #define PREDICT_FALSE(x) (x)
36 33
37 namespace net { 34 namespace net {
38 35
39 namespace { 36 namespace {
40 37
41 // Mask to select the lowest 48 bits of a packet number. 38 // Mask to select the lowest 48 bits of a packet number.
42 const QuicPacketNumber k6ByteSequenceNumberMask = UINT64_C(0x0000FFFFFFFFFFFF); 39 const QuicPacketNumber k6ByteSequenceNumberMask = UINT64_C(0x0000FFFFFFFFFFFF);
43 const QuicPacketNumber k4ByteSequenceNumberMask = UINT64_C(0x00000000FFFFFFFF); 40 const QuicPacketNumber k4ByteSequenceNumberMask = UINT64_C(0x00000000FFFFFFFF);
44 const QuicPacketNumber k2ByteSequenceNumberMask = UINT64_C(0x000000000000FFFF); 41 const QuicPacketNumber k2ByteSequenceNumberMask = UINT64_C(0x000000000000FFFF);
(...skipping 945 matching lines...) Expand 10 before | Expand all | Expand 10 after
990 const QuicAckFrame& frame) { 987 const QuicAckFrame& frame) {
991 AckFrameInfo ack_info; 988 AckFrameInfo ack_info;
992 if (frame.packets.Empty()) { 989 if (frame.packets.Empty()) {
993 return ack_info; 990 return ack_info;
994 } 991 }
995 DCHECK_GE(frame.largest_observed, frame.packets.Max()); 992 DCHECK_GE(frame.largest_observed, frame.packets.Max());
996 QuicPacketNumber last_largest_missing = 0; 993 QuicPacketNumber last_largest_missing = 0;
997 for (const Interval<QuicPacketNumber>& interval : frame.packets) { 994 for (const Interval<QuicPacketNumber>& interval : frame.packets) {
998 for (QuicPacketNumber interval_start = interval.min(); 995 for (QuicPacketNumber interval_start = interval.min();
999 interval_start < interval.max(); 996 interval_start < interval.max();
1000 interval_start += (1ull + numeric_limits<uint8_t>::max())) { 997 interval_start += (1ull + std::numeric_limits<uint8_t>::max())) {
1001 uint8_t cur_range_length = 998 uint8_t cur_range_length =
1002 interval.max() - interval_start > numeric_limits<uint8_t>::max() 999 interval.max() - interval_start > std::numeric_limits<uint8_t>::max()
1003 ? numeric_limits<uint8_t>::max() 1000 ? std::numeric_limits<uint8_t>::max()
1004 : (interval.max() - interval_start) - 1; 1001 : (interval.max() - interval_start) - 1;
1005 ack_info.nack_ranges[interval_start] = cur_range_length; 1002 ack_info.nack_ranges[interval_start] = cur_range_length;
1006 } 1003 }
1007 ack_info.max_delta = 1004 ack_info.max_delta =
1008 max(ack_info.max_delta, last_largest_missing == 0 1005 max(ack_info.max_delta, last_largest_missing == 0
1009 ? QuicPacketNumber{0} 1006 ? QuicPacketNumber{0}
1010 : (interval.min() - last_largest_missing)); 1007 : (interval.min() - last_largest_missing));
1011 last_largest_missing = interval.max() - 1; 1008 last_largest_missing = interval.max() - 1;
1012 } 1009 }
1013 // Include the range to the largest observed. 1010 // Include the range to the largest observed.
(...skipping 13 matching lines...) Expand all
1027 // encoding, so skip it. 1024 // encoding, so skip it.
1028 new_ack_info.first_block_length = frame.packets.LastIntervalLength(); 1025 new_ack_info.first_block_length = frame.packets.LastIntervalLength();
1029 auto itr = frame.packets.rbegin(); 1026 auto itr = frame.packets.rbegin();
1030 QuicPacketNumber previous_start = itr->min(); 1027 QuicPacketNumber previous_start = itr->min();
1031 new_ack_info.max_block_length = itr->Length(); 1028 new_ack_info.max_block_length = itr->Length();
1032 ++itr; 1029 ++itr;
1033 1030
1034 // Don't do any more work after getting information for 256 ACK blocks; any 1031 // Don't do any more work after getting information for 256 ACK blocks; any
1035 // more can't be encoded anyway. 1032 // more can't be encoded anyway.
1036 for (; itr != frame.packets.rend() && 1033 for (; itr != frame.packets.rend() &&
1037 new_ack_info.num_ack_blocks < numeric_limits<uint8_t>::max(); 1034 new_ack_info.num_ack_blocks < std::numeric_limits<uint8_t>::max();
1038 previous_start = itr->min(), ++itr) { 1035 previous_start = itr->min(), ++itr) {
1039 const auto& interval = *itr; 1036 const auto& interval = *itr;
1040 const QuicPacketNumber total_gap = previous_start - interval.max(); 1037 const QuicPacketNumber total_gap = previous_start - interval.max();
1041 new_ack_info.num_ack_blocks += 1038 new_ack_info.num_ack_blocks +=
1042 (total_gap + numeric_limits<uint8_t>::max() - 1) / 1039 (total_gap + std::numeric_limits<uint8_t>::max() - 1) /
1043 numeric_limits<uint8_t>::max(); 1040 std::numeric_limits<uint8_t>::max();
1044 new_ack_info.max_block_length = 1041 new_ack_info.max_block_length =
1045 max(new_ack_info.max_block_length, interval.Length()); 1042 max(new_ack_info.max_block_length, interval.Length());
1046 } 1043 }
1047 return new_ack_info; 1044 return new_ack_info;
1048 } 1045 }
1049 1046
1050 bool QuicFramer::ProcessUnauthenticatedHeader(QuicDataReader* encrypted_reader, 1047 bool QuicFramer::ProcessUnauthenticatedHeader(QuicDataReader* encrypted_reader,
1051 QuicPacketHeader* header) { 1048 QuicPacketHeader* header) {
1052 header->path_id = kDefaultPathId; 1049 header->path_id = kDefaultPathId;
1053 if (header->public_header.multipath_flag && 1050 if (header->public_header.multipath_flag &&
(...skipping 1024 matching lines...) Expand 10 before | Expand all | Expand 10 after
2078 QuicDataWriter* writer) { 2075 QuicDataWriter* writer) {
2079 if (!writer->WriteBytes(&frame.stream_id, GetStreamIdSize(frame.stream_id))) { 2076 if (!writer->WriteBytes(&frame.stream_id, GetStreamIdSize(frame.stream_id))) {
2080 QUIC_BUG << "Writing stream id size failed."; 2077 QUIC_BUG << "Writing stream id size failed.";
2081 return false; 2078 return false;
2082 } 2079 }
2083 if (!writer->WriteBytes(&frame.offset, GetStreamOffsetSize(frame.offset))) { 2080 if (!writer->WriteBytes(&frame.offset, GetStreamOffsetSize(frame.offset))) {
2084 QUIC_BUG << "Writing offset size failed."; 2081 QUIC_BUG << "Writing offset size failed.";
2085 return false; 2082 return false;
2086 } 2083 }
2087 if (!no_stream_frame_length) { 2084 if (!no_stream_frame_length) {
2088 if ((frame.data_length > numeric_limits<uint16_t>::max()) || 2085 if ((frame.data_length > std::numeric_limits<uint16_t>::max()) ||
2089 !writer->WriteUInt16(static_cast<uint16_t>(frame.data_length))) { 2086 !writer->WriteUInt16(static_cast<uint16_t>(frame.data_length))) {
2090 QUIC_BUG << "Writing stream frame length failed"; 2087 QUIC_BUG << "Writing stream frame length failed";
2091 return false; 2088 return false;
2092 } 2089 }
2093 } 2090 }
2094 2091
2095 if (!writer->WriteBytes(frame.data_buffer, frame.data_length)) { 2092 if (!writer->WriteBytes(frame.data_buffer, frame.data_length)) {
2096 QUIC_BUG << "Writing frame data failed."; 2093 QUIC_BUG << "Writing frame data failed.";
2097 return false; 2094 return false;
2098 } 2095 }
(...skipping 190 matching lines...) Expand 10 before | Expand all | Expand 10 after
2289 } 2286 }
2290 if (!writer->WriteUFloat16(ack_delay_time_us)) { 2287 if (!writer->WriteUFloat16(ack_delay_time_us)) {
2291 return false; 2288 return false;
2292 } 2289 }
2293 2290
2294 size_t max_num_ack_blocks = available_timestamp_and_ack_block_bytes / 2291 size_t max_num_ack_blocks = available_timestamp_and_ack_block_bytes /
2295 (ack_block_length + PACKET_1BYTE_PACKET_NUMBER); 2292 (ack_block_length + PACKET_1BYTE_PACKET_NUMBER);
2296 2293
2297 // Number of ack blocks. 2294 // Number of ack blocks.
2298 size_t num_ack_blocks = min(new_ack_info.num_ack_blocks, max_num_ack_blocks); 2295 size_t num_ack_blocks = min(new_ack_info.num_ack_blocks, max_num_ack_blocks);
2299 if (num_ack_blocks > numeric_limits<uint8_t>::max()) { 2296 if (num_ack_blocks > std::numeric_limits<uint8_t>::max()) {
2300 num_ack_blocks = numeric_limits<uint8_t>::max(); 2297 num_ack_blocks = std::numeric_limits<uint8_t>::max();
2301 } 2298 }
2302 2299
2303 if (num_ack_blocks > 0) { 2300 if (num_ack_blocks > 0) {
2304 if (!writer->WriteBytes(&num_ack_blocks, 1)) { 2301 if (!writer->WriteBytes(&num_ack_blocks, 1)) {
2305 return false; 2302 return false;
2306 } 2303 }
2307 } 2304 }
2308 2305
2309 // First ack block length. 2306 // First ack block length.
2310 if (!AppendPacketSequenceNumber(ack_block_length, 2307 if (!AppendPacketSequenceNumber(ack_block_length,
(...skipping 15 matching lines...) Expand all
2326 auto itr = frame.packets.rbegin(); 2323 auto itr = frame.packets.rbegin();
2327 QuicPacketNumber previous_start = itr->min(); 2324 QuicPacketNumber previous_start = itr->min();
2328 ++itr; 2325 ++itr;
2329 2326
2330 for (; 2327 for (;
2331 itr != frame.packets.rend() && num_ack_blocks_written < num_ack_blocks; 2328 itr != frame.packets.rend() && num_ack_blocks_written < num_ack_blocks;
2332 previous_start = itr->min(), ++itr) { 2329 previous_start = itr->min(), ++itr) {
2333 const auto& interval = *itr; 2330 const auto& interval = *itr;
2334 const QuicPacketNumber total_gap = previous_start - interval.max(); 2331 const QuicPacketNumber total_gap = previous_start - interval.max();
2335 const size_t num_encoded_gaps = 2332 const size_t num_encoded_gaps =
2336 (total_gap + numeric_limits<uint8_t>::max() - 1) / 2333 (total_gap + std::numeric_limits<uint8_t>::max() - 1) /
2337 numeric_limits<uint8_t>::max(); 2334 std::numeric_limits<uint8_t>::max();
2338 DCHECK_GT(num_encoded_gaps, 0u); 2335 DCHECK_GT(num_encoded_gaps, 0u);
2339 2336
2340 // Append empty ACK blocks because the gap is longer than a single gap. 2337 // Append empty ACK blocks because the gap is longer than a single gap.
2341 for (size_t i = 1; 2338 for (size_t i = 1;
2342 i < num_encoded_gaps && num_ack_blocks_written < num_ack_blocks; 2339 i < num_encoded_gaps && num_ack_blocks_written < num_ack_blocks;
2343 ++i) { 2340 ++i) {
2344 if (!AppendAckBlock(numeric_limits<uint8_t>::max(), ack_block_length, 0, 2341 if (!AppendAckBlock(std::numeric_limits<uint8_t>::max(),
2345 writer)) { 2342 ack_block_length, 0, writer)) {
2346 return false; 2343 return false;
2347 } 2344 }
2348 ++num_ack_blocks_written; 2345 ++num_ack_blocks_written;
2349 } 2346 }
2350 if (num_ack_blocks_written >= num_ack_blocks) { 2347 if (num_ack_blocks_written >= num_ack_blocks) {
2351 if (PREDICT_FALSE(num_ack_blocks_written != num_ack_blocks)) { 2348 if (PREDICT_FALSE(num_ack_blocks_written != num_ack_blocks)) {
2352 QUIC_BUG << "Wrote " << num_ack_blocks_written 2349 QUIC_BUG << "Wrote " << num_ack_blocks_written
2353 << ", expected to write " << num_ack_blocks; 2350 << ", expected to write " << num_ack_blocks;
2354 } 2351 }
2355 break; 2352 break;
2356 } 2353 }
2357 2354
2358 const uint8_t last_gap = 2355 const uint8_t last_gap =
2359 total_gap - (num_encoded_gaps - 1) * numeric_limits<uint8_t>::max(); 2356 total_gap -
2357 (num_encoded_gaps - 1) * std::numeric_limits<uint8_t>::max();
2360 // Append the final ACK block with a non-empty size. 2358 // Append the final ACK block with a non-empty size.
2361 if (!AppendAckBlock(last_gap, ack_block_length, interval.Length(), 2359 if (!AppendAckBlock(last_gap, ack_block_length, interval.Length(),
2362 writer)) { 2360 writer)) {
2363 return false; 2361 return false;
2364 } 2362 }
2365 ++num_ack_blocks_written; 2363 ++num_ack_blocks_written;
2366 } 2364 }
2367 DCHECK_EQ(num_ack_blocks, num_ack_blocks_written); 2365 DCHECK_EQ(num_ack_blocks, num_ack_blocks_written);
2368 } 2366 }
2369 2367
(...skipping 10 matching lines...) Expand all
2380 if (!writer->WriteBytes(&num_received_packets, 1)) { 2378 if (!writer->WriteBytes(&num_received_packets, 1)) {
2381 return false; 2379 return false;
2382 } 2380 }
2383 } 2381 }
2384 2382
2385 return true; 2383 return true;
2386 } 2384 }
2387 2385
2388 bool QuicFramer::AppendTimestampToAckFrame(const QuicAckFrame& frame, 2386 bool QuicFramer::AppendTimestampToAckFrame(const QuicAckFrame& frame,
2389 QuicDataWriter* writer) { 2387 QuicDataWriter* writer) {
2390 DCHECK_GE(numeric_limits<uint8_t>::max(), frame.received_packet_times.size()); 2388 DCHECK_GE(std::numeric_limits<uint8_t>::max(),
2389 frame.received_packet_times.size());
2391 // num_received_packets is only 1 byte. 2390 // num_received_packets is only 1 byte.
2392 if (frame.received_packet_times.size() > numeric_limits<uint8_t>::max()) { 2391 if (frame.received_packet_times.size() >
2392 std::numeric_limits<uint8_t>::max()) {
2393 return false; 2393 return false;
2394 } 2394 }
2395 2395
2396 uint8_t num_received_packets = frame.received_packet_times.size(); 2396 uint8_t num_received_packets = frame.received_packet_times.size();
2397 if (!writer->WriteBytes(&num_received_packets, 1)) { 2397 if (!writer->WriteBytes(&num_received_packets, 1)) {
2398 return false; 2398 return false;
2399 } 2399 }
2400 if (num_received_packets == 0) { 2400 if (num_received_packets == 0) {
2401 return true; 2401 return true;
2402 } 2402 }
2403 2403
2404 PacketTimeVector::const_iterator it = frame.received_packet_times.begin(); 2404 PacketTimeVector::const_iterator it = frame.received_packet_times.begin();
2405 QuicPacketNumber packet_number = it->first; 2405 QuicPacketNumber packet_number = it->first;
2406 QuicPacketNumber delta_from_largest_observed = 2406 QuicPacketNumber delta_from_largest_observed =
2407 frame.largest_observed - packet_number; 2407 frame.largest_observed - packet_number;
2408 2408
2409 DCHECK_GE(numeric_limits<uint8_t>::max(), delta_from_largest_observed); 2409 DCHECK_GE(std::numeric_limits<uint8_t>::max(), delta_from_largest_observed);
2410 if (delta_from_largest_observed > numeric_limits<uint8_t>::max()) { 2410 if (delta_from_largest_observed > std::numeric_limits<uint8_t>::max()) {
2411 return false; 2411 return false;
2412 } 2412 }
2413 2413
2414 if (!writer->WriteUInt8(delta_from_largest_observed & 2414 if (!writer->WriteUInt8(delta_from_largest_observed &
2415 k1ByteSequenceNumberMask)) { 2415 k1ByteSequenceNumberMask)) {
2416 return false; 2416 return false;
2417 } 2417 }
2418 2418
2419 // Use the lowest 4 bytes of the time delta from the creation_time_. 2419 // Use the lowest 4 bytes of the time delta from the creation_time_.
2420 const uint64_t time_epoch_delta_us = UINT64_C(1) << 32; 2420 const uint64_t time_epoch_delta_us = UINT64_C(1) << 32;
2421 uint32_t time_delta_us = 2421 uint32_t time_delta_us =
2422 static_cast<uint32_t>((it->second - creation_time_).ToMicroseconds() & 2422 static_cast<uint32_t>((it->second - creation_time_).ToMicroseconds() &
2423 (time_epoch_delta_us - 1)); 2423 (time_epoch_delta_us - 1));
2424 if (!writer->WriteBytes(&time_delta_us, sizeof(time_delta_us))) { 2424 if (!writer->WriteBytes(&time_delta_us, sizeof(time_delta_us))) {
2425 return false; 2425 return false;
2426 } 2426 }
2427 2427
2428 QuicTime prev_time = it->second; 2428 QuicTime prev_time = it->second;
2429 2429
2430 for (++it; it != frame.received_packet_times.end(); ++it) { 2430 for (++it; it != frame.received_packet_times.end(); ++it) {
2431 packet_number = it->first; 2431 packet_number = it->first;
2432 delta_from_largest_observed = frame.largest_observed - packet_number; 2432 delta_from_largest_observed = frame.largest_observed - packet_number;
2433 2433
2434 if (delta_from_largest_observed > numeric_limits<uint8_t>::max()) { 2434 if (delta_from_largest_observed > std::numeric_limits<uint8_t>::max()) {
2435 return false; 2435 return false;
2436 } 2436 }
2437 2437
2438 if (!writer->WriteUInt8(delta_from_largest_observed & 2438 if (!writer->WriteUInt8(delta_from_largest_observed &
2439 k1ByteSequenceNumberMask)) { 2439 k1ByteSequenceNumberMask)) {
2440 return false; 2440 return false;
2441 } 2441 }
2442 2442
2443 uint64_t frame_time_delta_us = (it->second - prev_time).ToMicroseconds(); 2443 uint64_t frame_time_delta_us = (it->second - prev_time).ToMicroseconds();
2444 prev_time = it->second; 2444 prev_time = it->second;
(...skipping 116 matching lines...) Expand 10 before | Expand all | Expand 10 after
2561 2561
2562 bool QuicFramer::RaiseError(QuicErrorCode error) { 2562 bool QuicFramer::RaiseError(QuicErrorCode error) {
2563 DVLOG(1) << "Error: " << QuicUtils::ErrorToString(error) 2563 DVLOG(1) << "Error: " << QuicUtils::ErrorToString(error)
2564 << " detail: " << detailed_error_; 2564 << " detail: " << detailed_error_;
2565 set_error(error); 2565 set_error(error);
2566 visitor_->OnError(this); 2566 visitor_->OnError(this);
2567 return false; 2567 return false;
2568 } 2568 }
2569 2569
2570 } // namespace net 2570 } // namespace net
OLDNEW
« no previous file with comments | « net/quic/core/quic_data_writer.cc ('k') | net/quic/core/quic_packet_creator_test.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698