From c9b0806c8454e0dd847bca7d18b9ae5ae517e067 Mon Sep 17 00:00:00 2001 From: Alexey Khit Date: Sun, 8 Jan 2023 20:00:48 +0300 Subject: [PATCH] Add producer url to logs --- cmd/streams/producer.go | 6 +++--- cmd/streams/stream.go | 2 +- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/cmd/streams/producer.go b/cmd/streams/producer.go index fac46ab7..28109027 100644 --- a/cmd/streams/producer.go +++ b/cmd/streams/producer.go @@ -48,7 +48,7 @@ func (p *Producer) GetMedias() []*streamer.Media { p.element, p.lastErr = GetProducer(p.url) if p.lastErr != nil || p.element == nil { - log.Error().Err(p.lastErr).Caller().Send() + log.Error().Err(p.lastErr).Str("url", p.url).Caller().Send() return nil } @@ -102,7 +102,7 @@ func (p *Producer) start() { go func() { // safe read element while mu locked if err := p.element.Start(); err != nil { - log.Warn().Err(err).Caller().Send() + log.Warn().Err(err).Str("url", p.url).Caller().Send() } p.reconnect() }() @@ -150,7 +150,7 @@ func (p *Producer) reconnect() { go func() { if err = p.element.Start(); err != nil { - log.Debug().Err(err).Caller().Send() + log.Debug().Err(err).Str("url", p.url).Caller().Send() } p.reconnect() }() diff --git a/cmd/streams/stream.go b/cmd/streams/stream.go index 99a9b946..ac998cb5 100644 --- a/cmd/streams/stream.go +++ b/cmd/streams/stream.go @@ -82,7 +82,7 @@ func (s *Stream) AddConsumer(cons streamer.Consumer) (err error) { // Step 4. Get producer track prodTrack := prod.GetTrack(prodMedia, prodCodec) if prodTrack == nil { - log.Warn().Msg("[stream] can't get track") + log.Warn().Str("url", prod.url).Msg("[stream] can't get track") continue }