X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=filter_common.c;h=acd84d5cd6332e3d4a2c5507ecc661f1822ba0e1;hp=7c71ff39243a7a63f7026c11726418377790c87e;hb=b71a84c94992821c4bd70f80a2fdb3d4e9a39a62;hpb=63c4f3404cfb3aea943949d81b03bca14dbea559 diff --git a/filter_common.c b/filter_common.c index 7c71ff39..acd84d5c 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) != 0) { + s->timeout.tv_sec = 0; + s->timeout.tv_usec = 1; + } +} +