Index: webrtc/call/flexfec_receive_stream_impl.cc |
diff --git a/webrtc/call/flexfec_receive_stream_impl.cc b/webrtc/call/flexfec_receive_stream_impl.cc |
index f01043349892574f5d240cacd27583173c68ad71..3ea50cd66a1ce6535da2349dd218c4e8bcd3d591 100644 |
--- a/webrtc/call/flexfec_receive_stream_impl.cc |
+++ b/webrtc/call/flexfec_receive_stream_impl.cc |
@@ -15,6 +15,7 @@ |
#include "webrtc/base/checks.h" |
#include "webrtc/base/location.h" |
#include "webrtc/base/logging.h" |
+#include "webrtc/call/rtp_stream_receiver_controller_interface.h" |
#include "webrtc/modules/rtp_rtcp/include/flexfec_receiver.h" |
#include "webrtc/modules/rtp_rtcp/include/receive_statistics.h" |
#include "webrtc/modules/rtp_rtcp/include/rtp_rtcp.h" |
@@ -122,6 +123,7 @@ std::unique_ptr<RtpRtcp> CreateRtpRtcpModule( |
} // namespace |
FlexfecReceiveStreamImpl::FlexfecReceiveStreamImpl( |
+ RtpStreamReceiverControllerInterface* receiver_controller, |
const Config& config, |
RecoveredPacketReceiver* recovered_packet_receiver, |
RtcpRttStats* rtt_stats, |
@@ -141,6 +143,13 @@ FlexfecReceiveStreamImpl::FlexfecReceiveStreamImpl( |
rtp_rtcp_->SetRTCPStatus(config_.rtcp_mode); |
rtp_rtcp_->SetSSRC(config_.local_ssrc); |
process_thread_->RegisterModule(rtp_rtcp_.get(), RTC_FROM_HERE); |
+ |
+ // Register with transport. |
+ // TODO(nisse): Register receiver_, and delete below OnRtpPacket method? |
danilchap
2017/06/13 15:58:32
I'm not sure what you are suggesting to do in this
nisse-webrtc
2017/06/14 06:31:06
The idea is that maybe this class doesn't need to
|
+ rtp_stream_receiver_ = |
+ receiver_controller->CreateReceiver(config_.remote_ssrc, this); |
+ for (uint32_t ssrc : config.protected_media_ssrcs) |
+ receiver_controller->AddSink(ssrc, this); |
} |
FlexfecReceiveStreamImpl::~FlexfecReceiveStreamImpl() { |