X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=sched.c;h=6233e40b950b3916c581882479461050cdd10551;hp=fad70132232268a2c9aade01c12b29e68f8987dc;hb=148c7c722fd5795228f586b6ef8d953662b68224;hpb=3c5c2ebfc2d651f2f77d0df89cbb58a2068bcad0 diff --git a/sched.c b/sched.c index fad70132..6233e40b 100644 --- a/sched.c +++ b/sched.c @@ -18,13 +18,6 @@ again: t->pre_select(s, t); if (t->ret > 0 || !t->error_handler) continue; - if (t->ret < 0) { - t->error_handler(t); - goto again; - } - if (!(t->flags & PRE_EOF_IS_ERROR)) - continue; - t->ret = -E_PRE_EOF; t->error_handler(t); goto again; } @@ -38,13 +31,6 @@ static void sched_post_select(struct sched *s) t->post_select(s, t); if (t->ret > 0 || !t->error_handler) continue; - if (t->ret < 0) { - t->error_handler(t); - continue; - } - if (!(t->flags & POST_EOF_IS_ERROR)) - continue; - t->ret = -E_POST_EOF; t->error_handler(t); } } @@ -72,7 +58,7 @@ again: void *register_task(struct task *t) { - PARA_INFO_LOG("registering task %p\n", t); + PARA_INFO_LOG("registering %s (%p)\n", t->status, t); if (t->pre_select) { PARA_DEBUG_LOG("pre_select: %p\n", &t->pre_select); if (t->flags & PRE_ADD_TAIL) @@ -92,7 +78,7 @@ void *register_task(struct task *t) void unregister_task(struct task *t) { - PARA_INFO_LOG("unregistering task %p\n", t); + PARA_INFO_LOG("unregistering %s (%p)\n", t->status, t); if (t->pre_select) list_del(&t->pre_select_node); if (t->post_select)