mirror of
https://github.com/Schrolli91/BOSWatch.git
synced 2025-12-06 07:42:03 +01:00
30320b3c71
If you are using many Plugins or Plugins with a long execution time you could execute them in an asynchronous manner. It must be pointed out that enabling (0|1) this consume time, so don't use it for one rapid Plugin.
99 lines
2.6 KiB
Python
99 lines
2.6 KiB
Python
#!/usr/bin/python
|
|
# -*- coding: UTF-8 -*-
|
|
|
|
"""
|
|
Handler for the filter and plugins at an alarm
|
|
|
|
@author: Bastian Schroll
|
|
@author: Jens Herrmann
|
|
|
|
@requires: none
|
|
"""
|
|
|
|
import logging # Global logger
|
|
from threading import Thread
|
|
|
|
from includes import globals # Global variables
|
|
|
|
##
|
|
#
|
|
# decide to run AlarmHandler sync or async
|
|
#
|
|
def processAlarmHandler(typ, freq, data):
|
|
"""
|
|
Function to decide if the alarm process will call sync
|
|
|
|
@type typ: string (FMS|ZVEI|POC)
|
|
@param typ: Typ of the dataset
|
|
@type freq: string
|
|
@param freq: frequency of the SDR Stick
|
|
@type data: map of data (structure see interface.txt)
|
|
@param data: Contains the parameter
|
|
|
|
@requires: active plugins in pluginList
|
|
@requires: Configuration has to be set in the config.ini
|
|
|
|
@return: nothing
|
|
@exception: Exception if starting a Thread failed
|
|
"""
|
|
if globals.config.getboolean("BOSWatch","processAlarmAsync") == True:
|
|
logging.debug("starting processAlarm async")
|
|
try:
|
|
Thread(target=processAlarm, args=(typ, freq, data)).start()
|
|
except:
|
|
logging.error("Error in starting alarm processing async")
|
|
logging.debug("Error in starting alarm processing async", exc_info=True)
|
|
pass
|
|
else:
|
|
processAlarm(typ, freq, data)
|
|
|
|
|
|
##
|
|
#
|
|
# main function for central filtering and calling the plugins
|
|
#
|
|
def processAlarm(typ, freq, data):
|
|
"""
|
|
Function to process filters and plugins at Alarm
|
|
|
|
@type typ: string (FMS|ZVEI|POC)
|
|
@param typ: Typ of the dataset
|
|
@type freq: string
|
|
@param freq: frequency of the SDR Stick
|
|
@type data: map of data (structure see interface.txt)
|
|
@param data: Contains the parameter
|
|
|
|
@requires: active plugins in pluginList
|
|
|
|
@return: nothing
|
|
@exception: Exception if Alarm processing itself failed
|
|
"""
|
|
try:
|
|
logging.debug("[ ALARM ]")
|
|
# Go to all plugins in pluginList
|
|
for pluginName, plugin in globals.pluginList.items():
|
|
# if enabled use RegEx-filter
|
|
if globals.config.getint("BOSWatch","useRegExFilter"):
|
|
from includes import filter
|
|
if filter.checkFilters(typ,data,pluginName,freq):
|
|
logging.debug("call Plugin: %s", pluginName)
|
|
try:
|
|
plugin.run(typ,freq,data)
|
|
logging.debug("return from: %s", pluginName)
|
|
except:
|
|
# call next plugin, if one has thrown an exception
|
|
pass
|
|
else: # RegEX filter off - call plugin directly
|
|
logging.debug("call Plugin: %s", pluginName)
|
|
try:
|
|
plugin.run(typ,freq,data)
|
|
logging.debug("return from: %s", pluginName)
|
|
except:
|
|
# call next plugin, if one has thrown an exception
|
|
pass
|
|
logging.debug("[END ALARM]")
|
|
except:
|
|
logging.error("Error in alarm processing")
|
|
logging.debug("Error in alarm processing", exc_info=True)
|
|
pass
|