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

Side by Side Diff: net/quic/test_tools/quic_test_packet_maker.cc

Issue 935333002: Update from https://crrev.com/316786 (Closed) Base URL: git@github.com:domokit/mojo.git@master
Patch Set: Created 5 years, 10 months 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/test_tools/quic_connection_peer.cc ('k') | net/quic/test_tools/quic_test_utils.h » ('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 2013 The Chromium Authors. All rights reserved. 1 // Copyright 2013 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/test_tools/quic_test_packet_maker.h" 5 #include "net/quic/test_tools/quic_test_packet_maker.h"
6 6
7 #include <list> 7 #include <list>
8 8
9 #include "net/quic/quic_framer.h" 9 #include "net/quic/quic_framer.h"
10 #include "net/quic/quic_http_utils.h" 10 #include "net/quic/quic_http_utils.h"
(...skipping 66 matching lines...) Expand 10 before | Expand all | Expand 10 after
77 77
78 QuicStopWaitingFrame stop_waiting; 78 QuicStopWaitingFrame stop_waiting;
79 stop_waiting.least_unacked = least_unacked; 79 stop_waiting.least_unacked = least_unacked;
80 frames.push_back(QuicFrame(&stop_waiting)); 80 frames.push_back(QuicFrame(&stop_waiting));
81 81
82 QuicRstStreamFrame rst(stream_id, error_code, 0); 82 QuicRstStreamFrame rst(stream_id, error_code, 0);
83 frames.push_back(QuicFrame(&rst)); 83 frames.push_back(QuicFrame(&rst));
84 84
85 QuicFramer framer(SupportedVersions(version_), clock_->Now(), false); 85 QuicFramer framer(SupportedVersions(version_), clock_->Now(), false);
86 scoped_ptr<QuicPacket> packet( 86 scoped_ptr<QuicPacket> packet(
87 BuildUnsizedDataPacket(&framer, header, frames).packet); 87 BuildUnsizedDataPacket(&framer, header, frames));
88 return scoped_ptr<QuicEncryptedPacket>(framer.EncryptPacket( 88 return scoped_ptr<QuicEncryptedPacket>(framer.EncryptPacket(
89 ENCRYPTION_NONE, header.packet_sequence_number, *packet)); 89 ENCRYPTION_NONE, header.packet_sequence_number, *packet));
90 } 90 }
91 91
92 scoped_ptr<QuicEncryptedPacket> QuicTestPacketMaker::MakeConnectionClosePacket( 92 scoped_ptr<QuicEncryptedPacket> QuicTestPacketMaker::MakeConnectionClosePacket(
93 QuicPacketSequenceNumber num) { 93 QuicPacketSequenceNumber num) {
94 QuicPacketHeader header; 94 QuicPacketHeader header;
95 header.public_header.connection_id = connection_id_; 95 header.public_header.connection_id = connection_id_;
96 header.public_header.reset_flag = false; 96 header.public_header.reset_flag = false;
97 header.public_header.version_flag = false; 97 header.public_header.version_flag = false;
(...skipping 32 matching lines...) Expand 10 before | Expand all | Expand 10 after
130 130
131 QuicFramer framer(SupportedVersions(version_), clock_->Now(), false); 131 QuicFramer framer(SupportedVersions(version_), clock_->Now(), false);
132 QuicFrames frames; 132 QuicFrames frames;
133 frames.push_back(QuicFrame(&ack)); 133 frames.push_back(QuicFrame(&ack));
134 134
135 QuicStopWaitingFrame stop_waiting; 135 QuicStopWaitingFrame stop_waiting;
136 stop_waiting.least_unacked = least_unacked; 136 stop_waiting.least_unacked = least_unacked;
137 frames.push_back(QuicFrame(&stop_waiting)); 137 frames.push_back(QuicFrame(&stop_waiting));
138 138
139 scoped_ptr<QuicPacket> packet( 139 scoped_ptr<QuicPacket> packet(
140 BuildUnsizedDataPacket(&framer, header, frames).packet); 140 BuildUnsizedDataPacket(&framer, header, frames));
141 return scoped_ptr<QuicEncryptedPacket>(framer.EncryptPacket( 141 return scoped_ptr<QuicEncryptedPacket>(framer.EncryptPacket(
142 ENCRYPTION_NONE, header.packet_sequence_number, *packet)); 142 ENCRYPTION_NONE, header.packet_sequence_number, *packet));
143 } 143 }
144 144
145 // Returns a newly created packet to send kData on stream 1. 145 // Returns a newly created packet to send kData on stream 1.
146 scoped_ptr<QuicEncryptedPacket> QuicTestPacketMaker::MakeDataPacket( 146 scoped_ptr<QuicEncryptedPacket> QuicTestPacketMaker::MakeDataPacket(
147 QuicPacketSequenceNumber sequence_number, 147 QuicPacketSequenceNumber sequence_number,
148 QuicStreamId stream_id, 148 QuicStreamId stream_id,
149 bool should_include_version, 149 bool should_include_version,
150 bool fin, 150 bool fin,
(...skipping 80 matching lines...) Expand 10 before | Expand all | Expand 10 after
231 return headers; 231 return headers;
232 } 232 }
233 233
234 scoped_ptr<QuicEncryptedPacket> QuicTestPacketMaker::MakePacket( 234 scoped_ptr<QuicEncryptedPacket> QuicTestPacketMaker::MakePacket(
235 const QuicPacketHeader& header, 235 const QuicPacketHeader& header,
236 const QuicFrame& frame) { 236 const QuicFrame& frame) {
237 QuicFramer framer(SupportedVersions(version_), QuicTime::Zero(), false); 237 QuicFramer framer(SupportedVersions(version_), QuicTime::Zero(), false);
238 QuicFrames frames; 238 QuicFrames frames;
239 frames.push_back(frame); 239 frames.push_back(frame);
240 scoped_ptr<QuicPacket> packet( 240 scoped_ptr<QuicPacket> packet(
241 BuildUnsizedDataPacket(&framer, header, frames).packet); 241 BuildUnsizedDataPacket(&framer, header, frames));
242 return scoped_ptr<QuicEncryptedPacket>(framer.EncryptPacket( 242 return scoped_ptr<QuicEncryptedPacket>(framer.EncryptPacket(
243 ENCRYPTION_NONE, header.packet_sequence_number, *packet)); 243 ENCRYPTION_NONE, header.packet_sequence_number, *packet));
244 } 244 }
245 245
246 void QuicTestPacketMaker::InitializeHeader( 246 void QuicTestPacketMaker::InitializeHeader(
247 QuicPacketSequenceNumber sequence_number, 247 QuicPacketSequenceNumber sequence_number,
248 bool should_include_version) { 248 bool should_include_version) {
249 header_.public_header.connection_id = connection_id_; 249 header_.public_header.connection_id = connection_id_;
250 header_.public_header.reset_flag = false; 250 header_.public_header.reset_flag = false;
251 header_.public_header.version_flag = should_include_version; 251 header_.public_header.version_flag = should_include_version;
252 header_.public_header.sequence_number_length = PACKET_1BYTE_SEQUENCE_NUMBER; 252 header_.public_header.sequence_number_length = PACKET_1BYTE_SEQUENCE_NUMBER;
253 header_.packet_sequence_number = sequence_number; 253 header_.packet_sequence_number = sequence_number;
254 header_.fec_group = 0; 254 header_.fec_group = 0;
255 header_.entropy_flag = false; 255 header_.entropy_flag = false;
256 header_.fec_flag = false; 256 header_.fec_flag = false;
257 } 257 }
258 258
259 } // namespace test 259 } // namespace test
260 } // namespace net 260 } // namespace net
OLDNEW
« no previous file with comments | « net/quic/test_tools/quic_connection_peer.cc ('k') | net/quic/test_tools/quic_test_utils.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698