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