| Index: net/quic/quic_connection_test.cc
|
| diff --git a/net/quic/quic_connection_test.cc b/net/quic/quic_connection_test.cc
|
| index 39a626ac4d100ed51e8972a9fffe6021985cebc4..0eaad974cedf36c00523d814dc0af19fe2f49ec5 100644
|
| --- a/net/quic/quic_connection_test.cc
|
| +++ b/net/quic/quic_connection_test.cc
|
| @@ -399,13 +399,13 @@ class TestPacketWriter : public QuicPacketWriter {
|
|
|
| class TestConnection : public QuicConnection {
|
| public:
|
| - TestConnection(QuicGuid guid,
|
| + TestConnection(QuicConnectionId connection_id,
|
| IPEndPoint address,
|
| TestConnectionHelper* helper,
|
| TestPacketWriter* writer,
|
| bool is_server,
|
| QuicVersion version)
|
| - : QuicConnection(guid, address, helper, writer, is_server,
|
| + : QuicConnection(connection_id, address, helper, writer, is_server,
|
| SupportedVersions(version)),
|
| helper_(helper),
|
| writer_(writer) {
|
| @@ -541,15 +541,15 @@ class TestConnection : public QuicConnection {
|
| class QuicConnectionTest : public ::testing::TestWithParam<QuicVersion> {
|
| protected:
|
| QuicConnectionTest()
|
| - : guid_(42),
|
| + : connection_id_(42),
|
| framer_(SupportedVersions(version()), QuicTime::Zero(), false),
|
| - creator_(guid_, &framer_, &random_generator_, false),
|
| + creator_(connection_id_, &framer_, &random_generator_, false),
|
| send_algorithm_(new StrictMock<MockSendAlgorithm>),
|
| loss_algorithm_(new MockLossAlgorithm()),
|
| helper_(new TestConnectionHelper(&clock_, &random_generator_)),
|
| writer_(new TestPacketWriter(version())),
|
| - connection_(guid_, IPEndPoint(), helper_.get(), writer_.get(),
|
| - false, version()),
|
| + connection_(connection_id_, IPEndPoint(), helper_.get(),
|
| + writer_.get(), false, version()),
|
| frame1_(1, false, 0, MakeIOVector(data1)),
|
| frame2_(1, false, 3, MakeIOVector(data2)),
|
| accept_packet_(true) {
|
| @@ -721,7 +721,7 @@ class QuicConnectionTest : public ::testing::TestWithParam<QuicVersion> {
|
| data_packet.reset(ConstructDataPacket(number, 1, !kEntropyFlag));
|
| }
|
|
|
| - header_.public_header.guid = guid_;
|
| + header_.public_header.connection_id = connection_id_;
|
| header_.public_header.reset_flag = false;
|
| header_.public_header.version_flag = false;
|
| header_.entropy_flag = entropy_flag;
|
| @@ -737,7 +737,7 @@ class QuicConnectionTest : public ::testing::TestWithParam<QuicVersion> {
|
| // with itself, depending on the number of packets.
|
| if (((number - min_protected_packet) % 2) == 0) {
|
| for (size_t i = GetStartOfFecProtectedData(
|
| - header_.public_header.guid_length,
|
| + header_.public_header.connection_id_length,
|
| header_.public_header.version_flag,
|
| header_.public_header.sequence_number_length);
|
| i < data_packet->length(); ++i) {
|
| @@ -799,7 +799,7 @@ class QuicConnectionTest : public ::testing::TestWithParam<QuicVersion> {
|
| QuicPacket* ConstructDataPacket(QuicPacketSequenceNumber number,
|
| QuicFecGroupNumber fec_group,
|
| bool entropy_flag) {
|
| - header_.public_header.guid = guid_;
|
| + header_.public_header.connection_id = connection_id_;
|
| header_.public_header.reset_flag = false;
|
| header_.public_header.version_flag = false;
|
| header_.entropy_flag = entropy_flag;
|
| @@ -819,7 +819,7 @@ class QuicConnectionTest : public ::testing::TestWithParam<QuicVersion> {
|
|
|
| QuicPacket* ConstructClosePacket(QuicPacketSequenceNumber number,
|
| QuicFecGroupNumber fec_group) {
|
| - header_.public_header.guid = guid_;
|
| + header_.public_header.connection_id = connection_id_;
|
| header_.packet_sequence_number = number;
|
| header_.public_header.reset_flag = false;
|
| header_.public_header.version_flag = false;
|
| @@ -909,7 +909,7 @@ class QuicConnectionTest : public ::testing::TestWithParam<QuicVersion> {
|
| EXPECT_CALL(visitor_, OnWriteBlocked()).Times(AtLeast(1));
|
| }
|
|
|
| - QuicGuid guid_;
|
| + QuicConnectionId connection_id_;
|
| QuicFramer framer_;
|
| QuicPacketCreator creator_;
|
| MockEntropyCalculator entropy_calculator_;
|
| @@ -2990,7 +2990,7 @@ TEST_P(QuicConnectionTest, SendWhenDisconnected) {
|
|
|
| TEST_P(QuicConnectionTest, PublicReset) {
|
| QuicPublicResetPacket header;
|
| - header.public_header.guid = guid_;
|
| + header.public_header.connection_id = connection_id_;
|
| header.public_header.reset_flag = true;
|
| header.public_header.version_flag = false;
|
| header.rejected_sequence_number = 10101;
|
| @@ -3200,7 +3200,7 @@ TEST_P(QuicConnectionTest, ServerSendsVersionNegotiationPacket) {
|
| framer_.set_version_for_tests(QUIC_VERSION_UNSUPPORTED);
|
|
|
| QuicPacketHeader header;
|
| - header.public_header.guid = guid_;
|
| + header.public_header.connection_id = connection_id_;
|
| header.public_header.reset_flag = false;
|
| header.public_header.version_flag = true;
|
| header.entropy_flag = false;
|
| @@ -3238,7 +3238,7 @@ TEST_P(QuicConnectionTest, ServerSendsVersionNegotiationPacketSocketBlocked) {
|
| framer_.set_version_for_tests(QUIC_VERSION_UNSUPPORTED);
|
|
|
| QuicPacketHeader header;
|
| - header.public_header.guid = guid_;
|
| + header.public_header.connection_id = connection_id_;
|
| header.public_header.reset_flag = false;
|
| header.public_header.version_flag = true;
|
| header.entropy_flag = false;
|
| @@ -3283,7 +3283,7 @@ TEST_P(QuicConnectionTest,
|
| framer_.set_version_for_tests(QUIC_VERSION_UNSUPPORTED);
|
|
|
| QuicPacketHeader header;
|
| - header.public_header.guid = guid_;
|
| + header.public_header.connection_id = connection_id_;
|
| header.public_header.reset_flag = false;
|
| header.public_header.version_flag = true;
|
| header.entropy_flag = false;
|
| @@ -3314,7 +3314,7 @@ TEST_P(QuicConnectionTest, ClientHandlesVersionNegotiation) {
|
| QUIC_VERSION_UNSUPPORTED);
|
|
|
| QuicPacketHeader header;
|
| - header.public_header.guid = guid_;
|
| + header.public_header.connection_id = connection_id_;
|
| header.public_header.reset_flag = false;
|
| header.public_header.version_flag = true;
|
| header.entropy_flag = false;
|
| @@ -3352,7 +3352,7 @@ TEST_P(QuicConnectionTest, ClientHandlesVersionNegotiation) {
|
|
|
| TEST_P(QuicConnectionTest, BadVersionNegotiation) {
|
| QuicPacketHeader header;
|
| - header.public_header.guid = guid_;
|
| + header.public_header.connection_id = connection_id_;
|
| header.public_header.reset_flag = false;
|
| header.public_header.version_flag = true;
|
| header.entropy_flag = false;
|
| @@ -3480,7 +3480,7 @@ TEST_P(QuicConnectionTest, TestFecGroupLimits) {
|
|
|
| TEST_P(QuicConnectionTest, ProcessFramesIfPacketClosedConnection) {
|
| // Construct a packet with stream frame and connection close frame.
|
| - header_.public_header.guid = guid_;
|
| + header_.public_header.connection_id = connection_id_;
|
| header_.packet_sequence_number = 1;
|
| header_.public_header.reset_flag = false;
|
| header_.public_header.version_flag = false;
|
| @@ -3512,7 +3512,7 @@ TEST_P(QuicConnectionTest, ProcessFramesIfPacketClosedConnection) {
|
| TEST_P(QuicConnectionTest, DontProcessStreamFrameAndIgnoreCloseFrame) {
|
| // Construct a packet with stream frame, ack frame,
|
| // and connection close frame.
|
| - header_.public_header.guid = guid_;
|
| + header_.public_header.connection_id = connection_id_;
|
| header_.packet_sequence_number = 1;
|
| header_.public_header.reset_flag = false;
|
| header_.public_header.version_flag = false;
|
| @@ -3715,7 +3715,7 @@ TEST_P(QuicConnectionTest, AckNotifierCallbackAfterFECRecovery) {
|
| frames.push_back(QuicFrame(&frame1_));
|
|
|
| QuicPacketHeader ack_header;
|
| - ack_header.public_header.guid = guid_;
|
| + ack_header.public_header.connection_id = connection_id_;
|
| ack_header.public_header.reset_flag = false;
|
| ack_header.public_header.version_flag = false;
|
| ack_header.entropy_flag = !kEntropyFlag;
|
| @@ -3800,10 +3800,10 @@ TEST_P(QuicConnectionTest, OnPacketHeaderDebugVisitor) {
|
| TEST_P(QuicConnectionTest, Pacing) {
|
| ValueRestore<bool> old_flag(&FLAGS_enable_quic_pacing, true);
|
|
|
| - TestConnection server(guid_, IPEndPoint(), helper_.get(), writer_.get(),
|
| - true, version());
|
| - TestConnection client(guid_, IPEndPoint(), helper_.get(), writer_.get(),
|
| - false, version());
|
| + TestConnection server(connection_id_, IPEndPoint(), helper_.get(),
|
| + writer_.get(), true, version());
|
| + TestConnection client(connection_id_, IPEndPoint(), helper_.get(),
|
| + writer_.get(), false, version());
|
| EXPECT_TRUE(client.sent_packet_manager().using_pacing());
|
| EXPECT_FALSE(server.sent_packet_manager().using_pacing());
|
| }
|
|
|