Index: webrtc/video/video_receive_stream.cc |
diff --git a/webrtc/video/video_receive_stream.cc b/webrtc/video/video_receive_stream.cc |
index a18d4375a19cee1a1020fd2ce4f75b0f9a459789..20b2f8fad615b85adb029e04ec9d12bbde512c9b 100644 |
--- a/webrtc/video/video_receive_stream.cc |
+++ b/webrtc/video/video_receive_stream.cc |
@@ -267,6 +267,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) { |
@@ -316,6 +317,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_); |
@@ -434,6 +436,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_RUN_ON(&worker_thread_checker_); |
return config_.rtp.remote_ssrc; |