dandri/livekit
1
0
Fork 0
mirror of https://github.com/livekit/livekit.git synced 2026-05-25 18:34:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

rtpstats add update last packet method (#858)

Browse Source
This commit is contained in:
cnderrauber
2022-07-29 15:29:36 +08:00
committed by GitHub
parent 52b2e6398b
commit 997461a2b6
1 changed files with 9 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/sfu/buffer/rtpstats.go
+9
View File
@@ -279,6 +279,15 @@ func (r *RTPStats) Update(rtph *rtp.Header, payloadSize int, paddingSize int, pa
return
}
func (r *RTPStats) ForceUpdateLastPacket(rtph *rtp.Header, packetTime int64) {
r.lock.Lock()
defer r.lock.Unlock()
r.highestSN = rtph.SequenceNumber - 1
r.highestTS = rtph.Timestamp
r.highestTime = packetTime
}
func (r *RTPStats) maybeAdjustStartSN(rtph *rtp.Header, packetTime int64, pktSize uint64, payloadSize int) bool {
if (r.getExtHighestSN() - r.extStartSN + 1) >= (NumSequenceNumbers / 2) {
return false