OLD | NEW |
---|---|
1 /* | 1 /* |
2 * Copyright (c) 2016 The WebRTC project authors. All Rights Reserved. | 2 * Copyright (c) 2016 The WebRTC project authors. All Rights Reserved. |
3 * | 3 * |
4 * Use of this source code is governed by a BSD-style license | 4 * Use of this source code is governed by a BSD-style license |
5 * that can be found in the LICENSE file in the root of the source | 5 * that can be found in the LICENSE file in the root of the source |
6 * tree. An additional intellectual property rights grant can be found | 6 * tree. An additional intellectual property rights grant can be found |
7 * in the file PATENTS. All contributing project authors may | 7 * in the file PATENTS. All contributing project authors may |
8 * be found in the AUTHORS file in the root of the source tree. | 8 * be found in the AUTHORS file in the root of the source tree. |
9 */ | 9 */ |
10 | 10 |
11 #include "webrtc/modules/rtp_rtcp/source/rtcp_packet/remb.h" | 11 #include "webrtc/modules/rtp_rtcp/source/rtcp_packet/remb.h" |
12 | 12 |
13 #include "testing/gmock/include/gmock/gmock.h" | 13 #include "testing/gmock/include/gmock/gmock.h" |
14 #include "testing/gtest/include/gtest/gtest.h" | 14 #include "testing/gtest/include/gtest/gtest.h" |
15 #include "webrtc/test/rtcp_packet_parser.h" | |
16 | 15 |
16 using testing::ElementsAreArray; | |
17 using testing::make_tuple; | |
17 using webrtc::rtcp::RawPacket; | 18 using webrtc::rtcp::RawPacket; |
18 using webrtc::rtcp::Remb; | 19 using webrtc::rtcp::Remb; |
19 using webrtc::test::RtcpPacketParser; | 20 using webrtc::RTCPUtility::RtcpCommonHeader; |
21 using webrtc::RTCPUtility::RtcpParseCommonHeader; | |
20 | 22 |
21 namespace webrtc { | 23 namespace webrtc { |
24 namespace { | |
22 | 25 |
23 const uint32_t kSenderSsrc = 0x12345678; | 26 const uint32_t kSenderSsrc = 0x12345678; |
24 const uint32_t kRemoteSsrc = 0x23456789; | |
25 | 27 |
26 TEST(RtcpPacketRembTest, Remb) { | 28 const uint32_t kRemoteSsrc[] = {0x23456789, 0x2345678a, 0x2345678b}; |
åsapersson
2016/01/20 15:33:13
s/kRemoteSsrc/kRemoteSsrcs
danilchap
2016/01/20 16:13:19
Done.
| |
29 const uint32_t kBitrate = 0x3fb93 * 2; // 522022; | |
30 const uint8_t kPacket[] = {0x8f, 206, 0x00, 0x07, 0x12, 0x34, 0x56, 0x78, | |
31 0x00, 0x00, 0x00, 0x00, 'R', 'E', 'M', 'B', | |
32 0x03, 0x07, 0xfb, 0x93, 0x23, 0x45, 0x67, 0x89, | |
33 0x23, 0x45, 0x67, 0x8a, 0x23, 0x45, 0x67, 0x8b}; | |
34 const size_t kPacketLength = sizeof(kPacket); | |
35 | |
36 bool ParseRemb(const uint8_t* buffer, size_t length, Remb* remb) { | |
37 RtcpCommonHeader header; | |
38 EXPECT_TRUE(RtcpParseCommonHeader(buffer, length, &header)); | |
39 EXPECT_EQ(length, header.BlockSize()); | |
40 return remb->Parse(header, buffer + RtcpCommonHeader::kHeaderSizeBytes); | |
41 } | |
42 | |
43 TEST(RtcpPacketRembTest, Create) { | |
27 Remb remb; | 44 Remb remb; |
28 remb.From(kSenderSsrc); | 45 remb.From(kSenderSsrc); |
29 remb.AppliesTo(kRemoteSsrc); | 46 remb.AppliesTo(kRemoteSsrc[0]); |
30 remb.AppliesTo(kRemoteSsrc + 1); | 47 remb.AppliesTo(kRemoteSsrc[1]); |
31 remb.AppliesTo(kRemoteSsrc + 2); | 48 remb.AppliesTo(kRemoteSsrc[2]); |
32 remb.WithBitrateBps(261011); | 49 remb.WithBitrateBps(kBitrate); |
33 | 50 |
34 rtc::scoped_ptr<RawPacket> packet(remb.Build()); | 51 rtc::scoped_ptr<RawPacket> packet(remb.Build()); |
35 RtcpPacketParser parser; | 52 |
36 parser.Parse(packet->Buffer(), packet->Length()); | 53 EXPECT_THAT(make_tuple(packet->Buffer(), packet->Length()), |
37 EXPECT_EQ(1, parser.psfb_app()->num_packets()); | 54 ElementsAreArray(kPacket)); |
38 EXPECT_EQ(kSenderSsrc, parser.psfb_app()->Ssrc()); | |
39 EXPECT_EQ(1, parser.remb_item()->num_packets()); | |
40 EXPECT_EQ(261011, parser.remb_item()->last_bitrate_bps()); | |
41 std::vector<uint32_t> ssrcs = parser.remb_item()->last_ssrc_list(); | |
42 EXPECT_EQ(kRemoteSsrc, ssrcs[0]); | |
43 EXPECT_EQ(kRemoteSsrc + 1, ssrcs[1]); | |
44 EXPECT_EQ(kRemoteSsrc + 2, ssrcs[2]); | |
45 } | 55 } |
56 | |
57 TEST(RtcpPacketRembTest, Parse) { | |
58 Remb remb; | |
59 EXPECT_TRUE(ParseRemb(kPacket, kPacketLength, &remb)); | |
60 const Remb& parsed = remb; | |
61 | |
62 EXPECT_EQ(kSenderSsrc, parsed.sender_ssrc()); | |
63 EXPECT_EQ(kBitrate, parsed.bitrate_bps()); | |
64 EXPECT_THAT(parsed.ssrcs(), ElementsAreArray(kRemoteSsrc)); | |
65 } | |
66 | |
67 TEST(RtcpPacketRembTest, CreateAndParseEmpty) { | |
åsapersson
2016/01/20 15:33:13
maybe CreateAndParseWithSsrcCountZero or similar
danilchap
2016/01/20 16:13:19
Done.
| |
68 const uint32_t kBitrate = 500000; | |
69 Remb remb; | |
70 remb.From(kSenderSsrc); | |
71 remb.WithBitrateBps(kBitrate); | |
72 rtc::scoped_ptr<RawPacket> packet(remb.Build()); | |
73 | |
74 Remb parsed; | |
75 EXPECT_TRUE(ParseRemb(packet->Buffer(), packet->Length(), &parsed)); | |
76 EXPECT_EQ(kSenderSsrc, parsed.sender_ssrc()); | |
77 EXPECT_EQ(kBitrate, parsed.bitrate_bps()); | |
åsapersson
2016/01/20 15:33:13
check parsed.ssrcs() empty
danilchap
2016/01/20 16:13:19
Done.
| |
78 } | |
79 | |
80 TEST(RtcpPacketRembTest, ParseFailsOnNonRembSmall) { | |
åsapersson
2016/01/20 15:33:13
maybe ParseFailsOnTooSmallPacket
danilchap
2016/01/20 16:13:19
Done.
| |
81 uint8_t packet[kPacketLength]; | |
82 memcpy(packet, kPacket, kPacketLength); | |
83 packet[3] = 3; // Make it too small. | |
84 | |
85 Remb remb; | |
86 EXPECT_FALSE(ParseRemb(packet, (1 + 3) * 4, &remb)); | |
87 } | |
88 | |
89 TEST(RtcpPacketRembTest, ParseFailsOnNonRembSignature) { | |
90 uint8_t packet[kPacketLength]; | |
91 memcpy(packet, kPacket, kPacketLength); | |
92 packet[12] = 'N'; // Swap 'R' -> 'N' in the 'REMB' signature. | |
93 | |
94 Remb remb; | |
95 EXPECT_FALSE(ParseRemb(packet, kPacketLength, &remb)); | |
96 } | |
97 | |
98 TEST(RtcpPacketRembTest, ParseFailsWhenSsrcCountMismatchLength) { | |
99 uint8_t packet[kPacketLength]; | |
100 memcpy(packet, kPacket, kPacketLength); | |
101 packet[16]++; // Swap 3 -> 4 in the ssrcs count. | |
102 | |
103 Remb remb; | |
104 EXPECT_FALSE(ParseRemb(packet, kPacketLength, &remb)); | |
105 } | |
106 | |
107 TEST(RtcpPacketRembTest, TooManySsrcs) { | |
108 const size_t kMax = 0xff; | |
109 Remb remb; | |
110 for (size_t i = 1; i <= kMax; ++i) | |
111 EXPECT_TRUE(remb.AppliesTo(kRemoteSsrc[0] + i)); | |
112 EXPECT_FALSE(remb.AppliesTo(kRemoteSsrc[0])); | |
113 } | |
114 | |
115 TEST(RtcpPacketRembTest, TooManyForBatchAssign) { | |
116 const size_t kMax = 0xff; | |
117 Remb remb; | |
åsapersson
2016/01/20 15:33:13
maybe define kRemoteSsrc and use same in test
danilchap
2016/01/20 16:13:19
Done.
| |
118 | |
119 std::vector<uint32_t> AlmostAll(kMax - 1, kRemoteSsrc[0]); | |
åsapersson
2016/01/20 15:33:13
s/AlmostAll/almostAll
call allButOneSsrc?
check
danilchap
2016/01/20 16:13:19
Done.
| |
120 EXPECT_TRUE(remb.AppliesToMany(AlmostAll)); | |
121 // Should be no place for 2 more. | |
122 std::vector<uint32_t> TwoMoreSsrcs(2, kRemoteSsrc[1]); | |
åsapersson
2016/01/20 15:33:13
s/TwoMoreSsrcs/twoMoreSsrcs
danilchap
2016/01/20 16:13:19
Done: handled same way as kAllButOneSsrc
| |
123 EXPECT_FALSE(remb.AppliesToMany(TwoMoreSsrcs)); | |
124 // But enough place for 1 more. | |
125 EXPECT_TRUE(remb.AppliesTo(kRemoteSsrc[2])); | |
126 // But not for another one. | |
127 EXPECT_FALSE(remb.AppliesTo(kRemoteSsrc[2] + 1)); | |
128 } | |
129 | |
130 } // namespace | |
46 } // namespace webrtc | 131 } // namespace webrtc |
OLD | NEW |