boswatch.inputSource.sdrInput.SdrInput Class Reference

Class for the sdr input source. More...

Protected Member Functions
	_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
	__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 Attributes inherited from boswatch.inputSource.inputBase.InputBase
	_inputThread
	_isRunning
	_inputQueue
	_inputConfig
	_decoderConfig

Detailed Description

Class for the sdr input source.

Member Function Documentation

_runThread()

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