From 6c3eba989770ca8bd57ae48fede88fbc0f5dbd6d Mon Sep 17 00:00:00 2001 From: David Chen Date: Tue, 22 Sep 2026 14:55:18 -0700 Subject: [PATCH] rename markAsFECRepair to setFECRepairBufferLimit for clarity --- pkg/sfu/buffer/buffer.go | 2 +- pkg/sfu/buffer/factory.go | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) 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)