emergency rate drop, stage 1

4 years ago · 597f58c73a
parent 5fcd97fffd
commit 597f58c73a
1 changed files with 6 additions and 0 deletions
--- a/bridge_master.py
+++ b/bridge_master.py
@ -1703,6 +1703,12 @@ class routerOBP(OPENBRIDGE):
                        systems[self._system].send_bcsq(_dst_id,_stream_id)
                        self.STATUS[_stream_id]['_bcsq'] = True
                    return
+                
+                #Rate drop
+                if self.STATUS[_stream_id]['packets'] > 18 and (self.STATUS[_stream_id]['packets'] / self.STATUS[_stream_id]['START'] > 25):
+                    logger.warning("(%s) *PacketControl* RATE DROP! Stream ID:, %s TGID: %s",self._system,int_id(_stream_id),int_id(_dst_id))
+                    return
+                
                        
                #Duplicate handling#
                #Handle inbound duplicates