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.SetSenderSsrc(kSenderSsrc); | 37 remb.From(kSenderSsrc); |
38 remb.SetSsrcs( | 38 remb.AppliesTo(kRemoteSsrcs[0]); |
39 std::vector<uint32_t>(std::begin(kRemoteSsrcs), std::end(kRemoteSsrcs))); | 39 remb.AppliesTo(kRemoteSsrcs[1]); |
40 remb.SetBitrateBps(kBitrateBps); | 40 remb.AppliesTo(kRemoteSsrcs[2]); |
| 41 remb.WithBitrateBps(kBitrateBps); |
41 | 42 |
42 rtc::Buffer packet = remb.Build(); | 43 rtc::Buffer packet = remb.Build(); |
43 | 44 |
44 EXPECT_THAT(make_tuple(packet.data(), packet.size()), | 45 EXPECT_THAT(make_tuple(packet.data(), packet.size()), |
45 ElementsAreArray(kPacket)); | 46 ElementsAreArray(kPacket)); |
46 } | 47 } |
47 | 48 |
48 TEST(RtcpPacketRembTest, Parse) { | 49 TEST(RtcpPacketRembTest, Parse) { |
49 Remb remb; | 50 Remb remb; |
50 EXPECT_TRUE(test::ParseSinglePacket(kPacket, &remb)); | 51 EXPECT_TRUE(test::ParseSinglePacket(kPacket, &remb)); |
51 const Remb& parsed = remb; | 52 const Remb& parsed = remb; |
52 | 53 |
53 EXPECT_EQ(kSenderSsrc, parsed.sender_ssrc()); | 54 EXPECT_EQ(kSenderSsrc, parsed.sender_ssrc()); |
54 EXPECT_EQ(kBitrateBps, parsed.bitrate_bps()); | 55 EXPECT_EQ(kBitrateBps, parsed.bitrate_bps()); |
55 EXPECT_THAT(parsed.ssrcs(), ElementsAreArray(kRemoteSsrcs)); | 56 EXPECT_THAT(parsed.ssrcs(), ElementsAreArray(kRemoteSsrcs)); |
56 } | 57 } |
57 | 58 |
58 TEST(RtcpPacketRembTest, CreateAndParseWithoutSsrcs) { | 59 TEST(RtcpPacketRembTest, CreateAndParseWithoutSsrcs) { |
59 Remb remb; | 60 Remb remb; |
60 remb.SetSenderSsrc(kSenderSsrc); | 61 remb.From(kSenderSsrc); |
61 remb.SetBitrateBps(kBitrateBps); | 62 remb.WithBitrateBps(kBitrateBps); |
62 rtc::Buffer packet = remb.Build(); | 63 rtc::Buffer packet = remb.Build(); |
63 | 64 |
64 Remb parsed; | 65 Remb parsed; |
65 EXPECT_TRUE(test::ParseSinglePacket(packet, &parsed)); | 66 EXPECT_TRUE(test::ParseSinglePacket(packet, &parsed)); |
66 EXPECT_EQ(kSenderSsrc, parsed.sender_ssrc()); | 67 EXPECT_EQ(kSenderSsrc, parsed.sender_ssrc()); |
67 EXPECT_EQ(kBitrateBps, parsed.bitrate_bps()); | 68 EXPECT_EQ(kBitrateBps, parsed.bitrate_bps()); |
68 EXPECT_THAT(parsed.ssrcs(), IsEmpty()); | 69 EXPECT_THAT(parsed.ssrcs(), IsEmpty()); |
69 } | 70 } |
70 | 71 |
71 TEST(RtcpPacketRembTest, CreateAndParse64bitBitrate) { | 72 TEST(RtcpPacketRembTest, CreateAndParse64bitBitrate) { |
72 Remb remb; | 73 Remb remb; |
73 remb.SetBitrateBps(kBitrateBps64bit); | 74 remb.WithBitrateBps(kBitrateBps64bit); |
74 rtc::Buffer packet = remb.Build(); | 75 rtc::Buffer packet = remb.Build(); |
75 | 76 |
76 Remb parsed; | 77 Remb parsed; |
77 EXPECT_TRUE(test::ParseSinglePacket(packet, &parsed)); | 78 EXPECT_TRUE(test::ParseSinglePacket(packet, &parsed)); |
78 EXPECT_EQ(kBitrateBps64bit, parsed.bitrate_bps()); | 79 EXPECT_EQ(kBitrateBps64bit, parsed.bitrate_bps()); |
79 } | 80 } |
80 | 81 |
81 TEST(RtcpPacketRembTest, ParseFailsOnTooSmallPacketToBeRemb) { | 82 TEST(RtcpPacketRembTest, ParseFailsOnTooSmallPacketToBeRemb) { |
82 // Make it too small. | 83 // Make it too small. |
83 constexpr size_t kTooSmallSize = (1 + 3) * 4; | 84 constexpr size_t kTooSmallSize = (1 + 3) * 4; |
(...skipping 27 matching lines...) Expand all Loading... |
111 TEST(RtcpPacketRembTest, ParseFailsWhenSsrcCountMismatchLength) { | 112 TEST(RtcpPacketRembTest, ParseFailsWhenSsrcCountMismatchLength) { |
112 uint8_t packet[kPacketLength]; | 113 uint8_t packet[kPacketLength]; |
113 memcpy(packet, kPacket, kPacketLength); | 114 memcpy(packet, kPacket, kPacketLength); |
114 packet[16]++; // Swap 3 -> 4 in the ssrcs count. | 115 packet[16]++; // Swap 3 -> 4 in the ssrcs count. |
115 | 116 |
116 Remb remb; | 117 Remb remb; |
117 EXPECT_FALSE(test::ParseSinglePacket(packet, &remb)); | 118 EXPECT_FALSE(test::ParseSinglePacket(packet, &remb)); |
118 } | 119 } |
119 | 120 |
120 TEST(RtcpPacketRembTest, TooManySsrcs) { | 121 TEST(RtcpPacketRembTest, TooManySsrcs) { |
| 122 const size_t kMax = 0xff; |
121 Remb remb; | 123 Remb remb; |
122 EXPECT_FALSE(remb.SetSsrcs( | 124 for (size_t i = 1; i <= kMax; ++i) |
123 std::vector<uint32_t>(Remb::kMaxNumberOfSsrcs + 1, kRemoteSsrcs[0]))); | 125 EXPECT_TRUE(remb.AppliesTo(kRemoteSsrcs[0] + i)); |
124 EXPECT_TRUE(remb.SetSsrcs( | 126 EXPECT_FALSE(remb.AppliesTo(kRemoteSsrcs[0])); |
125 std::vector<uint32_t>(Remb::kMaxNumberOfSsrcs, kRemoteSsrcs[0]))); | 127 } |
| 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)); |
126 } | 143 } |
127 | 144 |
128 } // namespace webrtc | 145 } // namespace webrtc |
OLD | NEW |