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 |
(...skipping 16 matching lines...) Expand all Loading... |
27 const uint64_t kBitrateBps64bit = 0x3fb93ULL << 30; | 27 const uint64_t kBitrateBps64bit = 0x3fb93ULL << 30; |
28 const uint8_t kPacket[] = {0x8f, 206, 0x00, 0x07, 0x12, 0x34, 0x56, 0x78, | 28 const uint8_t kPacket[] = {0x8f, 206, 0x00, 0x07, 0x12, 0x34, 0x56, 0x78, |
29 0x00, 0x00, 0x00, 0x00, 'R', 'E', 'M', 'B', | 29 0x00, 0x00, 0x00, 0x00, 'R', 'E', 'M', 'B', |
30 0x03, 0x07, 0xfb, 0x93, 0x23, 0x45, 0x67, 0x89, | 30 0x03, 0x07, 0xfb, 0x93, 0x23, 0x45, 0x67, 0x89, |
31 0x23, 0x45, 0x67, 0x8a, 0x23, 0x45, 0x67, 0x8b}; | 31 0x23, 0x45, 0x67, 0x8a, 0x23, 0x45, 0x67, 0x8b}; |
32 const size_t kPacketLength = sizeof(kPacket); | 32 const size_t kPacketLength = sizeof(kPacket); |
33 } // namespace | 33 } // namespace |
34 | 34 |
35 TEST(RtcpPacketRembTest, Create) { | 35 TEST(RtcpPacketRembTest, Create) { |
36 Remb remb; | 36 Remb remb; |
37 remb.From(kSenderSsrc); | 37 remb.SetSenderSsrc(kSenderSsrc); |
38 remb.AppliesTo(kRemoteSsrcs[0]); | 38 remb.SetSsrcs( |
39 remb.AppliesTo(kRemoteSsrcs[1]); | 39 std::vector<uint32_t>(std::begin(kRemoteSsrcs), std::end(kRemoteSsrcs))); |
40 remb.AppliesTo(kRemoteSsrcs[2]); | 40 remb.SetBitrateBps(kBitrateBps); |
41 remb.WithBitrateBps(kBitrateBps); | |
42 | 41 |
43 rtc::Buffer packet = remb.Build(); | 42 rtc::Buffer packet = remb.Build(); |
44 | 43 |
45 EXPECT_THAT(make_tuple(packet.data(), packet.size()), | 44 EXPECT_THAT(make_tuple(packet.data(), packet.size()), |
46 ElementsAreArray(kPacket)); | 45 ElementsAreArray(kPacket)); |
47 } | 46 } |
48 | 47 |
49 TEST(RtcpPacketRembTest, Parse) { | 48 TEST(RtcpPacketRembTest, Parse) { |
50 Remb remb; | 49 Remb remb; |
51 EXPECT_TRUE(test::ParseSinglePacket(kPacket, &remb)); | 50 EXPECT_TRUE(test::ParseSinglePacket(kPacket, &remb)); |
52 const Remb& parsed = remb; | 51 const Remb& parsed = remb; |
53 | 52 |
54 EXPECT_EQ(kSenderSsrc, parsed.sender_ssrc()); | 53 EXPECT_EQ(kSenderSsrc, parsed.sender_ssrc()); |
55 EXPECT_EQ(kBitrateBps, parsed.bitrate_bps()); | 54 EXPECT_EQ(kBitrateBps, parsed.bitrate_bps()); |
56 EXPECT_THAT(parsed.ssrcs(), ElementsAreArray(kRemoteSsrcs)); | 55 EXPECT_THAT(parsed.ssrcs(), ElementsAreArray(kRemoteSsrcs)); |
57 } | 56 } |
58 | 57 |
59 TEST(RtcpPacketRembTest, CreateAndParseWithoutSsrcs) { | 58 TEST(RtcpPacketRembTest, CreateAndParseWithoutSsrcs) { |
60 Remb remb; | 59 Remb remb; |
61 remb.From(kSenderSsrc); | 60 remb.SetSenderSsrc(kSenderSsrc); |
62 remb.WithBitrateBps(kBitrateBps); | 61 remb.SetBitrateBps(kBitrateBps); |
63 rtc::Buffer packet = remb.Build(); | 62 rtc::Buffer packet = remb.Build(); |
64 | 63 |
65 Remb parsed; | 64 Remb parsed; |
66 EXPECT_TRUE(test::ParseSinglePacket(packet, &parsed)); | 65 EXPECT_TRUE(test::ParseSinglePacket(packet, &parsed)); |
67 EXPECT_EQ(kSenderSsrc, parsed.sender_ssrc()); | 66 EXPECT_EQ(kSenderSsrc, parsed.sender_ssrc()); |
68 EXPECT_EQ(kBitrateBps, parsed.bitrate_bps()); | 67 EXPECT_EQ(kBitrateBps, parsed.bitrate_bps()); |
69 EXPECT_THAT(parsed.ssrcs(), IsEmpty()); | 68 EXPECT_THAT(parsed.ssrcs(), IsEmpty()); |
70 } | 69 } |
71 | 70 |
72 TEST(RtcpPacketRembTest, CreateAndParse64bitBitrate) { | 71 TEST(RtcpPacketRembTest, CreateAndParse64bitBitrate) { |
73 Remb remb; | 72 Remb remb; |
74 remb.WithBitrateBps(kBitrateBps64bit); | 73 remb.SetBitrateBps(kBitrateBps64bit); |
75 rtc::Buffer packet = remb.Build(); | 74 rtc::Buffer packet = remb.Build(); |
76 | 75 |
77 Remb parsed; | 76 Remb parsed; |
78 EXPECT_TRUE(test::ParseSinglePacket(packet, &parsed)); | 77 EXPECT_TRUE(test::ParseSinglePacket(packet, &parsed)); |
79 EXPECT_EQ(kBitrateBps64bit, parsed.bitrate_bps()); | 78 EXPECT_EQ(kBitrateBps64bit, parsed.bitrate_bps()); |
80 } | 79 } |
81 | 80 |
82 TEST(RtcpPacketRembTest, ParseFailsOnTooSmallPacketToBeRemb) { | 81 TEST(RtcpPacketRembTest, ParseFailsOnTooSmallPacketToBeRemb) { |
83 // Make it too small. | 82 // Make it too small. |
84 constexpr size_t kTooSmallSize = (1 + 3) * 4; | 83 constexpr size_t kTooSmallSize = (1 + 3) * 4; |
(...skipping 27 matching lines...) Expand all Loading... |
112 TEST(RtcpPacketRembTest, ParseFailsWhenSsrcCountMismatchLength) { | 111 TEST(RtcpPacketRembTest, ParseFailsWhenSsrcCountMismatchLength) { |
113 uint8_t packet[kPacketLength]; | 112 uint8_t packet[kPacketLength]; |
114 memcpy(packet, kPacket, kPacketLength); | 113 memcpy(packet, kPacket, kPacketLength); |
115 packet[16]++; // Swap 3 -> 4 in the ssrcs count. | 114 packet[16]++; // Swap 3 -> 4 in the ssrcs count. |
116 | 115 |
117 Remb remb; | 116 Remb remb; |
118 EXPECT_FALSE(test::ParseSinglePacket(packet, &remb)); | 117 EXPECT_FALSE(test::ParseSinglePacket(packet, &remb)); |
119 } | 118 } |
120 | 119 |
121 TEST(RtcpPacketRembTest, TooManySsrcs) { | 120 TEST(RtcpPacketRembTest, TooManySsrcs) { |
122 const size_t kMax = 0xff; | |
123 Remb remb; | 121 Remb remb; |
124 for (size_t i = 1; i <= kMax; ++i) | 122 EXPECT_FALSE(remb.SetSsrcs( |
125 EXPECT_TRUE(remb.AppliesTo(kRemoteSsrcs[0] + i)); | 123 std::vector<uint32_t>(Remb::kMaxNumberOfSsrcs + 1, kRemoteSsrcs[0]))); |
126 EXPECT_FALSE(remb.AppliesTo(kRemoteSsrcs[0])); | 124 EXPECT_TRUE(remb.SetSsrcs( |
127 } | 125 std::vector<uint32_t>(Remb::kMaxNumberOfSsrcs, kRemoteSsrcs[0]))); |
128 | |
129 TEST(RtcpPacketRembTest, TooManySsrcsForBatchAssign) { | |
130 const uint32_t kRemoteSsrc = kRemoteSsrcs[0]; | |
131 const size_t kMax = 0xff; | |
132 const std::vector<uint32_t> kAllButOneSsrc(kMax - 1, kRemoteSsrc); | |
133 const std::vector<uint32_t> kTwoSsrcs(2, kRemoteSsrc); | |
134 | |
135 Remb remb; | |
136 EXPECT_TRUE(remb.AppliesToMany(kAllButOneSsrc)); | |
137 // Should be no place for 2 more. | |
138 EXPECT_FALSE(remb.AppliesToMany(kTwoSsrcs)); | |
139 // But enough place for 1 more. | |
140 EXPECT_TRUE(remb.AppliesTo(kRemoteSsrc)); | |
141 // But not for another one. | |
142 EXPECT_FALSE(remb.AppliesTo(kRemoteSsrc)); | |
143 } | 126 } |
144 | 127 |
145 } // namespace webrtc | 128 } // namespace webrtc |
OLD | NEW |