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

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

Issue 1009543004: Create a Perspective enum to use instead of a bool is_server to improve (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Added NET_EXPORT_PRIVATE to fix compiler error Created 5 years, 9 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
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 64 matching lines...) Expand 10 before | Expand all | Expand 10 after
75 QuicFrames frames; 75 QuicFrames frames;
76 frames.push_back(QuicFrame(&ack)); 76 frames.push_back(QuicFrame(&ack));
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(),
86 Perspective::IS_CLIENT);
86 scoped_ptr<QuicPacket> packet( 87 scoped_ptr<QuicPacket> packet(
87 BuildUnsizedDataPacket(&framer, header, frames)); 88 BuildUnsizedDataPacket(&framer, header, frames));
88 return scoped_ptr<QuicEncryptedPacket>(framer.EncryptPacket( 89 return scoped_ptr<QuicEncryptedPacket>(framer.EncryptPacket(
89 ENCRYPTION_NONE, header.packet_sequence_number, *packet)); 90 ENCRYPTION_NONE, header.packet_sequence_number, *packet));
90 } 91 }
91 92
92 scoped_ptr<QuicEncryptedPacket> QuicTestPacketMaker::MakeConnectionClosePacket( 93 scoped_ptr<QuicEncryptedPacket> QuicTestPacketMaker::MakeConnectionClosePacket(
93 QuicPacketSequenceNumber num) { 94 QuicPacketSequenceNumber num) {
94 QuicPacketHeader header; 95 QuicPacketHeader header;
95 header.public_header.connection_id = connection_id_; 96 header.public_header.connection_id = connection_id_;
(...skipping 25 matching lines...) Expand all
121 header.entropy_flag = false; 122 header.entropy_flag = false;
122 header.fec_flag = false; 123 header.fec_flag = false;
123 header.fec_group = 0; 124 header.fec_group = 0;
124 125
125 QuicAckFrame ack(MakeAckFrame(largest_received)); 126 QuicAckFrame ack(MakeAckFrame(largest_received));
126 ack.delta_time_largest_observed = QuicTime::Delta::Zero(); 127 ack.delta_time_largest_observed = QuicTime::Delta::Zero();
127 for (QuicPacketSequenceNumber i = least_unacked; i <= largest_received; ++i) { 128 for (QuicPacketSequenceNumber i = least_unacked; i <= largest_received; ++i) {
128 ack.received_packet_times.push_back(make_pair(i, clock_->Now())); 129 ack.received_packet_times.push_back(make_pair(i, clock_->Now()));
129 } 130 }
130 131
131 QuicFramer framer(SupportedVersions(version_), clock_->Now(), false); 132 QuicFramer framer(SupportedVersions(version_), clock_->Now(),
133 Perspective::IS_CLIENT);
132 QuicFrames frames; 134 QuicFrames frames;
133 frames.push_back(QuicFrame(&ack)); 135 frames.push_back(QuicFrame(&ack));
134 136
135 QuicStopWaitingFrame stop_waiting; 137 QuicStopWaitingFrame stop_waiting;
136 stop_waiting.least_unacked = least_unacked; 138 stop_waiting.least_unacked = least_unacked;
137 frames.push_back(QuicFrame(&stop_waiting)); 139 frames.push_back(QuicFrame(&stop_waiting));
138 140
139 scoped_ptr<QuicPacket> packet( 141 scoped_ptr<QuicPacket> packet(
140 BuildUnsizedDataPacket(&framer, header, frames)); 142 BuildUnsizedDataPacket(&framer, header, frames));
141 return scoped_ptr<QuicEncryptedPacket>(framer.EncryptPacket( 143 return scoped_ptr<QuicEncryptedPacket>(framer.EncryptPacket(
(...skipping 85 matching lines...) Expand 10 before | Expand all | Expand 10 after
227 SpdyHeaderBlock headers; 229 SpdyHeaderBlock headers;
228 headers[":status"] = status; 230 headers[":status"] = status;
229 headers[":version"] = "HTTP/1.1"; 231 headers[":version"] = "HTTP/1.1";
230 headers["content-type"] = "text/plain"; 232 headers["content-type"] = "text/plain";
231 return headers; 233 return headers;
232 } 234 }
233 235
234 scoped_ptr<QuicEncryptedPacket> QuicTestPacketMaker::MakePacket( 236 scoped_ptr<QuicEncryptedPacket> QuicTestPacketMaker::MakePacket(
235 const QuicPacketHeader& header, 237 const QuicPacketHeader& header,
236 const QuicFrame& frame) { 238 const QuicFrame& frame) {
237 QuicFramer framer(SupportedVersions(version_), QuicTime::Zero(), false); 239 QuicFramer framer(SupportedVersions(version_), QuicTime::Zero(),
240 Perspective::IS_CLIENT);
238 QuicFrames frames; 241 QuicFrames frames;
239 frames.push_back(frame); 242 frames.push_back(frame);
240 scoped_ptr<QuicPacket> packet( 243 scoped_ptr<QuicPacket> packet(
241 BuildUnsizedDataPacket(&framer, header, frames)); 244 BuildUnsizedDataPacket(&framer, header, frames));
242 return scoped_ptr<QuicEncryptedPacket>(framer.EncryptPacket( 245 return scoped_ptr<QuicEncryptedPacket>(framer.EncryptPacket(
243 ENCRYPTION_NONE, header.packet_sequence_number, *packet)); 246 ENCRYPTION_NONE, header.packet_sequence_number, *packet));
244 } 247 }
245 248
246 void QuicTestPacketMaker::InitializeHeader( 249 void QuicTestPacketMaker::InitializeHeader(
247 QuicPacketSequenceNumber sequence_number, 250 QuicPacketSequenceNumber sequence_number,
248 bool should_include_version) { 251 bool should_include_version) {
249 header_.public_header.connection_id = connection_id_; 252 header_.public_header.connection_id = connection_id_;
250 header_.public_header.reset_flag = false; 253 header_.public_header.reset_flag = false;
251 header_.public_header.version_flag = should_include_version; 254 header_.public_header.version_flag = should_include_version;
252 header_.public_header.sequence_number_length = PACKET_1BYTE_SEQUENCE_NUMBER; 255 header_.public_header.sequence_number_length = PACKET_1BYTE_SEQUENCE_NUMBER;
253 header_.packet_sequence_number = sequence_number; 256 header_.packet_sequence_number = sequence_number;
254 header_.fec_group = 0; 257 header_.fec_group = 0;
255 header_.entropy_flag = false; 258 header_.entropy_flag = false;
256 header_.fec_flag = false; 259 header_.fec_flag = false;
257 } 260 }
258 261
259 } // namespace test 262 } // namespace test
260 } // namespace net 263 } // namespace net
OLDNEW
« no previous file with comments | « net/quic/test_tools/quic_sent_packet_manager_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