dandri/livekit
1
0
Fork 0
mirror of https://github.com/livekit/livekit.git synced 2026-05-14 01:05:19 +00:00
Code Issues Packages Projects Releases Wiki Activity

Set gapSN when initing. (#2893)

Browse Source
This commit is contained in:
Raja Subramanian
2024-07-30 07:48:06 +05:30
committed by GitHub
parent 3e6e6e2732
commit 4e29e18129
1 changed files with 3 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/sfu/buffer/rtpstats_receiver.go
+3 -5
View File
@@ -255,9 +255,9 @@ func (r *RTPStatsReceiver) Update(
"forcing sequence number rollover", nil,
getLoggingFields()...,
)
gapSN = int64(resSN.ExtendedVal - resSN.PreExtendedHighest)
}
}
gapSN = int64(resSN.ExtendedVal - resSN.PreExtendedHighest)
pktSize := uint64(hdrSize + payloadSize + paddingSize)
if gapSN <= 0 { // duplicate OR out-of-order
@@ -278,8 +278,6 @@ func (r *RTPStatsReceiver) Update(
}
flowState.IsOutOfOrder = true
flowState.ExtSequenceNumber = resSN.ExtendedVal
flowState.ExtTimestamp = resTS.ExtendedVal
if !flowState.IsDuplicate && -gapSN >= cSequenceNumberLargeJumpThreshold {
r.largeJumpNegativeCount++
@@ -331,9 +329,9 @@ func (r *RTPStatsReceiver) Update(
flowState.LossStartInclusive = resSN.PreExtendedHighest + 1
flowState.LossEndExclusive = resSN.ExtendedVal
}
flowState.ExtSequenceNumber = resSN.ExtendedVal
flowState.ExtTimestamp = resTS.ExtendedVal
}
flowState.ExtSequenceNumber = resSN.ExtendedVal
flowState.ExtTimestamp = resTS.ExtendedVal
if !flowState.IsDuplicate {
if payloadSize == 0 {