andpp/mopidy
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Swith to tee based pipeline to allow for multiple outputs

Browse Source
This commit is contained in:
Thomas Adamcik 2011-04-23 21:45:58 +02:00
parent aa0c309d23
commit 9f77f801ba
1 changed files with 14 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
mopidy/outputs/gstreamer.py
View File

@ -35,21 +35,28 @@ class GStreamerOutput(ThreadingActor, BaseOutput):
:class:`mopidy.utils.process.GObjectEventThread` to be running. This is
not enforced by :class:`GStreamerOutput` itself.
"""
logger.debug(u'Setting up GStreamer pipeline')
self.gst_pipeline = gst.parse_launch(' ! '.join([
base_pipeline = ' ! '.join([
'audioconvert name=convert',
'volume name=volume',
settings.GSTREAMER_AUDIO_SINK,
]))
'taginject name=tag',
'tee name=tee',
])
pad = self.gst_pipeline.get_by_name('convert').get_pad('sink')
logger.debug(u'Setting up base GStreamer pipeline: %s', base_pipeline)
self.gst_pipeline = gst.parse_launch(base_pipeline)
tee = self.gst_pipeline.get_by_name('tee')
convert = self.gst_pipeline.get_by_name('convert')
uridecodebin = gst.element_factory_make('uridecodebin', 'uri')
uridecodebin.connect('pad-added', self._process_new_pad, pad)
self.gst_pipeline.add(uridecodebin)
output_bin = gst.parse_bin_from_description('queue ! %s' %
settings.GSTREAMER_AUDIO_SINK, True)
gst.element_link_many(tee, output_bin)
# Setup bus and message processor
gst_bus = self.gst_pipeline.get_bus()
gst_bus.add_signal_watch()