| Index: net/quic/quic_connection_test.cc
|
| diff --git a/net/quic/quic_connection_test.cc b/net/quic/quic_connection_test.cc
|
| index 7f3f1d4366aac678ae0ac8cba8131732dffbb571..31ea1a6f4d78b24593fb8ddfab1a0793f85723ee 100644
|
| --- a/net/quic/quic_connection_test.cc
|
| +++ b/net/quic/quic_connection_test.cc
|
| @@ -331,10 +331,13 @@ class TestPacketWriter : public QuicPacketWriter {
|
| is_write_blocked_data_buffered_ = buffered;
|
| }
|
|
|
| - void set_is_server(bool is_server) {
|
| - // We invert is_server here, because the framer needs to parse packets
|
| + void set_perspective(Perspective perspective) {
|
| + // We invert perspective here, because the framer needs to parse packets
|
| // we send.
|
| - QuicFramerPeer::SetIsServer(framer_.framer(), !is_server);
|
| + perspective = perspective == Perspective::IS_CLIENT
|
| + ? Perspective::IS_SERVER
|
| + : Perspective::IS_CLIENT;
|
| + QuicFramerPeer::SetPerspective(framer_.framer(), perspective);
|
| }
|
|
|
| // final_bytes_of_last_packet_ returns the last four bytes of the previous
|
| @@ -385,20 +388,20 @@ class TestConnection : public QuicConnection {
|
| IPEndPoint address,
|
| TestConnectionHelper* helper,
|
| const PacketWriterFactory& factory,
|
| - bool is_server,
|
| + Perspective perspective,
|
| QuicVersion version)
|
| : QuicConnection(connection_id,
|
| address,
|
| helper,
|
| factory,
|
| /* owns_writer= */ false,
|
| - is_server,
|
| + perspective,
|
| /* is_secure= */ false,
|
| SupportedVersions(version)) {
|
| // Disable tail loss probes for most tests.
|
| QuicSentPacketManagerPeer::SetMaxTailLossProbes(
|
| QuicConnectionPeer::GetSentPacketManager(this), 0);
|
| - writer()->set_is_server(is_server);
|
| + writer()->set_perspective(perspective);
|
| }
|
|
|
| void SendAck() {
|
| @@ -501,10 +504,6 @@ class TestConnection : public QuicConnection {
|
| return SendStreamDataWithString(kCryptoStreamId, "chlo", 0, !kFin, nullptr);
|
| }
|
|
|
| - bool is_server() {
|
| - return QuicConnectionPeer::IsServer(this);
|
| - }
|
| -
|
| void set_version(QuicVersion version) {
|
| QuicConnectionPeer::GetFramer(this)->set_version(version);
|
| }
|
| @@ -514,9 +513,9 @@ class TestConnection : public QuicConnection {
|
| writer()->SetSupportedVersions(versions);
|
| }
|
|
|
| - void set_is_server(bool is_server) {
|
| - writer()->set_is_server(is_server);
|
| - QuicConnectionPeer::SetIsServer(this, is_server);
|
| + void set_perspective(Perspective perspective) {
|
| + writer()->set_perspective(perspective);
|
| + QuicConnectionPeer::SetPerspective(this, perspective);
|
| }
|
|
|
| TestConnectionHelper::TestAlarm* GetAckAlarm() {
|
| @@ -596,7 +595,9 @@ class QuicConnectionTest : public ::testing::TestWithParam<QuicVersion> {
|
| protected:
|
| QuicConnectionTest()
|
| : connection_id_(42),
|
| - framer_(SupportedVersions(version()), QuicTime::Zero(), false),
|
| + framer_(SupportedVersions(version()),
|
| + QuicTime::Zero(),
|
| + Perspective::IS_CLIENT),
|
| peer_creator_(connection_id_, &framer_, &random_generator_),
|
| send_algorithm_(new StrictMock<MockSendAlgorithm>),
|
| loss_algorithm_(new MockLossAlgorithm()),
|
| @@ -607,7 +608,7 @@ class QuicConnectionTest : public ::testing::TestWithParam<QuicVersion> {
|
| IPEndPoint(),
|
| helper_.get(),
|
| factory_,
|
| - false,
|
| + Perspective::IS_CLIENT,
|
| version()),
|
| creator_(QuicConnectionPeer::GetPacketCreator(&connection_)),
|
| generator_(QuicConnectionPeer::GetPacketGenerator(&connection_)),
|
| @@ -683,8 +684,9 @@ class QuicConnectionTest : public ::testing::TestWithParam<QuicVersion> {
|
| QuicPacketEntropyHash ProcessFramePacket(QuicFrame frame) {
|
| QuicFrames frames;
|
| frames.push_back(QuicFrame(frame));
|
| - QuicPacketCreatorPeer::SetSendVersionInPacket(&peer_creator_,
|
| - connection_.is_server());
|
| + QuicPacketCreatorPeer::SetSendVersionInPacket(
|
| + &peer_creator_, connection_.perspective() == Perspective::IS_SERVER);
|
| +
|
| SerializedPacket serialized_packet =
|
| peer_creator_.SerializeAllFrames(frames);
|
| scoped_ptr<QuicEncryptedPacket> encrypted(serialized_packet.packet);
|
| @@ -979,34 +981,32 @@ INSTANTIATE_TEST_CASE_P(SupportedVersion,
|
| ::testing::ValuesIn(QuicSupportedVersions()));
|
|
|
| TEST_P(QuicConnectionTest, MaxPacketSize) {
|
| - EXPECT_FALSE(connection_.is_server());
|
| + EXPECT_EQ(Perspective::IS_CLIENT, connection_.perspective());
|
| EXPECT_EQ(1350u, connection_.max_packet_length());
|
| }
|
|
|
| TEST_P(QuicConnectionTest, SmallerServerMaxPacketSize) {
|
| ValueRestore<bool> old_flag(&FLAGS_quic_small_default_packet_size, true);
|
| QuicConnectionId connection_id = 42;
|
| - bool kIsServer = true;
|
| TestConnection connection(connection_id, IPEndPoint(), helper_.get(),
|
| - factory_, kIsServer, version());
|
| - EXPECT_TRUE(connection.is_server());
|
| + factory_, Perspective::IS_SERVER, version());
|
| + EXPECT_EQ(Perspective::IS_SERVER, connection.perspective());
|
| EXPECT_EQ(1000u, connection.max_packet_length());
|
| }
|
|
|
| TEST_P(QuicConnectionTest, ServerMaxPacketSize) {
|
| ValueRestore<bool> old_flag(&FLAGS_quic_small_default_packet_size, false);
|
| QuicConnectionId connection_id = 42;
|
| - bool kIsServer = true;
|
| TestConnection connection(connection_id, IPEndPoint(), helper_.get(),
|
| - factory_, kIsServer, version());
|
| - EXPECT_TRUE(connection.is_server());
|
| + factory_, Perspective::IS_SERVER, version());
|
| + EXPECT_EQ(Perspective::IS_SERVER, connection.perspective());
|
| EXPECT_EQ(1350u, connection.max_packet_length());
|
| }
|
|
|
| TEST_P(QuicConnectionTest, IncreaseServerMaxPacketSize) {
|
| EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_));
|
|
|
| - connection_.set_is_server(true);
|
| + connection_.set_perspective(Perspective::IS_SERVER);
|
| connection_.set_max_packet_length(1000);
|
|
|
| QuicPacketHeader header;
|
| @@ -3299,13 +3299,13 @@ TEST_P(QuicConnectionTest, SendDelayedAckOnHandshakeConfirmed) {
|
| EXPECT_EQ(ack_time, connection_.GetAckAlarm()->deadline());
|
|
|
| // Completing the handshake as the server does nothing.
|
| - QuicConnectionPeer::SetIsServer(&connection_, true);
|
| + QuicConnectionPeer::SetPerspective(&connection_, Perspective::IS_SERVER);
|
| connection_.OnHandshakeComplete();
|
| EXPECT_TRUE(connection_.GetAckAlarm()->IsSet());
|
| EXPECT_EQ(ack_time, connection_.GetAckAlarm()->deadline());
|
|
|
| // Complete the handshake as the client decreases the delayed ack time to 0ms.
|
| - QuicConnectionPeer::SetIsServer(&connection_, false);
|
| + QuicConnectionPeer::SetPerspective(&connection_, Perspective::IS_CLIENT);
|
| connection_.OnHandshakeComplete();
|
| EXPECT_TRUE(connection_.GetAckAlarm()->IsSet());
|
| EXPECT_EQ(clock_.ApproximateNow(), connection_.GetAckAlarm()->deadline());
|
| @@ -3646,7 +3646,7 @@ TEST_P(QuicConnectionTest, ServerSendsVersionNegotiationPacket) {
|
| framer_.EncryptPacket(ENCRYPTION_NONE, 12, *packet));
|
|
|
| framer_.set_version(version());
|
| - connection_.set_is_server(true);
|
| + connection_.set_perspective(Perspective::IS_SERVER);
|
| connection_.ProcessUdpPacket(IPEndPoint(), IPEndPoint(), *encrypted);
|
| EXPECT_TRUE(writer_->version_negotiation_packet() != nullptr);
|
|
|
| @@ -3684,7 +3684,7 @@ TEST_P(QuicConnectionTest, ServerSendsVersionNegotiationPacketSocketBlocked) {
|
| framer_.EncryptPacket(ENCRYPTION_NONE, 12, *packet));
|
|
|
| framer_.set_version(version());
|
| - connection_.set_is_server(true);
|
| + connection_.set_perspective(Perspective::IS_SERVER);
|
| BlockOnNextWrite();
|
| connection_.ProcessUdpPacket(IPEndPoint(), IPEndPoint(), *encrypted);
|
| EXPECT_EQ(0u, writer_->last_packet_size());
|
| @@ -3729,7 +3729,7 @@ TEST_P(QuicConnectionTest,
|
| framer_.EncryptPacket(ENCRYPTION_NONE, 12, *packet));
|
|
|
| framer_.set_version(version());
|
| - connection_.set_is_server(true);
|
| + connection_.set_perspective(Perspective::IS_SERVER);
|
| BlockOnNextWrite();
|
| writer_->set_is_write_blocked_data_buffered(true);
|
| connection_.ProcessUdpPacket(IPEndPoint(), IPEndPoint(), *encrypted);
|
| @@ -4315,10 +4315,10 @@ TEST_P(QuicConnectionTest, OnPacketHeaderDebugVisitor) {
|
| }
|
|
|
| TEST_P(QuicConnectionTest, Pacing) {
|
| - TestConnection server(connection_id_, IPEndPoint(), helper_.get(),
|
| - factory_, /* is_server= */ true, version());
|
| - TestConnection client(connection_id_, IPEndPoint(), helper_.get(),
|
| - factory_, /* is_server= */ false, version());
|
| + TestConnection server(connection_id_, IPEndPoint(), helper_.get(), factory_,
|
| + Perspective::IS_SERVER, version());
|
| + TestConnection client(connection_id_, IPEndPoint(), helper_.get(), factory_,
|
| + Perspective::IS_CLIENT, version());
|
| EXPECT_FALSE(client.sent_packet_manager().using_pacing());
|
| EXPECT_FALSE(server.sent_packet_manager().using_pacing());
|
| }
|
|
|