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/base/array_view.h" |
11 #include "webrtc/base/basictypes.h" | 12 #include "webrtc/base/basictypes.h" |
12 #include "webrtc/call/flexfec_receive_stream_impl.h" | 13 #include "webrtc/call/flexfec_receive_stream_impl.h" |
13 #include "webrtc/modules/rtp_rtcp/include/flexfec_receiver.h" | 14 #include "webrtc/modules/rtp_rtcp/include/flexfec_receiver.h" |
14 #include "webrtc/modules/rtp_rtcp/source/byte_io.h" | 15 #include "webrtc/modules/rtp_rtcp/source/byte_io.h" |
| 16 #include "webrtc/modules/rtp_rtcp/source/rtp_packet_received.h" |
15 #include "webrtc/modules/rtp_rtcp/mocks/mock_recovered_packet_receiver.h" | 17 #include "webrtc/modules/rtp_rtcp/mocks/mock_recovered_packet_receiver.h" |
16 #include "webrtc/test/gmock.h" | 18 #include "webrtc/test/gmock.h" |
17 #include "webrtc/test/gtest.h" | 19 #include "webrtc/test/gtest.h" |
18 | 20 |
19 namespace webrtc { | 21 namespace webrtc { |
20 | 22 |
| 23 namespace { |
| 24 |
| 25 RtpPacketReceived ParsePacket(rtc::ArrayView<const uint8_t> packet) { |
| 26 RtpPacketReceived parsed_packet(nullptr); |
| 27 EXPECT_TRUE(parsed_packet.Parse(packet)); |
| 28 return parsed_packet; |
| 29 } |
| 30 |
| 31 } // namespace |
| 32 |
21 TEST(FlexfecReceiveStreamTest, ConstructDestruct) { | 33 TEST(FlexfecReceiveStreamTest, ConstructDestruct) { |
22 FlexfecReceiveStream::Config config; | 34 FlexfecReceiveStream::Config config; |
23 config.payload_type = 118; | 35 config.payload_type = 118; |
24 config.remote_ssrc = 424223; | 36 config.remote_ssrc = 424223; |
25 config.protected_media_ssrcs = {912512}; | 37 config.protected_media_ssrcs = {912512}; |
26 MockRecoveredPacketReceiver callback; | 38 MockRecoveredPacketReceiver recovered_packet_receiver; |
27 | 39 |
28 FlexfecReceiveStreamImpl receive_stream(config, &callback); | 40 FlexfecReceiveStreamImpl receive_stream(config, &recovered_packet_receiver); |
29 } | 41 } |
30 | 42 |
31 TEST(FlexfecReceiveStreamTest, StartStop) { | 43 TEST(FlexfecReceiveStreamTest, StartStop) { |
32 FlexfecReceiveStream::Config config; | 44 FlexfecReceiveStream::Config config; |
33 config.payload_type = 118; | 45 config.payload_type = 118; |
34 config.remote_ssrc = 1652392; | 46 config.remote_ssrc = 1652392; |
35 config.protected_media_ssrcs = {23300443}; | 47 config.protected_media_ssrcs = {23300443}; |
36 MockRecoveredPacketReceiver callback; | 48 MockRecoveredPacketReceiver recovered_packet_receiver; |
37 FlexfecReceiveStreamImpl receive_stream(config, &callback); | 49 FlexfecReceiveStreamImpl receive_stream(config, &recovered_packet_receiver); |
38 | 50 |
39 receive_stream.Start(); | 51 receive_stream.Start(); |
40 receive_stream.Stop(); | 52 receive_stream.Stop(); |
41 } | 53 } |
42 | 54 |
43 TEST(FlexfecReceiveStreamTest, DoesNotProcessPacketWhenNoMediaSsrcGiven) { | |
44 FlexfecReceiveStream::Config config; | |
45 config.payload_type = 118; | |
46 config.remote_ssrc = 424223; | |
47 config.protected_media_ssrcs = {}; | |
48 MockRecoveredPacketReceiver callback; | |
49 FlexfecReceiveStreamImpl receive_stream(config, &callback); | |
50 const uint8_t packet[] = {0x00, 0x11, 0x22, 0x33}; | |
51 const size_t packet_length = sizeof(packet); | |
52 | |
53 EXPECT_FALSE( | |
54 receive_stream.AddAndProcessReceivedPacket(packet, packet_length)); | |
55 } | |
56 | |
57 // Create a FlexFEC packet that protects a single media packet and ensure | 55 // Create a FlexFEC packet that protects a single media packet and ensure |
58 // that the callback is called. Correctness of recovery is checked in the | 56 // that the callback is called. Correctness of recovery is checked in the |
59 // FlexfecReceiver unit tests. | 57 // FlexfecReceiver unit tests. |
60 TEST(FlexfecReceiveStreamTest, RecoversPacketWhenStarted) { | 58 TEST(FlexfecReceiveStreamTest, RecoversPacketWhenStarted) { |
61 constexpr uint8_t kFlexfecPlType = 118; | 59 constexpr uint8_t kFlexfecPlType = 118; |
62 constexpr uint8_t kFlexfecSeqNum[] = {0x00, 0x01}; | 60 constexpr uint8_t kFlexfecSeqNum[] = {0x00, 0x01}; |
63 constexpr uint8_t kFlexfecTs[] = {0x00, 0x11, 0x22, 0x33}; | 61 constexpr uint8_t kFlexfecTs[] = {0x00, 0x11, 0x22, 0x33}; |
64 constexpr uint8_t kFlexfecSsrc[] = {0x00, 0x00, 0x00, 0x01}; | 62 constexpr uint8_t kFlexfecSsrc[] = {0x00, 0x00, 0x00, 0x01}; |
65 constexpr uint8_t kMediaPlType = 107; | 63 constexpr uint8_t kMediaPlType = 107; |
66 constexpr uint8_t kMediaSeqNum[] = {0x00, 0x02}; | 64 constexpr uint8_t kMediaSeqNum[] = {0x00, 0x02}; |
(...skipping 17 matching lines...) Expand all Loading... |
84 kFlexfecSsrc[0], kFlexfecSsrc[1], kFlexfecSsrc[2], kFlexfecSsrc[3], | 82 kFlexfecSsrc[0], kFlexfecSsrc[1], kFlexfecSsrc[2], kFlexfecSsrc[3], |
85 // FlexFEC header. | 83 // FlexFEC header. |
86 0x00, kMediaPlType, kPayloadLength[0], kPayloadLength[1], | 84 0x00, kMediaPlType, kPayloadLength[0], kPayloadLength[1], |
87 kMediaTs[0], kMediaTs[1], kMediaTs[2], kMediaTs[3], | 85 kMediaTs[0], kMediaTs[1], kMediaTs[2], kMediaTs[3], |
88 kSsrcCount, kReservedBits, kReservedBits, kReservedBits, | 86 kSsrcCount, kReservedBits, kReservedBits, kReservedBits, |
89 kMediaSsrc[0], kMediaSsrc[1], kMediaSsrc[2], kMediaSsrc[3], | 87 kMediaSsrc[0], kMediaSsrc[1], kMediaSsrc[2], kMediaSsrc[3], |
90 kMediaSeqNum[0], kMediaSeqNum[1], kFlexfecPktMask[0], kFlexfecPktMask[1], | 88 kMediaSeqNum[0], kMediaSeqNum[1], kFlexfecPktMask[0], kFlexfecPktMask[1], |
91 // FEC payload. | 89 // FEC payload. |
92 kPayloadBits, kPayloadBits, kPayloadBits, kPayloadBits}; | 90 kPayloadBits, kPayloadBits, kPayloadBits, kPayloadBits}; |
93 // clang-format on | 91 // clang-format on |
94 constexpr size_t kFlexfecPacketLength = sizeof(kFlexfecPacket); | |
95 | 92 |
96 FlexfecReceiveStream::Config config; | 93 FlexfecReceiveStream::Config config; |
97 config.payload_type = kFlexfecPlType; | 94 config.payload_type = kFlexfecPlType; |
98 config.remote_ssrc = ByteReader<uint32_t>::ReadBigEndian(kFlexfecSsrc); | 95 config.remote_ssrc = ByteReader<uint32_t>::ReadBigEndian(kFlexfecSsrc); |
99 config.protected_media_ssrcs = { | 96 config.protected_media_ssrcs = { |
100 ByteReader<uint32_t>::ReadBigEndian(kMediaSsrc)}; | 97 ByteReader<uint32_t>::ReadBigEndian(kMediaSsrc)}; |
101 testing::StrictMock<MockRecoveredPacketReceiver> recovered_packet_receiver; | 98 testing::StrictMock<MockRecoveredPacketReceiver> recovered_packet_receiver; |
102 FlexfecReceiveStreamImpl receive_stream(config, &recovered_packet_receiver); | 99 FlexfecReceiveStreamImpl receive_stream(config, &recovered_packet_receiver); |
103 | 100 |
104 // Do not call back before being started. | 101 // Do not call back before being started. |
105 receive_stream.AddAndProcessReceivedPacket(kFlexfecPacket, | 102 receive_stream.AddAndProcessReceivedPacket(ParsePacket(kFlexfecPacket)); |
106 kFlexfecPacketLength); | |
107 | 103 |
108 // Call back after being started. | 104 // Call back after being started. |
109 receive_stream.Start(); | 105 receive_stream.Start(); |
110 EXPECT_CALL( | 106 EXPECT_CALL( |
111 recovered_packet_receiver, | 107 recovered_packet_receiver, |
112 OnRecoveredPacket(::testing::_, kRtpHeaderSize + kPayloadLength[1])); | 108 OnRecoveredPacket(::testing::_, kRtpHeaderSize + kPayloadLength[1])); |
113 receive_stream.AddAndProcessReceivedPacket(kFlexfecPacket, | 109 receive_stream.AddAndProcessReceivedPacket(ParsePacket(kFlexfecPacket)); |
114 kFlexfecPacketLength); | |
115 } | 110 } |
116 | 111 |
117 } // namespace webrtc | 112 } // namespace webrtc |
OLD | NEW |