apps/engine
1
0
Fork 0
mirror of https://github.com/Monibuca/engine.git synced 2025-11-03 02:43:32 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix: remove additional logFeild stream

Browse Source
This commit is contained in:
langhuihui
2023-11-10 18:16:28 +08:00
parent ebf81cf963
commit 2f4a65afd5
2 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
io.go
View File

@@ -192,7 +192,6 @@ func (io *IO) receive(streamPath string, specific IIO) error {
logFeilds = append(logFeilds, zap.String("ID", io.ID)) logFeilds = append(logFeilds, zap.String("ID", io.ID))
} }
if io.Logger == nil { if io.Logger == nil {
logFeilds = append(logFeilds, zap.String("stream", s.Path))
io.Logger = s.With(logFeilds...) io.Logger = s.With(logFeilds...)
} else { } else {
io.Logger = io.Logger.With(logFeilds...) io.Logger = io.Logger.With(logFeilds...)

2
plugin.go
View File

@@ -354,7 +354,7 @@ var ErrNoPushConfig = errors.New("no push config")
var Pushers sync.Map var Pushers sync.Map
func (opt *Plugin) Push(streamPath string, url string, pusher IPusher, save bool) (err error) { func (opt *Plugin) Push(streamPath string, url string, pusher IPusher, save bool) (err error) {
zp, zu := zap.String("path", streamPath), zap.String("url", url) zp, zu := zap.String("stream", streamPath), zap.String("url", url)
opt.Info("push", zp, zu) opt.Info("push", zp, zu)
defer func() { defer func() {
if err != nil { if err != nil {