boswatch.inputSource.inputBase.InputBase Class Reference

Base class for handling inout sources. More...

Public Member Functions
	__init__ (self, inputQueue, inputConfig, decoderConfig)
	Build a new InputSource class.
	start (self)
	Start the input source thread.
	shutdown (self)
	Stop the input source thread.
	addToQueue (self, data)
	Decode and add alarm data to the queue for further processing during boswatch client.
	getDecoderInstance (self, decoderConfig, StdIn)

Protected Member Functions
	_runThread (self, dataQueue, sdrConfig, decoderConfig)
	Thread routine of the input source has to be inherit.

Protected Attributes
	_inputThread
	_isRunning
	_inputQueue
	_inputConfig
	_decoderConfig

Detailed Description

Base class for handling inout sources.

Constructor & Destructor Documentation

__init__()

boswatch.inputSource.inputBase.InputBase.__init__	(		self,
			inputQueue,
			inputConfig,
			decoderConfig
	)

Build a new InputSource class.

Parameters

inputQueue	Python queue object to store input data
inputConfig	ConfigYaml object with the inoutSource config
decoderConfig	ConfigYaml object with the decoder config

    def __init__(self, inputQueue, inputConfig, decoderConfig):
        r"""!Build a new InputSource class
 
        @param  inputQueue: Python queue object to store input data
        @param inputConfig: ConfigYaml object with the inoutSource config
        @param decoderConfig: ConfigYaml object with the decoder config"""
        self._inputThread = None
        self._isRunning = False
        self._inputQueue = inputQueue
        self._inputConfig = inputConfig
        self._decoderConfig = decoderConfig
 

Member Function Documentation

start()

boswatch.inputSource.inputBase.InputBase.start

(

self

)

Start the input source thread.

    def start(self):
        r"""!Start the input source thread"""
        logging.debug("starting input thread")
        self._isRunning = True
        self._inputThread = threading.Thread(target=self._runThread, name="inputThread",
                                             args=(self._inputQueue, self._inputConfig, self._decoderConfig))
        self._inputThread.daemon = True
        self._inputThread.start()
 

_runThread()

boswatch.inputSource.inputBase.InputBase._runThread (   self,   dataQueue,   sdrConfig,   decoderConfig  )

protected

Thread routine of the input source has to be inherit.

Reimplemented in boswatch.inputSource.lineInInput.LineInInput, boswatch.inputSource.pulseaudioInput.PulseAudioInput, and boswatch.inputSource.sdrInput.SdrInput.

    def _runThread(self, dataQueue, sdrConfig, decoderConfig):
        r"""!Thread routine of the input source has to be inherit"""
 

shutdown()

boswatch.inputSource.inputBase.InputBase.shutdown

(

self

)

Stop the input source thread.

    def shutdown(self):
        r"""!Stop the input source thread"""
        if self._isRunning:
            logging.debug("wait for stopping the input thread")
            self._isRunning = False
            self._inputThread.join()
            logging.debug("input thread stopped")
 

addToQueue()

boswatch.inputSource.inputBase.InputBase.addToQueue	(		self,
			data
	)

Decode and add alarm data to the queue for further processing during boswatch client.

    def addToQueue(self, data):
        r"""!Decode and add alarm data to the queue for further processing during boswatch client"""
        bwPacket = Decoder.decode(data)
        if bwPacket is not None:
            self._inputQueue.put_nowait((bwPacket, time.time()))
            logging.debug("Added received data to queue")
 

getDecoderInstance()

boswatch.inputSource.inputBase.InputBase.getDecoderInstance	(		self,
			decoderConfig,
			StdIn
	)

    def getDecoderInstance(self, decoderConfig, StdIn):
        mmProc = ProcessManager(str(decoderConfig.get("path", default="multimon-ng")), textMode=True)
        if decoderConfig.get("fms", default=0):
            mmProc.addArgument("-a FMSFSK")
        if decoderConfig.get("zvei", default=0):
            mmProc.addArgument("-a ZVEI1")
        if decoderConfig.get("poc512", default=0):
            mmProc.addArgument("-a POCSAG512")
        if decoderConfig.get("poc1200", default=0):
            mmProc.addArgument("-a POCSAG1200")
        if decoderConfig.get("poc2400", default=0):
            mmProc.addArgument("-a POCSAG2400")
        if decoderConfig.get("char", default=0):
            mmProc.addArgument("-C " + str(decoderConfig.get("char")))
        mmProc.addArgument("-f alpha")
        mmProc.addArgument("-t raw -")
        mmProc.setStdin(StdIn)
        mmProc.setStderr(open(paths.LOG_PATH + "multimon-ng.log", "a"))
        return mmProc

Field Documentation

_inputThread

boswatch.inputSource.inputBase.InputBase._inputThread

protected

_isRunning

boswatch.inputSource.inputBase.InputBase._isRunning

protected

_inputQueue

boswatch.inputSource.inputBase.InputBase._inputQueue

protected

_inputConfig

boswatch.inputSource.inputBase.InputBase._inputConfig

protected

_decoderConfig

boswatch.inputSource.inputBase.InputBase._decoderConfig

protected