heal fix

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

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/src/ambianic/pipeline/avsource/av_element.py b/src/ambianic/pipeline/avsource/av_element.py
@@ -113,7 +113,7 @@ def _stop_gst_service(self):
             # the gst process from stopping
             self._clear_gst_out_queue()
             # give it a few seconds to stop cleanly
-            for i in range(3):
+            for i in range(10):
                 time.sleep(1)
                 if not gst_proc.is_alive():
                     break
@@ -124,7 +124,7 @@ def _stop_gst_service(self):
                 # do not call join() because it may cause a deadlock
                 # due to the shared queue
                 # give it a few seconds to terminate cleanly
-                for i in range(3):
+                for i in range(10):
                     time.sleep(1)
                     if not gst_proc.is_alive():
                         break

diff --git a/src/ambianic/pipeline/interpreter.py b/src/ambianic/pipeline/interpreter.py
@@ -61,7 +61,7 @@ def healthcheck(self):
                     # more than a reasonable amount of time has passed
                     # since the pipeline reported a heartbeat.
                     # Let's recycle it
-                elif lapse > 10:
+                elif lapse > 20:
                     log.warning('Pipeline "%s" is not responsive. '
                                 'Latest heartbeat was %f seconds ago. '
                                 'Will attempt to heal it.', p.name, lapse)