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

Switch to event probe based solution to removing outputs.

Browse Source 
Based on http://lists.freedesktop.org/archives/gstreamer-devel/2009-August/023708.html
This commit is contained in:
Thomas Adamcik 2011-05-17 01:21:50 +02:00
parent 82bd77e24b
commit 801b3d1155
1 changed files with 30 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
mopidy/gstreamer.py
View File

@ -285,18 +285,38 @@ class GStreamer(ThreadingActor):
def remove_output(self, output): def remove_output(self, output):
if output not in self._outputs: if output not in self._outputs:
return # FIXME raise mopidy exception of some sort? return # FIXME raise mopidy exception of some sort?
src = output.get_pad('sink').get_peer() teesrc = output.get_pad('sink').get_peer()
src.set_blocked_async(True, self._blocked_callback, output) handler = teesrc.add_event_probe(self._handle_event_probe)
def _blocked_callback(self, pad, blocked, output): struct = gst.Structure('mopidy-unlink-tee')
gst.element_unlink_many(self._tee, output) struct.set_value('handler', handler)
pad.set_blocked_async(False, self._unblocked_callback, output)
def _unblocked_callback(self, pad, blocked, output): event = gst.event_new_custom(gst.EVENT_CUSTOM_DOWNSTREAM, struct)
output.set_state(gst.STATE_NULL) self._tee.send_event(event)
self._pipeline.remove(output)
self._outputs.remove(output) def _handle_event_probe(self, teesrc, event):
logger.warning(u'Removed %s', output.get_name()) if event.type == gst.EVENT_CUSTOM_DOWNSTREAM and event.has_name('mopidy-unlink-tee'):
data = self._get_structure_data(event.get_structure())
output = teesrc.get_peer().get_parent()
teesrc.unlink(teesrc.get_peer())
teesrc.remove_event_probe(data['handler'])
output.set_state(gst.STATE_NULL)
self._pipeline.remove(output)
logger.warning('Removed %s', output.get_name())
return False
return True
def _get_structure_data(self, struct):
# Ugly hack to get around missing get_value in pygst bindings :/
data = {}
def get_data(key, value):
data[key] = value
struct.foreach(get_data)
return data
def connect_message_handler(self, element, handler): def connect_message_handler(self, element, handler):
self._handlers[element] = handler self._handlers[element] = handler