From c57f6ddbb0bf7057828a8b22d79c1e105c7e008a Mon Sep 17 00:00:00 2001 From: Simon Date: Thu, 15 Apr 2021 18:59:56 +0100 Subject: [PATCH] KA commity --- bridge_master.py | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/bridge_master.py b/bridge_master.py index e6f588a..69e5e2a 100755 --- a/bridge_master.py +++ b/bridge_master.py @@ -1101,6 +1101,11 @@ class routerOBP(OPENBRIDGE): if ('_bcsq' in _target_system) and (_dst_id in _target_system['_bcsq']) and (_target_system['_bcsq'][_dst_id] == _stream_id): #logger.info('(%s) Conference Bridge: %s, is Source Quenched for Stream ID: %s, skipping system: %s TS: %s, TGID: %s', self._system, _bridge, int_id(_stream_id), _target['SYSTEM'], _target['TS'], int_id(_target['TGID'])) continue + + #If target has missed 6 (on 1 min) of keepalives, don't send + if _target_system['ENHANCED_OBP'] and '_bcka' in _target_system and _target_system['_bcka'] < _pkt_time - 60: + logger.debug('**************************') + continue # Is this a new call stream on the target? @@ -1449,7 +1454,10 @@ class routerHBP(HBSYSTEM): if ('_bcsq' in _target_system) and (_dst_id in _target_system['_bcsq']) and (_target_system['_bcsq'][_target['TGID']] == _stream_id): #logger.info('(%s) Conference Bridge: %s, is Source Quenched for Stream ID: %s, skipping system: %s TS: %s, TGID: %s', self._system, _bridge, int_id(_stream_id), _target['SYSTEM'], _target['TS'], int_id(_target['TGID'])) continue - + + #If target has missed 6 (on 1 min) of keepalives, don't send + if _target_system['ENHANCED_OBP'] and '_bcka' in _target_system and _target_system['_bcka'] < _pkt_time - 60: + continue # Is this a new call stream on the target? if (_stream_id not in _target_status):