From e7dd03181c2acc5fc51c102fda91164df17f9651 Mon Sep 17 00:00:00 2001 From: Raja Subramanian Date: Sat, 17 Feb 2024 21:30:19 +0530 Subject: [PATCH] Use smaller default deque size. (#2488) --- pkg/rtc/dynacastmanager.go | 2 +- pkg/utils/opsqueue.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/rtc/dynacastmanager.go b/pkg/rtc/dynacastmanager.go index 1163cb09a..c9395e60a 100644 --- a/pkg/rtc/dynacastmanager.go +++ b/pkg/rtc/dynacastmanager.go @@ -59,7 +59,7 @@ func NewDynacastManager(params DynacastManagerParams) *DynacastManager { maxSubscribedQuality: make(map[string]livekit.VideoQuality), committedMaxSubscribedQuality: make(map[string]livekit.VideoQuality), maxSubscribedQualityDebounce: debounce.New(params.DynacastPauseDelay), - qualityNotifyOpQueue: utils.NewOpsQueue("quality-notify", 0, true), + qualityNotifyOpQueue: utils.NewOpsQueue("quality-notify", 64, true), } d.qualityNotifyOpQueue.Start() return d diff --git a/pkg/utils/opsqueue.go b/pkg/utils/opsqueue.go index 30dbbe1ec..19f8d7ecc 100644 --- a/pkg/utils/opsqueue.go +++ b/pkg/utils/opsqueue.go @@ -41,7 +41,7 @@ func NewOpsQueue(name string, minSize uint, flushOnStop bool) *OpsQueue { wake: make(chan struct{}, 1), doneChan: make(chan struct{}), } - oq.ops.SetMinCapacity(uint(utils.Min(bits.Len64(uint64(minSize-1)), 16))) + oq.ops.SetMinCapacity(uint(utils.Min(bits.Len64(uint64(minSize-1)), 7))) return oq }