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

Keep next timestamp on switch closer to ref. (#1784)

Browse Source 
If ref is coming in slow (due to pacing), it is possible that
expected is ahead. Pulling next too far towards expected causes
warps in a subsequent report. Keep switches closer to ref.
This commit is contained in:
Raja Subramanian authored and GitHub committed 2023-06-10 11:38:46 +05:30
1 parent 4805dec1f0
commit 3d696ac39f
1 file changed
+2 -2
Download Patch File Download Diff File Expand all files Collapse all files
pkg/sfu/forwarder.go
+2 -2
View File
@@ -1842,7 +1842,7 @@ func getNextTimestamp(lastTS uint32, refTS uint32, expectedTS uint32, minTS uint
switch {
case rl && el && er: // lastTS < refTS < expectedTS
nextTS = uint32(float64(refTS) + 0.95*float64(expectedTS-refTS))
nextTS = uint32(float64(refTS) + 0.05*float64(expectedTS-refTS))
explain = fmt.Sprintf("l < r < e, %d, %d", refTS-lastTS, expectedTS-refTS)
case rl && el && !er: // lastTS < expectedTS < refTS
nextTS = uint32(float64(expectedTS) + 0.5*float64(refTS-expectedTS))
@@ -1854,7 +1854,7 @@ func getNextTimestamp(lastTS uint32, refTS uint32, expectedTS uint32, minTS uint
nextTS = lastTS + 1
explain = fmt.Sprintf("r < e < l, %d, %d", expectedTS-refTS, lastTS-expectedTS)
case rl && !el && !er: // expectedTS < lastTS < refTS
nextTS = uint32(float64(lastTS) + 0.5*float64(refTS-lastTS))
nextTS = uint32(float64(lastTS) + 0.75*float64(refTS-lastTS))
explain = fmt.Sprintf("e < l < r, %d, %d", lastTS-expectedTS, refTS-lastTS)
case !rl && !el && !er: // expectedTS < refTS < lastTS
nextTS = lastTS + 1