Index: webrtc/modules/rtp_rtcp/source/rtp_payload_registry_unittest.cc |
diff --git a/webrtc/modules/rtp_rtcp/source/rtp_payload_registry_unittest.cc b/webrtc/modules/rtp_rtcp/source/rtp_payload_registry_unittest.cc |
index 6e17eb9acaf60ddcb6becdd43c393a547f10a1fe..f5707d226cde96cfec6357f967e5c3ddb3097e06 100644 |
--- a/webrtc/modules/rtp_rtcp/source/rtp_payload_registry_unittest.cc |
+++ b/webrtc/modules/rtp_rtcp/source/rtp_payload_registry_unittest.cc |
@@ -13,6 +13,7 @@ |
#include "webrtc/common_types.h" |
#include "webrtc/modules/rtp_rtcp/include/rtp_header_parser.h" |
#include "webrtc/modules/rtp_rtcp/include/rtp_payload_registry.h" |
+#include "webrtc/modules/rtp_rtcp/source/byte_io.h" |
#include "webrtc/modules/rtp_rtcp/source/rtp_utility.h" |
#include "webrtc/test/gmock.h" |
#include "webrtc/test/gtest.h" |
@@ -258,6 +259,105 @@ |
rtp_payload_registry.RegisterReceivePayload(audio_codec, &ignored)); |
} |
+// Generates an RTX packet for the given length and original sequence number. |
+// The RTX sequence number and ssrc will use the default value of 9999. The |
+// caller takes ownership of the returned buffer. |
+const uint8_t* GenerateRtxPacket(size_t header_length, |
+ size_t payload_length, |
+ uint16_t original_sequence_number) { |
+ uint8_t* packet = |
+ new uint8_t[kRtxHeaderSize + header_length + payload_length](); |
+ // Write the RTP version to the first byte, so the resulting header can be |
+ // parsed. |
+ static const int kRtpExpectedVersion = 2; |
+ packet[0] = static_cast<uint8_t>(kRtpExpectedVersion << 6); |
+ // Write a junk sequence number. It should be thrown away when the packet is |
+ // restored. |
+ ByteWriter<uint16_t>::WriteBigEndian(packet + 2, 9999); |
+ // Write a junk ssrc. It should also be thrown away when the packet is |
+ // restored. |
+ ByteWriter<uint32_t>::WriteBigEndian(packet + 8, 9999); |
+ |
+ // Now write the RTX header. It occurs at the start of the payload block, and |
+ // contains just the sequence number. |
+ ByteWriter<uint16_t>::WriteBigEndian(packet + header_length, |
+ original_sequence_number); |
+ return packet; |
+} |
+ |
+void TestRtxPacket(RTPPayloadRegistry* rtp_payload_registry, |
+ int rtx_payload_type, |
+ int expected_payload_type, |
+ bool should_succeed) { |
+ size_t header_length = 100; |
+ size_t payload_length = 200; |
+ size_t original_length = header_length + payload_length + kRtxHeaderSize; |
+ |
+ RTPHeader header; |
+ header.ssrc = 1000; |
+ header.sequenceNumber = 100; |
+ header.payloadType = rtx_payload_type; |
+ header.headerLength = header_length; |
+ |
+ uint16_t original_sequence_number = 1234; |
+ uint32_t original_ssrc = 500; |
+ |
+ std::unique_ptr<const uint8_t[]> packet(GenerateRtxPacket( |
+ header_length, payload_length, original_sequence_number)); |
+ std::unique_ptr<uint8_t[]> restored_packet( |
+ new uint8_t[header_length + payload_length]); |
+ size_t length = original_length; |
+ bool success = rtp_payload_registry->RestoreOriginalPacket( |
+ restored_packet.get(), packet.get(), &length, original_ssrc, header); |
+ EXPECT_EQ(should_succeed, success) |
+ << "Test success should match should_succeed."; |
+ if (!success) { |
+ return; |
+ } |
+ |
+ EXPECT_EQ(original_length - kRtxHeaderSize, length) |
+ << "The restored packet should be exactly kRtxHeaderSize smaller."; |
+ |
+ std::unique_ptr<RtpHeaderParser> header_parser(RtpHeaderParser::Create()); |
+ RTPHeader restored_header; |
+ ASSERT_TRUE( |
+ header_parser->Parse(restored_packet.get(), length, &restored_header)); |
+ EXPECT_EQ(original_sequence_number, restored_header.sequenceNumber) |
+ << "The restored packet should have the original sequence number " |
+ << "in the correct location in the RTP header."; |
+ EXPECT_EQ(expected_payload_type, restored_header.payloadType) |
+ << "The restored packet should have the correct payload type."; |
+ EXPECT_EQ(original_ssrc, restored_header.ssrc) |
+ << "The restored packet should have the correct ssrc."; |
+} |
+ |
+TEST(RtpPayloadRegistryTest, MultipleRtxPayloadTypes) { |
+ RTPPayloadRegistry rtp_payload_registry; |
+ // Set the incoming payload type to 90. |
+ RTPHeader header; |
+ header.payloadType = 90; |
+ header.ssrc = 1; |
+ rtp_payload_registry.SetIncomingPayloadType(header); |
+ rtp_payload_registry.SetRtxSsrc(100); |
+ // Map two RTX payload types. |
+ rtp_payload_registry.SetRtxPayloadType(105, 95); |
+ rtp_payload_registry.SetRtxPayloadType(106, 96); |
+ |
+ TestRtxPacket(&rtp_payload_registry, 105, 95, true); |
+ TestRtxPacket(&rtp_payload_registry, 106, 96, true); |
+} |
+ |
+TEST(RtpPayloadRegistryTest, InvalidRtxConfiguration) { |
+ RTPPayloadRegistry rtp_payload_registry; |
+ rtp_payload_registry.SetRtxSsrc(100); |
+ // Fails because no mappings exist and the incoming payload type isn't known. |
+ TestRtxPacket(&rtp_payload_registry, 105, 0, false); |
+ // Succeeds when the mapping is used, but fails for the implicit fallback. |
+ rtp_payload_registry.SetRtxPayloadType(105, 95); |
+ TestRtxPacket(&rtp_payload_registry, 105, 95, true); |
+ TestRtxPacket(&rtp_payload_registry, 106, 0, false); |
+} |
+ |
INSTANTIATE_TEST_CASE_P(TestDynamicRange, |
RtpPayloadRegistryGenericTest, |
testing::Range(96, 127 + 1)); |