KB8PMY
/
ADN-DMR-Peer-Server
mirror of https://github.com/Amateur-Digital-Network/ADN-DMR-Peer-Server.git
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

TTS dual-slot: send announcements on both TS1 and TS2 based on active BRIDGES per system

Browse Source
pull/26/head
Joaquin Madrid Belando 3 weeks ago
parent 50b5e2ef3a
commit ec035b8a18
1 changed files with 50 additions and 27 deletions
Show Stats Download Patch File Download Diff File

65
bridge_master.py
Unescape View File

@ -1268,9 +1268,8 @@ def _ttsConversionDone(_ambe_path, _tts_num, _file, _tg, _timeslot, _lang, _mode
logger.warning('(%s) No AMBE file available for TTS announcement %s', _label, _file)
return
logger.info('(%s) Playing TTS file: %s to TG %s TS%s (mode: %s, lang: %s)', _label, _file, _tg, _timeslot, _mode, _lang)
logger.info('(%s) Playing TTS file: %s to TG %s (both TS, mode: %s, lang: %s)', _label, _file, _tg, _mode, _lang)
_slot_index = 2 if _timeslot == 2 else 1
_dst_id = bytes_3(_tg)
_source_id = bytes_3(5000)
_peer_id = CONFIG['GLOBAL']['SERVER_ID']
@ -1294,6 +1293,8 @@ def _ttsConversionDone(_ambe_path, _tts_num, _file, _tg, _timeslot, _lang, _mode
logger.debug('(%s) AMBE file loaded, %s words', _label, len(_say))
_tg_str = str(_tg)
_excluded = ['ECHO', 'D-APRS']
_targets = []
@ -1322,28 +1323,48 @@ def _ttsConversionDone(_ambe_path, _tts_num, _file, _tg, _timeslot, _lang, _mode
if _sn not in systems:
continue
_active_slots = []
if _tg_str in BRIDGES:
for _be in BRIDGES[_tg_str]:
if _be['SYSTEM'] == _sn and _be['ACTIVE'] and _be['TS'] not in _active_slots:
_active_slots.append(_be['TS'])
if not _active_slots:
continue
for _ts in _active_slots:
_slot_index = 2 if _ts == 2 else 1
_slot = systems[_sn].STATUS[_slot_index]
if (_slot['RX_TYPE'] != HBPF_SLT_VTERM) or (_slot['TX_TYPE'] != HBPF_SLT_VTERM):
logger.debug('(%s) System %s busy, skipping', _label, _sn)
logger.debug('(%s) System %s TS%s busy, skipping', _label, _sn, _ts)
continue
_targets.append({
'sys_obj': systems[_sn],
'name': _sn,
'slot': _slot
'slot': _slot,
'ts': _ts
})
logger.debug('(%s) System %s added for TG %s TS%s', _label, _sn, _tg, _ts)
if not _targets:
_tts_running[_tts_num] = False
logger.info('(%s) No systems with connected peers to send to', _label)
logger.info('(%s) No systems with active bridge for TG %s to send to', _label, _tg)
return
_pkts = list(pkt_gen(_source_id, _dst_id, _peer_id, _slot_index - 1, _say))
_sys_names = ', '.join([t['name'] for t in _targets[:5]])
if len(_targets) > 5:
_sys_names += ', ... +{}'.format(len(_targets) - 5)
logger.info('(%s) Broadcasting %s packets to %s systems simultaneously: %s', _label, len(_pkts), len(_targets), _sys_names)
reactor.callLater(1.0, _ttsSendBroadcast, _targets, _pkts, 0, _source_id, _dst_id, _tg, _timeslot, _tts_num)
_pkts_by_ts = {
1: list(pkt_gen(_source_id, _dst_id, _peer_id, 0, _say)),
2: list(pkt_gen(_source_id, _dst_id, _peer_id, 1, _say)),
}
_ts1_count = sum(1 for t in _targets if t['ts'] == 1)
_ts2_count = sum(1 for t in _targets if t['ts'] == 2)
_sys_names = ', '.join(['{}/TS{}'.format(t['name'], t['ts']) for t in _targets[:8]])
if len(_targets) > 8:
_sys_names += ', ... +{}'.format(len(_targets) - 8)
logger.info('(%s) Broadcasting %s packets to %s targets (TS1:%s TS2:%s): %s',
_label, len(_pkts_by_ts[1]), len(_targets), _ts1_count, _ts2_count, _sys_names)
reactor.callLater(1.0, _ttsSendBroadcast, _targets, _pkts_by_ts, 0, _source_id, _dst_id, _tg, 0, _tts_num)
def _ttsConversionError(failure, _tts_num, _label):
@ -1351,12 +1372,13 @@ def _ttsConversionError(failure, _tts_num, _label):
_tts_running[_tts_num] = False
logger.error('(%s) Error en conversion TTS: %s', _label, failure.getErrorMessage())
def _ttsSendBroadcast(_targets, _pkts, _pkt_idx, _source_id, _dst_id, _tg, _ts, _tts_num=1, _next_time=None):
def _ttsSendBroadcast(_targets, _pkts_by_ts, _pkt_idx, _source_id, _dst_id, _tg, _ts_unused, _tts_num=1, _next_time=None):
global _tts_running
_label = 'TTS-{}'.format(_tts_num)
if _pkt_idx >= len(_pkts):
_total_pkts = len(_pkts_by_ts[1])
if _pkt_idx >= _total_pkts:
for _t in _targets:
try:
for _sid in list(_t['sys_obj'].STATUS.keys()):
@ -1365,17 +1387,18 @@ def _ttsSendBroadcast(_targets, _pkts, _pkt_idx, _source_id, _dst_id, _tg, _ts,
except:
pass
_tts_running[_tts_num] = False
logger.info('(%s) Broadcast complete: %s packets sent to %s systems', _label, len(_pkts), len(_targets))
logger.info('(%s) Broadcast complete: %s packets sent to %s targets', _label, _total_pkts, len(_targets))
return
_now = time()
pkt = _pkts[_pkt_idx]
_stream_id = pkt[16:20]
for _t in _targets:
try:
_sys_obj = _t['sys_obj']
_slot = _t['slot']
_t_ts = _t['ts']
pkt = _pkts_by_ts[_t_ts][_pkt_idx]
_stream_id = pkt[16:20]
if _stream_id not in _sys_obj.STATUS:
_sys_obj.STATUS[_stream_id] = {
'START': _now,
@ -1388,11 +1411,11 @@ def _ttsSendBroadcast(_targets, _pkts, _pkt_idx, _source_id, _dst_id, _tg, _ts,
else:
_sys_obj.STATUS[_stream_id]['LAST'] = _now
_slot['TX_TIME'] = _now
_fc = _sendFilteredByTG(_sys_obj, pkt, _tg, _ts, _label, _pkt_idx)
_fc = _sendFilteredByTG(_sys_obj, pkt, _tg, _t_ts, _label, _pkt_idx)
if _pkt_idx == 0 and _fc == 0:
logger.debug('(%s) TG %s TS%s not active on %s, skipping', _label, _tg, _ts, _t['name'])
logger.debug('(%s) TG %s TS%s not active on %s, skipping', _label, _tg, _t_ts, _t['name'])
except Exception as e:
logger.error('(%s) Error sending packet %s to %s: %s', _label, _pkt_idx, _t['name'], e)
logger.error('(%s) Error sending packet %s to %s/TS%s: %s', _label, _pkt_idx, _t['name'], _t.get('ts', '?'), e)
_elapsed = time() - _now
if _next_time is None:
@ -1402,9 +1425,9 @@ def _ttsSendBroadcast(_targets, _pkts, _pkt_idx, _source_id, _dst_id, _tg, _ts,
_delay = max(0.001, _next_time - time())
if _pkt_idx < 3:
logger.debug('(%s) Packet %s/%s broadcast to %s systems (proc: %.1fms, delay: %.1fms)', _label, _pkt_idx + 1, len(_pkts), len(_targets), _elapsed * 1000, _delay * 1000)
logger.debug('(%s) Packet %s/%s broadcast to %s targets (proc: %.1fms, delay: %.1fms)', _label, _pkt_idx + 1, _total_pkts, len(_targets), _elapsed * 1000, _delay * 1000)
reactor.callLater(_delay, _ttsSendBroadcast, _targets, _pkts, _pkt_idx + 1, _source_id, _dst_id, _tg, _ts, _tts_num, _next_time)
reactor.callLater(_delay, _ttsSendBroadcast, _targets, _pkts_by_ts, _pkt_idx + 1, _source_id, _dst_id, _tg, _ts_unused, _tts_num, _next_time)
def bridge_reset():
logger.debug('(BRIDGERESET) Running bridge resetter')

Write Preview
Loading…
Cancel
Save

Powered by TurnKey Linux.