iridium/neko
2
2
Fork 0
mirror of https://github.com/m1k1o/neko.git synced 2024-07-24 14:40:50 +12:00
Code Issues Packages Projects Releases Wiki Activity

fix gst log.

Browse Source
This commit is contained in:
Miroslav Šedivý 2021-12-05 21:33:30 +01:00
parent f9fe303b50
commit 8de5cb2f4a
1 changed files with 6 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
internal/capture/gst/gst.go
View File

@ -135,7 +135,8 @@ func goHandlePipelineBuffer(buffer unsafe.Pointer, bufferLen C.int, duration C.i
log.Warn(). log.Warn().
Str("module", "capture"). Str("module", "capture").
Str("submodule", "gstreamer"). Str("submodule", "gstreamer").
Msgf("discarding sample, no pipeline with id %d", int(pipelineID)) Int("pipeline-id", int(pipelineID)).
Msgf("discarding sample, pipeline not found")
} }
} }
@ -144,21 +145,10 @@ func goPipelineLog(levelUnsafe *C.char, msgUnsafe *C.char, pipelineID C.int) {
levelStr := C.GoString(levelUnsafe) levelStr := C.GoString(levelUnsafe)
msg := C.GoString(msgUnsafe) msg := C.GoString(msgUnsafe)
logger := log.With(). level, _ := zerolog.ParseLevel(levelStr)
log.WithLevel(level).
Str("module", "capture"). Str("module", "capture").
Str("submodule", "gstreamer"). Str("submodule", "gstreamer").
Logger() Int("pipeline-id", int(pipelineID)).
Msg(msg)
pipelinesLock.Lock()
pipeline, ok := pipelines[int(pipelineID)]
pipelinesLock.Unlock()
if ok {
logger = logger.With().
Int("id", pipeline.id).
Logger()
}
level, _ := zerolog.ParseLevel(levelStr)
logger.WithLevel(level).Msg(msg)
} }