mirror of
https://github.com/livekit/livekit.git
synced 2026-05-24 08:05:33 +00:00
+2
-2
@@ -749,9 +749,9 @@ func (w *WebRTCReceiver) forwardRTP(layer int32, buff *buffer.Buffer) {
|
||||
// track video layers
|
||||
if w.Kind() == webrtc.RTPCodecTypeVideo {
|
||||
if spatialTrackers[spatialLayer] == nil {
|
||||
spatialTrackers[spatialLayer] = w.streamTrackerManager.GetTracker(pkt.Spatial)
|
||||
spatialTrackers[spatialLayer] = w.streamTrackerManager.GetTracker(spatialLayer)
|
||||
if spatialTrackers[spatialLayer] == nil {
|
||||
spatialTrackers[spatialLayer] = w.streamTrackerManager.AddTracker(pkt.Spatial)
|
||||
spatialTrackers[spatialLayer] = w.streamTrackerManager.AddTracker(spatialLayer)
|
||||
}
|
||||
}
|
||||
if spatialTrackers[spatialLayer] != nil {
|
||||
|
||||
@@ -349,7 +349,7 @@ func (s *StreamTrackerManager) GetTracker(layer int32) streamtracker.StreamTrack
|
||||
s.lock.RLock()
|
||||
defer s.lock.RUnlock()
|
||||
|
||||
if int(layer) >= len(s.trackers) {
|
||||
if layer < 0 || int(layer) >= len(s.trackers) {
|
||||
s.logger.Errorw("unexpected layer", nil, "layer", layer)
|
||||
return nil
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user