diff --git a/pkg/sfu/buffer/buffer.go b/pkg/sfu/buffer/buffer.go index 065fe887d..ce2640cbe 100644 --- a/pkg/sfu/buffer/buffer.go +++ b/pkg/sfu/buffer/buffer.go @@ -453,7 +453,7 @@ func (b *Buffer) SetPrimaryBufferForFEC(primaryBuffer *Buffer) { } } -func (b *Buffer) markAsFECRepair() { +func (b *Buffer) setFECRepairBufferLimit() { b.Lock() defer b.Unlock() diff --git a/pkg/sfu/buffer/factory.go b/pkg/sfu/buffer/factory.go index aaed2c561..fd7561e7f 100644 --- a/pkg/sfu/buffer/factory.go +++ b/pkg/sfu/buffer/factory.go @@ -93,7 +93,7 @@ func (f *Factory) GetOrNew(packetType packetio.BufferPacketType, ssrc uint32) io } for fec, base := range f.fecPair { if fec == ssrc { - buffer.markAsFECRepair() + buffer.setFECRepairBufferLimit() baseBuffer, ok := f.rtpBuffers[base] if ok { buffer.SetPrimaryBufferForFEC(baseBuffer) @@ -175,7 +175,7 @@ func (f *Factory) SetFECPair(fec, base uint32) { } f.Unlock() if fecBuffer != nil && baseBuffer == nil { - fecBuffer.markAsFECRepair() + fecBuffer.setFECRepairBufferLimit() } if fecBuffer != nil && baseBuffer != nil { fecBuffer.SetPrimaryBufferForFEC(baseBuffer)