1 /*
2 * Copyright (c) 2017 The WebRTC project authors. All Rights Reserved.
3 *
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
6 * tree. An additional intellectual property rights grant can be found
7 * in the file PATENTS. All contributing project authors may
8 * be found in the AUTHORS file in the root of the source tree.
9 */
10
11 #include "call/rtp_stream_receiver_controller.h"
12
13 #include <memory>
14
15 #include "rtc_base/logging.h"
16
17 namespace webrtc {
18
Receiver(RtpStreamReceiverController * controller,uint32_t ssrc,RtpPacketSinkInterface * sink)19 RtpStreamReceiverController::Receiver::Receiver(
20 RtpStreamReceiverController* controller,
21 uint32_t ssrc,
22 RtpPacketSinkInterface* sink)
23 : controller_(controller), sink_(sink) {
24 const bool sink_added = controller_->AddSink(ssrc, sink_);
25 if (!sink_added) {
26 RTC_LOG(LS_ERROR)
27 << "RtpStreamReceiverController::Receiver::Receiver: Sink "
28 "could not be added for SSRC="
29 << ssrc << ".";
30 }
31 }
32
~Receiver()33 RtpStreamReceiverController::Receiver::~Receiver() {
34 // This may fail, if corresponding AddSink in the constructor failed.
35 controller_->RemoveSink(sink_);
36 }
37
RtpStreamReceiverController()38 RtpStreamReceiverController::RtpStreamReceiverController() {}
39
40 RtpStreamReceiverController::~RtpStreamReceiverController() = default;
41
42 std::unique_ptr<RtpStreamReceiverInterface>
CreateReceiver(uint32_t ssrc,RtpPacketSinkInterface * sink)43 RtpStreamReceiverController::CreateReceiver(uint32_t ssrc,
44 RtpPacketSinkInterface* sink) {
45 return std::make_unique<Receiver>(this, ssrc, sink);
46 }
47
OnRtpPacket(const RtpPacketReceived & packet)48 bool RtpStreamReceiverController::OnRtpPacket(const RtpPacketReceived& packet) {
49 RTC_DCHECK_RUN_ON(&demuxer_sequence_);
50 return demuxer_.OnRtpPacket(packet);
51 }
52
AddSink(uint32_t ssrc,RtpPacketSinkInterface * sink)53 bool RtpStreamReceiverController::AddSink(uint32_t ssrc,
54 RtpPacketSinkInterface* sink) {
55 RTC_DCHECK_RUN_ON(&demuxer_sequence_);
56 return demuxer_.AddSink(ssrc, sink);
57 }
58
RemoveSink(const RtpPacketSinkInterface * sink)59 bool RtpStreamReceiverController::RemoveSink(
60 const RtpPacketSinkInterface* sink) {
61 RTC_DCHECK_RUN_ON(&demuxer_sequence_);
62 return demuxer_.RemoveSink(sink);
63 }
64
65 } // namespace webrtc
66