heal fix

ambianic · Sep 22, 2019 · a190f5a · a190f5a
1 parent e3b3bd5
commit a190f5a
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/src/ambianic/__init__.py b/src/ambianic/__init__.py
@@ -168,7 +168,8 @@ def _heartbeat():
         log.info('Service exit requested.')
         log.debug('Cleaning up before exit...')
         # Terminate the running threads.
-        # Set the shutdown flag on each thread to trigger a clean shutdown of each thread.
+        # Set the shutdown flag on each thread to trigger
+        # a clean shutdown of each thread.
         # j1.shutdown_flag.set()
         # j2.shutdown_flag.set()
         _stop_servers(servers)

diff --git a/src/ambianic/pipeline/avsource/gst_process.py b/src/ambianic/pipeline/avsource/gst_process.py
@@ -276,8 +276,7 @@ def _gst_cleanup(self):
 
     def _service_shutdown(self, signum, frame):
         log.info('GST service caught system shutdown signal %d', signum)
-        if not self._stop_signal.is_set():
-            self._stop_signal.set()
+        self._gst_cleanup()
 
     def _stop_handler(self):
         self._stop_signal.wait()