From 1bd35a4ac985d0909602ad99ff7e94b3f4b23903 Mon Sep 17 00:00:00 2001 From: yomguy Date: Wed, 30 Jan 2013 23:32:44 +0100 Subject: [PATCH] call release() for each processor at the end of the pipe run fix some tests --- tests/api/test_enc_flac.py | 14 ++++++++++++++ tests/api/test_enc_mp3.py | 2 +- tests/api/test_enc_ogg.py | 2 +- timeside/core.py | 3 +++ 4 files changed, 19 insertions(+), 2 deletions(-) create mode 100644 tests/api/test_enc_flac.py diff --git a/tests/api/test_enc_flac.py b/tests/api/test_enc_flac.py new file mode 100644 index 0000000..17e604a --- /dev/null +++ b/tests/api/test_enc_flac.py @@ -0,0 +1,14 @@ +# -*- coding: utf-8 -*- + +from timeside.decoder import * +from timeside.encoder import * +import os.path +import sys + +source = sys.argv[-1] +dest = source+'.flac' + +decoder = FileDecoder(source) +encoder = FlacEncoder(dest, overwrite=True) + +(decoder | encoder).run() diff --git a/tests/api/test_enc_mp3.py b/tests/api/test_enc_mp3.py index 2439027..2dea63c 100644 --- a/tests/api/test_enc_mp3.py +++ b/tests/api/test_enc_mp3.py @@ -15,7 +15,7 @@ dest = source+'.mp3' print 'converting', source, 'to', dest decoder = FileDecoder(source) -encoder = Mp3Encoder(dest) +encoder = Mp3Encoder(dest, overwrite=True) (decoder | encoder).run() diff --git a/tests/api/test_enc_ogg.py b/tests/api/test_enc_ogg.py index 5c2947e..b6be599 100644 --- a/tests/api/test_enc_ogg.py +++ b/tests/api/test_enc_ogg.py @@ -15,6 +15,6 @@ dest = source+'.ogg' print 'converting', source, 'to', dest decoder = FileDecoder(source) -encoder = VorbisEncoder(dest) +encoder = VorbisEncoder(dest, overwrite=True) (decoder | encoder).run() diff --git a/timeside/core.py b/timeside/core.py index 909109f..1f8337a 100644 --- a/timeside/core.py +++ b/timeside/core.py @@ -229,4 +229,7 @@ class ProcessPipe(object): for item in items: frames, eod = item.process(frames, eod) + for item in items: + item.release() + return self -- 2.39.5