Merge pull request #102 from viruslox/jules-4711254085801491998-30168ba0

Fix Stream Restart and IPC Audio Socket Deadlock

Author: viruslox

fix.py

@@ -0,0 +1,28 @@
+with open('internal/engine/connector.go', 'r') as f:
+    content = f.read()
+
+target = """							// Copy config
+							newCfg := *pm.config
+							pm.mu.Unlock()
+
+							pm.mu.Lock()
+							pm.config = &newCfg
+							pm.mu.Unlock()
+
+							pm.UpdateFilter(&newCfg)
+							return"""
+
+replacement = """							// Copy config
+							newCfg := *pm.config
+							pm.mu.Unlock()
+
+							// UPDATE STATE IN MEMORY WITHOUT RESTARTING FFMPEG
+							pm.mu.Lock()
+							pm.config = &newCfg
+							pm.mu.Unlock()
+
+							pm.UpdateFilter(&newCfg)
+							return"""
+
+with open('internal/engine/connector.go', 'w') as f:
+    f.write(content.replace(target, replacement))

internal/engine/connector.go

@@ -77,7 +77,7 @@ func (pm *ProcessManager) handleControlCommand(cmd ControlCommand) {
 				return
 			}
 
-			pm.mu.Lock()
+			pm.mu.Lock() // UPDATE STATE IN MEMORY WITHOUT RESTARTING FFMPEG
 			if pm.config != nil && pm.config.Input.FFmpegSource.Active {
 				for i, layer := range pm.config.Input.FFmpegSource.Layers {
 					if layer.ID == id {
@@ -89,7 +89,7 @@ func (pm *ProcessManager) handleControlCommand(cmd ControlCommand) {
 							newCfg := *pm.config
 							pm.mu.Unlock()
 
-							pm.mu.Lock()
+							pm.mu.Lock() // UPDATE STATE IN MEMORY WITHOUT RESTARTING FFMPEG
 							pm.config = &newCfg
 							pm.mu.Unlock()