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

Start preprations for supporting switching between sources

Browse Source
This commit is contained in:
Thomas Adamcik 2010-08-15 03:03:32 +02:00
parent da763be9d7
commit 83fbc8ea22
1 changed files with 4 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
mopidy/outputs/gstreamer.py
View File

@ -47,6 +47,7 @@ class GStreamerProcess(BaseProcess):
self.core_queue = core_queue self.core_queue = core_queue
self.output_queue = output_queue self.output_queue = output_queue
self.gst_pipeline = None self.gst_pipeline = None
self.gst_target = None
def run_inside_try(self): def run_inside_try(self):
self.setup() self.setup()
@ -63,23 +64,15 @@ class GStreamerProcess(BaseProcess):
messages_thread.start() messages_thread.start()
self.gst_pipeline = gst.parse_launch(' ! '.join([ self.gst_pipeline = gst.parse_launch(' ! '.join([
'multiqueue name=queue',
'volume name=volume', 'volume name=volume',
'alsasink' 'alsasink'
])) ]))
self.gst_target = self.gst_pipeline.get_by_name('volume')
decode_bin = gst.element_factory_make('uridecodebin', 'uri') decode_bin = gst.element_factory_make('uridecodebin', 'uri')
decode_bin.connect('pad-added', self.process_new_pad) decode_bin.connect('pad-added', self.process_new_pad)
app_src = gst.element_factory_make('appsrc', 'src')
queue = self.gst_pipeline.get_by_name('queue')
self.gst_pipeline.add(decode_bin) self.gst_pipeline.add(decode_bin)
self.gst_pipeline.add(app_src)
self.gst_uri_pad = queue.get_request_pad('sink0')
self.gst_src_pad = queue.get_request_pad('sink1')
app_src.get_pad('src').link(self.gst_src_pad)
# Setup bus and message processor # Setup bus and message processor
gst_bus = self.gst_pipeline.get_bus() gst_bus = self.gst_pipeline.get_bus()
@ -87,7 +80,7 @@ class GStreamerProcess(BaseProcess):
gst_bus.connect('message', self.process_gst_message) gst_bus.connect('message', self.process_gst_message)
def process_new_pad(self, source, pad): def process_new_pad(self, source, pad):
pad.link(self.gst_uri_pad) pad.link(self.gst_target.get_pad('sink'))
def process_mopidy_message(self, message): def process_mopidy_message(self, message):
"""Process messages from the rest of Mopidy.""" """Process messages from the rest of Mopidy."""