| Index: net/quic/quic_connection_test.cc
|
| diff --git a/net/quic/quic_connection_test.cc b/net/quic/quic_connection_test.cc
|
| index e1fb275d383e2e1525914a7e773d21b00c947fb7..38ec8f6d25da8ce9fecbc2a06951e0c0bac965f9 100644
|
| --- a/net/quic/quic_connection_test.cc
|
| +++ b/net/quic/quic_connection_test.cc
|
| @@ -2149,48 +2149,7 @@ TEST_P(QuicConnectionTest, SendPendingRetransmissionForQuicRstStreamNoError) {
|
| EXPECT_EQ(0u, writer_->rst_stream_frames().size());
|
| }
|
|
|
| -TEST_P(QuicConnectionTest, DiscardRetransmit) {
|
| - FLAGS_quic_always_write_queued_retransmissions = false;
|
| - QuicPacketNumber last_packet;
|
| - SendStreamDataToPeer(1, "foo", 0, !kFin, &last_packet); // Packet 1
|
| - SendStreamDataToPeer(1, "foos", 3, !kFin, &last_packet); // Packet 2
|
| - SendStreamDataToPeer(1, "fooos", 7, !kFin, &last_packet); // Packet 3
|
| -
|
| - EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_));
|
| -
|
| - // Instigate a loss with an ack.
|
| - QuicAckFrame nack_two = InitAckFrame(3);
|
| - NackPacket(2, &nack_two);
|
| - // The first nack should trigger a fast retransmission, but we'll be
|
| - // write blocked, so the packet will be queued.
|
| - BlockOnNextWrite();
|
| -
|
| - SendAlgorithmInterface::CongestionVector lost_packets;
|
| - lost_packets.push_back(std::make_pair(2, kMaxPacketSize));
|
| - EXPECT_CALL(*loss_algorithm_, DetectLosses(_, _, _, _, _))
|
| - .WillOnce(SetArgPointee<4>(lost_packets));
|
| - EXPECT_CALL(*send_algorithm_, OnCongestionEvent(true, _, _, _));
|
| - ProcessAckPacket(&nack_two);
|
| - EXPECT_EQ(1u, connection_.NumQueuedPackets());
|
| -
|
| - // Now, ack the previous transmission.
|
| - EXPECT_CALL(*loss_algorithm_, DetectLosses(_, _, _, _, _));
|
| - QuicAckFrame ack_all = InitAckFrame(3);
|
| - ProcessAckPacket(&ack_all);
|
| -
|
| - // Unblock the socket and attempt to send the queued packets. However,
|
| - // since the previous transmission has been acked, we will not
|
| - // send the retransmission.
|
| - EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)).Times(0);
|
| -
|
| - writer_->SetWritable();
|
| - connection_.OnCanWrite();
|
| -
|
| - EXPECT_EQ(0u, connection_.NumQueuedPackets());
|
| -}
|
| -
|
| TEST_P(QuicConnectionTest, RetransmitAckedPacket) {
|
| - FLAGS_quic_always_write_queued_retransmissions = true;
|
| QuicPacketNumber last_packet;
|
| SendStreamDataToPeer(1, "foo", 0, !kFin, &last_packet); // Packet 1
|
| SendStreamDataToPeer(1, "foos", 3, !kFin, &last_packet); // Packet 2
|
| @@ -2227,8 +2186,8 @@ TEST_P(QuicConnectionTest, RetransmitAckedPacket) {
|
|
|
| EXPECT_EQ(0u, connection_.NumQueuedPackets());
|
| // We do not store retransmittable frames of this retransmission.
|
| - EXPECT_FALSE(connection_.sent_packet_manager().HasRetransmittableFrames(
|
| - kDefaultPathId, 4));
|
| + EXPECT_FALSE(QuicConnectionPeer::HasRetransmittableFrames(&connection_,
|
| + kDefaultPathId, 4));
|
| }
|
|
|
| TEST_P(QuicConnectionTest, RetransmitNackedLargestObserved) {
|
| @@ -2331,8 +2290,8 @@ TEST_P(QuicConnectionTest, RetransmitWriteBlockedAckedOriginalThenSent) {
|
| connection_.OnCanWrite();
|
| // There is now a pending packet, but with no retransmittable frames.
|
| EXPECT_TRUE(connection_.GetRetransmissionAlarm()->IsSet());
|
| - EXPECT_FALSE(connection_.sent_packet_manager().HasRetransmittableFrames(
|
| - ack.path_id, 2));
|
| + EXPECT_FALSE(QuicConnectionPeer::HasRetransmittableFrames(&connection_,
|
| + ack.path_id, 2));
|
| }
|
|
|
| TEST_P(QuicConnectionTest, AlarmsWhenWriteBlocked) {
|
|
|