|
|
|
@ -34,7 +34,7 @@ This program currently only works with group voice calls.
|
|
|
|
# Python modules we need
|
|
|
|
# Python modules we need
|
|
|
|
import sys
|
|
|
|
import sys
|
|
|
|
from bitarray import bitarray
|
|
|
|
from bitarray import bitarray
|
|
|
|
from time import time,sleep,perf_counter
|
|
|
|
from time import time,sleep
|
|
|
|
import importlib.util
|
|
|
|
import importlib.util
|
|
|
|
import re
|
|
|
|
import re
|
|
|
|
import copy
|
|
|
|
import copy
|
|
|
|
@ -1362,7 +1362,7 @@ class routerOBP(OPENBRIDGE):
|
|
|
|
'CONTENTION':False,
|
|
|
|
'CONTENTION':False,
|
|
|
|
'RFS': _rf_src,
|
|
|
|
'RFS': _rf_src,
|
|
|
|
'TGID': _dst_id,
|
|
|
|
'TGID': _dst_id,
|
|
|
|
'1ST': perf_counter(),
|
|
|
|
'1ST': True,
|
|
|
|
'lastSeq': False,
|
|
|
|
'lastSeq': False,
|
|
|
|
'lastData': False,
|
|
|
|
'lastData': False,
|
|
|
|
'RX_PEER': _peer_id
|
|
|
|
'RX_PEER': _peer_id
|
|
|
|
@ -1394,8 +1394,7 @@ class routerOBP(OPENBRIDGE):
|
|
|
|
self.STATUS[_stream_id]['_finlog'] = True
|
|
|
|
self.STATUS[_stream_id]['_finlog'] = True
|
|
|
|
return
|
|
|
|
return
|
|
|
|
|
|
|
|
|
|
|
|
#LoopControl
|
|
|
|
#LoopControl#
|
|
|
|
hr_times = {}
|
|
|
|
|
|
|
|
for system in systems:
|
|
|
|
for system in systems:
|
|
|
|
if system == self._system:
|
|
|
|
if system == self._system:
|
|
|
|
continue
|
|
|
|
continue
|
|
|
|
@ -1410,15 +1409,6 @@ class routerOBP(OPENBRIDGE):
|
|
|
|
else:
|
|
|
|
else:
|
|
|
|
#if _stream_id in systems[system].STATUS and systems[system].STATUS[_stream_id]['START'] <= self.STATUS[_stream_id]['START']:
|
|
|
|
#if _stream_id in systems[system].STATUS and systems[system].STATUS[_stream_id]['START'] <= self.STATUS[_stream_id]['START']:
|
|
|
|
if _stream_id in systems[system].STATUS and '1ST' in systems[system].STATUS[_stream_id] and systems[system].STATUS[_stream_id]['TGID'] == _dst_id:
|
|
|
|
if _stream_id in systems[system].STATUS and '1ST' in systems[system].STATUS[_stream_id] and systems[system].STATUS[_stream_id]['TGID'] == _dst_id:
|
|
|
|
hr_times[system] = systems[system].STATUS[_stream_id]['1ST']
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
#use the minimum perf_counter to ensure
|
|
|
|
|
|
|
|
#We always use only the earliest packet
|
|
|
|
|
|
|
|
fi = min(hr_times, key=hr_times.get)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
hr_times = None
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if self._system != fi:
|
|
|
|
|
|
|
|
if 'LOOPLOG' not in self.STATUS[_stream_id] or not self.STATUS[_stream_id]['LOOPLOG']:
|
|
|
|
if 'LOOPLOG' not in self.STATUS[_stream_id] or not self.STATUS[_stream_id]['LOOPLOG']:
|
|
|
|
logger.warning("(%s) OBP *LoopControl* FIRST OBP %s, STREAM ID: %s, TG %s, IGNORE THIS SOURCE",self._system, system, int_id(_stream_id), int_id(_dst_id))
|
|
|
|
logger.warning("(%s) OBP *LoopControl* FIRST OBP %s, STREAM ID: %s, TG %s, IGNORE THIS SOURCE",self._system, system, int_id(_stream_id), int_id(_dst_id))
|
|
|
|
self.STATUS[_stream_id]['LOOPLOG'] = True
|
|
|
|
self.STATUS[_stream_id]['LOOPLOG'] = True
|
|
|
|
|