X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=sched.c;h=bc301778f9a8c20d567db31b1b19f4c413fc0ed3;hp=f355c9750bc3ee2c426b2b5505073813973ce3cb;hb=534a94f441767947874cb15d18211edf758e9277;hpb=879e52d49df6d00aa9eafe5cccb48bbd24ed4c81 diff --git a/sched.c b/sched.c index f355c975..bc301778 100644 --- a/sched.c +++ b/sched.c @@ -1,5 +1,5 @@ /* - * Copyright (C) 2006-2014 Andre Noll + * Copyright (C) 2006 Andre Noll * * Licensed under the GPL v2. For licencing details see COPYING. */ @@ -7,7 +7,6 @@ /** \file sched.c Paraslash's scheduling functions. */ #include -#include #include "para.h" #include "ipc.h" @@ -49,13 +48,7 @@ struct task { }; static struct timeval now_struct; -struct timeval *now = &now_struct; - -static inline bool timeout_is_zero(struct sched *s) -{ - struct timeval *tv = &s->select_timeout; - return tv->tv_sec == 0 && tv->tv_usec == 0; -} +const struct timeval *now = &now_struct; static void sched_preselect(struct sched *s) { @@ -73,7 +66,10 @@ static void sched_preselect(struct sched *s) static void unlink_and_free_task(struct task *t) { - PARA_INFO_LOG("freeing task %s\n", t->name); + PARA_INFO_LOG("freeing task %s (%s)\n", t->name, t->status < 0? + para_strerror(-t->status) : + (t->status == TS_DEAD? "[dead]" : "[running]")); + list_del(&t->node); free(t->name); free(t); @@ -147,7 +143,7 @@ again: FD_ZERO(&s->wfds); s->select_timeout = s->default_timeout; s->max_fileno = -1; - clock_get_realtime(now); + clock_get_realtime(&now_struct); sched_preselect(s); ret = s->select_function(s->max_fileno + 1, &s->rfds, &s->wfds, &s->select_timeout); @@ -163,7 +159,7 @@ again: FD_ZERO(&s->rfds); FD_ZERO(&s->wfds); } - clock_get_realtime(now); + clock_get_realtime(&now_struct); num_running_tasks = sched_post_select(s); if (num_running_tasks == 0) return 0;