From: Paul Brossier <piem@piem.org>
Date: Fri, 25 Jan 2013 21:24:14 +0000 (-0600)
Subject: timeside/encoder/core.py: block push-buffer when max-bytes are queued, make sure... 
X-Git-Tag: 0.4.3~2^2^2~3
X-Git-Url: https://git.parisson.com/?a=commitdiff_plain;h=d1e73792048155630b22d90abadc204b589dcb3a;p=timeside.git

timeside/encoder/core.py: block push-buffer when max-bytes are queued, make sure num-buffers is unlimited, clean up unused release
---

diff --git a/timeside/encoder/core.py b/timeside/encoder/core.py
index f957b1d..d656084 100644
--- a/timeside/encoder/core.py
+++ b/timeside/encoder/core.py
@@ -27,8 +27,7 @@ from timeside.tools import *
 class GstEncoder(Processor):
 
     def release(self):
-        while self.bus.have_pending():
-          self.bus.pop()
+        pass
 
     def __del__(self):
         self.release()
@@ -47,6 +46,8 @@ class GstEncoder(Processor):
             rate=(int)%d""" % (int(channels), int(samplerate)))
         self.src.set_property("caps", srccaps)
         self.src.set_property('emit-signals', True)
+        self.src.set_property('num-buffers', -1)
+        self.src.set_property('block', True)
 
         self.bus = self.pipeline.get_bus()
         self.bus.add_signal_watch()