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

Resync uses SSRC change. Reset to 0 when a resync is needed. (#446)

Browse Source
This commit is contained in:
Raja Subramanian
2022-02-18 16:26:27 +05:30
committed by GitHub
parent 517312fb87
commit 92d47ec421
1 changed files with 8 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/sfu/forwarder.go
+8 -4
View File
@@ -516,7 +516,7 @@ func (f *Forwarder) Allocate(availableChannelCapacity int64, allowPause bool, br
}
f.targetLayers = f.lastAllocation.targetLayers
if f.targetLayers == InvalidLayers {
f.currentLayers = InvalidLayers
f.resyncLocked()
}
return f.lastAllocation
@@ -825,7 +825,7 @@ func (f *Forwarder) ProvisionalAllocateCommit() VideoAllocation {
}
f.targetLayers = f.lastAllocation.targetLayers
if f.targetLayers == InvalidLayers {
f.currentLayers = InvalidLayers
f.resyncLocked()
}
return f.lastAllocation
@@ -856,7 +856,7 @@ func (f *Forwarder) FinalizeAllocate(brs Bitrates) VideoAllocation {
}
f.targetLayers = f.lastAllocation.targetLayers
if f.targetLayers == InvalidLayers {
f.currentLayers = InvalidLayers
f.resyncLocked()
}
}
@@ -1125,7 +1125,7 @@ func (f *Forwarder) Pause(brs Bitrates) VideoAllocation {
}
f.targetLayers = f.lastAllocation.targetLayers
if f.targetLayers == InvalidLayers {
f.currentLayers = InvalidLayers
f.resyncLocked()
}
return f.lastAllocation
@@ -1135,6 +1135,10 @@ func (f *Forwarder) Resync() {
f.lock.Lock()
defer f.lock.Unlock()
f.resyncLocked()
}
func (f *Forwarder) resyncLocked() {
f.currentLayers = InvalidLayers
f.lastSSRC = 0
}