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

normalize logs.

Browse Source
This commit is contained in:
Miroslav Šedivý 2020-11-13 17:42:04 +01:00
parent dd8867615e
commit ff97242bac
3 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
internal/capture/broadcast.go
View File

@ -15,7 +15,7 @@ func (manager *CaptureManagerCtx) StartBroadcastPipeline() {
Str("audio_device", manager.config.Device). Str("audio_device", manager.config.Device).
Str("video_display", manager.config.Display). Str("video_display", manager.config.Display).
Str("broadcast_pipeline", manager.config.BroadcastPipeline). Str("broadcast_pipeline", manager.config.BroadcastPipeline).
Msgf("Creating broadcast pipeline...") Msgf("creating broadcast pipeline")
manager.broadcast, err = gst.CreateRTMPPipeline( manager.broadcast, err = gst.CreateRTMPPipeline(
manager.config.Device, manager.config.Device,
@ -29,7 +29,7 @@ func (manager *CaptureManagerCtx) StartBroadcastPipeline() {
} }
manager.broadcast.Play() manager.broadcast.Play()
manager.logger.Info().Msgf("Starting broadcast pipeline...") manager.logger.Info().Msgf("starting broadcast pipeline")
} }
func (manager *CaptureManagerCtx) StopBroadcastPipeline() { func (manager *CaptureManagerCtx) StopBroadcastPipeline() {
@ -38,7 +38,7 @@ func (manager *CaptureManagerCtx) StopBroadcastPipeline() {
} }
manager.broadcast.Stop() manager.broadcast.Stop()
manager.logger.Info().Msgf("Stopping broadcast pipeline...") manager.logger.Info().Msgf("stopping broadcast pipeline")
manager.broadcast = nil manager.broadcast = nil
} }

2
internal/capture/manager.go
View File

@ -129,7 +129,7 @@ func (manager *CaptureManagerCtx) createVideoPipeline() {
manager.logger.Info(). manager.logger.Info().
Str("src", manager.video.Src). Str("src", manager.video.Src).
Msgf("starting video pipeline...") Msgf("starting video pipeline")
manager.video.Start() manager.video.Start()

4
internal/desktop/manager.go
View File

@ -41,7 +41,7 @@ func (manager *DesktopManagerCtx) Start() {
manager.logger.Info(). manager.logger.Info().
Str("screen_size", fmt.Sprintf("%dx%d@%d", manager.config.ScreenWidth, manager.config.ScreenHeight, manager.config.ScreenRate)). Str("screen_size", fmt.Sprintf("%dx%d@%d", manager.config.ScreenWidth, manager.config.ScreenHeight, manager.config.ScreenRate)).
Msgf("Setting initial screen size...") Msgf("setting initial screen size")
if err := xorg.ChangeScreenSize(manager.config.ScreenWidth, manager.config.ScreenHeight, manager.config.ScreenRate); err != nil { if err := xorg.ChangeScreenSize(manager.config.ScreenWidth, manager.config.ScreenHeight, manager.config.ScreenRate); err != nil {
manager.logger.Warn().Err(err).Msg("unable to set initial screen size") manager.logger.Warn().Err(err).Msg("unable to set initial screen size")
@ -77,7 +77,7 @@ func (manager *DesktopManagerCtx) OnAfterScreenSizeChange(listener func()) {
} }
func (manager *DesktopManagerCtx) Shutdown() error { func (manager *DesktopManagerCtx) Shutdown() error {
manager.logger.Info().Msgf("remote shutting down") manager.logger.Info().Msgf("desktop shutting down")
manager.cleanup.Stop() manager.cleanup.Stop()
manager.shutdown <- true manager.shutdown <- true