Additional RCM Features
This commit is contained in:
parent
ba1d108d06
commit
72721d9870
@ -94,11 +94,20 @@ STATUS = {
|
|||||||
'\x01': 'Active',
|
'\x01': 'Active',
|
||||||
'\x02': 'End',
|
'\x02': 'End',
|
||||||
'\x05': 'TS In Use',
|
'\x05': 'TS In Use',
|
||||||
|
'\x08': 'RPT Disabled',
|
||||||
|
'\x09': 'RF Interference',
|
||||||
'\x0A': 'BSID ON',
|
'\x0A': 'BSID ON',
|
||||||
'\x0B': 'Timeout',
|
'\x0B': 'Timeout',
|
||||||
'\x0C': 'TX Interrupt'
|
'\x0C': 'TX Interrupt'
|
||||||
}
|
}
|
||||||
|
|
||||||
|
REPEAT = {
|
||||||
|
'\x01': 'Repeating',
|
||||||
|
'\x02': 'Idle',
|
||||||
|
'\x03': 'TS Disabled',
|
||||||
|
'\x04': 'TS Enabled'
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
# Conditions for accepting certain types of messages... the cornerstone of a secure IPSC system :)
|
# Conditions for accepting certain types of messages... the cornerstone of a secure IPSC system :)
|
||||||
'''
|
'''
|
||||||
|
65
rcm.py
65
rcm.py
@ -17,6 +17,7 @@ from twisted.internet import task
|
|||||||
from binascii import b2a_hex as h
|
from binascii import b2a_hex as h
|
||||||
|
|
||||||
import time
|
import time
|
||||||
|
import datetime
|
||||||
import binascii
|
import binascii
|
||||||
import dmrlink
|
import dmrlink
|
||||||
from dmrlink import IPSC, NETWORK, networks, get_info, int_id, subscriber_ids, peer_ids, talkgroup_ids, logger
|
from dmrlink import IPSC, NETWORK, networks, get_info, int_id, subscriber_ids, peer_ids, talkgroup_ids, logger
|
||||||
@ -45,16 +46,18 @@ class rcmIPSC(IPSC):
|
|||||||
#************************************************
|
#************************************************
|
||||||
#
|
#
|
||||||
def call_mon_origin(self, _network, _data):
|
def call_mon_origin(self, _network, _data):
|
||||||
_source = _data[1:5]
|
_source = _data[1:5]
|
||||||
_ipsc_src = _data[5:9]
|
_ipsc_src = _data[5:9]
|
||||||
_rf_src = _data[16:19]
|
_seq_num = _data[9:13]
|
||||||
_rf_tgt = _data[19:22]
|
_ts = _data[13]
|
||||||
|
_status = _data[15] # suspect [14:16] but nothing in leading byte?
|
||||||
_ts = _data[13]
|
_rf_src = _data[16:19]
|
||||||
_status = _data[15]
|
_rf_tgt = _data[19:22]
|
||||||
_type = _data[22]
|
_type = _data[22]
|
||||||
_sec = _data[24]
|
_prio = _data[23]
|
||||||
|
_sec = _data[24]
|
||||||
|
|
||||||
|
_source = get_info(int_id(_source), peer_ids)
|
||||||
_ipsc_src = get_info(int_id(_ipsc_src), peer_ids)
|
_ipsc_src = get_info(int_id(_ipsc_src), peer_ids)
|
||||||
_rf_src = get_info(int_id(_rf_src), subscriber_ids)
|
_rf_src = get_info(int_id(_rf_src), subscriber_ids)
|
||||||
|
|
||||||
@ -63,20 +66,60 @@ class rcmIPSC(IPSC):
|
|||||||
else:
|
else:
|
||||||
_rf_tgt = get_info(int_id(_rf_tgt), subscriber_ids)
|
_rf_tgt = get_info(int_id(_rf_tgt), subscriber_ids)
|
||||||
|
|
||||||
|
prubt('Call Monitor - Traffic Origin')
|
||||||
|
print('TIME: ', datetime.datetime.now())
|
||||||
|
print('DATA SOURCE: ', _source)
|
||||||
print('IPSC: ', _network)
|
print('IPSC: ', _network)
|
||||||
print('IPSC Source: ', _ipsc_src)
|
print('IPSC Source: ', _ipsc_src)
|
||||||
print('Timeslot: ', TS[_ts])
|
print('Timeslot: ', TS[_ts])
|
||||||
print('Status: ', STATUS[_status])
|
try:
|
||||||
print('Type: ', TYPE[_type])
|
print('Status: ', STATUS[_status])
|
||||||
|
except KeyError:
|
||||||
|
print('Status (unknown): ', h(status))
|
||||||
|
try:
|
||||||
|
print('Type: ', TYPE[_type])
|
||||||
|
except KeyError:
|
||||||
|
print('Type (unknown): ', h(_type))
|
||||||
print('Source Sub: ', _rf_src)
|
print('Source Sub: ', _rf_src)
|
||||||
print('Target Sub: ', _rf_tgt)
|
print('Target Sub: ', _rf_tgt)
|
||||||
print()
|
print()
|
||||||
|
|
||||||
|
def call_mon_rpt(self, _network, _data):
|
||||||
|
_source = _data[1:5]
|
||||||
|
_state = _data[6]
|
||||||
|
|
||||||
|
_source = get_info(int_id(_source), peer_ids)
|
||||||
|
|
||||||
|
print('Call Monitor - Repeater State')
|
||||||
|
print('TIME: ', datetime.datetime.now())
|
||||||
|
print('DATA SOURCE: ', _source)
|
||||||
|
try:
|
||||||
|
print('Repeat State: ', REPEAT[_state])
|
||||||
|
except KeyError:
|
||||||
|
print('RPT State (unknown): ', h(_state))
|
||||||
|
print()
|
||||||
|
|
||||||
|
|
||||||
|
def call_mon_nack(self, _network, _data):
|
||||||
|
_source = _data[1:5]
|
||||||
|
_nack = _data[5]
|
||||||
|
|
||||||
|
_source = get_info(int_id(_source), peer_ids)
|
||||||
|
|
||||||
|
print(' Call Monitor - Transmission NACK')
|
||||||
|
print('TIME: ', datetime.datetime.now())
|
||||||
|
print('DATA SOURCE: ', _source)
|
||||||
|
try:
|
||||||
|
print('NACK Cause: ', REPEAT[_nack])
|
||||||
|
except KeyError:
|
||||||
|
print('NACK Cause (unknown): ', h(_nack))
|
||||||
|
print()
|
||||||
|
|
||||||
def repeater_wake_up(self, _network, _data):
|
def repeater_wake_up(self, _network, _data):
|
||||||
_source = _data[1:5]
|
_source = _data[1:5]
|
||||||
_source_dec = int_id(_source)
|
_source_dec = int_id(_source)
|
||||||
_source_name = get_info(_source_dec, peer_ids)
|
_source_name = get_info(_source_dec, peer_ids)
|
||||||
print('({}) Repeater Wake-Up Packet Received: {} ({})' .format(_network, _source_name, _source_dec))
|
#print('({}) Repeater Wake-Up Packet Received: {} ({})' .format(_network, _source_name, _source_dec))
|
||||||
|
|
||||||
|
|
||||||
if __name__ == '__main__':
|
if __name__ == '__main__':
|
||||||
|
Loading…
x
Reference in New Issue
Block a user