Lengthen OBP active queue length
This commit is contained in:
parent
d0fef204cf
commit
ff2818016d
@ -183,7 +183,7 @@ def stream_trimmer_loop():
|
|||||||
_system = systems[system].STATUS[stream_id]
|
_system = systems[system].STATUS[stream_id]
|
||||||
_config = CONFIG['SYSTEMS'][system]
|
_config = CONFIG['SYSTEMS'][system]
|
||||||
if systems[system].STATUS[stream_id]['REMOVE'] == True:
|
if systems[system].STATUS[stream_id]['REMOVE'] == True:
|
||||||
logger.info('(%s) *REMOVE ENDED* STREAM ID: %s SUB: %s PEER: %s TGID: %s TS 1 Duration: %s', \
|
logger.debug('(%s) *REMOVE ENDED* STREAM ID: %s SUB: %s PEER: %s TGID: %s TS 1 Duration: %s', \
|
||||||
system, int_id(stream_id), get_alias(int_id(_system['RFS']), subscriber_ids), get_alias(int_id(_config['NETWORK_ID']), peer_ids), get_alias(int_id(_system['TGID']), talkgroup_ids), _system['LAST'] - _system['START'])
|
system, int_id(stream_id), get_alias(int_id(_system['RFS']), subscriber_ids), get_alias(int_id(_config['NETWORK_ID']), peer_ids), get_alias(int_id(_system['TGID']), talkgroup_ids), _system['LAST'] - _system['START'])
|
||||||
else:
|
else:
|
||||||
logger.info('(%s) *TIME OUT* STREAM ID: %s SUB: %s PEER: %s TGID: %s TS 1 Duration: %s', \
|
logger.info('(%s) *TIME OUT* STREAM ID: %s SUB: %s PEER: %s TGID: %s TS 1 Duration: %s', \
|
||||||
|
@ -118,7 +118,7 @@ class OPENBRIDGE(DatagramProtocol):
|
|||||||
self._system = _name
|
self._system = _name
|
||||||
self._report = _report
|
self._report = _report
|
||||||
self._config = self._CONFIG['SYSTEMS'][self._system]
|
self._config = self._CONFIG['SYSTEMS'][self._system]
|
||||||
self._laststrid = deque([], 10)
|
self._laststrid = deque([], 20)
|
||||||
|
|
||||||
def dereg(self):
|
def dereg(self):
|
||||||
logger.info('(%s) is mode OPENBRIDGE. No De-Registration required, continuing shutdown', self._system)
|
logger.info('(%s) is mode OPENBRIDGE. No De-Registration required, continuing shutdown', self._system)
|
||||||
|
Loading…
x
Reference in New Issue
Block a user