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

Merge branch 'bugfix/85-fix-non-negotiated-appsrc' into hotfix/0.4.1

Browse Source
This commit is contained in:
Stein Magnus Jodal 2011-04-29 23:48:54 +02:00
commit eeeaed0a71
1 changed files with 17 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
mopidy/outputs/gstreamer.py
View File

@ -13,6 +13,15 @@ from mopidy.outputs.base import BaseOutput
logger = logging.getLogger('mopidy.outputs.gstreamer') logger = logging.getLogger('mopidy.outputs.gstreamer')
default_caps = gst.Caps("""
audio/x-raw-int,
endianness=(int)1234,
channels=(int)2,
width=(int)16,
depth=(int)16,
signed=(boolean)true,
rate=(int)44100""")
class GStreamerOutput(ThreadingActor, BaseOutput): class GStreamerOutput(ThreadingActor, BaseOutput):
""" """
Audio output through `GStreamer <http://gstreamer.freedesktop.org/>`_. Audio output through `GStreamer <http://gstreamer.freedesktop.org/>`_.
@ -48,6 +57,7 @@ class GStreamerOutput(ThreadingActor, BaseOutput):
uridecodebin = gst.element_factory_make('uridecodebin', 'uri') uridecodebin = gst.element_factory_make('uridecodebin', 'uri')
uridecodebin.connect('pad-added', self._process_new_pad, pad) uridecodebin.connect('pad-added', self._process_new_pad, pad)
uridecodebin.connect('notify::source', self._process_new_source)
self.gst_pipeline.add(uridecodebin) self.gst_pipeline.add(uridecodebin)
# Setup bus and message processor # Setup bus and message processor
@ -55,6 +65,13 @@ class GStreamerOutput(ThreadingActor, BaseOutput):
gst_bus.add_signal_watch() gst_bus.add_signal_watch()
gst_bus.connect('message', self._process_gstreamer_message) gst_bus.connect('message', self._process_gstreamer_message)
def _process_new_source(self, element, pad):
source = element.get_by_name('source')
try:
source.set_property('caps', default_caps)
except TypeError:
pass
def _process_new_pad(self, source, pad, target_pad): def _process_new_pad(self, source, pad, target_pad):
pad.link(target_pad) pad.link(target_pad)