X-Git-Url: http://git.tuebingen.mpg.de/?a=blobdiff_plain;ds=sidebyside;f=filter_common.c;h=a4f8868b6355a66d92eecd5bc4ebb10f282c27f1;hb=e35ea862df8fddbc7f70a0860cd36e31b27696c1;hp=7c71ff39243a7a63f7026c11726418377790c87e;hpb=684ea7f70948c9ce5077a8a6460946ff86fefe46;p=paraslash.git diff --git a/filter_common.c b/filter_common.c index 7c71ff39..a4f8868b 100644 --- a/filter_common.c +++ b/filter_common.c @@ -9,12 +9,14 @@ #include #include #include +#include #include "para.h" #include "list.h" #include "sched.h" #include "fd.h" #include "ggo.h" +#include "buffer_tree.h" #include "filter.h" #include "error.h" #include "string.h" @@ -273,3 +275,15 @@ void print_filter_helps(int detailed) } } + +void generic_filter_pre_select(struct sched *s, struct task *t) +{ + struct filter_node *fn = container_of(t, struct filter_node, task); + + t->error = 0; + if (btr_node_status(fn->btrn, fn->min_iqs, BTR_NT_INTERNAL) != 0) { + s->timeout.tv_sec = 0; + s->timeout.tv_usec = 1; + } +} +