X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=filter.c;h=40e3779eab4d22620125294e5024a443b18e6296;hp=93e4161802debea6af042bad8785556a5362046b;hb=7007aedb78262af262e7e7db8d010c6498e79290;hpb=eecc102ad0abeb0335fe994bb72031a15b9090d7 diff --git a/filter.c b/filter.c index 93e41618..40e3779e 100644 --- a/filter.c +++ b/filter.c @@ -1,5 +1,5 @@ /* - * Copyright (C) 2005-2009 Andre Noll + * Copyright (C) 2005-2013 Andre Noll * * Licensed under the GPL v2. For licencing details see COPYING. */ @@ -7,7 +7,6 @@ /** \file filter.c The stand-alone filter program. */ #include -#include #include "para.h" #include "filter.cmdline.h" @@ -20,6 +19,7 @@ #include "stdin.h" #include "stdout.h" #include "error.h" +#include "version.h" /** The list of all status items used by para_{server,audiod,gui}. */ const char *status_item_list[] = {STATUS_ITEM_ARRAY}; @@ -119,7 +119,7 @@ int main(int argc, char *argv[]) sit->btrn = btr_new_node(&(struct btr_node_description) EMBRACE(.name = "stdin")); stdin_set_defaults(sit); - register_task(&sit->task); + register_task(&s, &sit->task); fns = para_malloc(conf.filter_given * sizeof(*fns)); for (i = 0, parent = sit->btrn; i < conf.filter_given; i++) { @@ -142,13 +142,13 @@ int main(int argc, char *argv[]) fn->task.pre_select = f->pre_select; fn->task.post_select = f->post_select; f->open(fn); - register_task(&fn->task); + register_task(&s, &fn->task); parent = fn->btrn; } sot->btrn = btr_new_node(&(struct btr_node_description) EMBRACE(.name = "stdout", .parent = parent)); stdout_set_defaults(sot); - register_task(&sot->task); + register_task(&s, &sot->task); s.default_timeout.tv_sec = 1; s.default_timeout.tv_usec = 0; @@ -161,13 +161,14 @@ out_cleanup: f = filters + fn->filter_num; if (f->close) f->close(fn); - btr_free_node(fn->btrn); - free(fn->conf); + btr_remove_node(&fn->btrn); + if (f->free_config) + f->free_config(fn->conf); free(fn); } free(fns); - btr_free_node(sit->btrn); - btr_free_node(sot->btrn); + btr_remove_node(&sit->btrn); + btr_remove_node(&sot->btrn); out: if (ret < 0) PARA_EMERG_LOG("%s\n", para_strerror(-ret));