X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=filter.c;h=7dbc07851b00c78de96b4889663286f468611398;hp=99b12217b8cc1e701c428928478a03a00ccd0c74;hb=63c513602a6b6a97cdced053beea0b2d07a9f984;hpb=92339599bddb1b1b79b6aa76d645b403081f4835 diff --git a/filter.c b/filter.c index 99b12217..7dbc0785 100644 --- a/filter.c +++ b/filter.c @@ -62,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; @@ -70,13 +79,13 @@ 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; fc->task.error = 0; fc->output_error = &sot->task.error; - fc->task.pre_select = filter_pre_select; + fc->task.post_select = filter_post_select; sprintf(fc->task.status, "filter chain"); FOR_EACH_FILTER_NODE(fn, fc, i) { @@ -93,6 +102,7 @@ static int init_filter_chain(void) open_filters(); return 1; err: + free_filter_confs(); free(fc->filter_nodes); return ret; } @@ -133,7 +143,8 @@ static int parse_config(int argc, char *argv[]) .override = 0, .initialize = 0, .check_required = 0, - .check_ambiguity = 0 + .check_ambiguity = 0, + .print_errors = 1 }; if (filter_cmdline_parser_config_file(cf, &conf, ¶ms)) return -E_FILTER_SYNTAX; @@ -176,11 +187,12 @@ int main(int argc, char *argv[]) sot->input_error = &fc->task.error; register_task(&sit->task); - register_task(&fc->task); register_task(&sot->task); + register_task(&fc->task); 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);