diff --git a/pkg/sfu/buffer/buffer.go b/pkg/sfu/buffer/buffer.go index 3f254ef81..1678cba69 100644 --- a/pkg/sfu/buffer/buffer.go +++ b/pkg/sfu/buffer/buffer.go @@ -515,6 +515,9 @@ func (b *Buffer) getExtPacket(rawPacket []byte, rtpPacket *rtp.Packet, arrivalTi case "video/h264": ep.KeyFrame = IsH264Keyframe(rtpPacket.Payload) } + if ep.KeyFrame { + b.logger.Debugw("key frame received") + } return ep, temporalLayer } diff --git a/pkg/sfu/forwarder.go b/pkg/sfu/forwarder.go index d5db8e562..c6453a6f3 100644 --- a/pkg/sfu/forwarder.go +++ b/pkg/sfu/forwarder.go @@ -1252,6 +1252,7 @@ func (f *Forwarder) getTranslationParamsVideo(extPkt *buffer.ExtPacket, layer in if f.targetLayers.spatial == layer { if extPkt.KeyFrame { // lock to target layer + f.logger.Debugw("locking to target layer", "current", f.currentLayers, "target", f.targetLayers) f.currentLayers.spatial = f.targetLayers.spatial if f.currentLayers.spatial == f.maxLayers.spatial { tp.isSwitchingToMaxLayer = true