Index: webrtc/video/rtp_stream_receiver.cc |
diff --git a/webrtc/video/rtp_stream_receiver.cc b/webrtc/video/rtp_stream_receiver.cc |
index 4caf55aa8b40be01ac8fce691a31d58ea07196f7..e7367d8a1a276fc3e2461bcf497093f7812c35c3 100644 |
--- a/webrtc/video/rtp_stream_receiver.cc |
+++ b/webrtc/video/rtp_stream_receiver.cc |
@@ -39,7 +39,8 @@ std::unique_ptr<RtpRtcp> CreateRtpRtcpModule( |
RtcpPacketTypeCounterObserver* rtcp_packet_type_counter_observer, |
RemoteBitrateEstimator* remote_bitrate_estimator, |
RtpPacketSender* paced_sender, |
- TransportSequenceNumberAllocator* transport_sequence_number_allocator) { |
+ TransportSequenceNumberAllocator* transport_sequence_number_allocator, |
+ RateLimiter* retransmission_rate_limiter) { |
RtpRtcp::Configuration configuration; |
configuration.audio = false; |
configuration.receiver_only = true; |
@@ -58,7 +59,7 @@ std::unique_ptr<RtpRtcp> CreateRtpRtcpModule( |
configuration.send_packet_observer = nullptr; |
configuration.bandwidth_callback = nullptr; |
configuration.transport_feedback_callback = nullptr; |
- configuration.retransmission_rate_limiter = nullptr; |
+ configuration.retransmission_rate_limiter = retransmission_rate_limiter; |
std::unique_ptr<RtpRtcp> rtp_rtcp(RtpRtcp::CreateRtpRtcp(configuration)); |
rtp_rtcp->SetSendingStatus(false); |
@@ -80,7 +81,8 @@ RtpStreamReceiver::RtpStreamReceiver( |
VieRemb* remb, |
const VideoReceiveStream::Config* config, |
ReceiveStatisticsProxy* receive_stats_proxy, |
- ProcessThread* process_thread) |
+ ProcessThread* process_thread, |
+ RateLimiter* retransmission_rate_limiter) |
: clock_(Clock::GetRealTimeClock()), |
config_(*config), |
video_receiver_(video_receiver), |
@@ -106,7 +108,8 @@ RtpStreamReceiver::RtpStreamReceiver( |
receive_stats_proxy, |
remote_bitrate_estimator_, |
paced_sender, |
- packet_router)) { |
+ packet_router, |
+ retransmission_rate_limiter)) { |
packet_router_->AddRtpModule(rtp_rtcp_.get()); |
rtp_receive_statistics_->RegisterRtpStatisticsCallback(receive_stats_proxy); |
rtp_receive_statistics_->RegisterRtcpStatisticsCallback(receive_stats_proxy); |