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