X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=sched.c;h=44e66c9b62664eb3add50d9924db6b311ea7e273;hp=9e346df20f5f4d03e6d1dfaa4322a3eace524db1;hb=bb6721e17e741b7ea52fbf88661d2b177bed72c3;hpb=6bdac07456cb5872f824028912d1049883a9c21f diff --git a/sched.c b/sched.c index 9e346df2..44e66c9b 100644 --- a/sched.c +++ b/sched.c @@ -6,6 +6,7 @@ /** \file sched.c Paraslash's scheduling functions. */ +#include #include /* readdir() */ #include #include @@ -43,14 +44,14 @@ static void unregister_task(struct task *t) if (t->post_select) list_del(&t->post_select_node); t->error = -E_TASK_UNREGISTERED; -}; +} static void sched_preselect(struct sched *s) { struct task *t, *tmp; list_for_each_entry_safe(t, tmp, &pre_select_list, pre_select_node) { - if (t->error >= 0) + if (t->error >= 0 && t->pre_select) t->pre_select(s, t); // PARA_INFO_LOG("%s \n", t->status); if (t->error >= 0) @@ -135,7 +136,7 @@ static void init_sched(void) INIT_LIST_HEAD(&pre_select_list); INIT_LIST_HEAD(&post_select_list); initialized = 1; -}; +} /** * Add a task to the scheduler. @@ -157,7 +158,7 @@ void register_task(struct task *t) list_add_tail(&t->pre_select_node, &pre_select_list); } if (t->post_select) { - PARA_DEBUG_LOG("post_select: %p\n", &t->pre_select); + PARA_DEBUG_LOG("post_select: %p\n", &t->post_select); list_add_tail(&t->post_select_node, &post_select_list); } } @@ -179,7 +180,7 @@ void sched_shutdown(void) list_for_each_entry_safe(t, tmp, &post_select_list, post_select_node) unregister_task(t); initialized = 0; -}; +} /** * Get the list of all registered tasks.