OLD | NEW |
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 Loading... |
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 Loading... |
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 Loading... |
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 |
OLD | NEW |