X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=fecdec_filter.c;h=f1bd88595e3752397407c7afb8c4babe7f03baad;hp=d8b929760e6d450cf6412434f89f8c19438bd784;hb=74c88020bd325865fe26ed25ea8ad0ace0924136;hpb=b5b5d00eea33eccd3d2d75057c5254bf85568b00

diff --git a/fecdec_filter.c b/fecdec_filter.c
index d8b92976..f1bd8859 100644
--- a/fecdec_filter.c
+++ b/fecdec_filter.c
@@ -1,5 +1,5 @@
 /*
- * Copyright (C) 2009-2010 Andre Noll <maan@systemlinux.org>
+ * Copyright (C) 2009-2013 Andre Noll <maan@systemlinux.org>
  *
  * Licensed under the GPL v2. For licencing details see COPYING.
  */
@@ -7,9 +7,7 @@
 /** \file fecdec_filter.c A filter that fec-decodes an audio stream. */
 
 #include <regex.h>
-#include <stdbool.h>
 
-#include <dirent.h>
 #include "para.h"
 #include "error.h"
 #include "list.h"
@@ -292,7 +290,7 @@ static int decode_group(struct fecdec_group *fg, struct filter_node *fn)
 	size_t written, need;
 	struct private_fecdec_data *pfd = fn->private_data;
 	enum fec_group_usability u = group_is_usable(fg, pfd);
-	char *buf = NULL, *p;
+	char *buf = NULL;
 
 	if (u == FEC_GROUP_UNUSABLE) {
 		PARA_INFO_LOG("dropping unusable group %d\n", fg->h.group_num);
@@ -316,7 +314,6 @@ static int decode_group(struct fecdec_group *fg, struct filter_node *fn)
 	if (need > btr_pool_unused(pfd->btrp))
 		return -E_FECDEC_OVERRUN;
 	btr_pool_get_buffer(pfd->btrp, &buf);
-	p = buf;
 	if (u == FEC_GROUP_USABLE_WITH_HEADER) {
 		PARA_INFO_LOG("writing audio file header\n");
 		written = 0;
@@ -329,7 +326,6 @@ static int decode_group(struct fecdec_group *fg, struct filter_node *fn)
 			btr_copy(fg->data[i], n, pfd->btrp, fn->btrn);
 			written += n;
 		}
-		p += written;
 	}
 	written = 0;
 	for (; i < fg->h.data_slices_per_group; i++) {
@@ -339,7 +335,6 @@ static int decode_group(struct fecdec_group *fg, struct filter_node *fn)
 		btr_copy(fg->data[i], n, pfd->btrp, fn->btrn);
 		written += n;
 	}
-	p += written;
 	return 0;
 }
 
@@ -441,7 +436,7 @@ static void fecdec_close(struct filter_node *fn)
 	fn->private_data = NULL;
 }
 
-static void fecdec_post_select(__a_unused struct sched *s, struct task *t)
+static int fecdec_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;
@@ -473,9 +468,9 @@ next_buffer:
 	btr_consume(btrn, FEC_HEADER_SIZE + h.slice_bytes);
 	goto next_buffer;
 out:
-	t->error = ret;
 	if (ret < 0)
-		btr_remove_node(btrn);
+		btr_remove_node(&fn->btrn);
+	return ret;
 }
 
 static void fecdec_open(struct filter_node *fn)
@@ -496,5 +491,5 @@ void fecdec_filter_init(struct filter *f)
 	f->close = fecdec_close;
 	f->open = fecdec_open;
 	f->pre_select = generic_filter_pre_select;
-	f->post_select = fecdec_post_select;
+	f->new_post_select = fecdec_post_select;
 }