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

Update last error for reconnect stream

Browse Source
This commit is contained in:
Alexey Khit
2023-01-08 21:36:28 +03:00
parent 78ac88448c
commit bd2fc1252d
1 changed files with 5 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
cmd/streams/producer.go
+5 -6
View File
@@ -119,10 +119,9 @@ func (p *Producer) reconnect() {
log.Debug().Msgf("[streams] reconnect to url=%s", p.url) log.Debug().Msgf("[streams] reconnect to url=%s", p.url)
var err error p.element, p.lastErr = GetProducer(p.url)
p.element, err = GetProducer(p.url) if p.lastErr != nil || p.element == nil {
if err != nil || p.element == nil { log.Debug().Err(p.lastErr).Caller().Send()
log.Debug().Err(err).Caller().Send()
// TODO: dynamic timeout // TODO: dynamic timeout
p.restart = time.AfterFunc(30*time.Second, p.reconnect) p.restart = time.AfterFunc(30*time.Second, p.reconnect)
return return
@@ -149,8 +148,8 @@ func (p *Producer) reconnect() {
} }
go func() { go func() {
if err = p.element.Start(); err != nil { if err := p.element.Start(); err != nil {
log.Debug().Err(err).Str("url", p.url).Caller().Send() log.Debug().Err(err).Caller().Send()
} }
p.reconnect() p.reconnect()
}() }()