| Index: net/quic/test_tools/quic_test_packet_maker.cc
|
| diff --git a/net/quic/test_tools/quic_test_packet_maker.cc b/net/quic/test_tools/quic_test_packet_maker.cc
|
| index 65404264643876614d13fbdb49efd24d86661dc8..c6828cc965cb28bcbb81a8140d370ccb491b4727 100644
|
| --- a/net/quic/test_tools/quic_test_packet_maker.cc
|
| +++ b/net/quic/test_tools/quic_test_packet_maker.cc
|
| @@ -31,11 +31,13 @@ QuicTestPacketMaker::~QuicTestPacketMaker() {
|
|
|
| scoped_ptr<QuicEncryptedPacket> QuicTestPacketMaker::MakeRstPacket(
|
| QuicPacketSequenceNumber num,
|
| + QuicConnectionIdLength connection_id_length,
|
| bool include_version,
|
| QuicStreamId stream_id,
|
| QuicRstStreamErrorCode error_code) {
|
| QuicPacketHeader header;
|
| header.public_header.connection_id = connection_id_;
|
| + header.public_header.connection_id_length = connection_id_length;
|
| header.public_header.reset_flag = false;
|
| header.public_header.version_flag = include_version;
|
| header.public_header.sequence_number_length = PACKET_1BYTE_SEQUENCE_NUMBER;
|
| @@ -56,9 +58,9 @@ scoped_ptr<QuicEncryptedPacket> QuicTestPacketMaker::MakeAckAndRstPacket(
|
| QuicPacketSequenceNumber largest_received,
|
| QuicPacketSequenceNumber least_unacked,
|
| bool send_feedback) {
|
| -
|
| QuicPacketHeader header;
|
| header.public_header.connection_id = connection_id_;
|
| + header.public_header.connection_id_length = PACKET_8BYTE_CONNECTION_ID;
|
| header.public_header.reset_flag = false;
|
| header.public_header.version_flag = include_version;
|
| header.public_header.sequence_number_length = PACKET_1BYTE_SEQUENCE_NUMBER;
|
| @@ -103,6 +105,7 @@ scoped_ptr<QuicEncryptedPacket> QuicTestPacketMaker::MakeConnectionClosePacket(
|
| QuicPacketSequenceNumber num) {
|
| QuicPacketHeader header;
|
| header.public_header.connection_id = connection_id_;
|
| + header.public_header.connection_id_length = PACKET_0BYTE_CONNECTION_ID;
|
| header.public_header.reset_flag = false;
|
| header.public_header.version_flag = false;
|
| header.public_header.sequence_number_length = PACKET_1BYTE_SEQUENCE_NUMBER;
|
| @@ -119,11 +122,13 @@ scoped_ptr<QuicEncryptedPacket> QuicTestPacketMaker::MakeConnectionClosePacket(
|
|
|
| scoped_ptr<QuicEncryptedPacket> QuicTestPacketMaker::MakeAckPacket(
|
| QuicPacketSequenceNumber sequence_number,
|
| + QuicConnectionIdLength connection_id_length,
|
| QuicPacketSequenceNumber largest_received,
|
| QuicPacketSequenceNumber least_unacked,
|
| bool send_feedback) {
|
| QuicPacketHeader header;
|
| header.public_header.connection_id = connection_id_;
|
| + header.public_header.connection_id_length = connection_id_length;
|
| header.public_header.reset_flag = false;
|
| header.public_header.version_flag = false;
|
| header.public_header.sequence_number_length = PACKET_1BYTE_SEQUENCE_NUMBER;
|
| @@ -169,7 +174,8 @@ scoped_ptr<QuicEncryptedPacket> QuicTestPacketMaker::MakeDataPacket(
|
| bool fin,
|
| QuicStreamOffset offset,
|
| base::StringPiece data) {
|
| - InitializeHeader(sequence_number, should_include_version);
|
| + InitializeHeader(sequence_number, PACKET_8BYTE_CONNECTION_ID,
|
| + should_include_version);
|
| QuicStreamFrame frame(stream_id, fin, offset, MakeIOVector(data));
|
| return MakePacket(header_, QuicFrame(&frame));
|
| }
|
| @@ -177,10 +183,12 @@ scoped_ptr<QuicEncryptedPacket> QuicTestPacketMaker::MakeDataPacket(
|
| scoped_ptr<QuicEncryptedPacket> QuicTestPacketMaker::MakeRequestHeadersPacket(
|
| QuicPacketSequenceNumber sequence_number,
|
| QuicStreamId stream_id,
|
| + QuicConnectionIdLength connection_id_length,
|
| bool should_include_version,
|
| bool fin,
|
| const SpdyHeaderBlock& headers) {
|
| - InitializeHeader(sequence_number, should_include_version);
|
| + InitializeHeader(sequence_number, connection_id_length,
|
| + should_include_version);
|
| SpdySynStreamIR syn_stream(stream_id);
|
| syn_stream.set_name_value_block(headers);
|
| syn_stream.set_fin(fin);
|
| @@ -196,10 +204,12 @@ scoped_ptr<QuicEncryptedPacket> QuicTestPacketMaker::MakeRequestHeadersPacket(
|
| scoped_ptr<QuicEncryptedPacket> QuicTestPacketMaker::MakeResponseHeadersPacket(
|
| QuicPacketSequenceNumber sequence_number,
|
| QuicStreamId stream_id,
|
| + QuicConnectionIdLength connection_id_length,
|
| bool should_include_version,
|
| bool fin,
|
| const SpdyHeaderBlock& headers) {
|
| - InitializeHeader(sequence_number, should_include_version);
|
| + InitializeHeader(sequence_number, connection_id_length,
|
| + should_include_version);
|
| SpdySynReplyIR syn_reply(stream_id);
|
| syn_reply.set_name_value_block(headers);
|
| syn_reply.set_fin(fin);
|
| @@ -247,8 +257,10 @@ scoped_ptr<QuicEncryptedPacket> QuicTestPacketMaker::MakePacket(
|
|
|
| void QuicTestPacketMaker::InitializeHeader(
|
| QuicPacketSequenceNumber sequence_number,
|
| + QuicConnectionIdLength connection_id_length,
|
| bool should_include_version) {
|
| header_.public_header.connection_id = connection_id_;
|
| + header_.public_header.connection_id_length = connection_id_length;
|
| header_.public_header.reset_flag = false;
|
| header_.public_header.version_flag = should_include_version;
|
| header_.public_header.sequence_number_length = PACKET_1BYTE_SEQUENCE_NUMBER;
|
|
|