diff --git a/pkg/sfu/buffer/rtpstats_base.go b/pkg/sfu/buffer/rtpstats_base.go index eba2425b9..af8ecfe21 100644 --- a/pkg/sfu/buffer/rtpstats_base.go +++ b/pkg/sfu/buffer/rtpstats_base.go @@ -35,6 +35,8 @@ const ( cFirstPacketTimeAdjustWindow = 2 * time.Minute cFirstPacketTimeAdjustThreshold = 15 * time.Second + + cPassthroughNTPTimestamp = true ) // ------------------------------------------------------- @@ -118,6 +120,10 @@ type RTCPSenderReportData struct { } func (r *RTCPSenderReportData) PropagationDelay() time.Duration { + if cPassthroughNTPTimestamp { + return 0 + } + return r.AtAdjusted.Sub(r.NTPTimestamp.Time()) } diff --git a/pkg/sfu/buffer/rtpstats_sender.go b/pkg/sfu/buffer/rtpstats_sender.go index 6f32ac0a7..3074803d0 100644 --- a/pkg/sfu/buffer/rtpstats_sender.go +++ b/pkg/sfu/buffer/rtpstats_sender.go @@ -31,8 +31,6 @@ const ( cSnInfoMask = cSnInfoSize - 1 cSenderReportInitialWait = time.Second - - cPassthroughNTPTimestamp = true ) // -------------------------------------------------------------------