X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=sched.h;h=f119025c4c73f2d6b811f8220e6cec4c2449cd0d;hp=7ab830861a940bff99c3085d3e07be055eb5c513;hb=e7e55d0ad711a46e4768066be197bb41caa5c5eb;hpb=6105cde18ae21b82708a4c98aa2d54820afd47a5;ds=inline diff --git a/sched.h b/sched.h index 7ab83086..f119025c 100644 --- a/sched.h +++ b/sched.h @@ -1,14 +1,14 @@ /* - * Copyright (C) 2006 Andre Noll + * Copyright (C) 2006-2009 Andre Noll * * Licensed under the GPL v2. For licencing details see COPYING. */ -/** \file sched.h sched and task structures and exported symbols from sched.c */ +/** \file sched.h Sched and task structures and exported symbols from sched.c. */ /** - * paraslash's scheduler + * Paraslash's scheduler. * * Designed with KISS in mind. It manages two lists of tasks. The pre_select * list contains pointers to functions that are called before calling select() @@ -17,60 +17,53 @@ * these lists by registering themselves to the scheduler. */ struct sched { - /** initial value before any pre_select call */ + /** Initial value before any pre_select call. */ struct timeval default_timeout; - /** the current timeout for the upcoming select call */ + /** The current timeout for the upcoming select call. */ struct timeval timeout; - /** fds that should be watched for readability */ + /** fds that should be watched for readability. */ fd_set rfds; - /** fds that should be watched for writability */ + /** fds that should be watched for writability. */ fd_set wfds; - /** highest numbered file descriptor in any of the above fd sets */ + /** Highest numbered file descriptor in any of the above fd sets. */ int max_fileno; - /** the return value of the previous select call */ - int select_ret; + /** In non-NULL, use this function instead of para_select. */ + int (*select_function)(int, fd_set *, fd_set *, struct timeval *); }; /** - * paraslash's task structure + * Paraslash's task structure. * - * before registering a task to the scheduler, the task structure must be + * Before registering a task to the scheduler, the task structure must be * filled in properly by the caller. * - * If one of these functions return a negative value via \a t->ret the - * (optional) event_handler gets called (it may also be called in case another - * event happened). In many cases the only possible event is an error or an eof - * condition and the event handler simply unregisters the task from the - * scheduler. + * If one of these functions sets \a t->error to a negative value, the + * task gets unregistered automatically. * - * \sa struct sched + * \sa struct sched. */ struct task { - /** pointer to the struct this task is embedded in */ - void *private_data; /** - * the pre select hook of \a t + * The pre select hook of \a t. * * Its purpose is to add file descriptors to the fd sets of the * scheduler and to decrease the select timeout if necessary. */ void (*pre_select)(struct sched *s, struct task *t); /** - * the postselect hook of \a t + * The postselect hook of \a t. * - * evaluate and act upon the results of the previous select call. + * Evaluate and act upon the results of the previous select call. */ void (*post_select)(struct sched *s, struct task *t); - /** gets called if pre_select or post_select returned an error */ - void (*event_handler)(struct task *t); - /** pre_select() and post_select store their return value here */ - int ret; - /** position of the task in the pre_select list of the scheduler */ + /** Whether this task is in error state. */ + int error; + /** Position of the task in the pre_select list of the scheduler. */ struct list_head pre_select_node; - /** position of the task in the post_select list of the scheduler */ + /** Position of the task in the post_select list of the scheduler. */ struct list_head post_select_node; - /** descriptive text and current status of the task */ - char status[MAXLINE]; + /** Descriptive text and current status of the task. */ + char status[255]; }; /** @@ -82,7 +75,10 @@ struct task { extern struct timeval *now; void register_task(struct task *t); -void unregister_task(struct task *t); int schedule(struct sched *s); char *get_task_list(void); int kill_task(char *id); +void sched_shutdown(void); +void sched_min_delay(struct sched *s); +void sched_request_timeout(struct timeval *timeout, struct sched *s); +void sched_request_timeout_ms(long unsigned ms, struct sched *s);