From 52c08780c2b5ec19f207fed38bd636491b6901c6 Mon Sep 17 00:00:00 2001 From: Paul Brossier Date: Mon, 28 Jan 2013 22:10:35 -0500 Subject: [PATCH] timeside/encoder/core.py: add mainloop to get messages from bus --- timeside/encoder/core.py | 12 ++++++++++++ 1 file changed, 12 insertions(+) diff --git a/timeside/encoder/core.py b/timeside/encoder/core.py index e87587e..9d6eaaa 100644 --- a/timeside/encoder/core.py +++ b/timeside/encoder/core.py @@ -71,6 +71,18 @@ class GstEncoder(Processor): self.bus.add_signal_watch() self.bus.connect("message", self.on_message) + import threading + class MainloopThread(threading.Thread): + def __init__(self, mainloop): + threading.Thread.__init__(self) + self.mainloop = mainloop + + def run(self): + self.mainloop.run() + self.mainloop = gobject.MainLoop() + self.mainloopthread = MainloopThread(self.mainloop) + self.mainloopthread.start() + # start pipeline self.pipeline.set_state(gst.STATE_PLAYING) -- 2.39.5