boswatch.inputSource.sdrInput.SdrInput Class Reference

Class for the sdr input source. More...

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

Additional Inherited Members
Public Member Functions inherited from boswatch.inputSource.inputBase.InputBase
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 Attributes inherited from boswatch.inputSource.inputBase.InputBase
	_inputThread
	_isRunning
	_inputQueue
	_inputConfig
	_decoderConfig

Detailed Description

Class for the sdr input source.

Member Function Documentation

_runThread()

def boswatch.inputSource.sdrInput.SdrInput._runThread (   self,   dataQueue,   sdrConfig,   decoderConfig  )

protected

Thread routine of the input source has to be inherit.

Reimplemented from boswatch.inputSource.inputBase.InputBase.

    def _runThread(self, dataQueue, sdrConfig, decoderConfig):
        sdrProc = None
        mmProc = None
        try:
            sdrProc = ProcessManager(str(sdrConfig.get("rtlPath", default="rtl_fm")))
            sdrProc.addArgument("-d " + str(sdrConfig.get("device", default="0")))     # device id
            sdrProc.addArgument("-f " + str(sdrConfig.get("frequency")))               # frequencies
            sdrProc.addArgument("-p " + str(sdrConfig.get("error", default="0")))      # frequency error in ppm
            sdrProc.addArgument("-l " + str(sdrConfig.get("squelch", default="1")))    # squelch
            sdrProc.addArgument("-g " + str(sdrConfig.get("gain", default="100")))     # gain
            if (sdrConfig.get("fir_size", default=None) is not None):
                sdrProc.addArgument("-F " + str(sdrConfig.get("fir_size")))            # fir_size
            sdrProc.addArgument("-M fm")                                               # set mode to fm
            sdrProc.addArgument("-E DC")                                               # set DC filter
            sdrProc.addArgument("-s 22050")                                            # bit rate of audio stream
            sdrProc.setStderr(open(paths.LOG_PATH + "rtl_fm.log", "a"))
            sdrProc.start()
 
            mmProc = self.getDecoderInstance(decoderConfig, sdrProc.stdout)
            mmProc.start()
 
            logging.info("start decoding")
            while self._isRunning:
                if not sdrProc.isRunning:
                    logging.warning("rtl_fm was down - trying to restart in 10 seconds")
                    time.sleep(10)
 
                    sdrProc.start()
                    if sdrProc.isRunning:
                        logging.info("rtl_fm is back up - restarting multimon...")
                        mmProc.setStdin(sdrProc.stdout)
                        mmProc.start()
                elif not mmProc.isRunning:
                    logging.warning("multimon was down - try to restart")
                    mmProc.start()
                elif sdrProc.isRunning and mmProc.isRunning:
                    line = mmProc.readline()
                    if line:
                        self.addToQueue(line)
        except:
            logging.exception("error in sdr input routine")
        finally:
            mmProc.stop()
            sdrProc.stop()