dandri/livekit
1
0
Fork 0
mirror of https://github.com/livekit/livekit.git synced 2026-05-10 21:27:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

Support no dynacast pause. (#2512)

Browse Source
This commit is contained in:
Raja Subramanian
2024-02-26 15:15:04 +05:30
committed by GitHub
parent 8b6fc9ae53
commit ef4bc0b46d
1 changed files with 8 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/rtc/dynacastmanager.go
+8 -4
View File
@@ -59,9 +59,11 @@ func NewDynacastManager(params DynacastManagerParams) *DynacastManager {
dynacastQuality: make(map[string]*DynacastQuality),
maxSubscribedQuality: make(map[string]livekit.VideoQuality),
committedMaxSubscribedQuality: make(map[string]livekit.VideoQuality),
maxSubscribedQualityDebounce: debounce.New(params.DynacastPauseDelay),
qualityNotifyOpQueue: utils.NewOpsQueue("quality-notify", 64, true),
}
if params.DynacastPauseDelay > 0 {
d.maxSubscribedQualityDebounce = debounce.New(params.DynacastPauseDelay)
}
d.qualityNotifyOpQueue.Start()
return d
}
@@ -223,7 +225,7 @@ func (d *DynacastManager) update(force bool) {
return
}
if downgradesOnly {
if downgradesOnly && d.maxSubscribedQualityDebounce != nil {
if !d.maxSubscribedQualityDebouncePending {
d.params.Logger.Debugw("debouncing quality downgrade",
"committedMaxSubscribedQuality", d.committedMaxSubscribedQuality,
@@ -245,8 +247,10 @@ func (d *DynacastManager) update(force bool) {
}
// clear debounce on send
d.maxSubscribedQualityDebounce(func() {})
d.maxSubscribedQualityDebouncePending = false
if d.maxSubscribedQualityDebounce != nil {
d.maxSubscribedQualityDebounce(func() {})
d.maxSubscribedQualityDebouncePending = false
}
d.params.Logger.Debugw("committing quality change",
"force", force,