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

Use uridecodebin with auto connecting to play local music

Browse Source
This commit is contained in:
Thomas Adamcik 2010-08-14 23:54:54 +02:00
parent e93e3d4265
commit b2b169eaa9
1 changed files with 16 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
mopidy/outputs/gstreamer.py
View File

@ -47,6 +47,7 @@ class GStreamerProcess(BaseProcess):
self.core_queue = core_queue
self.output_queue = output_queue
self.gst_pipeline = None
self.gst_decoder = None
def run_inside_try(self):
self.setup()
@ -62,13 +63,26 @@ class GStreamerProcess(BaseProcess):
messages_thread.daemon = True
messages_thread.start()
self.gst_pipeline = gst.parse_launch('playbin')
self.gst_pipeline = gst.parse_launch(' ! '.join([
'volume name=volume',
'autoaudiosink'
]))
decode_bin = gst.element_factory_make('uridecodebin', 'uri')
decode_bin.connect('pad-added', self.process_new_pad, 'volume')
app_src = gst.element_factory_make('appsrc', 'src')
self.gst_pipeline.add(decode_bin)
self.gst_pipeline.add(app_src)
# Setup bus and message processor
gst_bus = self.gst_pipeline.get_bus()
gst_bus.add_signal_watch()
gst_bus.connect('message', self.process_gst_message)
def process_new_pad(self, source, pad, target):
pad.link(self.gst_pipeline.get_by_name(target).get_pad('sink'))
def process_mopidy_message(self, message):
"""Process messages from the rest of Mopidy."""
if message['command'] == 'play_uri':
@ -114,7 +128,7 @@ class GStreamerProcess(BaseProcess):
def play_uri(self, uri):
"""Play audio at URI"""
self.set_state('READY')
self.gst_pipeline.set_property('uri', uri)
self.gst_pipeline.get_by_name('uri').set_property('uri', uri)
return self.set_state('PLAYING')
def deliver_data(self, caps_string, data):