OLD | NEW |
1 /* | 1 /* |
2 * Copyright (c) 2017 The WebRTC project authors. All Rights Reserved. | 2 * Copyright (c) 2017 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 <utility> | 11 #include <utility> |
12 | 12 |
13 #include "webrtc/call/rtx_receive_stream.h" | 13 #include "webrtc/call/rtx_receive_stream.h" |
14 #include "webrtc/modules/rtp_rtcp/source/rtp_packet_received.h" | 14 #include "webrtc/modules/rtp_rtcp/source/rtp_packet_received.h" |
15 | 15 |
16 namespace webrtc { | 16 namespace webrtc { |
17 | 17 |
18 RtxReceiveStream::RtxReceiveStream( | 18 RtxReceiveStream::RtxReceiveStream( |
19 RtpPacketSinkInterface* media_sink, | 19 RtpPacketSinkInterface* media_sink, |
20 std::map<int, int> rtx_payload_type_map, | 20 std::map<int, int> rtx_payload_type_map, |
21 uint32_t media_ssrc) | 21 uint32_t media_ssrc) |
22 : media_sink_(media_sink), | 22 : media_sink_(media_sink), |
23 rtx_payload_type_map_(std::move(rtx_payload_type_map)), | 23 rtx_payload_type_map_(std::move(rtx_payload_type_map)), |
24 media_ssrc_(media_ssrc) {} | 24 media_ssrc_(media_ssrc) {} |
25 | 25 |
| 26 RtxReceiveStream::~RtxReceiveStream() = default; |
| 27 |
26 void RtxReceiveStream::OnRtpPacket(const RtpPacketReceived& rtx_packet) { | 28 void RtxReceiveStream::OnRtpPacket(const RtpPacketReceived& rtx_packet) { |
27 rtc::ArrayView<const uint8_t> payload = rtx_packet.payload(); | 29 rtc::ArrayView<const uint8_t> payload = rtx_packet.payload(); |
28 | 30 |
29 if (payload.size() < kRtxHeaderSize) { | 31 if (payload.size() < kRtxHeaderSize) { |
30 return; | 32 return; |
31 } | 33 } |
32 | 34 |
33 auto it = rtx_payload_type_map_.find(rtx_packet.PayloadType()); | 35 auto it = rtx_payload_type_map_.find(rtx_packet.PayloadType()); |
34 if (it == rtx_payload_type_map_.end()) { | 36 if (it == rtx_payload_type_map_.end()) { |
35 return; | 37 return; |
(...skipping 11 matching lines...) Expand all Loading... |
47 | 49 |
48 uint8_t* media_payload = media_packet.AllocatePayload(rtx_payload.size()); | 50 uint8_t* media_payload = media_packet.AllocatePayload(rtx_payload.size()); |
49 RTC_DCHECK(media_payload != nullptr); | 51 RTC_DCHECK(media_payload != nullptr); |
50 | 52 |
51 memcpy(media_payload, rtx_payload.data(), rtx_payload.size()); | 53 memcpy(media_payload, rtx_payload.data(), rtx_payload.size()); |
52 | 54 |
53 media_sink_->OnRtpPacket(media_packet); | 55 media_sink_->OnRtpPacket(media_packet); |
54 } | 56 } |
55 | 57 |
56 } // namespace webrtc | 58 } // namespace webrtc |
OLD | NEW |