Browse Source

make logs more clear

pull/858/head
aler9 4 years ago
parent
commit
507afbf73d
  1. 4
      internal/core/hls_muxer.go
  2. 4
      internal/core/path.go
  3. 4
      internal/core/path_manager.go
  4. 4
      internal/core/rtsp_session.go

4
internal/core/hls_muxer.go

@ -185,7 +185,7 @@ func newHLSMuxer( @@ -185,7 +185,7 @@ func newHLSMuxer(
hlsServerAPIMuxersList: make(chan hlsServerAPIMuxersListSubReq),
}
m.log(logger.Info, "opened")
m.log(logger.Info, "created")
m.wg.Add(1)
go m.run()
@ -261,7 +261,7 @@ func (m *hlsMuxer) run() { @@ -261,7 +261,7 @@ func (m *hlsMuxer) run() {
m.parent.onMuxerClose(m)
m.log(logger.Info, "closed (%v)", err)
m.log(logger.Info, "destroyed (%v)", err)
}
func (m *hlsMuxer) runInner(innerCtx context.Context, innerReady chan struct{}) error {

4
internal/core/path.go

@ -303,7 +303,7 @@ func newPath( @@ -303,7 +303,7 @@ func newPath(
apiPathsList: make(chan pathAPIPathsListSubReq),
}
pa.log(logger.Debug, "opened")
pa.log(logger.Debug, "created")
pa.wg.Add(1)
go pa.run()
@ -492,7 +492,7 @@ func (pa *path) run() { @@ -492,7 +492,7 @@ func (pa *path) run() {
pa.log(logger.Info, "runOnDemand command stopped")
}
pa.log(logger.Debug, "closed (%v)", err)
pa.log(logger.Debug, "destroyed (%v)", err)
pa.parent.onPathClose(pa)
}

4
internal/core/path_manager.go

@ -92,7 +92,7 @@ func newPathManager( @@ -92,7 +92,7 @@ func newPathManager(
pm.metrics.onPathManagerSet(pm)
}
pm.log(logger.Debug, "path manager opened")
pm.log(logger.Debug, "path manager created")
pm.wg.Add(1)
go pm.run()
@ -101,7 +101,7 @@ func newPathManager( @@ -101,7 +101,7 @@ func newPathManager(
}
func (pm *pathManager) close() {
pm.log(logger.Debug, "path manager is closing")
pm.log(logger.Debug, "path manager is shutting down")
pm.ctxCancel()
pm.wg.Wait()
}

4
internal/core/rtsp_session.go

@ -69,7 +69,7 @@ func newRTSPSession( @@ -69,7 +69,7 @@ func newRTSPSession(
parent: parent,
}
s.log(logger.Info, "opened by %v", s.author.NetConn().RemoteAddr())
s.log(logger.Info, "created by %v", s.author.NetConn().RemoteAddr())
return s
}
@ -122,7 +122,7 @@ func (s *rtspSession) onClose(err error) { @@ -122,7 +122,7 @@ func (s *rtspSession) onClose(err error) {
s.path = nil
}
s.log(logger.Info, "closed (%v)", err)
s.log(logger.Info, "destroyed (%v)", err)
}
// onAnnounce is called by rtspServer.

Loading…
Cancel
Save