INIT_STDERR_LOGGING(conf.loglevel_arg);
-static void filter_event_handler(struct task *t)
-{
- PARA_NOTICE_LOG("%s\n", para_strerror(-t->ret));
- unregister_task(t);
-}
-
static void open_filters(void)
{
struct filter_node *fn;
fc->inbuf = sit->buf;
fc->in_loaded = &sit->loaded;
- fc->input_error = &sit->error;
- fc->error = 0;
- fc->output_error = &sot->error;
- fc->task.private_data = fc;
+ 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.event_handler = filter_event_handler;
sprintf(fc->task.status, "filter chain");
for (i = 0; i < conf.filter_given; i++) {
stdout_set_defaults(sot);
sot->buf = fc->outbuf;
sot->loaded = fc->out_loaded;
- sot->input_error = &fc->error;
+ sot->input_error = &fc->task.error;
register_task(&sit->task);
register_task(&fc->task);