From f694dad105ad3ccbeb7559f0bb5d585cf25acdae Mon Sep 17 00:00:00 2001 From: Raja Subramanian Date: Tue, 29 Mar 2022 08:16:18 +0530 Subject: [PATCH] Reset available layers when removing all trackers (#575) --- pkg/sfu/streamallocator.go | 2 +- pkg/sfu/streamtrackermanager.go | 2 ++ 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/pkg/sfu/streamallocator.go b/pkg/sfu/streamallocator.go index 04d9d0656..29ca3a0db 100644 --- a/pkg/sfu/streamallocator.go +++ b/pkg/sfu/streamallocator.go @@ -134,7 +134,7 @@ type Event struct { } func (e Event) String() string { - return fmt.Sprintf("StreamAllocator:Event{signal: %s, data: %s}", e.Signal, e.Data) + return fmt.Sprintf("StreamAllocator:Event{signal: %s, data: %+v}", e.Signal, e.Data) } type StreamAllocatorParams struct { diff --git a/pkg/sfu/streamtrackermanager.go b/pkg/sfu/streamtrackermanager.go index 759e45eb1..05f2c7c77 100644 --- a/pkg/sfu/streamtrackermanager.go +++ b/pkg/sfu/streamtrackermanager.go @@ -148,6 +148,8 @@ func (s *StreamTrackerManager) RemoveAllTrackers() { for layer := range s.trackers { s.trackers[layer] = nil } + s.availableLayers = make([]int32, 0) + s.maxExpectedLayer = DefaultMaxLayerSpatial s.lock.Unlock() for _, tracker := range trackers {