|
|
|
@ -363,7 +363,6 @@ def deactivate_all_dynamic_bridges(system_name):
|
|
|
|
|
|
|
|
|
|
|
|
### MODIFIED: Core logic updated to handle special TGIDs (9990-9999) correctly with SINGLE_MODE
|
|
|
|
### MODIFIED: Core logic updated to handle special TGIDs (9990-9999) correctly with SINGLE_MODE
|
|
|
|
def rule_timer_loop():
|
|
|
|
def rule_timer_loop():
|
|
|
|
logger.debug('(ROUTER) routerHBP Rule timer loop started')
|
|
|
|
|
|
|
|
_now = time()
|
|
|
|
_now = time()
|
|
|
|
_remove_bridges = deque()
|
|
|
|
_remove_bridges = deque()
|
|
|
|
|
|
|
|
|
|
|
|
@ -402,9 +401,9 @@ def rule_timer_loop():
|
|
|
|
if _system['SYSTEM'] not in _active_dynamic_bridges:
|
|
|
|
if _system['SYSTEM'] not in _active_dynamic_bridges:
|
|
|
|
_active_dynamic_bridges[_system['SYSTEM']] = []
|
|
|
|
_active_dynamic_bridges[_system['SYSTEM']] = []
|
|
|
|
_active_dynamic_bridges[_system['SYSTEM']].append((_bridge, _system))
|
|
|
|
_active_dynamic_bridges[_system['SYSTEM']].append((_bridge, _system))
|
|
|
|
logger.debug('(ROUTER) Conference Bridge ACTIVE (INFINITE TIMER): System: %s Bridge: %s, TS: %s, TGID: %s', _system['SYSTEM'], _bridge, _system['TS'], int_id(_system['TGID']))
|
|
|
|
pass
|
|
|
|
else:
|
|
|
|
else:
|
|
|
|
logger.debug('(ROUTER) Conference Bridge INACTIVE (no change): System: %s Bridge: %s, TS: %s, TGID: %s', _system['SYSTEM'], _bridge, _system['TS'], int_id(_system['TGID']))
|
|
|
|
pass
|
|
|
|
elif _system['TO_TYPE'] == 'OFF':
|
|
|
|
elif _system['TO_TYPE'] == 'OFF':
|
|
|
|
if _system['ACTIVE'] == False:
|
|
|
|
if _system['ACTIVE'] == False:
|
|
|
|
# Activar inmediatamente sin timer
|
|
|
|
# Activar inmediatamente sin timer
|
|
|
|
@ -413,7 +412,6 @@ def rule_timer_loop():
|
|
|
|
logger.info('(ROUTER) Conference Bridge ACTIVATED (NO TIMEOUT): System: %s, Bridge: %s, TS: %s, TGID: %s', _system['SYSTEM'], _bridge, _system['TS'], int_id(_system['TGID']))
|
|
|
|
logger.info('(ROUTER) Conference Bridge ACTIVATED (NO TIMEOUT): System: %s, Bridge: %s, TS: %s, TGID: %s', _system['SYSTEM'], _bridge, _system['TS'], int_id(_system['TGID']))
|
|
|
|
else:
|
|
|
|
else:
|
|
|
|
_bridge_used = True
|
|
|
|
_bridge_used = True
|
|
|
|
logger.debug('(ROUTER) Conference Bridge ACTIVE (no change): System: %s Bridge: %s, TS: %s, TGID: %s', _system['SYSTEM'], _bridge, _system['TS'], int_id(_system['TGID']))
|
|
|
|
|
|
|
|
else:
|
|
|
|
else:
|
|
|
|
# COMPORTAMIENTO ORIGINAL (SINGLE MODE ACTIVADO o bridges estáticos o TGIDs especiales)
|
|
|
|
# COMPORTAMIENTO ORIGINAL (SINGLE MODE ACTIVADO o bridges estáticos o TGIDs especiales)
|
|
|
|
if _system['TO_TYPE'] == 'ON':
|
|
|
|
if _system['TO_TYPE'] == 'ON':
|
|
|
|
@ -429,7 +427,7 @@ def rule_timer_loop():
|
|
|
|
_bridge_used = True
|
|
|
|
_bridge_used = True
|
|
|
|
logger.info('(ROUTER) Conference Bridge ACTIVE (ON timer running): System: %s Bridge: %s, TS: %s, TGID: %s, Timeout in: %.2fs,', _system['SYSTEM'], _bridge, _system['TS'], int_id(_system['TGID']), timeout_in)
|
|
|
|
logger.info('(ROUTER) Conference Bridge ACTIVE (ON timer running): System: %s Bridge: %s, TS: %s, TGID: %s, Timeout in: %.2fs,', _system['SYSTEM'], _bridge, _system['TS'], int_id(_system['TGID']), timeout_in)
|
|
|
|
elif _system['ACTIVE'] == False:
|
|
|
|
elif _system['ACTIVE'] == False:
|
|
|
|
logger.debug('(ROUTER) Conference Bridge INACTIVE (no change): System: %s Bridge: %s, TS: %s, TGID: %s', _system['SYSTEM'], _bridge, _system['TS'], int_id(_system['TGID']))
|
|
|
|
pass
|
|
|
|
elif _system['TO_TYPE'] == 'OFF':
|
|
|
|
elif _system['TO_TYPE'] == 'OFF':
|
|
|
|
if _system['ACTIVE'] == False:
|
|
|
|
if _system['ACTIVE'] == False:
|
|
|
|
if _system['TIMER'] < _now:
|
|
|
|
if _system['TIMER'] < _now:
|
|
|
|
@ -442,13 +440,11 @@ def rule_timer_loop():
|
|
|
|
logger.info('(ROUTER) Conference Bridge INACTIVE (OFF timer running): System: %s Bridge: %s, TS: %s, TGID: %s, Timeout in: %.2fs,', _system['SYSTEM'], _bridge, _system['TS'], int_id(_system['TGID']), timeout_in)
|
|
|
|
logger.info('(ROUTER) Conference Bridge INACTIVE (OFF timer running): System: %s Bridge: %s, TS: %s, TGID: %s, Timeout in: %.2fs,', _system['SYSTEM'], _bridge, _system['TS'], int_id(_system['TGID']), timeout_in)
|
|
|
|
elif _system['ACTIVE'] == True:
|
|
|
|
elif _system['ACTIVE'] == True:
|
|
|
|
_bridge_used = True
|
|
|
|
_bridge_used = True
|
|
|
|
logger.debug('(ROUTER) Conference Bridge ACTIVE (no change): System: %s Bridge: %s, TS: %s, TGID: %s', _system['SYSTEM'], _bridge, _system['TS'], int_id(_system['TGID']))
|
|
|
|
|
|
|
|
else:
|
|
|
|
else:
|
|
|
|
if _system['SYSTEM'][0:3] != 'OBP':
|
|
|
|
if _system['SYSTEM'][0:3] != 'OBP':
|
|
|
|
_bridge_used = True
|
|
|
|
_bridge_used = True
|
|
|
|
elif _system['SYSTEM'][0:3] == 'OBP' and _system['TO_TYPE'] == 'STAT':
|
|
|
|
elif _system['SYSTEM'][0:3] == 'OBP' and _system['TO_TYPE'] == 'STAT':
|
|
|
|
_bridge_used = True
|
|
|
|
_bridge_used = True
|
|
|
|
logger.debug('(ROUTER) Conference Bridge NO ACTION: System: %s, Bridge: %s, TS: %s, TGID: %s', _system['SYSTEM'], _bridge, _system['TS'], int_id(_system['TGID']))
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if _bridge_used == False:
|
|
|
|
if _bridge_used == False:
|
|
|
|
_remove_bridges.append(_bridge)
|
|
|
|
_remove_bridges.append(_bridge)
|
|
|
|
@ -463,7 +459,7 @@ def rule_timer_loop():
|
|
|
|
### END MODIFIED ###
|
|
|
|
### END MODIFIED ###
|
|
|
|
|
|
|
|
|
|
|
|
def statTrimmer():
|
|
|
|
def statTrimmer():
|
|
|
|
logger.debug('(ROUTER) STAT trimmer loop started')
|
|
|
|
pass
|
|
|
|
_remove_bridges = deque()
|
|
|
|
_remove_bridges = deque()
|
|
|
|
for _bridge in BRIDGES:
|
|
|
|
for _bridge in BRIDGES:
|
|
|
|
_bridge_stat = False
|
|
|
|
_bridge_stat = False
|
|
|
|
@ -543,7 +539,7 @@ def bridgeDebug():
|
|
|
|
logger.info('(BRIDGEDEBUG) The server currently has %s STATic bridges',statroll)
|
|
|
|
logger.info('(BRIDGEDEBUG) The server currently has %s STATic bridges',statroll)
|
|
|
|
|
|
|
|
|
|
|
|
def kaReporting():
|
|
|
|
def kaReporting():
|
|
|
|
logger.debug('(ROUTER) KeepAlive reporting loop started')
|
|
|
|
pass
|
|
|
|
for system in systems:
|
|
|
|
for system in systems:
|
|
|
|
if CONFIG['SYSTEMS'][system]['MODE'] == 'OPENBRIDGE':
|
|
|
|
if CONFIG['SYSTEMS'][system]['MODE'] == 'OPENBRIDGE':
|
|
|
|
if CONFIG['SYSTEMS'][system]['ENHANCED_OBP']:
|
|
|
|
if CONFIG['SYSTEMS'][system]['ENHANCED_OBP']:
|
|
|
|
|