mirror of
https://github.com/Schrolli91/BOSWatch.git
synced 2025-12-06 07:42:03 +01:00
b7141d986b
Changed for loop to iterate over a copy of multiList fixed replacement of data from xData
64 lines
1.9 KiB
Python
64 lines
1.9 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)
|
|
except:
|
|
logging.error("processing alarm failed")
|
|
logging.debug("processing alarm failed", exc_info=True)
|