From d1e73792048155630b22d90abadc204b589dcb3a Mon Sep 17 00:00:00 2001 From: Paul Brossier Date: Fri, 25 Jan 2013 15:24:14 -0600 Subject: [PATCH] timeside/encoder/core.py: block push-buffer when max-bytes are queued, make sure num-buffers is unlimited, clean up unused release --- timeside/encoder/core.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) 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() -- 2.39.5