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 32 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
43 } | 43 } |
44 | 44 |
45 scoped_ptr<QuicEncryptedPacket> QuicTestPacketMaker::MakeAckAndRstPacket( | 45 scoped_ptr<QuicEncryptedPacket> QuicTestPacketMaker::MakeAckAndRstPacket( |
46 QuicPacketSequenceNumber num, | 46 QuicPacketSequenceNumber num, |
47 bool include_version, | 47 bool include_version, |
48 QuicStreamId stream_id, | 48 QuicStreamId stream_id, |
49 QuicRstStreamErrorCode error_code, | 49 QuicRstStreamErrorCode error_code, |
50 QuicPacketSequenceNumber largest_received, | 50 QuicPacketSequenceNumber largest_received, |
51 QuicPacketSequenceNumber least_unacked, | 51 QuicPacketSequenceNumber least_unacked, |
52 bool send_feedback) { | 52 bool send_feedback) { |
53 | |
54 QuicPacketHeader header; | 53 QuicPacketHeader header; |
55 header.public_header.connection_id = connection_id_; | 54 header.public_header.connection_id = connection_id_; |
56 header.public_header.reset_flag = false; | 55 header.public_header.reset_flag = false; |
57 header.public_header.version_flag = include_version; | 56 header.public_header.version_flag = include_version; |
58 header.public_header.sequence_number_length = PACKET_1BYTE_SEQUENCE_NUMBER; | 57 header.public_header.sequence_number_length = PACKET_1BYTE_SEQUENCE_NUMBER; |
59 header.packet_sequence_number = num; | 58 header.packet_sequence_number = num; |
60 header.entropy_flag = false; | 59 header.entropy_flag = false; |
61 header.fec_flag = false; | 60 header.fec_flag = false; |
62 header.fec_group = 0; | 61 header.fec_group = 0; |
63 | 62 |
(...skipping 103 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
167 bool should_include_version, | 166 bool should_include_version, |
168 bool fin, | 167 bool fin, |
169 const SpdyHeaderBlock& headers) { | 168 const SpdyHeaderBlock& headers) { |
170 InitializeHeader(sequence_number, should_include_version); | 169 InitializeHeader(sequence_number, should_include_version); |
171 SpdySynStreamIR syn_stream(stream_id); | 170 SpdySynStreamIR syn_stream(stream_id); |
172 syn_stream.set_name_value_block(headers); | 171 syn_stream.set_name_value_block(headers); |
173 syn_stream.set_fin(fin); | 172 syn_stream.set_fin(fin); |
174 syn_stream.set_priority(0); | 173 syn_stream.set_priority(0); |
175 scoped_ptr<SpdySerializedFrame> spdy_frame( | 174 scoped_ptr<SpdySerializedFrame> spdy_frame( |
176 spdy_request_framer_.SerializeSynStream(syn_stream)); | 175 spdy_request_framer_.SerializeSynStream(syn_stream)); |
177 QuicStreamFrame frame(kHeadersStreamId, false, 0, | 176 QuicStreamFrame frame( |
178 MakeIOVector(base::StringPiece(spdy_frame->data(), | 177 kHeadersStreamId, |
179 spdy_frame->size()))); | 178 false, |
| 179 0, |
| 180 MakeIOVector(base::StringPiece(spdy_frame->data(), spdy_frame->size()))); |
180 return MakePacket(header_, QuicFrame(&frame)); | 181 return MakePacket(header_, QuicFrame(&frame)); |
181 } | 182 } |
182 | 183 |
183 scoped_ptr<QuicEncryptedPacket> QuicTestPacketMaker::MakeResponseHeadersPacket( | 184 scoped_ptr<QuicEncryptedPacket> QuicTestPacketMaker::MakeResponseHeadersPacket( |
184 QuicPacketSequenceNumber sequence_number, | 185 QuicPacketSequenceNumber sequence_number, |
185 QuicStreamId stream_id, | 186 QuicStreamId stream_id, |
186 bool should_include_version, | 187 bool should_include_version, |
187 bool fin, | 188 bool fin, |
188 const SpdyHeaderBlock& headers) { | 189 const SpdyHeaderBlock& headers) { |
189 InitializeHeader(sequence_number, should_include_version); | 190 InitializeHeader(sequence_number, should_include_version); |
190 SpdySynReplyIR syn_reply(stream_id); | 191 SpdySynReplyIR syn_reply(stream_id); |
191 syn_reply.set_name_value_block(headers); | 192 syn_reply.set_name_value_block(headers); |
192 syn_reply.set_fin(fin); | 193 syn_reply.set_fin(fin); |
193 scoped_ptr<SpdySerializedFrame> spdy_frame( | 194 scoped_ptr<SpdySerializedFrame> spdy_frame( |
194 spdy_response_framer_.SerializeSynReply(syn_reply)); | 195 spdy_response_framer_.SerializeSynReply(syn_reply)); |
195 QuicStreamFrame frame(kHeadersStreamId, false, 0, | 196 QuicStreamFrame frame( |
196 MakeIOVector(base::StringPiece(spdy_frame->data(), | 197 kHeadersStreamId, |
197 spdy_frame->size()))); | 198 false, |
| 199 0, |
| 200 MakeIOVector(base::StringPiece(spdy_frame->data(), spdy_frame->size()))); |
198 return MakePacket(header_, QuicFrame(&frame)); | 201 return MakePacket(header_, QuicFrame(&frame)); |
199 } | 202 } |
200 | 203 |
201 SpdyHeaderBlock QuicTestPacketMaker::GetRequestHeaders( | 204 SpdyHeaderBlock QuicTestPacketMaker::GetRequestHeaders( |
202 const std::string& method, | 205 const std::string& method, |
203 const std::string& scheme, | 206 const std::string& scheme, |
204 const std::string& path) { | 207 const std::string& path) { |
205 SpdyHeaderBlock headers; | 208 SpdyHeaderBlock headers; |
206 headers[":method"] = method; | 209 headers[":method"] = method; |
207 headers[":host"] = "www.google.com"; | 210 headers[":host"] = "www.google.com"; |
(...skipping 32 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
240 header_.public_header.version_flag = should_include_version; | 243 header_.public_header.version_flag = should_include_version; |
241 header_.public_header.sequence_number_length = PACKET_1BYTE_SEQUENCE_NUMBER; | 244 header_.public_header.sequence_number_length = PACKET_1BYTE_SEQUENCE_NUMBER; |
242 header_.packet_sequence_number = sequence_number; | 245 header_.packet_sequence_number = sequence_number; |
243 header_.fec_group = 0; | 246 header_.fec_group = 0; |
244 header_.entropy_flag = false; | 247 header_.entropy_flag = false; |
245 header_.fec_flag = false; | 248 header_.fec_flag = false; |
246 } | 249 } |
247 | 250 |
248 } // namespace test | 251 } // namespace test |
249 } // namespace net | 252 } // namespace net |
OLD | NEW |