gilles/go2rtc
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix GetMedias on stream reconnection issue

Browse Source
This commit is contained in:
Alexey Khit
2023-03-26 08:09:54 +03:00
parent 5c164de393
commit 8241af8b9d
1 changed files with 8 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
cmd/streams/producer.go
+8 -6
View File
@@ -171,8 +171,8 @@ func (p *Producer) reconnect(workerID, retry int) {
log.Debug().Msgf("[streams] retry=%d to url=%s", retry, p.url) log.Debug().Msgf("[streams] retry=%d to url=%s", retry, p.url)
var err error conn, err := GetProducer(p.url)
if p.conn, err = GetProducer(p.url); err != nil { if err != nil {
log.Debug().Msgf("[streams] producer=%s", err) log.Debug().Msgf("[streams] producer=%s", err)
timeout := time.Minute timeout := time.Minute
@@ -190,7 +190,7 @@ func (p *Producer) reconnect(workerID, retry int) {
return return
} }
for _, media := range p.conn.GetMedias() { for _, media := range conn.GetMedias() {
switch media.Direction { switch media.Direction {
case core.DirectionRecvonly: case core.DirectionRecvonly:
for _, receiver := range p.receivers { for _, receiver := range p.receivers {
@@ -199,7 +199,7 @@ func (p *Producer) reconnect(workerID, retry int) {
continue continue
} }
track, err := p.conn.GetTrack(media, codec) track, err := conn.GetTrack(media, codec)
if err != nil { if err != nil {
continue continue
} }
@@ -215,12 +215,14 @@ func (p *Producer) reconnect(workerID, retry int) {
continue continue
} }
_ = p.conn.(core.Consumer).AddTrack(media, codec, sender) _ = conn.(core.Consumer).AddTrack(media, codec, sender)
} }
} }
} }
go p.worker(p.conn, workerID) p.conn = conn
go p.worker(conn, workerID)
} }
func (p *Producer) stop() { func (p *Producer) stop() {