Error ia kaReporting
This commit is contained in:
parent
014edd8893
commit
45e10a9472
@ -359,10 +359,10 @@ def statTrimmer():
|
||||
|
||||
def kaReporting():
|
||||
logger.debug('(ROUTER) KeepAlive reporting loop started')
|
||||
#for system in systems:
|
||||
if CONFIG['SYSTEMS'][system]['MODE'] == 'OPENBRIDGE':
|
||||
if '_bcka' in CONFIG['SYSTEMS'][system] and CONFIG['SYSTEMS'][system]['_bcka'] < time() - 60:
|
||||
logger.warning('(ROUTER) not sending to system %s as last keepalive was %s ago',system, config['SYSTEMS'][system]['_bcka'] - time())
|
||||
for system in systems:
|
||||
if CONFIG['SYSTEMS'][system]['MODE'] == 'OPENBRIDGE':
|
||||
if '_bcka' in CONFIG['SYSTEMS'][system] and CONFIG['SYSTEMS'][system]['_bcka'] < time() - 60:
|
||||
logger.warning('(ROUTER) not sending to system %s as last keepalive was %s ago',system, config['SYSTEMS'][system]['_bcka'] - time())
|
||||
|
||||
# run this every 10 seconds to trim orphaned stream ids
|
||||
def stream_trimmer_loop():
|
||||
|
Loading…
Reference in New Issue
Block a user