Fix loopback for stream

2022-11-02 08:51:54 +03:00
parent 2629dccb81
commit 3d4514eab9
1 changed files with 7 additions and 7 deletions
@@ -59,10 +59,6 @@ func (p *Producer) GetTrack(media *streamer.Media, codec *streamer.Codec) *strea
 	p.mx.Lock()
 	defer p.mx.Unlock()

-	if p.state == stateMedias {
-		p.state = stateTracks
-	}
-
 	track := p.element.GetTrack(media, codec)
 	if track == nil {
 		return nil
@@ -74,6 +70,10 @@ func (p *Producer) GetTrack(media *streamer.Media, codec *streamer.Codec) *strea
 		}
 	}

+	if p.state == stateMedias {
+		p.state = stateTracks
+	}
+
 	p.tracks = append(p.tracks, track)

 	return track
@@ -82,13 +82,13 @@ func (p *Producer) GetTrack(media *streamer.Media, codec *streamer.Codec) *strea
 // internals

 func (p *Producer) start() {
-	p.mx.Lock()
-	defer p.mx.Unlock()
-
 	if p.state != stateTracks {
 		return
 	}

+	p.mx.Lock()
+	defer p.mx.Unlock()
+
 	log.Debug().Str("url", p.url).Msg("[streams] start producer")

 	p.state = stateStart