| 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 |