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

diff --git a/timeside/encoder/core.py b/timeside/encoder/core.py
index e87587eb987df331bc587ffab2404a393a9e64e8..9d6eaaa50730437294c27c388d76c1cfb7efa898 100644 (file)
--- 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)