From da52167cd967d02407ff3e0d405b4259e6f5e9cc Mon Sep 17 00:00:00 2001 From: Raja Subramanian Date: Wed, 30 Aug 2023 23:08:53 +0530 Subject: [PATCH] Adjust extended sequence number to account for dropped packets (#2017) --- pkg/sfu/buffer/buffer.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/pkg/sfu/buffer/buffer.go b/pkg/sfu/buffer/buffer.go index a08d75d5a..b94cb0265 100644 --- a/pkg/sfu/buffer/buffer.go +++ b/pkg/sfu/buffer/buffer.go @@ -453,7 +453,8 @@ func (b *Buffer) calc(pkt []byte, arrivalTime time.Time) { b.logger.Errorw("could not get sequence number adjustment", err, "sn", flowState.ExtSequenceNumber, "payloadSize", len(rtpPacket.Payload)) return } - rtpPacket.Header.SequenceNumber = uint16(flowState.ExtSequenceNumber - snAdjustment) + flowState.ExtSequenceNumber -= snAdjustment + rtpPacket.Header.SequenceNumber = uint16(flowState.ExtSequenceNumber) _, err = b.bucket.AddPacketWithSequenceNumber(pkt, rtpPacket.Header.SequenceNumber) if err != nil { if err != bucket.ErrRTXPacket {