| Index: webrtc/modules/rtp_rtcp/source/rtp_fec_unittest.cc
|
| diff --git a/webrtc/modules/rtp_rtcp/source/rtp_fec_unittest.cc b/webrtc/modules/rtp_rtcp/source/rtp_fec_unittest.cc
|
| index 1bb1d6543cc14cbff76dae0ba5c5e5770f37fbb6..9f6dee2be9c3bc378c2b4877f43293d599f8c701 100644
|
| --- a/webrtc/modules/rtp_rtcp/source/rtp_fec_unittest.cc
|
| +++ b/webrtc/modules/rtp_rtcp/source/rtp_fec_unittest.cc
|
| @@ -10,45 +10,55 @@
|
|
|
| #include <algorithm>
|
| #include <list>
|
| +#include <memory>
|
|
|
| #include "testing/gtest/include/gtest/gtest.h"
|
| +#include "webrtc/base/basictypes.h"
|
| #include "webrtc/base/random.h"
|
| #include "webrtc/modules/rtp_rtcp/source/byte_io.h"
|
| +#include "webrtc/modules/rtp_rtcp/source/fec_test_helper.h"
|
| #include "webrtc/modules/rtp_rtcp/source/forward_error_correction.h"
|
|
|
| -using webrtc::ForwardErrorCorrection;
|
| +namespace webrtc {
|
|
|
| -// Minimum RTP header size in bytes.
|
| -constexpr uint8_t kRtpHeaderSize = 12;
|
| +namespace {
|
|
|
| // Transport header size in bytes. Assume UDP/IPv4 as a reasonable minimum.
|
| -constexpr uint8_t kTransportOverhead = 28;
|
| +constexpr size_t kTransportOverhead = 28;
|
|
|
| -// Maximum number of media packets used in the FEC (RFC 5109).
|
| -constexpr uint8_t kMaxNumberMediaPackets =
|
| - ForwardErrorCorrection::kMaxMediaPackets;
|
| +constexpr uint32_t kMediaSsrc = 83542;
|
|
|
| -using PacketList = ForwardErrorCorrection::PacketList;
|
| -using ReceivedPacketList = ForwardErrorCorrection::ReceivedPacketList;
|
| -using RecoveredPacketList = ForwardErrorCorrection::RecoveredPacketList;
|
| +// Deep copies |src| to |dst|, but only keeps every Nth packet.
|
| +void DeepCopyEveryNthPacket(const ForwardErrorCorrection::PacketList& src,
|
| + int n,
|
| + ForwardErrorCorrection::PacketList* dst) {
|
| + RTC_DCHECK_GT(n, 0);
|
| + int i = 0;
|
| + for (const auto& packet : src) {
|
| + if (i % n == 0) {
|
| + dst->emplace_back(new ForwardErrorCorrection::Packet(*packet));
|
| + }
|
| + ++i;
|
| + }
|
| +}
|
|
|
| +} // namespace
|
| +
|
| +using ::testing::Types;
|
| +
|
| +template <typename ForwardErrorCorrectionType>
|
| class RtpFecTest : public ::testing::Test {
|
| protected:
|
| RtpFecTest()
|
| - : random_(0xfec133700742),
|
| - ssrc_(random_.Rand<uint32_t>()),
|
| - fec_seq_num_(0) {}
|
| -
|
| - // Construct the media packet list, up to |num_media_packets| packets.
|
| - // Returns the next sequence number after the last media packet.
|
| - // (this will be the sequence of the first FEC packet)
|
| - int ConstructMediaPacketsSeqNum(int num_media_packets, int start_seq_num);
|
| - int ConstructMediaPackets(int num_media_packets);
|
| -
|
| - // Deep copies |src| to |dst|, but only keeps every Nth packet.
|
| - void DeepCopyEveryNthPacket(const PacketList& src, int n, PacketList* dst);
|
| -
|
| - // Construct |received_packet_list_|: a subset of the media and FEC packets.
|
| + : random_(0xabcdef123456),
|
| + media_packet_generator_(
|
| + kRtpHeaderSize, // Minimum packet size.
|
| + IP_PACKET_SIZE - kRtpHeaderSize - kTransportOverhead -
|
| + fec_.MaxPacketOverhead(), // Maximum packet size.
|
| + kMediaSsrc,
|
| + &random_) {}
|
| +
|
| + // Construct |received_packets_|: a subset of the media and FEC packets.
|
| //
|
| // Media packet "i" is lost if media_loss_mask_[i] = 1, received if
|
| // media_loss_mask_[i] = 0.
|
| @@ -66,91 +76,102 @@ class RtpFecTest : public ::testing::Test {
|
| // Check for complete recovery after FEC decoding.
|
| bool IsRecoveryComplete();
|
|
|
| - // Delete the media and FEC packets.
|
| - void TearDown();
|
| + ForwardErrorCorrectionType fec_;
|
|
|
| - webrtc::Random random_;
|
| - ForwardErrorCorrection fec_;
|
| - int ssrc_;
|
| - uint16_t fec_seq_num_;
|
| + Random random_;
|
| + test::fec::MediaPacketGenerator media_packet_generator_;
|
|
|
| - PacketList media_packet_list_;
|
| - std::list<ForwardErrorCorrection::Packet*> fec_packet_list_;
|
| - ReceivedPacketList received_packet_list_;
|
| - RecoveredPacketList recovered_packet_list_;
|
| + ForwardErrorCorrection::PacketList media_packets_;
|
| + std::list<ForwardErrorCorrection::Packet*> generated_fec_packets_;
|
| + ForwardErrorCorrection::ReceivedPacketList received_packets_;
|
| + ForwardErrorCorrection::RecoveredPacketList recovered_packets_;
|
|
|
| - int media_loss_mask_[kMaxNumberMediaPackets];
|
| - int fec_loss_mask_[kMaxNumberMediaPackets];
|
| + int media_loss_mask_[ForwardErrorCorrection::kMaxMediaPackets];
|
| + int fec_loss_mask_[ForwardErrorCorrection::kMaxMediaPackets];
|
| };
|
|
|
| -TEST_F(RtpFecTest, FecRecoveryNoLoss) {
|
| +// Define gTest typed test to loop over both ULPFEC and FlexFEC.
|
| +// Since the tests now are parameterized, we need to access
|
| +// member variables using |this|, thereby enforcing runtime
|
| +// resolution.
|
| +using FecTypes = Types<ForwardErrorCorrection>;
|
| +TYPED_TEST_CASE(RtpFecTest, FecTypes);
|
| +
|
| +TYPED_TEST(RtpFecTest, FecRecoveryNoLoss) {
|
| constexpr int kNumImportantPackets = 0;
|
| constexpr bool kUseUnequalProtection = false;
|
| constexpr int kNumMediaPackets = 4;
|
| constexpr uint8_t kProtectionFactor = 60;
|
|
|
| - fec_seq_num_ = ConstructMediaPackets(kNumMediaPackets);
|
| + this->media_packets_ =
|
| + this->media_packet_generator_.ConstructMediaPackets(kNumMediaPackets);
|
|
|
| - EXPECT_EQ(0, fec_.GenerateFec(media_packet_list_, kProtectionFactor,
|
| - kNumImportantPackets, kUseUnequalProtection,
|
| - webrtc::kFecMaskBursty, &fec_packet_list_));
|
| + EXPECT_EQ(
|
| + 0, this->fec_.EncodeFec(this->media_packets_, kProtectionFactor,
|
| + kNumImportantPackets, kUseUnequalProtection,
|
| + kFecMaskBursty, &this->generated_fec_packets_));
|
|
|
| // Expect 1 FEC packet.
|
| - EXPECT_EQ(1u, fec_packet_list_.size());
|
| + EXPECT_EQ(1u, this->generated_fec_packets_.size());
|
|
|
| // No packets lost.
|
| - memset(media_loss_mask_, 0, sizeof(media_loss_mask_));
|
| - memset(fec_loss_mask_, 0, sizeof(fec_loss_mask_));
|
| - NetworkReceivedPackets(media_loss_mask_, fec_loss_mask_);
|
| + memset(this->media_loss_mask_, 0, sizeof(this->media_loss_mask_));
|
| + memset(this->fec_loss_mask_, 0, sizeof(this->fec_loss_mask_));
|
| + this->NetworkReceivedPackets(this->media_loss_mask_, this->fec_loss_mask_);
|
|
|
| - EXPECT_EQ(0, fec_.DecodeFec(&received_packet_list_, &recovered_packet_list_));
|
| + EXPECT_EQ(0, this->fec_.DecodeFec(&this->received_packets_,
|
| + &this->recovered_packets_));
|
|
|
| // No packets lost, expect complete recovery.
|
| - EXPECT_TRUE(IsRecoveryComplete());
|
| + EXPECT_TRUE(this->IsRecoveryComplete());
|
| }
|
|
|
| -TEST_F(RtpFecTest, FecRecoveryWithLoss) {
|
| +TYPED_TEST(RtpFecTest, FecRecoveryWithLoss) {
|
| constexpr int kNumImportantPackets = 0;
|
| constexpr bool kUseUnequalProtection = false;
|
| constexpr int kNumMediaPackets = 4;
|
| constexpr uint8_t kProtectionFactor = 60;
|
|
|
| - fec_seq_num_ = ConstructMediaPackets(kNumMediaPackets);
|
| + this->media_packets_ =
|
| + this->media_packet_generator_.ConstructMediaPackets(kNumMediaPackets);
|
|
|
| - EXPECT_EQ(0, fec_.GenerateFec(media_packet_list_, kProtectionFactor,
|
| - kNumImportantPackets, kUseUnequalProtection,
|
| - webrtc::kFecMaskBursty, &fec_packet_list_));
|
| + EXPECT_EQ(
|
| + 0, this->fec_.EncodeFec(this->media_packets_, kProtectionFactor,
|
| + kNumImportantPackets, kUseUnequalProtection,
|
| + kFecMaskBursty, &this->generated_fec_packets_));
|
|
|
| // Expect 1 FEC packet.
|
| - EXPECT_EQ(1u, fec_packet_list_.size());
|
| + EXPECT_EQ(1u, this->generated_fec_packets_.size());
|
|
|
| // 1 media packet lost
|
| - memset(media_loss_mask_, 0, sizeof(media_loss_mask_));
|
| - memset(fec_loss_mask_, 0, sizeof(fec_loss_mask_));
|
| - media_loss_mask_[3] = 1;
|
| - NetworkReceivedPackets(media_loss_mask_, fec_loss_mask_);
|
| + memset(this->media_loss_mask_, 0, sizeof(this->media_loss_mask_));
|
| + memset(this->fec_loss_mask_, 0, sizeof(this->fec_loss_mask_));
|
| + this->media_loss_mask_[3] = 1;
|
| + this->NetworkReceivedPackets(this->media_loss_mask_, this->fec_loss_mask_);
|
|
|
| - EXPECT_EQ(0, fec_.DecodeFec(&received_packet_list_, &recovered_packet_list_));
|
| + EXPECT_EQ(0, this->fec_.DecodeFec(&this->received_packets_,
|
| + &this->recovered_packets_));
|
|
|
| // One packet lost, one FEC packet, expect complete recovery.
|
| - EXPECT_TRUE(IsRecoveryComplete());
|
| - recovered_packet_list_.clear();
|
| + EXPECT_TRUE(this->IsRecoveryComplete());
|
| + this->recovered_packets_.clear();
|
|
|
| // 2 media packets lost.
|
| - memset(media_loss_mask_, 0, sizeof(media_loss_mask_));
|
| - memset(fec_loss_mask_, 0, sizeof(fec_loss_mask_));
|
| - media_loss_mask_[1] = 1;
|
| - media_loss_mask_[3] = 1;
|
| - NetworkReceivedPackets(media_loss_mask_, fec_loss_mask_);
|
| + memset(this->media_loss_mask_, 0, sizeof(this->media_loss_mask_));
|
| + memset(this->fec_loss_mask_, 0, sizeof(this->fec_loss_mask_));
|
| + this->media_loss_mask_[1] = 1;
|
| + this->media_loss_mask_[3] = 1;
|
| + this->NetworkReceivedPackets(this->media_loss_mask_, this->fec_loss_mask_);
|
|
|
| - EXPECT_EQ(0, fec_.DecodeFec(&received_packet_list_, &recovered_packet_list_));
|
| + EXPECT_EQ(0, this->fec_.DecodeFec(&this->received_packets_,
|
| + &this->recovered_packets_));
|
|
|
| // 2 packets lost, one FEC packet, cannot get complete recovery.
|
| - EXPECT_FALSE(IsRecoveryComplete());
|
| + EXPECT_FALSE(this->IsRecoveryComplete());
|
| }
|
|
|
| // Verify that we don't use an old FEC packet for FEC decoding.
|
| -TEST_F(RtpFecTest, FecRecoveryWithSeqNumGapTwoFrames) {
|
| +TYPED_TEST(RtpFecTest, FecRecoveryWithSeqNumGapTwoFrames) {
|
| constexpr int kNumImportantPackets = 0;
|
| constexpr bool kUseUnequalProtection = false;
|
| constexpr uint8_t kProtectionFactor = 20;
|
| @@ -163,43 +184,47 @@ TEST_F(RtpFecTest, FecRecoveryWithSeqNumGapTwoFrames) {
|
| // try to decode using "old" FEC packet #2.
|
|
|
| // Construct media packets for first frame, starting at sequence number 0.
|
| - fec_seq_num_ = ConstructMediaPacketsSeqNum(2, 0);
|
| + this->media_packets_ =
|
| + this->media_packet_generator_.ConstructMediaPackets(2, 0);
|
|
|
| - EXPECT_EQ(0, fec_.GenerateFec(media_packet_list_, kProtectionFactor,
|
| - kNumImportantPackets, kUseUnequalProtection,
|
| - webrtc::kFecMaskBursty, &fec_packet_list_));
|
| + EXPECT_EQ(
|
| + 0, this->fec_.EncodeFec(this->media_packets_, kProtectionFactor,
|
| + kNumImportantPackets, kUseUnequalProtection,
|
| + kFecMaskBursty, &this->generated_fec_packets_));
|
| // Expect 1 FEC packet.
|
| - EXPECT_EQ(1u, fec_packet_list_.size());
|
| + EXPECT_EQ(1u, this->generated_fec_packets_.size());
|
| // Add FEC packet (seq#2) of this first frame to received list (i.e., assume
|
| // the two media packet were lost).
|
| - memset(fec_loss_mask_, 0, sizeof(fec_loss_mask_));
|
| - ReceivedPackets(fec_packet_list_, fec_loss_mask_, true);
|
| + memset(this->fec_loss_mask_, 0, sizeof(this->fec_loss_mask_));
|
| + this->ReceivedPackets(this->generated_fec_packets_, this->fec_loss_mask_,
|
| + true);
|
|
|
| // Construct media packets for second frame, with sequence number wrap.
|
| - media_packet_list_.clear();
|
| - fec_seq_num_ = ConstructMediaPacketsSeqNum(3, 65535);
|
| + this->media_packets_ =
|
| + this->media_packet_generator_.ConstructMediaPackets(3, 65535);
|
|
|
| // Expect 3 media packets for this frame.
|
| - EXPECT_EQ(3u, media_packet_list_.size());
|
| + EXPECT_EQ(3u, this->media_packets_.size());
|
|
|
| // Second media packet lost (seq#0).
|
| - memset(media_loss_mask_, 0, sizeof(media_loss_mask_));
|
| - media_loss_mask_[1] = 1;
|
| + memset(this->media_loss_mask_, 0, sizeof(this->media_loss_mask_));
|
| + this->media_loss_mask_[1] = 1;
|
| // Add packets #65535, and #1 to received list.
|
| - ReceivedPackets(media_packet_list_, media_loss_mask_, false);
|
| + this->ReceivedPackets(this->media_packets_, this->media_loss_mask_, false);
|
|
|
| - EXPECT_EQ(0, fec_.DecodeFec(&received_packet_list_, &recovered_packet_list_));
|
| + EXPECT_EQ(0, this->fec_.DecodeFec(&this->received_packets_,
|
| + &this->recovered_packets_));
|
|
|
| // Expect that no decoding is done to get missing packet (seq#0) of second
|
| // frame, using old FEC packet (seq#2) from first (old) frame. So number of
|
| // recovered packets is 2, and not equal to number of media packets (=3).
|
| - EXPECT_EQ(2u, recovered_packet_list_.size());
|
| - EXPECT_TRUE(recovered_packet_list_.size() != media_packet_list_.size());
|
| + EXPECT_EQ(2u, this->recovered_packets_.size());
|
| + EXPECT_TRUE(this->recovered_packets_.size() != this->media_packets_.size());
|
| }
|
|
|
| // Verify we can still recover frame if sequence number wrap occurs within
|
| // the frame and FEC packet following wrap is received after media packets.
|
| -TEST_F(RtpFecTest, FecRecoveryWithSeqNumGapOneFrameRecovery) {
|
| +TYPED_TEST(RtpFecTest, FecRecoveryWithSeqNumGapOneFrameRecovery) {
|
| constexpr int kNumImportantPackets = 0;
|
| constexpr bool kUseUnequalProtection = false;
|
| constexpr uint8_t kProtectionFactor = 20;
|
| @@ -207,29 +232,33 @@ TEST_F(RtpFecTest, FecRecoveryWithSeqNumGapOneFrameRecovery) {
|
| // One frame, with sequence number wrap in media packets.
|
| // -----Frame 1----
|
| // #65534(media) #65535(media) #0(media) #1(FEC).
|
| - fec_seq_num_ = ConstructMediaPacketsSeqNum(3, 65534);
|
| + this->media_packets_ =
|
| + this->media_packet_generator_.ConstructMediaPackets(3, 65534);
|
|
|
| - EXPECT_EQ(0, fec_.GenerateFec(media_packet_list_, kProtectionFactor,
|
| - kNumImportantPackets, kUseUnequalProtection,
|
| - webrtc::kFecMaskBursty, &fec_packet_list_));
|
| + EXPECT_EQ(
|
| + 0, this->fec_.EncodeFec(this->media_packets_, kProtectionFactor,
|
| + kNumImportantPackets, kUseUnequalProtection,
|
| + kFecMaskBursty, &this->generated_fec_packets_));
|
|
|
| // Expect 1 FEC packet.
|
| - EXPECT_EQ(1u, fec_packet_list_.size());
|
| + EXPECT_EQ(1u, this->generated_fec_packets_.size());
|
|
|
| // Lose one media packet (seq# 65535).
|
| - memset(media_loss_mask_, 0, sizeof(media_loss_mask_));
|
| - memset(fec_loss_mask_, 0, sizeof(fec_loss_mask_));
|
| - media_loss_mask_[1] = 1;
|
| - ReceivedPackets(media_packet_list_, media_loss_mask_, false);
|
| + memset(this->media_loss_mask_, 0, sizeof(this->media_loss_mask_));
|
| + memset(this->fec_loss_mask_, 0, sizeof(this->fec_loss_mask_));
|
| + this->media_loss_mask_[1] = 1;
|
| + this->ReceivedPackets(this->media_packets_, this->media_loss_mask_, false);
|
| // Add FEC packet to received list following the media packets.
|
| - ReceivedPackets(fec_packet_list_, fec_loss_mask_, true);
|
| + this->ReceivedPackets(this->generated_fec_packets_, this->fec_loss_mask_,
|
| + true);
|
|
|
| - EXPECT_EQ(0, fec_.DecodeFec(&received_packet_list_, &recovered_packet_list_));
|
| + EXPECT_EQ(0, this->fec_.DecodeFec(&this->received_packets_,
|
| + &this->recovered_packets_));
|
|
|
| // Expect 3 media packets in recovered list, and complete recovery.
|
| // Wrap-around won't remove FEC packet, as it follows the wrap.
|
| - EXPECT_EQ(3u, recovered_packet_list_.size());
|
| - EXPECT_TRUE(IsRecoveryComplete());
|
| + EXPECT_EQ(3u, this->recovered_packets_.size());
|
| + EXPECT_TRUE(this->IsRecoveryComplete());
|
| }
|
|
|
| // Sequence number wrap occurs within the FEC packets for the frame.
|
| @@ -238,7 +267,7 @@ TEST_F(RtpFecTest, FecRecoveryWithSeqNumGapOneFrameRecovery) {
|
| // received before the media packets. This may be improved if timing information
|
| // is used to detect old FEC packets.
|
| // TODO(marpan): Update test if wrap-around handling changes in FEC decoding.
|
| -TEST_F(RtpFecTest, FecRecoveryWithSeqNumGapOneFrameNoRecovery) {
|
| +TYPED_TEST(RtpFecTest, FecRecoveryWithSeqNumGapOneFrameNoRecovery) {
|
| constexpr int kNumImportantPackets = 0;
|
| constexpr bool kUseUnequalProtection = false;
|
| constexpr uint8_t kProtectionFactor = 200;
|
| @@ -247,36 +276,40 @@ TEST_F(RtpFecTest, FecRecoveryWithSeqNumGapOneFrameNoRecovery) {
|
| // Sequence number wrap in FEC packets.
|
| // -----Frame 1----
|
| // #65532(media) #65533(media) #65534(media) #65535(FEC) #0(FEC).
|
| - fec_seq_num_ = ConstructMediaPacketsSeqNum(3, 65532);
|
| + this->media_packets_ =
|
| + this->media_packet_generator_.ConstructMediaPackets(3, 65532);
|
|
|
| - EXPECT_EQ(0, fec_.GenerateFec(media_packet_list_, kProtectionFactor,
|
| - kNumImportantPackets, kUseUnequalProtection,
|
| - webrtc::kFecMaskBursty, &fec_packet_list_));
|
| + EXPECT_EQ(
|
| + 0, this->fec_.EncodeFec(this->media_packets_, kProtectionFactor,
|
| + kNumImportantPackets, kUseUnequalProtection,
|
| + kFecMaskBursty, &this->generated_fec_packets_));
|
|
|
| // Expect 2 FEC packets.
|
| - EXPECT_EQ(2u, fec_packet_list_.size());
|
| + EXPECT_EQ(2u, this->generated_fec_packets_.size());
|
|
|
| // Lose the last two media packets (seq# 65533, 65534).
|
| - memset(media_loss_mask_, 0, sizeof(media_loss_mask_));
|
| - memset(fec_loss_mask_, 0, sizeof(fec_loss_mask_));
|
| - media_loss_mask_[1] = 1;
|
| - media_loss_mask_[2] = 1;
|
| - ReceivedPackets(media_packet_list_, media_loss_mask_, false);
|
| - ReceivedPackets(fec_packet_list_, fec_loss_mask_, true);
|
| + memset(this->media_loss_mask_, 0, sizeof(this->media_loss_mask_));
|
| + memset(this->fec_loss_mask_, 0, sizeof(this->fec_loss_mask_));
|
| + this->media_loss_mask_[1] = 1;
|
| + this->media_loss_mask_[2] = 1;
|
| + this->ReceivedPackets(this->media_packets_, this->media_loss_mask_, false);
|
| + this->ReceivedPackets(this->generated_fec_packets_, this->fec_loss_mask_,
|
| + true);
|
|
|
| - EXPECT_EQ(0, fec_.DecodeFec(&received_packet_list_, &recovered_packet_list_));
|
| + EXPECT_EQ(0, this->fec_.DecodeFec(&this->received_packets_,
|
| + &this->recovered_packets_));
|
|
|
| // The two FEC packets are received and should allow for complete recovery,
|
| // but because of the wrap the second FEC packet will be discarded, and only
|
| // one media packet is recoverable. So exepct 2 media packets on recovered
|
| // list and no complete recovery.
|
| - EXPECT_EQ(2u, recovered_packet_list_.size());
|
| - EXPECT_TRUE(recovered_packet_list_.size() != media_packet_list_.size());
|
| - EXPECT_FALSE(IsRecoveryComplete());
|
| + EXPECT_EQ(2u, this->recovered_packets_.size());
|
| + EXPECT_TRUE(this->recovered_packets_.size() != this->media_packets_.size());
|
| + EXPECT_FALSE(this->IsRecoveryComplete());
|
| }
|
|
|
| // Verify we can still recover frame if media packets are reordered.
|
| -TEST_F(RtpFecTest, FecRecoveryWithMediaOutOfOrder) {
|
| +TYPED_TEST(RtpFecTest, FecRecoveryWithMediaOutOfOrder) {
|
| constexpr int kNumImportantPackets = 0;
|
| constexpr bool kUseUnequalProtection = false;
|
| constexpr uint8_t kProtectionFactor = 20;
|
| @@ -284,36 +317,39 @@ TEST_F(RtpFecTest, FecRecoveryWithMediaOutOfOrder) {
|
| // One frame: 3 media packets, 1 FEC packet.
|
| // -----Frame 1----
|
| // #0(media) #1(media) #2(media) #3(FEC).
|
| - fec_seq_num_ = ConstructMediaPacketsSeqNum(3, 0);
|
| + this->media_packets_ =
|
| + this->media_packet_generator_.ConstructMediaPackets(3, 0);
|
|
|
| - EXPECT_EQ(0, fec_.GenerateFec(media_packet_list_, kProtectionFactor,
|
| - kNumImportantPackets, kUseUnequalProtection,
|
| - webrtc::kFecMaskBursty, &fec_packet_list_));
|
| + EXPECT_EQ(
|
| + 0, this->fec_.EncodeFec(this->media_packets_, kProtectionFactor,
|
| + kNumImportantPackets, kUseUnequalProtection,
|
| + kFecMaskBursty, &this->generated_fec_packets_));
|
|
|
| // Expect 1 FEC packet.
|
| - EXPECT_EQ(1u, fec_packet_list_.size());
|
| + EXPECT_EQ(1u, this->generated_fec_packets_.size());
|
|
|
| // Lose one media packet (seq# 1).
|
| - memset(media_loss_mask_, 0, sizeof(media_loss_mask_));
|
| - memset(fec_loss_mask_, 0, sizeof(fec_loss_mask_));
|
| - media_loss_mask_[1] = 1;
|
| - NetworkReceivedPackets(media_loss_mask_, fec_loss_mask_);
|
| + memset(this->media_loss_mask_, 0, sizeof(this->media_loss_mask_));
|
| + memset(this->fec_loss_mask_, 0, sizeof(this->fec_loss_mask_));
|
| + this->media_loss_mask_[1] = 1;
|
| + this->NetworkReceivedPackets(this->media_loss_mask_, this->fec_loss_mask_);
|
|
|
| // Reorder received media packets.
|
| - auto it0 = received_packet_list_.begin();
|
| - auto it2 = received_packet_list_.begin();
|
| + auto it0 = this->received_packets_.begin();
|
| + auto it2 = this->received_packets_.begin();
|
| it2++;
|
| std::swap(*it0, *it2);
|
|
|
| - EXPECT_EQ(0, fec_.DecodeFec(&received_packet_list_, &recovered_packet_list_));
|
| + EXPECT_EQ(0, this->fec_.DecodeFec(&this->received_packets_,
|
| + &this->recovered_packets_));
|
|
|
| // Expect 3 media packets in recovered list, and complete recovery.
|
| - EXPECT_EQ(3u, recovered_packet_list_.size());
|
| - EXPECT_TRUE(IsRecoveryComplete());
|
| + EXPECT_EQ(3u, this->recovered_packets_.size());
|
| + EXPECT_TRUE(this->IsRecoveryComplete());
|
| }
|
|
|
| // Verify we can still recover frame if FEC is received before media packets.
|
| -TEST_F(RtpFecTest, FecRecoveryWithFecOutOfOrder) {
|
| +TYPED_TEST(RtpFecTest, FecRecoveryWithFecOutOfOrder) {
|
| constexpr int kNumImportantPackets = 0;
|
| constexpr bool kUseUnequalProtection = false;
|
| constexpr uint8_t kProtectionFactor = 20;
|
| @@ -321,35 +357,39 @@ TEST_F(RtpFecTest, FecRecoveryWithFecOutOfOrder) {
|
| // One frame: 3 media packets, 1 FEC packet.
|
| // -----Frame 1----
|
| // #0(media) #1(media) #2(media) #3(FEC).
|
| - fec_seq_num_ = ConstructMediaPacketsSeqNum(3, 0);
|
| + this->media_packets_ =
|
| + this->media_packet_generator_.ConstructMediaPackets(3, 0);
|
|
|
| - EXPECT_EQ(0, fec_.GenerateFec(media_packet_list_, kProtectionFactor,
|
| - kNumImportantPackets, kUseUnequalProtection,
|
| - webrtc::kFecMaskBursty, &fec_packet_list_));
|
| + EXPECT_EQ(
|
| + 0, this->fec_.EncodeFec(this->media_packets_, kProtectionFactor,
|
| + kNumImportantPackets, kUseUnequalProtection,
|
| + kFecMaskBursty, &this->generated_fec_packets_));
|
|
|
| // Expect 1 FEC packet.
|
| - EXPECT_EQ(1u, fec_packet_list_.size());
|
| + EXPECT_EQ(1u, this->generated_fec_packets_.size());
|
|
|
| // Lose one media packet (seq# 1).
|
| - memset(media_loss_mask_, 0, sizeof(media_loss_mask_));
|
| - memset(fec_loss_mask_, 0, sizeof(fec_loss_mask_));
|
| - media_loss_mask_[1] = 1;
|
| + memset(this->media_loss_mask_, 0, sizeof(this->media_loss_mask_));
|
| + memset(this->fec_loss_mask_, 0, sizeof(this->fec_loss_mask_));
|
| + this->media_loss_mask_[1] = 1;
|
| // Add FEC packet to received list before the media packets.
|
| - ReceivedPackets(fec_packet_list_, fec_loss_mask_, true);
|
| + this->ReceivedPackets(this->generated_fec_packets_, this->fec_loss_mask_,
|
| + true);
|
| // Add media packets to received list.
|
| - ReceivedPackets(media_packet_list_, media_loss_mask_, false);
|
| + this->ReceivedPackets(this->media_packets_, this->media_loss_mask_, false);
|
|
|
| - EXPECT_EQ(0, fec_.DecodeFec(&received_packet_list_, &recovered_packet_list_));
|
| + EXPECT_EQ(0, this->fec_.DecodeFec(&this->received_packets_,
|
| + &this->recovered_packets_));
|
|
|
| // Expect 3 media packets in recovered list, and complete recovery.
|
| - EXPECT_EQ(3u, recovered_packet_list_.size());
|
| - EXPECT_TRUE(IsRecoveryComplete());
|
| + EXPECT_EQ(3u, this->recovered_packets_.size());
|
| + EXPECT_TRUE(this->IsRecoveryComplete());
|
| }
|
|
|
| // Test 50% protection with random mask type: Two cases are considered:
|
| // a 50% non-consecutive loss which can be fully recovered, and a 50%
|
| // consecutive loss which cannot be fully recovered.
|
| -TEST_F(RtpFecTest, FecRecoveryWithLoss50percRandomMask) {
|
| +TYPED_TEST(RtpFecTest, FecRecoveryWithLoss50percRandomMask) {
|
| constexpr int kNumImportantPackets = 0;
|
| constexpr bool kUseUnequalProtection = false;
|
| constexpr int kNumMediaPackets = 4;
|
| @@ -365,49 +405,53 @@ TEST_F(RtpFecTest, FecRecoveryWithLoss50percRandomMask) {
|
| // fec#3: 0 1 0 1
|
| //
|
|
|
| - fec_seq_num_ = ConstructMediaPackets(kNumMediaPackets);
|
| + this->media_packets_ =
|
| + this->media_packet_generator_.ConstructMediaPackets(kNumMediaPackets);
|
|
|
| - EXPECT_EQ(0, fec_.GenerateFec(media_packet_list_, kProtectionFactor,
|
| - kNumImportantPackets, kUseUnequalProtection,
|
| - webrtc::kFecMaskRandom, &fec_packet_list_));
|
| + EXPECT_EQ(
|
| + 0, this->fec_.EncodeFec(this->media_packets_, kProtectionFactor,
|
| + kNumImportantPackets, kUseUnequalProtection,
|
| + kFecMaskRandom, &this->generated_fec_packets_));
|
|
|
| // Expect 4 FEC packets.
|
| - EXPECT_EQ(4u, fec_packet_list_.size());
|
| + EXPECT_EQ(4u, this->generated_fec_packets_.size());
|
|
|
| // 4 packets lost: 3 media packets (0, 2, 3), and one FEC packet (0) lost.
|
| - memset(media_loss_mask_, 0, sizeof(media_loss_mask_));
|
| - memset(fec_loss_mask_, 0, sizeof(fec_loss_mask_));
|
| - fec_loss_mask_[0] = 1;
|
| - media_loss_mask_[0] = 1;
|
| - media_loss_mask_[2] = 1;
|
| - media_loss_mask_[3] = 1;
|
| - NetworkReceivedPackets(media_loss_mask_, fec_loss_mask_);
|
| + memset(this->media_loss_mask_, 0, sizeof(this->media_loss_mask_));
|
| + memset(this->fec_loss_mask_, 0, sizeof(this->fec_loss_mask_));
|
| + this->fec_loss_mask_[0] = 1;
|
| + this->media_loss_mask_[0] = 1;
|
| + this->media_loss_mask_[2] = 1;
|
| + this->media_loss_mask_[3] = 1;
|
| + this->NetworkReceivedPackets(this->media_loss_mask_, this->fec_loss_mask_);
|
|
|
| - EXPECT_EQ(0, fec_.DecodeFec(&received_packet_list_, &recovered_packet_list_));
|
| + EXPECT_EQ(0, this->fec_.DecodeFec(&this->received_packets_,
|
| + &this->recovered_packets_));
|
|
|
| // With media packet#1 and FEC packets #1, #2, #3, expect complete recovery.
|
| - EXPECT_TRUE(IsRecoveryComplete());
|
| - recovered_packet_list_.clear();
|
| + EXPECT_TRUE(this->IsRecoveryComplete());
|
| + this->recovered_packets_.clear();
|
|
|
| // 4 consecutive packets lost: media packets 0, 1, 2, 3.
|
| - memset(media_loss_mask_, 0, sizeof(media_loss_mask_));
|
| - memset(fec_loss_mask_, 0, sizeof(fec_loss_mask_));
|
| - media_loss_mask_[0] = 1;
|
| - media_loss_mask_[1] = 1;
|
| - media_loss_mask_[2] = 1;
|
| - media_loss_mask_[3] = 1;
|
| - NetworkReceivedPackets(media_loss_mask_, fec_loss_mask_);
|
| + memset(this->media_loss_mask_, 0, sizeof(this->media_loss_mask_));
|
| + memset(this->fec_loss_mask_, 0, sizeof(this->fec_loss_mask_));
|
| + this->media_loss_mask_[0] = 1;
|
| + this->media_loss_mask_[1] = 1;
|
| + this->media_loss_mask_[2] = 1;
|
| + this->media_loss_mask_[3] = 1;
|
| + this->NetworkReceivedPackets(this->media_loss_mask_, this->fec_loss_mask_);
|
|
|
| - EXPECT_EQ(0, fec_.DecodeFec(&received_packet_list_, &recovered_packet_list_));
|
| + EXPECT_EQ(0, this->fec_.DecodeFec(&this->received_packets_,
|
| + &this->recovered_packets_));
|
|
|
| // Cannot get complete recovery for this loss configuration with random mask.
|
| - EXPECT_FALSE(IsRecoveryComplete());
|
| + EXPECT_FALSE(this->IsRecoveryComplete());
|
| }
|
|
|
| // Test 50% protection with bursty type: Three cases are considered:
|
| // two 50% consecutive losses which can be fully recovered, and one
|
| // non-consecutive which cannot be fully recovered.
|
| -TEST_F(RtpFecTest, FecRecoveryWithLoss50percBurstyMask) {
|
| +TYPED_TEST(RtpFecTest, FecRecoveryWithLoss50percBurstyMask) {
|
| constexpr int kNumImportantPackets = 0;
|
| constexpr bool kUseUnequalProtection = false;
|
| constexpr int kNumMediaPackets = 4;
|
| @@ -423,128 +467,140 @@ TEST_F(RtpFecTest, FecRecoveryWithLoss50percBurstyMask) {
|
| // fec#3: 0 0 1 1
|
| //
|
|
|
| - fec_seq_num_ = ConstructMediaPackets(kNumMediaPackets);
|
| + this->media_packets_ =
|
| + this->media_packet_generator_.ConstructMediaPackets(kNumMediaPackets);
|
|
|
| - EXPECT_EQ(0, fec_.GenerateFec(media_packet_list_, kProtectionFactor,
|
| - kNumImportantPackets, kUseUnequalProtection,
|
| - webrtc::kFecMaskBursty, &fec_packet_list_));
|
| + EXPECT_EQ(
|
| + 0, this->fec_.EncodeFec(this->media_packets_, kProtectionFactor,
|
| + kNumImportantPackets, kUseUnequalProtection,
|
| + kFecMaskBursty, &this->generated_fec_packets_));
|
|
|
| // Expect 4 FEC packets.
|
| - EXPECT_EQ(4u, fec_packet_list_.size());
|
| + EXPECT_EQ(4u, this->generated_fec_packets_.size());
|
|
|
| // 4 consecutive packets lost: media packets 0,1,2,3.
|
| - memset(media_loss_mask_, 0, sizeof(media_loss_mask_));
|
| - memset(fec_loss_mask_, 0, sizeof(fec_loss_mask_));
|
| - media_loss_mask_[0] = 1;
|
| - media_loss_mask_[1] = 1;
|
| - media_loss_mask_[2] = 1;
|
| - media_loss_mask_[3] = 1;
|
| - NetworkReceivedPackets(media_loss_mask_, fec_loss_mask_);
|
| + memset(this->media_loss_mask_, 0, sizeof(this->media_loss_mask_));
|
| + memset(this->fec_loss_mask_, 0, sizeof(this->fec_loss_mask_));
|
| + this->media_loss_mask_[0] = 1;
|
| + this->media_loss_mask_[1] = 1;
|
| + this->media_loss_mask_[2] = 1;
|
| + this->media_loss_mask_[3] = 1;
|
| + this->NetworkReceivedPackets(this->media_loss_mask_, this->fec_loss_mask_);
|
|
|
| - EXPECT_EQ(0, fec_.DecodeFec(&received_packet_list_, &recovered_packet_list_));
|
| + EXPECT_EQ(0, this->fec_.DecodeFec(&this->received_packets_,
|
| + &this->recovered_packets_));
|
|
|
| // Expect complete recovery for consecutive packet loss <= 50%.
|
| - EXPECT_TRUE(IsRecoveryComplete());
|
| - recovered_packet_list_.clear();
|
| + EXPECT_TRUE(this->IsRecoveryComplete());
|
| + this->recovered_packets_.clear();
|
|
|
| // 4 consecutive packets lost: media packets 1,2, 3, and FEC packet 0.
|
| - memset(media_loss_mask_, 0, sizeof(media_loss_mask_));
|
| - memset(fec_loss_mask_, 0, sizeof(fec_loss_mask_));
|
| - fec_loss_mask_[0] = 1;
|
| - media_loss_mask_[1] = 1;
|
| - media_loss_mask_[2] = 1;
|
| - media_loss_mask_[3] = 1;
|
| - NetworkReceivedPackets(media_loss_mask_, fec_loss_mask_);
|
| + memset(this->media_loss_mask_, 0, sizeof(this->media_loss_mask_));
|
| + memset(this->fec_loss_mask_, 0, sizeof(this->fec_loss_mask_));
|
| + this->fec_loss_mask_[0] = 1;
|
| + this->media_loss_mask_[1] = 1;
|
| + this->media_loss_mask_[2] = 1;
|
| + this->media_loss_mask_[3] = 1;
|
| + this->NetworkReceivedPackets(this->media_loss_mask_, this->fec_loss_mask_);
|
|
|
| - EXPECT_EQ(0, fec_.DecodeFec(&received_packet_list_, &recovered_packet_list_));
|
| + EXPECT_EQ(0, this->fec_.DecodeFec(&this->received_packets_,
|
| + &this->recovered_packets_));
|
|
|
| // Expect complete recovery for consecutive packet loss <= 50%.
|
| - EXPECT_TRUE(IsRecoveryComplete());
|
| - recovered_packet_list_.clear();
|
| + EXPECT_TRUE(this->IsRecoveryComplete());
|
| + this->recovered_packets_.clear();
|
|
|
| // 4 packets lost (non-consecutive loss): media packets 0, 3, and FEC# 0, 3.
|
| - memset(media_loss_mask_, 0, sizeof(media_loss_mask_));
|
| - memset(fec_loss_mask_, 0, sizeof(fec_loss_mask_));
|
| - fec_loss_mask_[0] = 1;
|
| - fec_loss_mask_[3] = 1;
|
| - media_loss_mask_[0] = 1;
|
| - media_loss_mask_[3] = 1;
|
| - NetworkReceivedPackets(media_loss_mask_, fec_loss_mask_);
|
| + memset(this->media_loss_mask_, 0, sizeof(this->media_loss_mask_));
|
| + memset(this->fec_loss_mask_, 0, sizeof(this->fec_loss_mask_));
|
| + this->fec_loss_mask_[0] = 1;
|
| + this->fec_loss_mask_[3] = 1;
|
| + this->media_loss_mask_[0] = 1;
|
| + this->media_loss_mask_[3] = 1;
|
| + this->NetworkReceivedPackets(this->media_loss_mask_, this->fec_loss_mask_);
|
|
|
| - EXPECT_EQ(0, fec_.DecodeFec(&received_packet_list_, &recovered_packet_list_));
|
| + EXPECT_EQ(0, this->fec_.DecodeFec(&this->received_packets_,
|
| + &this->recovered_packets_));
|
|
|
| // Cannot get complete recovery for this loss configuration.
|
| - EXPECT_FALSE(IsRecoveryComplete());
|
| + EXPECT_FALSE(this->IsRecoveryComplete());
|
| }
|
|
|
| -TEST_F(RtpFecTest, FecRecoveryNoLossUep) {
|
| +TYPED_TEST(RtpFecTest, FecRecoveryNoLossUep) {
|
| constexpr int kNumImportantPackets = 2;
|
| constexpr bool kUseUnequalProtection = true;
|
| constexpr int kNumMediaPackets = 4;
|
| constexpr uint8_t kProtectionFactor = 60;
|
|
|
| - fec_seq_num_ = ConstructMediaPackets(kNumMediaPackets);
|
| + this->media_packets_ =
|
| + this->media_packet_generator_.ConstructMediaPackets(kNumMediaPackets);
|
|
|
| - EXPECT_EQ(0, fec_.GenerateFec(media_packet_list_, kProtectionFactor,
|
| - kNumImportantPackets, kUseUnequalProtection,
|
| - webrtc::kFecMaskBursty, &fec_packet_list_));
|
| + EXPECT_EQ(
|
| + 0, this->fec_.EncodeFec(this->media_packets_, kProtectionFactor,
|
| + kNumImportantPackets, kUseUnequalProtection,
|
| + kFecMaskBursty, &this->generated_fec_packets_));
|
|
|
| // Expect 1 FEC packet.
|
| - EXPECT_EQ(1u, fec_packet_list_.size());
|
| + EXPECT_EQ(1u, this->generated_fec_packets_.size());
|
|
|
| // No packets lost.
|
| - memset(media_loss_mask_, 0, sizeof(media_loss_mask_));
|
| - memset(fec_loss_mask_, 0, sizeof(fec_loss_mask_));
|
| - NetworkReceivedPackets(media_loss_mask_, fec_loss_mask_);
|
| + memset(this->media_loss_mask_, 0, sizeof(this->media_loss_mask_));
|
| + memset(this->fec_loss_mask_, 0, sizeof(this->fec_loss_mask_));
|
| + this->NetworkReceivedPackets(this->media_loss_mask_, this->fec_loss_mask_);
|
|
|
| - EXPECT_EQ(0, fec_.DecodeFec(&received_packet_list_, &recovered_packet_list_));
|
| + EXPECT_EQ(0, this->fec_.DecodeFec(&this->received_packets_,
|
| + &this->recovered_packets_));
|
|
|
| // No packets lost, expect complete recovery.
|
| - EXPECT_TRUE(IsRecoveryComplete());
|
| + EXPECT_TRUE(this->IsRecoveryComplete());
|
| }
|
|
|
| -TEST_F(RtpFecTest, FecRecoveryWithLossUep) {
|
| +TYPED_TEST(RtpFecTest, FecRecoveryWithLossUep) {
|
| constexpr int kNumImportantPackets = 2;
|
| constexpr bool kUseUnequalProtection = true;
|
| constexpr int kNumMediaPackets = 4;
|
| constexpr uint8_t kProtectionFactor = 60;
|
|
|
| - fec_seq_num_ = ConstructMediaPackets(kNumMediaPackets);
|
| + this->media_packets_ =
|
| + this->media_packet_generator_.ConstructMediaPackets(kNumMediaPackets);
|
|
|
| - EXPECT_EQ(0, fec_.GenerateFec(media_packet_list_, kProtectionFactor,
|
| - kNumImportantPackets, kUseUnequalProtection,
|
| - webrtc::kFecMaskBursty, &fec_packet_list_));
|
| + EXPECT_EQ(
|
| + 0, this->fec_.EncodeFec(this->media_packets_, kProtectionFactor,
|
| + kNumImportantPackets, kUseUnequalProtection,
|
| + kFecMaskBursty, &this->generated_fec_packets_));
|
|
|
| // Expect 1 FEC packet.
|
| - EXPECT_EQ(1u, fec_packet_list_.size());
|
| + EXPECT_EQ(1u, this->generated_fec_packets_.size());
|
|
|
| // 1 media packet lost.
|
| - memset(media_loss_mask_, 0, sizeof(media_loss_mask_));
|
| - memset(fec_loss_mask_, 0, sizeof(fec_loss_mask_));
|
| - media_loss_mask_[3] = 1;
|
| - NetworkReceivedPackets(media_loss_mask_, fec_loss_mask_);
|
| + memset(this->media_loss_mask_, 0, sizeof(this->media_loss_mask_));
|
| + memset(this->fec_loss_mask_, 0, sizeof(this->fec_loss_mask_));
|
| + this->media_loss_mask_[3] = 1;
|
| + this->NetworkReceivedPackets(this->media_loss_mask_, this->fec_loss_mask_);
|
|
|
| - EXPECT_EQ(0, fec_.DecodeFec(&received_packet_list_, &recovered_packet_list_));
|
| + EXPECT_EQ(0, this->fec_.DecodeFec(&this->received_packets_,
|
| + &this->recovered_packets_));
|
|
|
| // One packet lost, one FEC packet, expect complete recovery.
|
| - EXPECT_TRUE(IsRecoveryComplete());
|
| - recovered_packet_list_.clear();
|
| + EXPECT_TRUE(this->IsRecoveryComplete());
|
| + this->recovered_packets_.clear();
|
|
|
| // 2 media packets lost.
|
| - memset(media_loss_mask_, 0, sizeof(media_loss_mask_));
|
| - memset(fec_loss_mask_, 0, sizeof(fec_loss_mask_));
|
| - media_loss_mask_[1] = 1;
|
| - media_loss_mask_[3] = 1;
|
| - NetworkReceivedPackets(media_loss_mask_, fec_loss_mask_);
|
| + memset(this->media_loss_mask_, 0, sizeof(this->media_loss_mask_));
|
| + memset(this->fec_loss_mask_, 0, sizeof(this->fec_loss_mask_));
|
| + this->media_loss_mask_[1] = 1;
|
| + this->media_loss_mask_[3] = 1;
|
| + this->NetworkReceivedPackets(this->media_loss_mask_, this->fec_loss_mask_);
|
|
|
| - EXPECT_EQ(0, fec_.DecodeFec(&received_packet_list_, &recovered_packet_list_));
|
| + EXPECT_EQ(0, this->fec_.DecodeFec(&this->received_packets_,
|
| + &this->recovered_packets_));
|
|
|
| // 2 packets lost, one FEC packet, cannot get complete recovery.
|
| - EXPECT_FALSE(IsRecoveryComplete());
|
| + EXPECT_FALSE(this->IsRecoveryComplete());
|
| }
|
|
|
| // Test 50% protection with random mask type for UEP on.
|
| -TEST_F(RtpFecTest, FecRecoveryWithLoss50percUepRandomMask) {
|
| +TYPED_TEST(RtpFecTest, FecRecoveryWithLoss50percUepRandomMask) {
|
| constexpr int kNumImportantPackets = 1;
|
| constexpr bool kUseUnequalProtection = true;
|
| constexpr int kNumMediaPackets = 4;
|
| @@ -560,241 +616,254 @@ TEST_F(RtpFecTest, FecRecoveryWithLoss50percUepRandomMask) {
|
| // fec#3: 0 1 1 0
|
| //
|
|
|
| - fec_seq_num_ = ConstructMediaPackets(kNumMediaPackets);
|
| + this->media_packets_ =
|
| + this->media_packet_generator_.ConstructMediaPackets(kNumMediaPackets);
|
|
|
| - EXPECT_EQ(0, fec_.GenerateFec(media_packet_list_, kProtectionFactor,
|
| - kNumImportantPackets, kUseUnequalProtection,
|
| - webrtc::kFecMaskRandom, &fec_packet_list_));
|
| + EXPECT_EQ(
|
| + 0, this->fec_.EncodeFec(this->media_packets_, kProtectionFactor,
|
| + kNumImportantPackets, kUseUnequalProtection,
|
| + kFecMaskRandom, &this->generated_fec_packets_));
|
|
|
| // Expect 4 FEC packets.
|
| - EXPECT_EQ(4u, fec_packet_list_.size());
|
| + EXPECT_EQ(4u, this->generated_fec_packets_.size());
|
|
|
| // 4 packets lost: 3 media packets and FEC packet#1 lost.
|
| - memset(media_loss_mask_, 0, sizeof(media_loss_mask_));
|
| - memset(fec_loss_mask_, 0, sizeof(fec_loss_mask_));
|
| - fec_loss_mask_[1] = 1;
|
| - media_loss_mask_[0] = 1;
|
| - media_loss_mask_[2] = 1;
|
| - media_loss_mask_[3] = 1;
|
| - NetworkReceivedPackets(media_loss_mask_, fec_loss_mask_);
|
| + memset(this->media_loss_mask_, 0, sizeof(this->media_loss_mask_));
|
| + memset(this->fec_loss_mask_, 0, sizeof(this->fec_loss_mask_));
|
| + this->fec_loss_mask_[1] = 1;
|
| + this->media_loss_mask_[0] = 1;
|
| + this->media_loss_mask_[2] = 1;
|
| + this->media_loss_mask_[3] = 1;
|
| + this->NetworkReceivedPackets(this->media_loss_mask_, this->fec_loss_mask_);
|
|
|
| - EXPECT_EQ(0, fec_.DecodeFec(&received_packet_list_, &recovered_packet_list_));
|
| + EXPECT_EQ(0, this->fec_.DecodeFec(&this->received_packets_,
|
| + &this->recovered_packets_));
|
|
|
| // With media packet#3 and FEC packets #0, #1, #3, expect complete recovery.
|
| - EXPECT_TRUE(IsRecoveryComplete());
|
| - recovered_packet_list_.clear();
|
| + EXPECT_TRUE(this->IsRecoveryComplete());
|
| + this->recovered_packets_.clear();
|
|
|
| // 5 packets lost: 4 media packets and one FEC packet#2 lost.
|
| - memset(media_loss_mask_, 0, sizeof(media_loss_mask_));
|
| - memset(fec_loss_mask_, 0, sizeof(fec_loss_mask_));
|
| - fec_loss_mask_[2] = 1;
|
| - media_loss_mask_[0] = 1;
|
| - media_loss_mask_[1] = 1;
|
| - media_loss_mask_[2] = 1;
|
| - media_loss_mask_[3] = 1;
|
| - NetworkReceivedPackets(media_loss_mask_, fec_loss_mask_);
|
| -
|
| - EXPECT_EQ(0, fec_.DecodeFec(&received_packet_list_, &recovered_packet_list_));
|
| + memset(this->media_loss_mask_, 0, sizeof(this->media_loss_mask_));
|
| + memset(this->fec_loss_mask_, 0, sizeof(this->fec_loss_mask_));
|
| + this->fec_loss_mask_[2] = 1;
|
| + this->media_loss_mask_[0] = 1;
|
| + this->media_loss_mask_[1] = 1;
|
| + this->media_loss_mask_[2] = 1;
|
| + this->media_loss_mask_[3] = 1;
|
| + this->NetworkReceivedPackets(this->media_loss_mask_, this->fec_loss_mask_);
|
| +
|
| + EXPECT_EQ(0, this->fec_.DecodeFec(&this->received_packets_,
|
| + &this->recovered_packets_));
|
|
|
| // Cannot get complete recovery for this loss configuration.
|
| - EXPECT_FALSE(IsRecoveryComplete());
|
| + EXPECT_FALSE(this->IsRecoveryComplete());
|
| }
|
|
|
| -TEST_F(RtpFecTest, FecRecoveryNonConsecutivePackets) {
|
| +TYPED_TEST(RtpFecTest, FecRecoveryNonConsecutivePackets) {
|
| constexpr int kNumImportantPackets = 0;
|
| constexpr bool kUseUnequalProtection = false;
|
| constexpr int kNumMediaPackets = 5;
|
| constexpr uint8_t kProtectionFactor = 60;
|
|
|
| - fec_seq_num_ = ConstructMediaPackets(kNumMediaPackets);
|
| + this->media_packets_ =
|
| + this->media_packet_generator_.ConstructMediaPackets(kNumMediaPackets);
|
|
|
| // Create a new temporary packet list for generating FEC packets.
|
| // This list should have every other packet removed.
|
| - PacketList protected_media_packets;
|
| - DeepCopyEveryNthPacket(media_packet_list_, 2, &protected_media_packets);
|
| + ForwardErrorCorrection::PacketList protected_media_packets;
|
| + DeepCopyEveryNthPacket(this->media_packets_, 2, &protected_media_packets);
|
|
|
| - EXPECT_EQ(0, fec_.GenerateFec(protected_media_packets, kProtectionFactor,
|
| - kNumImportantPackets, kUseUnequalProtection,
|
| - webrtc::kFecMaskBursty, &fec_packet_list_));
|
| + EXPECT_EQ(
|
| + 0, this->fec_.EncodeFec(protected_media_packets, kProtectionFactor,
|
| + kNumImportantPackets, kUseUnequalProtection,
|
| + kFecMaskBursty, &this->generated_fec_packets_));
|
|
|
| // Expect 1 FEC packet.
|
| - EXPECT_EQ(1u, fec_packet_list_.size());
|
| + EXPECT_EQ(1u, this->generated_fec_packets_.size());
|
|
|
| // 1 protected media packet lost
|
| - memset(media_loss_mask_, 0, sizeof(media_loss_mask_));
|
| - memset(fec_loss_mask_, 0, sizeof(fec_loss_mask_));
|
| - media_loss_mask_[2] = 1;
|
| - NetworkReceivedPackets(media_loss_mask_, fec_loss_mask_);
|
| + memset(this->media_loss_mask_, 0, sizeof(this->media_loss_mask_));
|
| + memset(this->fec_loss_mask_, 0, sizeof(this->fec_loss_mask_));
|
| + this->media_loss_mask_[2] = 1;
|
| + this->NetworkReceivedPackets(this->media_loss_mask_, this->fec_loss_mask_);
|
|
|
| - EXPECT_EQ(0, fec_.DecodeFec(&received_packet_list_, &recovered_packet_list_));
|
| + EXPECT_EQ(0, this->fec_.DecodeFec(&this->received_packets_,
|
| + &this->recovered_packets_));
|
|
|
| // One packet lost, one FEC packet, expect complete recovery.
|
| - EXPECT_TRUE(IsRecoveryComplete());
|
| - recovered_packet_list_.clear();
|
| + EXPECT_TRUE(this->IsRecoveryComplete());
|
| + this->recovered_packets_.clear();
|
|
|
| // Unprotected packet lost.
|
| - memset(media_loss_mask_, 0, sizeof(media_loss_mask_));
|
| - memset(fec_loss_mask_, 0, sizeof(fec_loss_mask_));
|
| - media_loss_mask_[1] = 1;
|
| - NetworkReceivedPackets(media_loss_mask_, fec_loss_mask_);
|
| + memset(this->media_loss_mask_, 0, sizeof(this->media_loss_mask_));
|
| + memset(this->fec_loss_mask_, 0, sizeof(this->fec_loss_mask_));
|
| + this->media_loss_mask_[1] = 1;
|
| + this->NetworkReceivedPackets(this->media_loss_mask_, this->fec_loss_mask_);
|
|
|
| - EXPECT_EQ(0, fec_.DecodeFec(&received_packet_list_, &recovered_packet_list_));
|
| + EXPECT_EQ(0, this->fec_.DecodeFec(&this->received_packets_,
|
| + &this->recovered_packets_));
|
|
|
| // Unprotected packet lost. Recovery not possible.
|
| - EXPECT_FALSE(IsRecoveryComplete());
|
| - recovered_packet_list_.clear();
|
| + EXPECT_FALSE(this->IsRecoveryComplete());
|
| + this->recovered_packets_.clear();
|
|
|
| // 2 media packets lost.
|
| - memset(media_loss_mask_, 0, sizeof(media_loss_mask_));
|
| - memset(fec_loss_mask_, 0, sizeof(fec_loss_mask_));
|
| - media_loss_mask_[0] = 1;
|
| - media_loss_mask_[2] = 1;
|
| - NetworkReceivedPackets(media_loss_mask_, fec_loss_mask_);
|
| + memset(this->media_loss_mask_, 0, sizeof(this->media_loss_mask_));
|
| + memset(this->fec_loss_mask_, 0, sizeof(this->fec_loss_mask_));
|
| + this->media_loss_mask_[0] = 1;
|
| + this->media_loss_mask_[2] = 1;
|
| + this->NetworkReceivedPackets(this->media_loss_mask_, this->fec_loss_mask_);
|
|
|
| - EXPECT_EQ(0, fec_.DecodeFec(&received_packet_list_, &recovered_packet_list_));
|
| + EXPECT_EQ(0, this->fec_.DecodeFec(&this->received_packets_,
|
| + &this->recovered_packets_));
|
|
|
| // 2 protected packets lost, one FEC packet, cannot get complete recovery.
|
| - EXPECT_FALSE(IsRecoveryComplete());
|
| + EXPECT_FALSE(this->IsRecoveryComplete());
|
| }
|
|
|
| -TEST_F(RtpFecTest, FecRecoveryNonConsecutivePacketsExtension) {
|
| +TYPED_TEST(RtpFecTest, FecRecoveryNonConsecutivePacketsExtension) {
|
| constexpr int kNumImportantPackets = 0;
|
| constexpr bool kUseUnequalProtection = false;
|
| constexpr int kNumMediaPackets = 21;
|
| uint8_t kProtectionFactor = 127;
|
|
|
| - fec_seq_num_ = ConstructMediaPackets(kNumMediaPackets);
|
| + this->media_packets_ =
|
| + this->media_packet_generator_.ConstructMediaPackets(kNumMediaPackets);
|
|
|
| // Create a new temporary packet list for generating FEC packets.
|
| // This list should have every other packet removed.
|
| - PacketList protected_media_packets;
|
| - DeepCopyEveryNthPacket(media_packet_list_, 2, &protected_media_packets);
|
| + ForwardErrorCorrection::PacketList protected_media_packets;
|
| + DeepCopyEveryNthPacket(this->media_packets_, 2, &protected_media_packets);
|
|
|
| // Zero column insertion will have to extend the size of the packet
|
| // mask since the number of actual packets are 21, while the number
|
| // of protected packets are 11.
|
| - EXPECT_EQ(0, fec_.GenerateFec(protected_media_packets, kProtectionFactor,
|
| - kNumImportantPackets, kUseUnequalProtection,
|
| - webrtc::kFecMaskBursty, &fec_packet_list_));
|
| + EXPECT_EQ(
|
| + 0, this->fec_.EncodeFec(protected_media_packets, kProtectionFactor,
|
| + kNumImportantPackets, kUseUnequalProtection,
|
| + kFecMaskBursty, &this->generated_fec_packets_));
|
|
|
| // Expect 5 FEC packet.
|
| - EXPECT_EQ(5u, fec_packet_list_.size());
|
| + EXPECT_EQ(5u, this->generated_fec_packets_.size());
|
|
|
| // Last protected media packet lost
|
| - memset(media_loss_mask_, 0, sizeof(media_loss_mask_));
|
| - memset(fec_loss_mask_, 0, sizeof(fec_loss_mask_));
|
| - media_loss_mask_[kNumMediaPackets - 1] = 1;
|
| - NetworkReceivedPackets(media_loss_mask_, fec_loss_mask_);
|
| + memset(this->media_loss_mask_, 0, sizeof(this->media_loss_mask_));
|
| + memset(this->fec_loss_mask_, 0, sizeof(this->fec_loss_mask_));
|
| + this->media_loss_mask_[kNumMediaPackets - 1] = 1;
|
| + this->NetworkReceivedPackets(this->media_loss_mask_, this->fec_loss_mask_);
|
|
|
| - EXPECT_EQ(0, fec_.DecodeFec(&received_packet_list_, &recovered_packet_list_));
|
| + EXPECT_EQ(0, this->fec_.DecodeFec(&this->received_packets_,
|
| + &this->recovered_packets_));
|
|
|
| // One packet lost, one FEC packet, expect complete recovery.
|
| - EXPECT_TRUE(IsRecoveryComplete());
|
| - recovered_packet_list_.clear();
|
| + EXPECT_TRUE(this->IsRecoveryComplete());
|
| + this->recovered_packets_.clear();
|
|
|
| // Last unprotected packet lost.
|
| - memset(media_loss_mask_, 0, sizeof(media_loss_mask_));
|
| - memset(fec_loss_mask_, 0, sizeof(fec_loss_mask_));
|
| - media_loss_mask_[kNumMediaPackets - 2] = 1;
|
| - NetworkReceivedPackets(media_loss_mask_, fec_loss_mask_);
|
| + memset(this->media_loss_mask_, 0, sizeof(this->media_loss_mask_));
|
| + memset(this->fec_loss_mask_, 0, sizeof(this->fec_loss_mask_));
|
| + this->media_loss_mask_[kNumMediaPackets - 2] = 1;
|
| + this->NetworkReceivedPackets(this->media_loss_mask_, this->fec_loss_mask_);
|
|
|
| - EXPECT_EQ(0, fec_.DecodeFec(&received_packet_list_, &recovered_packet_list_));
|
| + EXPECT_EQ(0, this->fec_.DecodeFec(&this->received_packets_,
|
| + &this->recovered_packets_));
|
|
|
| // Unprotected packet lost. Recovery not possible.
|
| - EXPECT_FALSE(IsRecoveryComplete());
|
| - recovered_packet_list_.clear();
|
| + EXPECT_FALSE(this->IsRecoveryComplete());
|
| + this->recovered_packets_.clear();
|
|
|
| // 6 media packets lost.
|
| - memset(media_loss_mask_, 0, sizeof(media_loss_mask_));
|
| - memset(fec_loss_mask_, 0, sizeof(fec_loss_mask_));
|
| - media_loss_mask_[kNumMediaPackets - 11] = 1;
|
| - media_loss_mask_[kNumMediaPackets - 9] = 1;
|
| - media_loss_mask_[kNumMediaPackets - 7] = 1;
|
| - media_loss_mask_[kNumMediaPackets - 5] = 1;
|
| - media_loss_mask_[kNumMediaPackets - 3] = 1;
|
| - media_loss_mask_[kNumMediaPackets - 1] = 1;
|
| - NetworkReceivedPackets(media_loss_mask_, fec_loss_mask_);
|
| -
|
| - EXPECT_EQ(0, fec_.DecodeFec(&received_packet_list_, &recovered_packet_list_));
|
| + memset(this->media_loss_mask_, 0, sizeof(this->media_loss_mask_));
|
| + memset(this->fec_loss_mask_, 0, sizeof(this->fec_loss_mask_));
|
| + this->media_loss_mask_[kNumMediaPackets - 11] = 1;
|
| + this->media_loss_mask_[kNumMediaPackets - 9] = 1;
|
| + this->media_loss_mask_[kNumMediaPackets - 7] = 1;
|
| + this->media_loss_mask_[kNumMediaPackets - 5] = 1;
|
| + this->media_loss_mask_[kNumMediaPackets - 3] = 1;
|
| + this->media_loss_mask_[kNumMediaPackets - 1] = 1;
|
| + this->NetworkReceivedPackets(this->media_loss_mask_, this->fec_loss_mask_);
|
| +
|
| + EXPECT_EQ(0, this->fec_.DecodeFec(&this->received_packets_,
|
| + &this->recovered_packets_));
|
|
|
| // 5 protected packets lost, one FEC packet, cannot get complete recovery.
|
| - EXPECT_FALSE(IsRecoveryComplete());
|
| + EXPECT_FALSE(this->IsRecoveryComplete());
|
| }
|
|
|
| -TEST_F(RtpFecTest, FecRecoveryNonConsecutivePacketsWrap) {
|
| +TYPED_TEST(RtpFecTest, FecRecoveryNonConsecutivePacketsWrap) {
|
| constexpr int kNumImportantPackets = 0;
|
| constexpr bool kUseUnequalProtection = false;
|
| constexpr int kNumMediaPackets = 21;
|
| uint8_t kProtectionFactor = 127;
|
|
|
| - fec_seq_num_ = ConstructMediaPacketsSeqNum(kNumMediaPackets, 0xFFFF - 5);
|
| + this->media_packets_ = this->media_packet_generator_.ConstructMediaPackets(
|
| + kNumMediaPackets, 0xFFFF - 5);
|
|
|
| // Create a new temporary packet list for generating FEC packets.
|
| // This list should have every other packet removed.
|
| - PacketList protected_media_packets;
|
| - DeepCopyEveryNthPacket(media_packet_list_, 2, &protected_media_packets);
|
| + ForwardErrorCorrection::PacketList protected_media_packets;
|
| + DeepCopyEveryNthPacket(this->media_packets_, 2, &protected_media_packets);
|
|
|
| // Zero column insertion will have to extend the size of the packet
|
| // mask since the number of actual packets are 21, while the number
|
| // of protected packets are 11.
|
| - EXPECT_EQ(0, fec_.GenerateFec(protected_media_packets, kProtectionFactor,
|
| - kNumImportantPackets, kUseUnequalProtection,
|
| - webrtc::kFecMaskBursty, &fec_packet_list_));
|
| + EXPECT_EQ(
|
| + 0, this->fec_.EncodeFec(protected_media_packets, kProtectionFactor,
|
| + kNumImportantPackets, kUseUnequalProtection,
|
| + kFecMaskBursty, &this->generated_fec_packets_));
|
|
|
| // Expect 5 FEC packet.
|
| - EXPECT_EQ(5u, fec_packet_list_.size());
|
| + EXPECT_EQ(5u, this->generated_fec_packets_.size());
|
|
|
| // Last protected media packet lost
|
| - memset(media_loss_mask_, 0, sizeof(media_loss_mask_));
|
| - memset(fec_loss_mask_, 0, sizeof(fec_loss_mask_));
|
| - media_loss_mask_[kNumMediaPackets - 1] = 1;
|
| - NetworkReceivedPackets(media_loss_mask_, fec_loss_mask_);
|
| + memset(this->media_loss_mask_, 0, sizeof(this->media_loss_mask_));
|
| + memset(this->fec_loss_mask_, 0, sizeof(this->fec_loss_mask_));
|
| + this->media_loss_mask_[kNumMediaPackets - 1] = 1;
|
| + this->NetworkReceivedPackets(this->media_loss_mask_, this->fec_loss_mask_);
|
|
|
| - EXPECT_EQ(0, fec_.DecodeFec(&received_packet_list_, &recovered_packet_list_));
|
| + EXPECT_EQ(0, this->fec_.DecodeFec(&this->received_packets_,
|
| + &this->recovered_packets_));
|
|
|
| // One packet lost, one FEC packet, expect complete recovery.
|
| - EXPECT_TRUE(IsRecoveryComplete());
|
| - recovered_packet_list_.clear();
|
| + EXPECT_TRUE(this->IsRecoveryComplete());
|
| + this->recovered_packets_.clear();
|
|
|
| // Last unprotected packet lost.
|
| - memset(media_loss_mask_, 0, sizeof(media_loss_mask_));
|
| - memset(fec_loss_mask_, 0, sizeof(fec_loss_mask_));
|
| - media_loss_mask_[kNumMediaPackets - 2] = 1;
|
| - NetworkReceivedPackets(media_loss_mask_, fec_loss_mask_);
|
| + memset(this->media_loss_mask_, 0, sizeof(this->media_loss_mask_));
|
| + memset(this->fec_loss_mask_, 0, sizeof(this->fec_loss_mask_));
|
| + this->media_loss_mask_[kNumMediaPackets - 2] = 1;
|
| + this->NetworkReceivedPackets(this->media_loss_mask_, this->fec_loss_mask_);
|
|
|
| - EXPECT_EQ(0, fec_.DecodeFec(&received_packet_list_, &recovered_packet_list_));
|
| + EXPECT_EQ(0, this->fec_.DecodeFec(&this->received_packets_,
|
| + &this->recovered_packets_));
|
|
|
| // Unprotected packet lost. Recovery not possible.
|
| - EXPECT_FALSE(IsRecoveryComplete());
|
| - recovered_packet_list_.clear();
|
| + EXPECT_FALSE(this->IsRecoveryComplete());
|
| + this->recovered_packets_.clear();
|
|
|
| // 6 media packets lost.
|
| - memset(media_loss_mask_, 0, sizeof(media_loss_mask_));
|
| - memset(fec_loss_mask_, 0, sizeof(fec_loss_mask_));
|
| - media_loss_mask_[kNumMediaPackets - 11] = 1;
|
| - media_loss_mask_[kNumMediaPackets - 9] = 1;
|
| - media_loss_mask_[kNumMediaPackets - 7] = 1;
|
| - media_loss_mask_[kNumMediaPackets - 5] = 1;
|
| - media_loss_mask_[kNumMediaPackets - 3] = 1;
|
| - media_loss_mask_[kNumMediaPackets - 1] = 1;
|
| - NetworkReceivedPackets(media_loss_mask_, fec_loss_mask_);
|
| -
|
| - EXPECT_EQ(0, fec_.DecodeFec(&received_packet_list_, &recovered_packet_list_));
|
| + memset(this->media_loss_mask_, 0, sizeof(this->media_loss_mask_));
|
| + memset(this->fec_loss_mask_, 0, sizeof(this->fec_loss_mask_));
|
| + this->media_loss_mask_[kNumMediaPackets - 11] = 1;
|
| + this->media_loss_mask_[kNumMediaPackets - 9] = 1;
|
| + this->media_loss_mask_[kNumMediaPackets - 7] = 1;
|
| + this->media_loss_mask_[kNumMediaPackets - 5] = 1;
|
| + this->media_loss_mask_[kNumMediaPackets - 3] = 1;
|
| + this->media_loss_mask_[kNumMediaPackets - 1] = 1;
|
| + this->NetworkReceivedPackets(this->media_loss_mask_, this->fec_loss_mask_);
|
| +
|
| + EXPECT_EQ(0, this->fec_.DecodeFec(&this->received_packets_,
|
| + &this->recovered_packets_));
|
|
|
| // 5 protected packets lost, one FEC packet, cannot get complete recovery.
|
| - EXPECT_FALSE(IsRecoveryComplete());
|
| + EXPECT_FALSE(this->IsRecoveryComplete());
|
| }
|
|
|
| -void RtpFecTest::TearDown() {
|
| - fec_.ResetState(&recovered_packet_list_);
|
| - recovered_packet_list_.clear();
|
| - media_packet_list_.clear();
|
| - EXPECT_TRUE(media_packet_list_.empty());
|
| -}
|
| -
|
| -bool RtpFecTest::IsRecoveryComplete() {
|
| +template <typename ForwardErrorCorrectionType>
|
| +bool RtpFecTest<ForwardErrorCorrectionType>::IsRecoveryComplete() {
|
| // We must have equally many recovered packets as original packets.
|
| - if (recovered_packet_list_.size() != media_packet_list_.size()) {
|
| + if (recovered_packets_.size() != media_packets_.size()) {
|
| return false;
|
| }
|
|
|
| @@ -815,21 +884,26 @@ bool RtpFecTest::IsRecoveryComplete() {
|
| }
|
| return true;
|
| };
|
| - return std::equal(media_packet_list_.cbegin(), media_packet_list_.cend(),
|
| - recovered_packet_list_.cbegin(), cmp);
|
| + return std::equal(media_packets_.cbegin(), media_packets_.cend(),
|
| + recovered_packets_.cbegin(), cmp);
|
| }
|
|
|
| -void RtpFecTest::NetworkReceivedPackets(int* media_loss_mask,
|
| - int* fec_loss_mask) {
|
| +template <typename ForwardErrorCorrectionType>
|
| +void RtpFecTest<ForwardErrorCorrectionType>::NetworkReceivedPackets(
|
| + int* media_loss_mask,
|
| + int* fec_loss_mask) {
|
| constexpr bool kFecPacket = true;
|
| - ReceivedPackets(media_packet_list_, media_loss_mask, !kFecPacket);
|
| - ReceivedPackets(fec_packet_list_, fec_loss_mask, kFecPacket);
|
| + ReceivedPackets(media_packets_, media_loss_mask, !kFecPacket);
|
| + ReceivedPackets(generated_fec_packets_, fec_loss_mask, kFecPacket);
|
| }
|
|
|
| -template <typename T>
|
| -void RtpFecTest::ReceivedPackets(const T& packet_list, int* loss_mask,
|
| - bool is_fec) {
|
| - int seq_num = fec_seq_num_;
|
| +template <typename ForwardErrorCorrectionType>
|
| +template <typename PacketListType>
|
| +void RtpFecTest<ForwardErrorCorrectionType>::ReceivedPackets(
|
| + const PacketListType& packet_list,
|
| + int* loss_mask,
|
| + bool is_fec) {
|
| + uint16_t fec_seq_num = media_packet_generator_.GetFecSeqNum();
|
| int packet_idx = 0;
|
|
|
| for (const auto& packet : packet_list) {
|
| @@ -844,91 +918,25 @@ void RtpFecTest::ReceivedPackets(const T& packet_list, int* loss_mask,
|
| // For media packets, the sequence number and marker bit is
|
| // obtained from RTP header. These were set in ConstructMediaPackets().
|
| received_packet->seq_num =
|
| - webrtc::ByteReader<uint16_t>::ReadBigEndian(&packet->data[2]);
|
| + ByteReader<uint16_t>::ReadBigEndian(&packet->data[2]);
|
| } else {
|
| // The sequence number, marker bit, and ssrc number are defined in the
|
| // RTP header of the FEC packet, which is not constructed in this test.
|
| // So we set these values below based on the values generated in
|
| // ConstructMediaPackets().
|
| - received_packet->seq_num = seq_num;
|
| + received_packet->seq_num = fec_seq_num;
|
| // The ssrc value for FEC packets is set to the one used for the
|
| // media packets in ConstructMediaPackets().
|
| - received_packet->ssrc = ssrc_;
|
| + received_packet->ssrc = kMediaSsrc;
|
| }
|
| - received_packet_list_.push_back(std::move(received_packet));
|
| + received_packets_.push_back(std::move(received_packet));
|
| }
|
| packet_idx++;
|
| // Sequence number of FEC packets are defined as increment by 1 from
|
| // last media packet in frame.
|
| - if (is_fec) seq_num++;
|
| - }
|
| -}
|
| -
|
| -int RtpFecTest::ConstructMediaPacketsSeqNum(int num_media_packets,
|
| - int start_seq_num) {
|
| - RTC_DCHECK_GT(num_media_packets, 0);
|
| - int sequence_number = start_seq_num;
|
| - int time_stamp = random_.Rand<int>();
|
| -
|
| - for (int i = 0; i < num_media_packets; ++i) {
|
| - std::unique_ptr<ForwardErrorCorrection::Packet> media_packet(
|
| - new ForwardErrorCorrection::Packet());
|
| - constexpr uint32_t kMinPacketSize = kRtpHeaderSize;
|
| - const uint32_t kMaxPacketSize = IP_PACKET_SIZE - kRtpHeaderSize -
|
| - kTransportOverhead -
|
| - fec_.MaxPacketOverhead();
|
| - media_packet->length = random_.Rand(kMinPacketSize, kMaxPacketSize);
|
| -
|
| - // Generate random values for the first 2 bytes
|
| - media_packet->data[0] = random_.Rand<uint8_t>();
|
| - media_packet->data[1] = random_.Rand<uint8_t>();
|
| -
|
| - // The first two bits are assumed to be 10 by the FEC encoder.
|
| - // In fact the FEC decoder will set the two first bits to 10 regardless of
|
| - // what they actually were. Set the first two bits to 10 so that a memcmp
|
| - // can be performed for the whole restored packet.
|
| - media_packet->data[0] |= 0x80;
|
| - media_packet->data[0] &= 0xbf;
|
| -
|
| - // FEC is applied to a whole frame.
|
| - // A frame is signaled by multiple packets without the marker bit set
|
| - // followed by the last packet of the frame for which the marker bit is set.
|
| - // Only push one (fake) frame to the FEC.
|
| - media_packet->data[1] &= 0x7f;
|
| -
|
| - webrtc::ByteWriter<uint16_t>::WriteBigEndian(&media_packet->data[2],
|
| - sequence_number);
|
| - webrtc::ByteWriter<uint32_t>::WriteBigEndian(&media_packet->data[4],
|
| - time_stamp);
|
| - webrtc::ByteWriter<uint32_t>::WriteBigEndian(&media_packet->data[8], ssrc_);
|
| -
|
| - // Generate random values for payload.
|
| - for (size_t j = 12; j < media_packet->length; ++j) {
|
| - media_packet->data[j] = random_.Rand<uint8_t>();
|
| - }
|
| - sequence_number++;
|
| - media_packet_list_.push_back(std::move(media_packet));
|
| + if (is_fec)
|
| + fec_seq_num++;
|
| }
|
| - // Last packet, set marker bit.
|
| - ForwardErrorCorrection::Packet* media_packet =
|
| - media_packet_list_.back().get();
|
| - RTC_DCHECK(media_packet);
|
| - media_packet->data[1] |= 0x80;
|
| - return sequence_number;
|
| -}
|
| -
|
| -int RtpFecTest::ConstructMediaPackets(int num_media_packets) {
|
| - return ConstructMediaPacketsSeqNum(num_media_packets, random_.Rand<int>());
|
| }
|
|
|
| -void RtpFecTest::DeepCopyEveryNthPacket(const PacketList& src, int n,
|
| - PacketList* dst) {
|
| - RTC_DCHECK_GT(n, 0);
|
| - int i = 0;
|
| - for (const auto& packet : src) {
|
| - if (i % n == 0) {
|
| - dst->emplace_back(new ForwardErrorCorrection::Packet(*packet));
|
| - }
|
| - ++i;
|
| - }
|
| -}
|
| +} // namespace webrtc
|
|
|