From 9b8111df96e13c8d1c26887d86edce5d17cdf684 Mon Sep 17 00:00:00 2001 From: Paul Brossier Date: Fri, 25 Jan 2013 15:24:53 -0600 Subject: [PATCH] timeside/decoder/core.py: temporary hack to wait for pipeline to be ready in setup, clean up unused release --- timeside/decoder/core.py | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/timeside/decoder/core.py b/timeside/decoder/core.py index 9031c35..839543a 100644 --- a/timeside/decoder/core.py +++ b/timeside/decoder/core.py @@ -144,6 +144,10 @@ class FileDecoder(Processor): self.release() raise self.read_error + while not hasattr(self,'input_samplerate'): + import time + time.sleep(.1) + def _pad_added_cb(self, decodebin, pad): caps = pad.get_caps() if caps.to_string().startswith('audio'): @@ -199,8 +203,8 @@ class FileDecoder(Processor): def _on_message_cb(self, bus, message): t = message.type if t == gst.MESSAGE_EOS: - self.pipeline.set_state(gst.STATE_NULL) self.queue.put(gst.MESSAGE_EOS) + self.pipeline.set_state(gst.STATE_NULL) self.mainloop.quit() elif t == gst.MESSAGE_ERROR: self.pipeline.set_state(gst.STATE_NULL) @@ -257,8 +261,7 @@ class FileDecoder(Processor): @interfacedoc def release(self): - if self.pipeline: self.pipeline.set_state(gst.STATE_NULL) - if self.mainloopthread: self.mainloopthread.join() + pass def __del__(self): self.release() -- 2.39.5