Add finished stream detection to OBP

2021-04-01 00:45:38 +01:00 · 2021-04-01 00:45:38 +01:00 · 1161787c8d
parent e83c148932
commit 1161787c8d
1 changed files with 4 additions and 0 deletions
--- a/bridge_master.py
+++ b/bridge_master.py
@ -1259,6 +1259,10 @@ class routerOBP(OPENBRIDGE):

            else:
                
+               if '_fin' in self.STATUS[_stream_id]:
+                   logger.warning("(%s) OBP *LoopControl* STREAM ID: %s ALREADY FINISHED FROM THIS SOURCE, IGNORING",self._system, int_id(_stream_id))
+                   return
+               
               # Loop Control

                for system in systems: