ShaYmez/HBLink3
1
0
Fork 0
mirror of https://github.com/ShaYmez/hblink3.git synced 2024-11-21 23:45:15 -05:00
Code Issues Projects Releases Wiki Activity

fixed initial slot status values to be bytes

Browse Source
This commit is contained in:
n0mjs710 2019-01-09 08:55:50 -06:00
parent 95f8064114
commit 2491a1776a
1 changed files with 35 additions and 35 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

70
bridge.py
View File

@ -270,7 +270,7 @@ class routerOBP(OPENBRIDGE):
logger.info('(%s) Conference Bridge: %s, Call Bridged to OBP System: %s TS: %s, TGID: %s', self._system, _bridge, _target['SYSTEM'], _target['TS'], int_id(_target['TGID'])) logger.info('(%s) Conference Bridge: %s, Call Bridged to OBP System: %s TS: %s, TGID: %s', self._system, _bridge, _target['SYSTEM'], _target['TS'], int_id(_target['TGID']))
if CONFIG['REPORTS']['REPORT']: if CONFIG['REPORTS']['REPORT']:
systems[_target['SYSTEM']]._report.send_bridgeEvent('GROUP VOICE,START,TX,{},{},{},{},{},{}'.format(_target['SYSTEM'], int_id(_stream_id), int_id(_peer_id), int_id(_rf_src), _target['TS'], int_id(_target['TGID'])).encode(encoding='utf-8', errors='ignore')) systems[_target['SYSTEM']]._report.send_bridgeEvent('GROUP VOICE,START,TX,{},{},{},{},{},{}'.format(_target['SYSTEM'], int_id(_stream_id), int_id(_peer_id), int_id(_rf_src), _target['TS'], int_id(_target['TGID'])).encode(encoding='utf-8', errors='ignore'))
# Record the time of this packet so we can later identify a stale stream # Record the time of this packet so we can later identify a stale stream
_target_status[_stream_id]['LAST'] = pkt_time _target_status[_stream_id]['LAST'] = pkt_time
# Clear the TS bit -- all OpenBridge streams are effectively on TS1 # Clear the TS bit -- all OpenBridge streams are effectively on TS1
@ -390,7 +390,7 @@ class routerOBP(OPENBRIDGE):
# Final actions - Is this a voice terminator? # Final actions - Is this a voice terminator?
if (_frame_type == HBPF_DATA_SYNC) and (_dtype_vseq == HBPF_SLT_VTERM): if (_frame_type == HBPF_DATA_SYNC) and (_dtype_vseq == HBPF_SLT_VTERM):
call_duration = pkt_time - self.STATUS[_stream_id]['START'] call_duration = pkt_time - self.STATUS[_stream_id]['START']
logger.info('(%s) *CALL END* STREAM ID: %s SUB: %s (%s) PEER: %s (%s) TGID %s (%s), TS %s, Duration: %s', \ logger.info('(%s) *CALL END* STREAM ID: %s SUB: %s (%s) PEER: %s (%s) TGID %s (%s), TS %s, Duration: %.2f', \
self._system, int_id(_stream_id), get_alias(_rf_src, subscriber_ids), int_id(_rf_src), get_alias(_peer_id, peer_ids), int_id(_peer_id), get_alias(_dst_id, talkgroup_ids), int_id(_dst_id), _slot, call_duration) self._system, int_id(_stream_id), get_alias(_rf_src, subscriber_ids), int_id(_rf_src), get_alias(_peer_id, peer_ids), int_id(_peer_id), get_alias(_dst_id, talkgroup_ids), int_id(_dst_id), _slot, call_duration)
if CONFIG['REPORTS']['REPORT']: if CONFIG['REPORTS']['REPORT']:
self._report.send_bridgeEvent('GROUP VOICE,END,RX,{},{},{},{},{},{},{:.2f}'.format(self._system, int_id(_stream_id), int_id(_peer_id), int_id(_rf_src), _slot, int_id(_dst_id), call_duration).encode(encoding='utf-8', errors='ignore')) self._report.send_bridgeEvent('GROUP VOICE,END,RX,{},{},{},{},{},{},{:.2f}'.format(self._system, int_id(_stream_id), int_id(_peer_id), int_id(_rf_src), _slot, int_id(_dst_id), call_duration).encode(encoding='utf-8', errors='ignore'))
@ -411,53 +411,53 @@ class routerHBP(HBSYSTEM):
1: { 1: {
'RX_START': time(), 'RX_START': time(),
'TX_START': time(), 'TX_START': time(),
'RX_SEQ': '\x00', 'RX_SEQ': b'\x00',
'RX_RFS': '\x00', 'RX_RFS': b'\x00',
'TX_RFS': '\x00', 'TX_RFS': b'\x00',
'RX_PEER': '\x00', 'RX_PEER': b'\x00',
'TX_PEER': '\x00', 'TX_PEER': b'\x00',
'RX_STREAM_ID': '\x00', 'RX_STREAM_ID': b'\x00',
'TX_STREAM_ID': '\x00', 'TX_STREAM_ID': b'\x00',
'RX_TGID': '\x00\x00\x00', 'RX_TGID': b'\x00\x00\x00',
'TX_TGID': '\x00\x00\x00', 'TX_TGID': b'\x00\x00\x00',
'RX_TIME': time(), 'RX_TIME': time(),
'TX_TIME': time(), 'TX_TIME': time(),
'RX_TYPE': HBPF_SLT_VTERM, 'RX_TYPE': HBPF_SLT_VTERM,
'TX_TYPE': HBPF_SLT_VTERM, 'TX_TYPE': HBPF_SLT_VTERM,
'RX_LC': '\x00', 'RX_LC': b'\x00',
'TX_H_LC': '\x00', 'TX_H_LC': b'\x00',
'TX_T_LC': '\x00', 'TX_T_LC': b'\x00',
'TX_EMB_LC': { 'TX_EMB_LC': {
1: '\x00', 1: b'\x00',
2: '\x00', 2: b'\x00',
3: '\x00', 3: b'\x00',
4: '\x00', 4: b'\x00',
} }
}, },
2: { 2: {
'RX_START': time(), 'RX_START': time(),
'TX_START': time(), 'TX_START': time(),
'RX_SEQ': '\x00', 'RX_SEQ': b'\x00',
'RX_RFS': '\x00', 'RX_RFS': b'\x00',
'TX_RFS': '\x00', 'TX_RFS': b'\x00',
'RX_PEER': '\x00', 'RX_PEER': b'\x00',
'TX_PEER': '\x00', 'TX_PEER': b'\x00',
'RX_STREAM_ID': '\x00', 'RX_STREAM_ID': b'\x00',
'TX_STREAM_ID': '\x00', 'TX_STREAM_ID': b'\x00',
'RX_TGID': '\x00\x00\x00', 'RX_TGID': b'\x00\x00\x00',
'TX_TGID': '\x00\x00\x00', 'TX_TGID': b'\x00\x00\x00',
'RX_TIME': time(), 'RX_TIME': time(),
'TX_TIME': time(), 'TX_TIME': time(),
'RX_TYPE': HBPF_SLT_VTERM, 'RX_TYPE': HBPF_SLT_VTERM,
'TX_TYPE': HBPF_SLT_VTERM, 'TX_TYPE': HBPF_SLT_VTERM,
'RX_LC': '\x00', 'RX_LC': b'\x00',
'TX_H_LC': '\x00', 'TX_H_LC': b'\x00',
'TX_T_LC': '\x00', 'TX_T_LC': b'\x00',
'TX_EMB_LC': { 'TX_EMB_LC': {
1: '\x00', 1: b'\x00',
2: '\x00', 2: b'\x00',
3: '\x00', 3: b'\x00',
4: '\x00', 4: b'\x00',
} }
} }
} }
@ -638,7 +638,7 @@ class routerHBP(HBSYSTEM):
# Final actions - Is this a voice terminator? # Final actions - Is this a voice terminator?
if (_frame_type == HBPF_DATA_SYNC) and (_dtype_vseq == HBPF_SLT_VTERM) and (self.STATUS[_slot]['RX_TYPE'] != HBPF_SLT_VTERM): if (_frame_type == HBPF_DATA_SYNC) and (_dtype_vseq == HBPF_SLT_VTERM) and (self.STATUS[_slot]['RX_TYPE'] != HBPF_SLT_VTERM):
call_duration = pkt_time - self.STATUS[_slot]['RX_START'] call_duration = pkt_time - self.STATUS[_slot]['RX_START']
logger.info('(%s) *CALL END* STREAM ID: %s SUB: %s (%s) PEER: %s (%s) TGID %s (%s), TS %s, Duration: %s', \ logger.info('(%s) *CALL END* STREAM ID: %s SUB: %s (%s) PEER: %s (%s) TGID %s (%s), TS %s, Duration: %.2f', \
self._system, int_id(_stream_id), get_alias(_rf_src, subscriber_ids), int_id(_rf_src), get_alias(_peer_id, peer_ids), int_id(_peer_id), get_alias(_dst_id, talkgroup_ids), int_id(_dst_id), _slot, call_duration) self._system, int_id(_stream_id), get_alias(_rf_src, subscriber_ids), int_id(_rf_src), get_alias(_peer_id, peer_ids), int_id(_peer_id), get_alias(_dst_id, talkgroup_ids), int_id(_dst_id), _slot, call_duration)
if CONFIG['REPORTS']['REPORT']: if CONFIG['REPORTS']['REPORT']:
self._report.send_bridgeEvent('GROUP VOICE,END,RX,{},{},{},{},{},{},{:.2f}'.format(self._system, int_id(_stream_id), int_id(_peer_id), int_id(_rf_src), _slot, int_id(_dst_id), call_duration).encode(encoding='utf-8', errors='ignore')) self._report.send_bridgeEvent('GROUP VOICE,END,RX,{},{},{},{},{},{},{:.2f}'.format(self._system, int_id(_stream_id), int_id(_peer_id), int_id(_rf_src), _slot, int_id(_dst_id), call_duration).encode(encoding='utf-8', errors='ignore'))