dandri/livekit
1
0
Fork 0
mirror of https://github.com/livekit/livekit.git synced 2026-03-29 07:09:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

Do NACK updates as soon as flow state is processed. (#4221)

Browse Source
This commit is contained in:
Raja Subramanian
2026-01-06 11:59:21 +05:30
committed by GitHub
parent 4405afe24d
commit 80ba93fa18
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
pkg/sfu/buffer/buffer_base.go
View File

@@ -769,6 +769,12 @@ func (b *BufferBase) HandleIncomingPacketLocked(
return 0, fmt.Errorf("unhandled reason: %s", flowState.UnhandledReason.String())
}
if b.params.IsOOBSequenceNumber {
b.updateOOBNACKState(oobSequenceNumber, arrivalTime, len(rawPkt))
} else {
b.updateNACKState(rtpPacket.SequenceNumber, flowState)
}
if len(rtpPacket.Payload) == 0 && (!flowState.IsOutOfOrder || flowState.IsDuplicate) {
// drop padding only in-order or duplicate packet
if !flowState.IsOutOfOrder {
@@ -873,12 +879,6 @@ func (b *BufferBase) HandleIncomingPacketLocked(
b.maybeGrowBucket(arrivalTime)
if b.params.IsOOBSequenceNumber {
b.updateOOBNACKState(oobSequenceNumber, arrivalTime, len(rawPkt))
} else {
b.updateNACKState(rtpPacket.SequenceNumber, flowState)
}
return ep.ExtSequenceNumber, nil
}