diff --git a/pkg/sfu/buffer/rtpstats.go b/pkg/sfu/buffer/rtpstats.go index d650f33a0..fda74a257 100644 --- a/pkg/sfu/buffer/rtpstats.go +++ b/pkg/sfu/buffer/rtpstats.go @@ -1049,7 +1049,7 @@ func (r *RTPStats) DeltaInfo(snapshotId uint32) *RTPDeltaInfo { packetsExpected := now.extStartSN - then.extStartSN if packetsExpected > NumSequenceNumbers { - r.logger.Warnw( + r.logger.Errorw( "too many packets expected in delta", fmt.Errorf("start: %d, end: %d, expected: %d", then.extStartSN, now.extStartSN, packetsExpected), ) diff --git a/pkg/sfu/downtrack.go b/pkg/sfu/downtrack.go index e8704da08..8fc30d542 100644 --- a/pkg/sfu/downtrack.go +++ b/pkg/sfu/downtrack.go @@ -114,8 +114,8 @@ type DownTrackState struct { } func (d DownTrackState) String() string { - return fmt.Sprintf("DownTrackState{rtpStats: %s, delta: %d, forwarder: %s}", - d.RTPStats.ToString(), d.DeltaStatsSnapshotId, d.ForwarderState.String()) + return fmt.Sprintf("DownTrackState{rtpStats: %s, delta: %d, deltaOverridden: %d, forwarder: %s}", + d.RTPStats.ToString(), d.DeltaStatsSnapshotId, d.DeltaStatsOverriddenSnapshotId, d.ForwarderState.String()) } // -------------------------------------------------------------------