Teardown GStreamer mixer

This commit is contained in:
Stein Magnus Jodal 2012-09-11 10:08:59 +02:00
parent 2f33a6c4ff
commit 0e56b15fcc

View File

@ -62,6 +62,7 @@ class GStreamer(ThreadingActor):
def on_stop(self):
self._teardown_message_processor()
self._teardown_mixer()
self._teardown_pipeline()
def _setup_pipeline(self):
@ -133,6 +134,11 @@ class GStreamer(ThreadingActor):
gst.interfaces.MIXER_TRACK_OUTPUT):
return track
def _teardown_mixer(self):
if self._mixer is not None:
(mixer, track) = self._mixer
mixer.set_state(gst.STATE_NULL)
def _setup_message_processor(self):
bus = self._pipeline.get_bus()
bus.add_signal_watch()