X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=sched.c;h=4c9f14a8001abe415e378b4f890c774e8cfc58c2;hp=b6efb1ae815309e672997abca57ae97a8f6906d1;hb=23f053fc0a392079213bf2f979b7c098baa9d30c;hpb=a2fb56bdfa2726d401de8c1c3cd569ba96a5ccc3 diff --git a/sched.c b/sched.c index b6efb1ae..4c9f14a8 100644 --- a/sched.c +++ b/sched.c @@ -25,7 +25,7 @@ static int initialized; static struct timeval now_struct; struct timeval *now = &now_struct; -/** +/* * Remove a task from the scheduler. * * \param t The task to remove. @@ -137,7 +137,7 @@ again: goto again; } -/** +/* * Initialize the paraslash scheduler. */ static void init_sched(void) @@ -199,7 +199,7 @@ void sched_shutdown(void) * * Each entry of the list contains an identifier which is simply a hex number * that may be used in \a kill_task() to terminate the task. - * The result ist dynamically allocated and must be freed by the caller. + * The result is dynamically allocated and must be freed by the caller. */ char *get_task_list(void) { @@ -261,18 +261,46 @@ int kill_task(char *id) return -E_NO_SUCH_TASK; } +/** + * Set the select timeout to the minimal possible value. + * + * \param s Pointer to the scheduler struct. + * + * This causes the next select() call to return immediately. + */ void sched_min_delay(struct sched *s) { s->timeout.tv_sec = 0; s->timeout.tv_usec = 1; } +/** + * Impose an upper bound for the timeout of the next select() call. + * + * \param timeout Maximal allowed timeout. + * \param s Pointer to the scheduler struct. + * + * If the current scheduler timeout is already smaller than \a timeout, this + * function does nothing. Otherwise the timeout for the next select() call is + * set to the given value. + * + * \sa sched_request_timeout_ms(). + */ void sched_request_timeout(struct timeval *timeout, struct sched *s) { if (tv_diff(&s->timeout, timeout, NULL) > 0) s->timeout = *timeout; } +/** + * Force the next select() call to return before the given amount of milliseconds. + * + * \param ms The maximal allowed timeout in milliseconds. + * \param s Pointer to the scheduler struct. + * + * Like sched_request_timeout() this imposes an upper bound on the timeout + * value for the next select() call. + */ void sched_request_timeout_ms(long unsigned ms, struct sched *s) { struct timeval tv; @@ -280,6 +308,16 @@ void sched_request_timeout_ms(long unsigned ms, struct sched *s) sched_request_timeout(&tv, s); } +/** + * Force the next select() call to return before the given future time. + * + * \param barrier Absolute time before select() should return. + * \param s Pointer to the scheduler struct. + * + * If \a barrier is in the past, this function does nothing. + * + * \sa sched_request_barrier_or_min_delay(). + */ void sched_request_barrier(struct timeval *barrier, struct sched *s) { struct timeval diff; @@ -289,6 +327,16 @@ void sched_request_barrier(struct timeval *barrier, struct sched *s) sched_request_timeout(&diff, s); } +/** + * Force the next select() call to return before the given time. + * + * \param barrier Absolute time before select() should return. + * \param s Pointer to the scheduler struct. + * + * If \a barrier is in the past, this function requests a minimal timeout. + * + * \sa sched_min_delay(), sched_request_barrier(). + */ void sched_request_barrier_or_min_delay(struct timeval *barrier, struct sched *s) { struct timeval diff;