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()); |
} |