diff --git a/pkg/sfu/forwarder.go b/pkg/sfu/forwarder.go index 79d0c2ee5..7abc6ebb4 100644 --- a/pkg/sfu/forwarder.go +++ b/pkg/sfu/forwarder.go @@ -1748,6 +1748,9 @@ func (f *Forwarder) getTranslationParamsVideo(extPkt *buffer.ExtPacket, layer in } func (f *Forwarder) TranslateCodecHeader(extPkt *buffer.ExtPacket, tpr *TranslationParamsRTP, outputBuffer []byte) (bool, int, int, error) { + f.lock.Lock() + defer f.lock.Unlock() + maybeRollback := func(isSwitching bool) { if isSwitching { f.vls.Rollback()