boswatch.inputSource.pulseaudioInput.PulseAudioInput Class Reference

Class for the PulseAudio input source. More...

Protected Member Functions
	_runThread (self, dataQueue, PulseAudioConfig, 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 PulseAudio input source.

Member Function Documentation

_runThread()

boswatch.inputSource.pulseaudioInput.PulseAudioInput._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, PulseAudioConfig, decoderConfig):
        PulseAudioProc = None
        mmProc = None
        try:
            PulseAudioProc = ProcessManager("parec")
            PulseAudioProc.addArgument("--channels=1")                            # supress any other outputs
            PulseAudioProc.addArgument("--format=s16le")                          # set output format (16bit)
            PulseAudioProc.addArgument("--rate=22050")                            # set output sampling rate (22050Hz)
            PulseAudioProc.addArgument("--device=" +
                                       str(PulseAudioConfig.get("device", default="boswatch")) +
                                       ".monitor")                                # sink name
            PulseAudioProc.setStderr(open(paths.LOG_PATH + "pulseaudio.log", "a"))
            PulseAudioProc.start()
 
            mmProc = self.getDecoderInstance(decoderConfig, PulseAudioProc.stdout)
            mmProc.start()
 
            logging.info("start decoding")
            while self._isRunning:
                if not PulseAudioProc.isRunning:
                    logging.warning("PulseAudio was down - try to restart")
                    PulseAudioProc.start()
 
                    if PulseAudioProc.isRunning:
                        logging.info("rtl_fm is back up - restarting multimon...")
                        mmProc.setStdin(PulseAudioProc.stdout)
                        mmProc.start()
                elif not mmProc.isRunning:
                    logging.warning("multimon was down - try to restart")
                    mmProc.start()
                elif PulseAudioProc.isRunning and mmProc.isRunning:
                    line = mmProc.readline()
                    if line:
                        self.addToQueue(line)
        except:
            logging.exception("error in PulseAudio input routine")
        finally:
            mmProc.stop()
            PulseAudioProc.stop()