mirror of
https://github.com/livekit/livekit.git
synced 2026-10-22 12:52:29 +00:00
refactor: using slices.Contains to simplify the code (#3495)
Signed-off-by: NinaLua <iturf@sina.cn>
This commit is contained in:
1 parent
01e51dbd7f
commit
c2f17a1072
1 file changed
+2
-11
@@ -15,6 +15,7 @@
|
||||
package sfu
|
||||
|
||||
import (
|
||||
"slices"
|
||||
"sort"
|
||||
"sync"
|
||||
"time"
|
||||
@@ -480,7 +481,7 @@ func (s *StreamTrackerManager) getLayeredBitrateLocked() ([]int32, Bitrates) {
|
||||
for i, tracker := range s.trackers {
|
||||
if tracker != nil {
|
||||
tls := make([]int64, buffer.DefaultMaxLayerTemporal+1)
|
||||
if s.hasSpatialLayerLocked(int32(i)) {
|
||||
if slices.Contains(s.availableLayers ,int32(i)) {
|
||||
tls = tracker.BitrateTemporalCumulative()
|
||||
}
|
||||
|
||||
@@ -509,16 +510,6 @@ func (s *StreamTrackerManager) getLayeredBitrateLocked() ([]int32, Bitrates) {
|
||||
return availableLayers, br
|
||||
}
|
||||
|
||||
func (s *StreamTrackerManager) hasSpatialLayerLocked(layer int32) bool {
|
||||
for _, l := range s.availableLayers {
|
||||
if l == layer {
|
||||
return true
|
||||
}
|
||||
}
|
||||
|
||||
return false
|
||||
}
|
||||
|
||||
func (s *StreamTrackerManager) addAvailableLayer(layer int32) {
|
||||
s.lock.Lock()
|
||||
hasLayer := false
|
||||
|
||||
Reference in new issue
Block a user