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 <list> | 7 #include <list> |
8 #include <utility> | 8 #include <utility> |
9 | 9 |
10 #include "base/memory/ptr_util.h" | 10 #include "base/memory/ptr_util.h" |
(...skipping 278 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
289 // Returns a newly created packet to send kData on stream 1. | 289 // Returns a newly created packet to send kData on stream 1. |
290 std::unique_ptr<QuicReceivedPacket> QuicTestPacketMaker::MakeDataPacket( | 290 std::unique_ptr<QuicReceivedPacket> QuicTestPacketMaker::MakeDataPacket( |
291 QuicPacketNumber packet_number, | 291 QuicPacketNumber packet_number, |
292 QuicStreamId stream_id, | 292 QuicStreamId stream_id, |
293 bool should_include_version, | 293 bool should_include_version, |
294 bool fin, | 294 bool fin, |
295 QuicStreamOffset offset, | 295 QuicStreamOffset offset, |
296 base::StringPiece data) { | 296 base::StringPiece data) { |
297 InitializeHeader(packet_number, should_include_version); | 297 InitializeHeader(packet_number, should_include_version); |
298 QuicStreamFrame frame(stream_id, fin, offset, data); | 298 QuicStreamFrame frame(stream_id, fin, offset, data); |
| 299 DVLOG(1) << "Adding frame: " << frame; |
299 return MakePacket(header_, QuicFrame(&frame)); | 300 return MakePacket(header_, QuicFrame(&frame)); |
300 } | 301 } |
301 | 302 |
302 std::unique_ptr<QuicReceivedPacket> | 303 std::unique_ptr<QuicReceivedPacket> |
303 QuicTestPacketMaker::MakeMultipleDataFramesPacket( | 304 QuicTestPacketMaker::MakeMultipleDataFramesPacket( |
304 QuicPacketNumber packet_number, | 305 QuicPacketNumber packet_number, |
305 QuicStreamId stream_id, | 306 QuicStreamId stream_id, |
306 bool should_include_version, | 307 bool should_include_version, |
307 bool fin, | 308 bool fin, |
308 QuicStreamOffset offset, | 309 QuicStreamOffset offset, |
(...skipping 202 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
511 *offset += spdy_frame.size(); | 512 *offset += spdy_frame.size(); |
512 return MakePacket(header_, QuicFrame(&frame)); | 513 return MakePacket(header_, QuicFrame(&frame)); |
513 } else { | 514 } else { |
514 QuicStreamFrame frame( | 515 QuicStreamFrame frame( |
515 kHeadersStreamId, false, 0, | 516 kHeadersStreamId, false, 0, |
516 base::StringPiece(spdy_frame.data(), spdy_frame.size())); | 517 base::StringPiece(spdy_frame.data(), spdy_frame.size())); |
517 return MakePacket(header_, QuicFrame(&frame)); | 518 return MakePacket(header_, QuicFrame(&frame)); |
518 } | 519 } |
519 } | 520 } |
520 | 521 |
| 522 std::unique_ptr<QuicReceivedPacket> QuicTestPacketMaker::MakeForceHolDataPacket( |
| 523 QuicPacketNumber packet_number, |
| 524 QuicStreamId stream_id, |
| 525 bool should_include_version, |
| 526 bool fin, |
| 527 QuicStreamOffset* offset, |
| 528 base::StringPiece data) { |
| 529 SpdyDataIR spdy_data(stream_id, data); |
| 530 spdy_data.set_fin(fin); |
| 531 SpdySerializedFrame spdy_frame( |
| 532 spdy_request_framer_.SerializeFrame(spdy_data)); |
| 533 InitializeHeader(packet_number, should_include_version); |
| 534 QuicStreamFrame quic_frame(kHeadersStreamId, false, *offset, |
| 535 StringPiece(spdy_frame.data(), spdy_frame.size())); |
| 536 *offset += spdy_frame.size(); |
| 537 return MakePacket(header_, QuicFrame(&quic_frame)); |
| 538 } |
| 539 |
521 // If |offset| is provided, will use the value when creating the packet. | 540 // If |offset| is provided, will use the value when creating the packet. |
522 // Will also update the value after packet creation. | 541 // Will also update the value after packet creation. |
523 std::unique_ptr<QuicReceivedPacket> | 542 std::unique_ptr<QuicReceivedPacket> |
524 QuicTestPacketMaker::MakeResponseHeadersPacket( | 543 QuicTestPacketMaker::MakeResponseHeadersPacket( |
525 QuicPacketNumber packet_number, | 544 QuicPacketNumber packet_number, |
526 QuicStreamId stream_id, | 545 QuicStreamId stream_id, |
527 bool should_include_version, | 546 bool should_include_version, |
528 bool fin, | 547 bool fin, |
529 SpdyHeaderBlock headers, | 548 SpdyHeaderBlock headers, |
530 size_t* spdy_headers_frame_length, | 549 size_t* spdy_headers_frame_length, |
(...skipping 113 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
644 header_.public_header.reset_flag = false; | 663 header_.public_header.reset_flag = false; |
645 header_.public_header.version_flag = should_include_version; | 664 header_.public_header.version_flag = should_include_version; |
646 header_.public_header.packet_number_length = PACKET_1BYTE_PACKET_NUMBER; | 665 header_.public_header.packet_number_length = PACKET_1BYTE_PACKET_NUMBER; |
647 header_.packet_number = packet_number; | 666 header_.packet_number = packet_number; |
648 header_.entropy_flag = false; | 667 header_.entropy_flag = false; |
649 header_.fec_flag = false; | 668 header_.fec_flag = false; |
650 } | 669 } |
651 | 670 |
652 } // namespace test | 671 } // namespace test |
653 } // namespace net | 672 } // namespace net |
OLD | NEW |