X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=wav_filter.c;h=c2a9329f15e931af76fa10cdcab9913e627b0a24;hp=3149e5b42a6a84f84eed1ad603226b0df5b93862;hb=74c88020bd325865fe26ed25ea8ad0ace0924136;hpb=d16fe3df649cb48d5ffa26187da3dad4c3066646 diff --git a/wav_filter.c b/wav_filter.c index 3149e5b4..c2a9329f 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. */ @@ -74,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; @@ -83,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) { @@ -113,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); else { - btr_remove_node(btrn); + btr_remove_node(&fn->btrn); PARA_ERROR_LOG("%s\n", para_strerror(-ret)); } + return ret; } /** @@ -132,5 +131,5 @@ void wav_filter_init(struct filter *f) f->close = wav_close; f->open = wav_open; f->pre_select = wav_pre_select; - f->post_select = wav_post_select; + f->new_post_select = wav_post_select; }