From: Paul Brossier <piem@piem.org>
Date: Tue, 29 Jan 2013 03:10:35 +0000 (-0500)
Subject: timeside/encoder/core.py: add mainloop to get messages from bus
X-Git-Tag: 0.4.3~1^2~7
X-Git-Url: https://git.parisson.com/?a=commitdiff_plain;h=52c08780c2b5ec19f207fed38bd636491b6901c6;p=timeside.git

timeside/encoder/core.py: add mainloop to get messages from bus
---

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)