X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=filter.c;h=e6c75556b91e5ecc0c3ca1f005f5471056bdfb7a;hp=b8a7c5c19231d415f0e2488a6275f619901e2d65;hb=899677b50128e00e58d76d26c05be9f078204c67;hpb=318fbe90e08b6d9c5e781d9b517b670c5a1a04d7 diff --git a/filter.c b/filter.c index b8a7c5c1..e6c75556 100644 --- a/filter.c +++ b/filter.c @@ -6,8 +6,9 @@ /** \file filter.c The stand-alone filter program. */ -#include "para.h" +#include +#include "para.h" #include "filter.cmdline.h" #include "list.h" #include "sched.h" @@ -61,6 +62,15 @@ static void open_filters(void) } } +static void free_filter_confs(void) +{ + int i; + struct filter_node *fn; + + FOR_EACH_FILTER_NODE(fn, fc, i) + free(fn->conf); +} + static int init_filter_chain(void) { int i, ret; @@ -69,7 +79,7 @@ static int init_filter_chain(void) if (!conf.filter_given) return -E_NO_FILTERS; fc->num_filters = conf.filter_given; - fc->filter_nodes = para_malloc(fc->num_filters * sizeof(struct filter_node)); + fc->filter_nodes = para_calloc(fc->num_filters * sizeof(struct filter_node)); fc->inbufp = &sit->buf; fc->in_loaded = &sit->loaded; fc->input_error = &sit->task.error; @@ -92,6 +102,7 @@ static int init_filter_chain(void) open_filters(); return 1; err: + free_filter_confs(); free(fc->filter_nodes); return ret; } @@ -121,6 +132,7 @@ static int parse_config(int argc, char *argv[]) HANDLE_VERSION_FLAG("filter", conf); if (conf.help_given || conf.detailed_help_given) print_help_and_die(); + loglevel = get_loglevel_by_name(conf.loglevel_arg); if (!cf) { char *home = para_homedir(); cf = make_message("%s/.paraslash/filter.conf", home); @@ -163,7 +175,6 @@ int main(int argc, char *argv[]) ret = parse_config(argc, argv); if (ret < 0) goto out; - loglevel = get_loglevel_by_name(conf.loglevel_arg); ret = init_filter_chain(); if (ret < 0) goto out; @@ -180,6 +191,7 @@ int main(int argc, char *argv[]) s.default_timeout.tv_sec = 1; s.default_timeout.tv_usec = 0; ret = schedule(&s); + free_filter_confs(); close_filters(fc); out: free(sit->buf);