dandri/livekit
1
0
Fork 0
mirror of https://github.com/livekit/livekit.git synced 2026-10-07 20:38:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

rename markAsFECRepair to setFECRepairBufferLimit for clarity

Browse Source
This commit is contained in:
David Chen
2026-09-22 14:55:18 -07:00
parent fa7c9df9a9
commit 6c3eba9897
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/sfu/buffer/buffer.go
+1 -1
View File
@@ -453,7 +453,7 @@ func (b *Buffer) SetPrimaryBufferForFEC(primaryBuffer *Buffer) {
}
}
func (b *Buffer) markAsFECRepair() {
func (b *Buffer) setFECRepairBufferLimit() {
b.Lock()
defer b.Unlock()
pkg/sfu/buffer/factory.go
+2 -2
View File
@@ -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)