Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(197)

Side by Side Diff: net/quic/core/quic_sent_packet_manager_test.cc

Issue 2310273002: Deprecate FLAGS_quic_loss_recovery_use_largest_acked. (Closed)
Patch Set: Created 4 years, 3 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
« no previous file with comments | « net/quic/core/quic_sent_packet_manager.cc ('k') | no next file » | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright 2013 The Chromium Authors. All rights reserved. 1 // Copyright 2013 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #include "net/quic/core/quic_sent_packet_manager.h" 5 #include "net/quic/core/quic_sent_packet_manager.h"
6 6
7 #include <memory> 7 #include <memory>
8 #include "base/memory/ptr_util.h" 8 #include "base/memory/ptr_util.h"
9 #include "base/stl_util.h" 9 #include "base/stl_util.h"
10 #include "net/quic/core/quic_flags.h" 10 #include "net/quic/core/quic_flags.h"
(...skipping 552 matching lines...) Expand 10 before | Expand all | Expand 10 after
563 // Ack 3, which causes SpuriousRetransmitDetected to be called. 563 // Ack 3, which causes SpuriousRetransmitDetected to be called.
564 { 564 {
565 QuicAckFrame ack_frame = InitAckFrame(4); 565 QuicAckFrame ack_frame = InitAckFrame(4);
566 NackPackets(2, 3, &ack_frame); 566 NackPackets(2, 3, &ack_frame);
567 EXPECT_CALL(*loss_algorithm, DetectLosses(_, _, _, _, _)); 567 EXPECT_CALL(*loss_algorithm, DetectLosses(_, _, _, _, _));
568 EXPECT_CALL(*loss_algorithm, SpuriousRetransmitDetected(_, _, _, 5)); 568 EXPECT_CALL(*loss_algorithm, SpuriousRetransmitDetected(_, _, _, 5));
569 manager_.OnIncomingAck(ack_frame, clock_.Now()); 569 manager_.OnIncomingAck(ack_frame, clock_.Now());
570 } 570 }
571 } 571 }
572 572
573 TEST_P(QuicSentPacketManagerTest, AckPreviousTransmissionThenTruncatedAck) {
574 FLAGS_quic_loss_recovery_use_largest_acked = false;
575 if (!GetParam().missing) {
576 return;
577 }
578 SendDataPacket(1);
579 RetransmitAndSendPacket(1, 2);
580 RetransmitAndSendPacket(2, 3);
581 RetransmitAndSendPacket(3, 4);
582 SendDataPacket(5);
583 SendDataPacket(6);
584 SendDataPacket(7);
585 SendDataPacket(8);
586 SendDataPacket(9);
587
588 // Ack previous transmission
589 {
590 QuicAckFrame ack_frame = InitAckFrame(2);
591 NackPackets(1, 2, &ack_frame);
592 ExpectAck(2);
593 manager_.OnIncomingAck(ack_frame, clock_.Now());
594 EXPECT_TRUE(QuicSentPacketManagerPeer::IsUnacked(&manager_, 4));
595 }
596
597 // Truncated ack with 4 NACKs
598 {
599 QuicAckFrame ack_frame = InitAckFrame(6);
600 NackPackets(3, 7, &ack_frame);
601 ack_frame.is_truncated = true;
602 ExpectAckAndLoss(true, 1, 3);
603 manager_.OnIncomingAck(ack_frame, clock_.Now());
604 }
605
606 // High water mark will be raised.
607 QuicPacketNumber unacked[] = {4, 5, 6, 7, 8, 9};
608 VerifyUnackedPackets(unacked, arraysize(unacked));
609 QuicPacketNumber retransmittable[] = {5, 6, 7, 8, 9};
610 VerifyRetransmittablePackets(retransmittable, arraysize(retransmittable));
611 }
612
613 TEST_P(QuicSentPacketManagerTest, GetLeastUnacked) { 573 TEST_P(QuicSentPacketManagerTest, GetLeastUnacked) {
614 EXPECT_EQ(1u, manager_.GetLeastUnacked(kDefaultPathId)); 574 EXPECT_EQ(1u, manager_.GetLeastUnacked(kDefaultPathId));
615 } 575 }
616 576
617 TEST_P(QuicSentPacketManagerTest, GetLeastUnackedUnacked) { 577 TEST_P(QuicSentPacketManagerTest, GetLeastUnackedUnacked) {
618 SendDataPacket(1); 578 SendDataPacket(1);
619 EXPECT_EQ(1u, manager_.GetLeastUnacked(kDefaultPathId)); 579 EXPECT_EQ(1u, manager_.GetLeastUnacked(kDefaultPathId));
620 } 580 }
621 581
622 TEST_P(QuicSentPacketManagerTest, AckAckAndUpdateRtt) { 582 TEST_P(QuicSentPacketManagerTest, AckAckAndUpdateRtt) {
(...skipping 916 matching lines...) Expand 10 before | Expand all | Expand 10 after
1539 options.push_back(kNRTO); 1499 options.push_back(kNRTO);
1540 QuicSentPacketManagerPeer::SetPerspective(&manager_, Perspective::IS_CLIENT); 1500 QuicSentPacketManagerPeer::SetPerspective(&manager_, Perspective::IS_CLIENT);
1541 client_config.SetConnectionOptionsToSend(options); 1501 client_config.SetConnectionOptionsToSend(options);
1542 EXPECT_CALL(*network_change_visitor_, OnCongestionChange()); 1502 EXPECT_CALL(*network_change_visitor_, OnCongestionChange());
1543 EXPECT_CALL(*send_algorithm_, SetFromConfig(_, _)); 1503 EXPECT_CALL(*send_algorithm_, SetFromConfig(_, _));
1544 manager_.SetFromConfig(client_config); 1504 manager_.SetFromConfig(client_config);
1545 EXPECT_TRUE(QuicSentPacketManagerPeer::GetUseNewRto(&manager_)); 1505 EXPECT_TRUE(QuicSentPacketManagerPeer::GetUseNewRto(&manager_));
1546 } 1506 }
1547 1507
1548 TEST_P(QuicSentPacketManagerTest, NegotiateUndoFromOptionsAtServer) { 1508 TEST_P(QuicSentPacketManagerTest, NegotiateUndoFromOptionsAtServer) {
1549 FLAGS_quic_loss_recovery_use_largest_acked = true;
1550 EXPECT_FALSE(QuicSentPacketManagerPeer::GetUndoRetransmits(&manager_)); 1509 EXPECT_FALSE(QuicSentPacketManagerPeer::GetUndoRetransmits(&manager_));
1551 QuicConfig config; 1510 QuicConfig config;
1552 QuicTagVector options; 1511 QuicTagVector options;
1553 1512
1554 options.push_back(kUNDO); 1513 options.push_back(kUNDO);
1555 QuicConfigPeer::SetReceivedConnectionOptions(&config, options); 1514 QuicConfigPeer::SetReceivedConnectionOptions(&config, options);
1556 EXPECT_CALL(*network_change_visitor_, OnCongestionChange()); 1515 EXPECT_CALL(*network_change_visitor_, OnCongestionChange());
1557 EXPECT_CALL(*send_algorithm_, SetFromConfig(_, _)); 1516 EXPECT_CALL(*send_algorithm_, SetFromConfig(_, _));
1558 manager_.SetFromConfig(config); 1517 manager_.SetFromConfig(config);
1559 EXPECT_TRUE(QuicSentPacketManagerPeer::GetUndoRetransmits(&manager_)); 1518 EXPECT_TRUE(QuicSentPacketManagerPeer::GetUndoRetransmits(&manager_));
(...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after
1591 // Ack 1 and ensure the retransmissions are cancelled and put back in flight. 1550 // Ack 1 and ensure the retransmissions are cancelled and put back in flight.
1592 EXPECT_CALL(*loss_algorithm, DetectLosses(_, _, _, _, _)); 1551 EXPECT_CALL(*loss_algorithm, DetectLosses(_, _, _, _, _));
1593 ack_frame = InitAckFrame(5); 1552 ack_frame = InitAckFrame(5);
1594 NackPackets(2, kNumSentPackets, &ack_frame); 1553 NackPackets(2, kNumSentPackets, &ack_frame);
1595 manager_.OnIncomingAck(ack_frame, clock_.Now()); 1554 manager_.OnIncomingAck(ack_frame, clock_.Now());
1596 EXPECT_FALSE(manager_.HasPendingRetransmissions()); 1555 EXPECT_FALSE(manager_.HasPendingRetransmissions());
1597 EXPECT_EQ(3u * kDefaultLength, BytesInFlight()); 1556 EXPECT_EQ(3u * kDefaultLength, BytesInFlight());
1598 } 1557 }
1599 1558
1600 TEST_P(QuicSentPacketManagerTest, NegotiateUndoFromOptionsAtClient) { 1559 TEST_P(QuicSentPacketManagerTest, NegotiateUndoFromOptionsAtClient) {
1601 FLAGS_quic_loss_recovery_use_largest_acked = true;
1602 EXPECT_FALSE(QuicSentPacketManagerPeer::GetUndoRetransmits(&manager_)); 1560 EXPECT_FALSE(QuicSentPacketManagerPeer::GetUndoRetransmits(&manager_));
1603 QuicConfig client_config; 1561 QuicConfig client_config;
1604 QuicTagVector options; 1562 QuicTagVector options;
1605 1563
1606 options.push_back(kUNDO); 1564 options.push_back(kUNDO);
1607 QuicSentPacketManagerPeer::SetPerspective(&manager_, Perspective::IS_CLIENT); 1565 QuicSentPacketManagerPeer::SetPerspective(&manager_, Perspective::IS_CLIENT);
1608 client_config.SetConnectionOptionsToSend(options); 1566 client_config.SetConnectionOptionsToSend(options);
1609 EXPECT_CALL(*network_change_visitor_, OnCongestionChange()); 1567 EXPECT_CALL(*network_change_visitor_, OnCongestionChange());
1610 EXPECT_CALL(*send_algorithm_, SetFromConfig(_, _)); 1568 EXPECT_CALL(*send_algorithm_, SetFromConfig(_, _));
1611 manager_.SetFromConfig(client_config); 1569 manager_.SetFromConfig(client_config);
(...skipping 96 matching lines...) Expand 10 before | Expand all | Expand 10 after
1708 ExpectAck(1); 1666 ExpectAck(1);
1709 EXPECT_CALL(*network_change_visitor_, 1667 EXPECT_CALL(*network_change_visitor_,
1710 OnPathMtuIncreased(kDefaultLength + 100)); 1668 OnPathMtuIncreased(kDefaultLength + 100));
1711 QuicAckFrame ack_frame = InitAckFrame(1); 1669 QuicAckFrame ack_frame = InitAckFrame(1);
1712 manager_.OnIncomingAck(ack_frame, clock_.Now()); 1670 manager_.OnIncomingAck(ack_frame, clock_.Now());
1713 } 1671 }
1714 1672
1715 } // namespace 1673 } // namespace
1716 } // namespace test 1674 } // namespace test
1717 } // namespace net 1675 } // namespace net
OLDNEW
« no previous file with comments | « net/quic/core/quic_sent_packet_manager.cc ('k') | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698