From ca499a27c3d471354d1a32d7bdd24b2deae63d74 Mon Sep 17 00:00:00 2001
From: aler9 <46489434+aler9@users.noreply.github.com>
Date: Wed, 18 Aug 2021 15:43:56 +0200
Subject: [PATCH] remove stats from rtmp and rtsp source

---
 internal/core/path.go        | 2 --
 internal/core/rtmp_source.go | 3 ---
 internal/core/rtsp_source.go | 3 ---
 3 files changed, 8 deletions(-)

diff --git a/internal/core/path.go b/internal/core/path.go
index 409751d8..cb06db59 100644
--- a/internal/core/path.go
+++ b/internal/core/path.go
@@ -589,7 +589,6 @@ func (pa *path) staticSourceCreate() {
 			pa.readBufferCount,
 			pa.readBufferSize,
 			&pa.sourceStaticWg,
-			pa.stats,
 			pa)
 	} else if strings.HasPrefix(pa.conf.Source, "rtmp://") {
 		pa.source = newRTMPSource(
@@ -598,7 +597,6 @@ func (pa *path) staticSourceCreate() {
 			pa.readTimeout,
 			pa.writeTimeout,
 			&pa.sourceStaticWg,
-			pa.stats,
 			pa)
 	}
 }
diff --git a/internal/core/rtmp_source.go b/internal/core/rtmp_source.go
index 9a4793b2..34ed9cd2 100644
--- a/internal/core/rtmp_source.go
+++ b/internal/core/rtmp_source.go
@@ -32,7 +32,6 @@ type rtmpSource struct {
 	readTimeout  time.Duration
 	writeTimeout time.Duration
 	wg           *sync.WaitGroup
-	stats        *stats
 	parent       rtmpSourceParent
 
 	ctx       context.Context
@@ -45,7 +44,6 @@ func newRTMPSource(
 	readTimeout time.Duration,
 	writeTimeout time.Duration,
 	wg *sync.WaitGroup,
-	stats *stats,
 	parent rtmpSourceParent) *rtmpSource {
 	ctx, ctxCancel := context.WithCancel(parentCtx)
 
@@ -54,7 +52,6 @@ func newRTMPSource(
 		readTimeout:  readTimeout,
 		writeTimeout: writeTimeout,
 		wg:           wg,
-		stats:        stats,
 		parent:       parent,
 		ctx:          ctx,
 		ctxCancel:    ctxCancel,
diff --git a/internal/core/rtsp_source.go b/internal/core/rtsp_source.go
index 465b7a26..d3045e78 100644
--- a/internal/core/rtsp_source.go
+++ b/internal/core/rtsp_source.go
@@ -36,7 +36,6 @@ type rtspSource struct {
 	readBufferCount int
 	readBufferSize  int
 	wg              *sync.WaitGroup
-	stats           *stats
 	parent          rtspSourceParent
 
 	ctx       context.Context
@@ -54,7 +53,6 @@ func newRTSPSource(
 	readBufferCount int,
 	readBufferSize int,
 	wg *sync.WaitGroup,
-	stats *stats,
 	parent rtspSourceParent) *rtspSource {
 	ctx, ctxCancel := context.WithCancel(parentCtx)
 
@@ -68,7 +66,6 @@ func newRTSPSource(
 		readBufferCount: readBufferCount,
 		readBufferSize:  readBufferSize,
 		wg:              wg,
-		stats:           stats,
 		parent:          parent,
 		ctx:             ctx,
 		ctxCancel:       ctxCancel,