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

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

Issue 180723003: Land Recent QUIC Changes. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Fix unintialized memory error Created 6 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 | Annotate | Revision Log
« no previous file with comments | « net/quic/reliable_quic_stream_test.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 "net/quic/quic_framer.h" 7 #include "net/quic/quic_framer.h"
8 #include "net/quic/quic_http_utils.h" 8 #include "net/quic/quic_http_utils.h"
9 #include "net/quic/quic_utils.h" 9 #include "net/quic/quic_utils.h"
10 #include "net/quic/test_tools/quic_test_utils.h" 10 #include "net/quic/test_tools/quic_test_utils.h"
(...skipping 53 matching lines...) Expand 10 before | Expand all | Expand 10 after
64 QuicFrames frames; 64 QuicFrames frames;
65 frames.push_back(QuicFrame(&ack)); 65 frames.push_back(QuicFrame(&ack));
66 if (send_feedback) { 66 if (send_feedback) {
67 QuicCongestionFeedbackFrame feedback; 67 QuicCongestionFeedbackFrame feedback;
68 feedback.type = kTCP; 68 feedback.type = kTCP;
69 feedback.tcp.receive_window = 256000; 69 feedback.tcp.receive_window = 256000;
70 70
71 frames.push_back(QuicFrame(&feedback)); 71 frames.push_back(QuicFrame(&feedback));
72 } 72 }
73 73
74 if (version_ > QUIC_VERSION_15) {
75 QuicStopWaitingFrame stop_waiting;
76 stop_waiting.least_unacked = least_unacked;
77 frames.push_back(QuicFrame(&stop_waiting));
78 }
79
74 QuicRstStreamFrame rst(stream_id, error_code, 0); 80 QuicRstStreamFrame rst(stream_id, error_code, 0);
75 frames.push_back(QuicFrame(&rst)); 81 frames.push_back(QuicFrame(&rst));
76 82
77 QuicFramer framer(SupportedVersions(version_), QuicTime::Zero(), false); 83 QuicFramer framer(SupportedVersions(version_), QuicTime::Zero(), false);
78 scoped_ptr<QuicPacket> packet( 84 scoped_ptr<QuicPacket> packet(
79 framer.BuildUnsizedDataPacket(header, frames).packet); 85 framer.BuildUnsizedDataPacket(header, frames).packet);
80 return scoped_ptr<QuicEncryptedPacket>(framer.EncryptPacket( 86 return scoped_ptr<QuicEncryptedPacket>(framer.EncryptPacket(
81 ENCRYPTION_NONE, header.packet_sequence_number, *packet)); 87 ENCRYPTION_NONE, header.packet_sequence_number, *packet));
82 } 88 }
83 89
(...skipping 35 matching lines...) Expand 10 before | Expand all | Expand 10 after
119 QuicCongestionFeedbackFrame feedback; 125 QuicCongestionFeedbackFrame feedback;
120 feedback.type = kTCP; 126 feedback.type = kTCP;
121 feedback.tcp.receive_window = 256000; 127 feedback.tcp.receive_window = 256000;
122 128
123 QuicFramer framer(SupportedVersions(version_), QuicTime::Zero(), false); 129 QuicFramer framer(SupportedVersions(version_), QuicTime::Zero(), false);
124 QuicFrames frames; 130 QuicFrames frames;
125 frames.push_back(QuicFrame(&ack)); 131 frames.push_back(QuicFrame(&ack));
126 if (send_feedback) { 132 if (send_feedback) {
127 frames.push_back(QuicFrame(&feedback)); 133 frames.push_back(QuicFrame(&feedback));
128 } 134 }
135
136 if (version_ > QUIC_VERSION_15) {
137 QuicStopWaitingFrame stop_waiting;
138 stop_waiting.least_unacked = least_unacked;
139 frames.push_back(QuicFrame(&stop_waiting));
140 }
141
129 scoped_ptr<QuicPacket> packet( 142 scoped_ptr<QuicPacket> packet(
130 framer.BuildUnsizedDataPacket(header, frames).packet); 143 framer.BuildUnsizedDataPacket(header, frames).packet);
131 return scoped_ptr<QuicEncryptedPacket>(framer.EncryptPacket( 144 return scoped_ptr<QuicEncryptedPacket>(framer.EncryptPacket(
132 ENCRYPTION_NONE, header.packet_sequence_number, *packet)); 145 ENCRYPTION_NONE, header.packet_sequence_number, *packet));
133 } 146 }
134 147
135 // Returns a newly created packet to send kData on stream 1. 148 // Returns a newly created packet to send kData on stream 1.
136 scoped_ptr<QuicEncryptedPacket> QuicTestPacketMaker::MakeDataPacket( 149 scoped_ptr<QuicEncryptedPacket> QuicTestPacketMaker::MakeDataPacket(
137 QuicPacketSequenceNumber sequence_number, 150 QuicPacketSequenceNumber sequence_number,
138 QuicStreamId stream_id, 151 QuicStreamId stream_id,
(...skipping 108 matching lines...) Expand 10 before | Expand all | Expand 10 after
247 260
248 std::string QuicTestPacketMaker::SerializeHeaderBlock( 261 std::string QuicTestPacketMaker::SerializeHeaderBlock(
249 const SpdyHeaderBlock& headers) { 262 const SpdyHeaderBlock& headers) {
250 QuicSpdyCompressor compressor; 263 QuicSpdyCompressor compressor;
251 return compressor.CompressHeadersWithPriority( 264 return compressor.CompressHeadersWithPriority(
252 ConvertRequestPriorityToQuicPriority(DEFAULT_PRIORITY), headers); 265 ConvertRequestPriorityToQuicPriority(DEFAULT_PRIORITY), headers);
253 } 266 }
254 267
255 } // namespace test 268 } // namespace test
256 } // namespace net 269 } // namespace net
OLDNEW
« no previous file with comments | « net/quic/reliable_quic_stream_test.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