Increase the send-time history to 60 seconds.

webrtc/modules/congestion_controller/transport_feedback_adapter_unittest.cc

 /*
  *  Copyright (c) 2015 The WebRTC project authors. All Rights Reserved.
  *
  *  Use of this source code is governed by a BSD-style license
  *  that can be found in the LICENSE file in the root of the source
  *  tree. An additional intellectual property rights grant can be found
  *  in the file PATENTS.  All contributing project authors may
  *  be found in the AUTHORS file in the root of the source tree.
  */
 
 #include <limits>
 #include <memory>
 #include <vector>
 
 #include "webrtc/base/checks.h"
+#include "webrtc/base/safe_conversions.h"
 #include "webrtc/modules/bitrate_controller/include/mock/mock_bitrate_controller.h"
 #include "webrtc/modules/congestion_controller/transport_feedback_adapter.h"
 #include "webrtc/modules/rtp_rtcp/include/rtp_rtcp_defines.h"
 #include "webrtc/modules/rtp_rtcp/source/rtcp_packet/transport_feedback.h"
 #include "webrtc/system_wrappers/include/clock.h"
 #include "webrtc/test/gmock.h"
 #include "webrtc/test/gtest.h"
 
 using ::testing::_;
 using ::testing::Invoke;
@@ skipping 95 matching lines @@
     EXPECT_TRUE(feedback.AddReceivedPacket(packet.sequence_number,
                                            packet.arrival_time_ms * 1000));
   }
 
   feedback.Build();
 
   adapter_->OnTransportFeedback(feedback);
   ComparePacketVectors(packets, adapter_->GetTransportFeedbackVector());
 }
 
+TEST_F(TransportFeedbackAdapterTest, Timeout) {
+  const int64_t kFeedbackTimeoutMs = 60001;
+  {
+    std::vector<PacketInfo> packets;
+    packets.push_back(PacketInfo(100, 200, 0, 1500, 0));
+    packets.push_back(PacketInfo(110, 210, 1, 1500, 0));
+    packets.push_back(PacketInfo(120, 220, 2, 1500, 0));
+    packets.push_back(PacketInfo(130, 230, 3, 1500, 1));
+    packets.push_back(PacketInfo(140, 240, 4, 1500, 1));
+
+    for (const PacketInfo& packet : packets)
+      OnSentPacket(packet);
+
+    rtcp::TransportFeedback feedback;
+    feedback.SetBase(packets[0].sequence_number,
+                     packets[0].arrival_time_ms * 1000);
+
+    for (const PacketInfo& packet : packets) {
+      EXPECT_TRUE(feedback.AddReceivedPacket(packet.sequence_number,
+                                             packet.arrival_time_ms * 1000));
+    }
+
+    feedback.Build();
+
+    clock_.AdvanceTimeMilliseconds(kFeedbackTimeoutMs);
+    PacketInfo later_packet(kFeedbackTimeoutMs + 140, kFeedbackTimeoutMs + 240,
+                            5, 1500, 1);
+    OnSentPacket(later_packet);
+
+    adapter_->OnTransportFeedback(feedback);
+    EXPECT_EQ(0, rtc::checked_cast<int>(
+                     adapter_->GetTransportFeedbackVector().size()));
+  }
+
+  {
+    std::vector<PacketInfo> packets;
+    packets.push_back(PacketInfo(100, 200, 0, 1500, 0));
+    packets.push_back(PacketInfo(110, 210, 1, 1500, 0));
+    packets.push_back(PacketInfo(120, 220, 2, 1500, 0));
+    packets.push_back(PacketInfo(130, 230, 3, 1500, 1));
+    packets.push_back(PacketInfo(140, 240, 4, 1500, 1));
+
+    for (const PacketInfo& packet : packets)
+      OnSentPacket(packet);
+
+    rtcp::TransportFeedback feedback;
+    feedback.SetBase(packets[0].sequence_number,
+                     packets[0].arrival_time_ms * 1000);
+
+    for (const PacketInfo& packet : packets) {
+      EXPECT_TRUE(feedback.AddReceivedPacket(packet.sequence_number,
+                                             packet.arrival_time_ms * 1000));
+    }
+
+    feedback.Build();
+
+    clock_.AdvanceTimeMilliseconds(kFeedbackTimeoutMs - 1);
+    PacketInfo later_packet(kFeedbackTimeoutMs + 140, kFeedbackTimeoutMs + 240,
+                            5, 1500, 1);
+    OnSentPacket(later_packet);
+
+    adapter_->OnTransportFeedback(feedback);
+    ComparePacketVectors(packets, adapter_->GetTransportFeedbackVector());
+  }
+}
+
 TEST_F(TransportFeedbackAdapterTest, HandlesDroppedPackets) {
   std::vector<PacketInfo> packets;
   packets.push_back(PacketInfo(100, 200, 0, 1500, 1));
   packets.push_back(PacketInfo(110, 210, 1, 1500, 2));
   packets.push_back(PacketInfo(120, 220, 2, 1500, 3));
   packets.push_back(PacketInfo(130, 230, 3, 1500, 4));
   packets.push_back(PacketInfo(140, 240, 4, 1500, 5));
 
   const uint16_t kSendSideDropBefore = 1;
   const uint16_t kReceiveSideDropAfter = 3;
@@ skipping 205 matching lines @@
     EXPECT_TRUE(feedback.get() != nullptr);
     adapter_->OnTransportFeedback(*feedback.get());
     clock_.AdvanceTimeMilliseconds(50);
     ++seq_num;
   }
   EXPECT_GT(target_bitrate_bps_, 0u);
 }
 
 }  // namespace test
 }  // namespace webrtc