From 7d6bdb55534dd96a364f86bb96a16681f563335d Mon Sep 17 00:00:00 2001
From: Thulinma <jaron@vietors.com>
Date: Tue, 7 Nov 2017 11:09:27 +0100
Subject: [PATCH] Fixed left-over stream state problems

---
 src/input/input.cpp | 12 +++++++++++-
 1 file changed, 11 insertions(+), 1 deletion(-)

diff --git a/src/input/input.cpp b/src/input/input.cpp
index bafdfb8e..131a5ec8 100644
--- a/src/input/input.cpp
+++ b/src/input/input.cpp
@@ -118,13 +118,15 @@ namespace Mist {
       snprintf(pageName, NAME_BUFFER_SIZE, SHM_STREAM_STATE, streamName.c_str());
       streamStatus.init(pageName, 1, true, false);
       if (streamStatus){streamStatus.mapped[0] = STRMSTAT_INIT;}
+      streamStatus.master = false;
+      streamStatus.close();
     }
     config->activate();
     uint64_t reTimer = 0;
     while (config->is_active){
       pid_t pid = fork();
       if (pid == 0){
-        //Re-init streamStatus to fix Cygwin issues
+        //Re-init streamStatus, previously closed
         char pageName[NAME_BUFFER_SIZE];
         snprintf(pageName, NAME_BUFFER_SIZE, SHM_STREAM_STATE, streamName.c_str());
         streamStatus.init(pageName, 1, false, false);
@@ -152,6 +154,9 @@ namespace Mist {
         MEDIUM_MSG("Input for stream %s shut down cleanly", streamName.c_str());
         break;
       }
+      char pageName[NAME_BUFFER_SIZE];
+      snprintf(pageName, NAME_BUFFER_SIZE, SHM_STREAM_STATE, streamName.c_str());
+      streamStatus.init(pageName, 1, true, false);
       if (streamStatus){streamStatus.mapped[0] = STRMSTAT_INVALID;}
 #if DEBUG >= DLVL_DEVEL
       WARN_MSG("Aborting autoclean; this is a development build.");
@@ -169,6 +174,11 @@ namespace Mist {
       playerLock.unlink();
       playerLock.close();
     }
+    char pageName[NAME_BUFFER_SIZE];
+    snprintf(pageName, NAME_BUFFER_SIZE, SHM_STREAM_STATE, streamName.c_str());
+    streamStatus.init(pageName, 1, true, false);
+    streamStatus.close();
+    HIGH_MSG("Angel process for %s exiting", streamName.c_str());
     return 0;
   }