diff --git a/pkg/sfu/buffer/rtpstats.go b/pkg/sfu/buffer/rtpstats.go index f8e2f4f6e..ed943a19f 100644 --- a/pkg/sfu/buffer/rtpstats.go +++ b/pkg/sfu/buffer/rtpstats.go @@ -210,6 +210,18 @@ func (r *RTPStats) Update(rtph *rtp.Header, payloadSize int, paddingSize int, pa flowState.LossStartInclusive = r.highestSN + 1 flowState.LossEndExclusive = rtph.SequenceNumber } + // LK-DEBUG-REMOVE START + if diff > 100 { + logger.Debugw( + "DEBUG huge difference in sequence number", + "diff", diff, + "highestSN", r.highestSN, + "sn", rtph.SequenceNumber, + "highestTime", r.highestTime, + "now", packetTime, + ) + } + // LK-DEBUG-REMOVE END // update gap histogram r.updateGapHistogram(int(diff)) diff --git a/pkg/sfu/streamtrackermanager.go b/pkg/sfu/streamtrackermanager.go index b13d02679..58f91d761 100644 --- a/pkg/sfu/streamtrackermanager.go +++ b/pkg/sfu/streamtrackermanager.go @@ -273,6 +273,8 @@ func (s *StreamTrackerManager) removeAvailableLayer(layer int32) { s.availableLayers = newLayers s.lock.Unlock() + s.logger.Debugw("available layers changed", "layers", newLayers) + // need to immediately switch off unavailable layers if s.onAvailableLayersChanged != nil { s.onAvailableLayersChanged(newLayers)