mirror of
https://github.com/Schrolli91/BOSWatch.git
synced 2025-12-06 07:42:03 +01:00
58ad0e5308
Fix for networks that mix normal alarms with multicastAlarms (delimiter needs to be deactivated). If the delimiter is deactivated, RICs in the buffer will be deleted only if they are older than multicastAlarm_ignore_time. This could cause a mixture of RICs of the current and the privious multicastAlarm. This problem can be fixed, by clearing the buffer after the multicastAlarm sequence has finished.
66 lines
2 KiB
Python
66 lines
2 KiB
Python
#!/usr/bin/python
|
|
# -*- coding: utf-8 -*-
|
|
|
|
"""
|
|
multicastAlarm is the function to enable BOSwatch to work in networks that optimise the transmission of POCSAG telegrams
|
|
|
|
@author: Fabian Kessler
|
|
|
|
@requires: Configuration has to be set in the config.ini
|
|
"""
|
|
|
|
import logging # Global logger
|
|
import time # timestamp for multicastAlarm
|
|
|
|
from includes import globalVars # Global variables
|
|
|
|
#
|
|
# ListStructure [0..n] = (Data, TimeStamp)
|
|
#
|
|
multiList = []
|
|
|
|
def newEntrymultiList(data):
|
|
"""
|
|
add entry to multi alarm list and remove old entries
|
|
|
|
@return: nothing
|
|
"""
|
|
global multiList
|
|
timestamp = int(time.time())
|
|
# multicastAlarm processing if enabled and delimiter RIC has been received
|
|
if data['ric'] == globalVars.config.get("multicastAlarm", "multicastAlarm_delimiter_ric"):
|
|
multiList = []
|
|
logging.debug("delimiter RIC received - buffer cleared")
|
|
else:
|
|
multiList.append([data, timestamp])
|
|
logging.debug("Added %s to multiList", data['ric'])
|
|
# check for old entries in multiList
|
|
for (xData, xTimestamp) in multiList[:]:
|
|
if xTimestamp < timestamp-globalVars.config.getint("multicastAlarm", "multicastAlarm_ignore_time"):
|
|
multiList.remove([xData, xTimestamp])
|
|
logging.debug("RIC %s removed - %s sec. older than current timestamp", xData['ric'], xTimestamp-timestamp)
|
|
|
|
|
|
def multicastAlarmExec(freq, data):
|
|
"""
|
|
call alarmHandler for every entry in multiList
|
|
|
|
@return: nothing
|
|
"""
|
|
logging.debug("data before update from multiList: %s", data)
|
|
for (xData, _) in multiList:
|
|
#update data with values multiList
|
|
data['ric'] = xData['ric']
|
|
data['function'] = xData['function']
|
|
data['functionChar'] = xData['functionChar']
|
|
data['description'] = xData['description']
|
|
logging.debug("data after update from multiList: %s", data)
|
|
try:
|
|
from includes import alarmHandler
|
|
alarmHandler.processAlarmHandler("POC", freq, data)
|
|
multiList = []
|
|
logging.debug("multicastAlarm finished - buffer cleared")
|
|
except:
|
|
logging.error("processing alarm failed")
|
|
logging.debug("processing alarm failed", exc_info=True)
|