| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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_utils.h" | 5 #include "net/quic/test_tools/quic_test_utils.h" |
| 6 | 6 |
| 7 #include <memory> | 7 #include <memory> |
| 8 | 8 |
| 9 #include "base/sha1.h" | 9 #include "base/sha1.h" |
| 10 #include "base/stl_util.h" | 10 #include "base/stl_util.h" |
| (...skipping 573 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 584 header.public_header.connection_id_length = connection_id_length; | 584 header.public_header.connection_id_length = connection_id_length; |
| 585 header.public_header.version_flag = version_flag; | 585 header.public_header.version_flag = version_flag; |
| 586 header.public_header.multipath_flag = multipath_flag; | 586 header.public_header.multipath_flag = multipath_flag; |
| 587 header.public_header.reset_flag = reset_flag; | 587 header.public_header.reset_flag = reset_flag; |
| 588 header.public_header.packet_number_length = packet_number_length; | 588 header.public_header.packet_number_length = packet_number_length; |
| 589 header.path_id = path_id; | 589 header.path_id = path_id; |
| 590 header.packet_number = packet_number; | 590 header.packet_number = packet_number; |
| 591 header.entropy_flag = false; | 591 header.entropy_flag = false; |
| 592 header.entropy_hash = 0; | 592 header.entropy_hash = 0; |
| 593 header.fec_flag = false; | 593 header.fec_flag = false; |
| 594 header.is_in_fec_group = NOT_IN_FEC_GROUP; | |
| 595 header.fec_group = 0; | |
| 596 QuicStreamFrame stream_frame(1, false, 0, StringPiece(data)); | 594 QuicStreamFrame stream_frame(1, false, 0, StringPiece(data)); |
| 597 QuicFrame frame(&stream_frame); | 595 QuicFrame frame(&stream_frame); |
| 598 QuicFrames frames; | 596 QuicFrames frames; |
| 599 frames.push_back(frame); | 597 frames.push_back(frame); |
| 600 QuicFramer framer(versions != nullptr ? *versions : QuicSupportedVersions(), | 598 QuicFramer framer(versions != nullptr ? *versions : QuicSupportedVersions(), |
| 601 QuicTime::Zero(), perspective); | 599 QuicTime::Zero(), perspective); |
| 602 | 600 |
| 603 std::unique_ptr<QuicPacket> packet( | 601 std::unique_ptr<QuicPacket> packet( |
| 604 BuildUnsizedDataPacket(&framer, header, frames)); | 602 BuildUnsizedDataPacket(&framer, header, frames)); |
| 605 EXPECT_TRUE(packet != nullptr); | 603 EXPECT_TRUE(packet != nullptr); |
| (...skipping 30 matching lines...) Expand all Loading... |
| 636 header.public_header.connection_id_length = connection_id_length; | 634 header.public_header.connection_id_length = connection_id_length; |
| 637 header.public_header.version_flag = version_flag; | 635 header.public_header.version_flag = version_flag; |
| 638 header.public_header.multipath_flag = multipath_flag; | 636 header.public_header.multipath_flag = multipath_flag; |
| 639 header.public_header.reset_flag = reset_flag; | 637 header.public_header.reset_flag = reset_flag; |
| 640 header.public_header.packet_number_length = packet_number_length; | 638 header.public_header.packet_number_length = packet_number_length; |
| 641 header.path_id = path_id; | 639 header.path_id = path_id; |
| 642 header.packet_number = packet_number; | 640 header.packet_number = packet_number; |
| 643 header.entropy_flag = false; | 641 header.entropy_flag = false; |
| 644 header.entropy_hash = 0; | 642 header.entropy_hash = 0; |
| 645 header.fec_flag = false; | 643 header.fec_flag = false; |
| 646 header.is_in_fec_group = NOT_IN_FEC_GROUP; | |
| 647 header.fec_group = 0; | |
| 648 QuicStreamFrame stream_frame(1, false, 0, StringPiece(data)); | 644 QuicStreamFrame stream_frame(1, false, 0, StringPiece(data)); |
| 649 QuicFrame frame(&stream_frame); | 645 QuicFrame frame(&stream_frame); |
| 650 QuicFrames frames; | 646 QuicFrames frames; |
| 651 frames.push_back(frame); | 647 frames.push_back(frame); |
| 652 QuicFramer framer(versions != nullptr ? *versions : QuicSupportedVersions(), | 648 QuicFramer framer(versions != nullptr ? *versions : QuicSupportedVersions(), |
| 653 QuicTime::Zero(), perspective); | 649 QuicTime::Zero(), perspective); |
| 654 | 650 |
| 655 std::unique_ptr<QuicPacket> packet( | 651 std::unique_ptr<QuicPacket> packet( |
| 656 BuildUnsizedDataPacket(&framer, header, frames)); | 652 BuildUnsizedDataPacket(&framer, header, frames)); |
| 657 EXPECT_TRUE(packet != nullptr); | 653 EXPECT_TRUE(packet != nullptr); |
| (...skipping 74 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 732 Perspective::IS_CLIENT); | 728 Perspective::IS_CLIENT); |
| 733 | 729 |
| 734 QuicPacketHeader header; | 730 QuicPacketHeader header; |
| 735 header.public_header.connection_id = connection_id; | 731 header.public_header.connection_id = connection_id; |
| 736 header.public_header.reset_flag = false; | 732 header.public_header.reset_flag = false; |
| 737 header.public_header.version_flag = should_include_version; | 733 header.public_header.version_flag = should_include_version; |
| 738 header.packet_number = 1; | 734 header.packet_number = 1; |
| 739 header.entropy_flag = false; | 735 header.entropy_flag = false; |
| 740 header.entropy_hash = 0; | 736 header.entropy_hash = 0; |
| 741 header.fec_flag = false; | 737 header.fec_flag = false; |
| 742 header.fec_group = 0; | |
| 743 | 738 |
| 744 QuicStreamFrame stream_frame(kCryptoStreamId, false, 0, | 739 QuicStreamFrame stream_frame(kCryptoStreamId, false, 0, |
| 745 data->AsStringPiece()); | 740 data->AsStringPiece()); |
| 746 | 741 |
| 747 QuicFrame frame(&stream_frame); | 742 QuicFrame frame(&stream_frame); |
| 748 QuicFrames frames; | 743 QuicFrames frames; |
| 749 frames.push_back(frame); | 744 frames.push_back(frame); |
| 750 return BuildUnsizedDataPacket(&quic_framer, header, frames); | 745 return BuildUnsizedDataPacket(&quic_framer, header, frames); |
| 751 } | 746 } |
| 752 | 747 |
| (...skipping 131 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 884 // strike register worries that we've just overflowed a uint32_t time. | 879 // strike register worries that we've just overflowed a uint32_t time. |
| 885 (*server_connection)->AdvanceTime(connection_start_time); | 880 (*server_connection)->AdvanceTime(connection_start_time); |
| 886 } | 881 } |
| 887 | 882 |
| 888 QuicStreamId QuicClientDataStreamId(int i) { | 883 QuicStreamId QuicClientDataStreamId(int i) { |
| 889 return kClientDataStreamId1 + 2 * i; | 884 return kClientDataStreamId1 + 2 * i; |
| 890 } | 885 } |
| 891 | 886 |
| 892 } // namespace test | 887 } // namespace test |
| 893 } // namespace net | 888 } // namespace net |
| OLD | NEW |