From e37f5c13ca8971eff85b60d71e980c5e2b689fd4 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Miroslav=20=C5=A0ediv=C3=BD?= Date: Mon, 4 Jul 2022 18:03:35 +0200 Subject: [PATCH] fix bug. --- internal/capture/streamsrc.go | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/internal/capture/streamsrc.go b/internal/capture/streamsrc.go index 3c3aef17..59e2632b 100644 --- a/internal/capture/streamsrc.go +++ b/internal/capture/streamsrc.go @@ -94,6 +94,7 @@ func streamSrcNew(enabled bool, codecPipeline map[string]string, video_id string // metrics pushedData: pushedData, pipelinesCounter: pipelinesCounter, + pipelinesActive: pipelinesActive, } } @@ -166,9 +167,13 @@ func (manager *StreamSrcManagerCtx) Stop() { } manager.pipeline.Destroy() - manager.logger.Info().Msgf("destroying pipeline") manager.pipeline = nil + manager.logger.Info(). + Str("codec", manager.codec.Name). + Str("src", manager.pipelineStr). + Msgf("destroying pipeline") + manager.pipelinesActive[manager.codec.Name].Set(0) }