diff --git a/pkg/sfu/connectionquality/scorer.go b/pkg/sfu/connectionquality/scorer.go index adddcb933..ebafcd9bd 100644 --- a/pkg/sfu/connectionquality/scorer.go +++ b/pkg/sfu/connectionquality/scorer.go @@ -408,10 +408,10 @@ func (q *qualityScorer) updateAtLocked(stat *windowStat, at time.Time) { var score, packetScore, bitrateScore, layerScore float64 if stat.packets+stat.packetsPadding == 0 { if !stat.lastRTCPAt.IsZero() && at.Sub(stat.lastRTCPAt) > stat.duration { - reason = "dry" + reason = "rtcp" score = qualityTransitionScore[livekit.ConnectionQuality_LOST] } else { - reason = "rtcp" + reason = "dry" score = qualityTransitionScore[livekit.ConnectionQuality_POOR] } } else { diff --git a/pkg/sfu/rtpstats/rtpstats_base.go b/pkg/sfu/rtpstats/rtpstats_base.go index d42a40df8..7aa28adfd 100644 --- a/pkg/sfu/rtpstats/rtpstats_base.go +++ b/pkg/sfu/rtpstats/rtpstats_base.go @@ -468,6 +468,13 @@ func (r *rtpStatsBase) deltaInfo( StartTime: time.Unix(0, startTime), EndTime: time.Unix(0, endTime), } + loggingFields = []interface{}{ + "snapshotID", snapshotID, + "snapshotNow", now, + "snapshotThen", then, + "duration", time.Duration(endTime - startTime), + } + err = errors.New("no packets in delta") return }