boswatch.inputSource.inputBase.InputBase Class Reference

Base class for handling inout sources. More...

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

Protected Member Functions
def	_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__()

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

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

    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()

def 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()

def 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()

def 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()

def 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()

def 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