X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=wav_filter.c;h=eaef1f5cca7b79c4b532d91dda239aaa7e53c0ee;hp=8408034d905c6f20eb375385d638de31a43df0e3;hb=761d9bd95a6601c0b3be6591a6b6672b755e1fbe;hpb=b62e2796b85c7d7f3138fe729f4637853e0fafe0 diff --git a/wav_filter.c b/wav_filter.c index 8408034d..eaef1f5c 100644 --- a/wav_filter.c +++ b/wav_filter.c @@ -1,5 +1,5 @@ /* - * Copyright (C) 2005-2011 Andre Noll + * Copyright (C) 2005-2013 Andre Noll * * Licensed under the GPL v2. For licencing details see COPYING. */ @@ -7,7 +7,6 @@ /** \file wav_filter.c A filter that inserts a wave header. */ #include -#include #include "para.h" #include "error.h" @@ -75,7 +74,7 @@ static void wav_pre_select(struct sched *s, struct task *t) sched_min_delay(s); } -static void wav_post_select(__a_unused struct sched *s, struct task *t) +static int wav_post_select(__a_unused struct sched *s, struct task *t) { struct filter_node *fn = container_of(t, struct filter_node, task); struct btr_node *btrn = fn->btrn; @@ -84,12 +83,11 @@ static void wav_post_select(__a_unused struct sched *s, struct task *t) char *header, *buf; int32_t rate, ch; - t->error = 0; if (iqs == 0) { ret = -E_WAV_EOF; if (btr_no_parent(btrn)) goto err; - return; + return 0; } ret = btr_exec_up(btrn, "sample_rate", &buf); if (ret < 0) { @@ -114,13 +112,13 @@ static void wav_post_select(__a_unused struct sched *s, struct task *t) btr_add_output(header, WAV_HEADER_LEN, btrn); ret = -E_WAV_SUCCESS; err: - t->error = ret; if (ret == -E_WAV_SUCCESS) - btr_splice_out_node(btrn); + btr_splice_out_node(&fn->btrn); else { - btr_remove_node(btrn); + btr_remove_node(&fn->btrn); PARA_ERROR_LOG("%s\n", para_strerror(-ret)); } + return ret; } /**