diff --git a/pkg/sfu/buffer/rtpstats.go b/pkg/sfu/buffer/rtpstats.go index d99954bb0..120285129 100644 --- a/pkg/sfu/buffer/rtpstats.go +++ b/pkg/sfu/buffer/rtpstats.go @@ -402,6 +402,14 @@ func (r *RTPStats) Update(rtph *rtp.Header, payloadSize int, paddingSize int, pa extStartSNOverridden: r.extStartSN, } } + + r.logger.Debugw( + "rtp stream start", + "startTime", r.startTime.String(), + "firstTime", r.firstTime.String(), + "startSN", r.extStartSN, + "startTS", r.extStartTS, + ) } if r.resyncOnNextPacket { @@ -529,7 +537,7 @@ func (r *RTPStats) maybeAdjustStart(rtph *rtp.Header, pktSize uint64, hdrSize ui r.tsCycles++ } r.logger.Infow( - "adjusting starting sequence number", + "adjusting start", "snBefore", snBeforeAdjust, "snAfter", r.extStartSN, "snCyles", r.cycles, @@ -817,8 +825,13 @@ func (r *RTPStats) maybeAdjustFirstPacketTime(ts uint32) { if firstTime.Before(r.firstTime) { r.logger.Debugw( "adjusting first packet time", + "startTime", r.startTime.String(), + "nowTime", now.String(), "before", r.firstTime.String(), "after", firstTime.String(), + "adjustment", r.firstTime.Sub(firstTime), + "nowTS", ts, + "extStartTS", r.extStartTS, ) if r.firstTime.Sub(firstTime) > firstPacketTimeAdjustThreshold { r.logger.Infow("first packet time adjustment too big, ignoring",