OPC/mediamtx
2
0
Fork 0
Code Issues 3 Pull Requests Actions Packages Projects Releases Wiki Activity

add missing Start() call; fix wrong sprintf (#4369)

Browse Source
This commit is contained in:
Alessandro Ros
2025-03-26 12:47:09 +01:00
committed by GitHub
parent 986e270862
commit f851cb6961
7 changed files with 10 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/servers/rtsp/session.go
+1 -1
View File
@@ -68,7 +68,7 @@ func (s *session) initialize() {
s.decodeErrors = &counterdumper.CounterDumper{
OnReport: func(val uint64) {
s.Log(logger.Warn, "%s decode %s",
s.Log(logger.Warn, "%d decode %s",
val,
func() string {
if val == 1 {
internal/servers/srt/conn.go
+1 -1
View File
@@ -210,7 +210,7 @@ func (c *conn) runPublishReader(sconn srt.Conn, path defs.Path) error {
decodeErrors := &counterdumper.CounterDumper{
OnReport: func(val uint64) {
c.Log(logger.Warn, "%s decode %s",
c.Log(logger.Warn, "%d decode %s",
val,
func() string {
if val == 1 {
internal/staticsources/hls/source.go
+1 -1
View File
@@ -40,7 +40,7 @@ func (s *Source) Run(params defs.StaticSourceRunParams) error {
decodeErrors := &counterdumper.CounterDumper{
OnReport: func(val uint64) {
s.Log(logger.Warn, "%s decode %s",
s.Log(logger.Warn, "%d decode %s",
val,
func() string {
if val == 1 {
internal/staticsources/rtsp/source.go
+1 -1
View File
@@ -96,7 +96,7 @@ func (s *Source) Run(params defs.StaticSourceRunParams) error {
decodeErrors := &counterdumper.CounterDumper{
OnReport: func(val uint64) {
s.Log(logger.Warn, "%s decode %s",
s.Log(logger.Warn, "%d decode %s",
val,
func() string {
if val == 1 {
internal/staticsources/srt/source.go
+1 -1
View File
@@ -78,7 +78,7 @@ func (s *Source) runReader(sconn srt.Conn) error {
decodeErrors := &counterdumper.CounterDumper{
OnReport: func(val uint64) {
s.Log(logger.Warn, "%s decode %s",
s.Log(logger.Warn, "%d decode %s",
val,
func() string {
if val == 1 {
internal/staticsources/udp/source.go
+1 -1
View File
@@ -115,7 +115,7 @@ func (s *Source) runReader(pc net.PacketConn) error {
decodeErrors := &counterdumper.CounterDumper{
OnReport: func(val uint64) {
s.Log(logger.Warn, "%s decode %s",
s.Log(logger.Warn, "%d decode %s",
val,
func() string {
if val == 1 {
internal/stream/stream.go
+4 -1
View File
@@ -55,7 +55,7 @@ func (s *Stream) Initialize() error {
s.decodeErrors = &counterdumper.CounterDumper{
OnReport: func(val uint64) {
s.Parent.Log(logger.Warn, "%s decode %s",
s.Parent.Log(logger.Warn, "%d decode %s",
val,
func() string {
if val == 1 {
@@ -65,6 +65,7 @@ func (s *Stream) Initialize() error {
}())
},
}
s.decodeErrors.Start()
for _, media := range s.Desc.Medias {
s.streamMedias[media] = &streamMedia{
@@ -84,6 +85,8 @@ func (s *Stream) Initialize() error {
// Close closes all resources of the stream.
func (s *Stream) Close() {
s.decodeErrors.Stop()
if s.rtspStream != nil {
s.rtspStream.Close()
}