Index: video/video_receive_stream.cc |
diff --git a/video/video_receive_stream.cc b/video/video_receive_stream.cc |
index 7de42f8a1da8dd6f1310f21c2034c655dff1a6ba..22baff262a090c9cc7564ac7849eb6269f242b1d 100644 |
--- a/video/video_receive_stream.cc |
+++ b/video/video_receive_stream.cc |
@@ -176,6 +176,7 @@ void VideoReceiveStream::Start() { |
frame_buffer_->Start(); |
call_stats_->RegisterStatsObserver(&rtp_video_stream_receiver_); |
+ call_stats_->RegisterStatsObserver(this); |
if (rtp_video_stream_receiver_.IsRetransmissionsEnabled() && |
protected_by_fec) { |
@@ -225,6 +226,7 @@ void VideoReceiveStream::Stop() { |
rtp_video_stream_receiver_.StopReceive(); |
frame_buffer_->Stop(); |
+ call_stats_->DeregisterStatsObserver(this); |
call_stats_->DeregisterStatsObserver(&rtp_video_stream_receiver_); |
process_thread_->DeRegisterModule(&video_receiver_); |
@@ -347,6 +349,10 @@ void VideoReceiveStream::OnCompleteFrame( |
rtp_video_stream_receiver_.FrameContinuous(last_continuous_pid); |
} |
+void VideoReceiveStream::OnRttUpdate(int64_t avg_rtt_ms, int64_t max_rtt_ms) { |
+ frame_buffer_->UpdateRtt(max_rtt_ms); |
+} |
+ |
int VideoReceiveStream::id() const { |
RTC_DCHECK_CALLED_SEQUENTIALLY(&worker_sequence_checker_); |
return config_.rtp.remote_ssrc; |