From 8e80ef2c694e5ca9f99e0df60e6e07438497e8e4 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Miroslav=20=C5=A0ediv=C3=BD?= <sedivy.miro@gmail.com>
Date: Sat, 25 Jun 2022 23:53:19 +0200
Subject: [PATCH] streamsrc mutex.

---
 internal/capture/streamsrc.go | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/internal/capture/streamsrc.go b/internal/capture/streamsrc.go
index e31f2834..3c3aef17 100644
--- a/internal/capture/streamsrc.go
+++ b/internal/capture/streamsrc.go
@@ -39,6 +39,7 @@ func streamSrcNew(enabled bool, codecPipeline map[string]string, video_id string
 	pushedData := map[string]prometheus.Summary{}
 	pipelinesCounter := map[string]prometheus.Counter{}
 	pipelinesActive := map[string]prometheus.Gauge{}
+
 	for codecName, pipeline := range codecPipeline {
 		codec, ok := codec.ParseStr(codecName)
 		if !ok {
@@ -103,6 +104,9 @@ func (manager *StreamSrcManagerCtx) shutdown() {
 }
 
 func (manager *StreamSrcManagerCtx) Codec() codec.RTPCodec {
+	manager.pipelineMu.Lock()
+	defer manager.pipelineMu.Unlock()
+
 	return manager.codec
 }