|
version 1.1.1.1.2.7, 2011/09/12 08:06:19
|
version 1.3.2.1, 2011/12/08 09:17:34
|
|
Line 50 SUCH DAMAGE.
|
Line 50 SUCH DAMAGE.
|
| #include <sys/types.h> |
#include <sys/types.h> |
| #include <sys/queue.h> |
#include <sys/queue.h> |
| #include <sys/uio.h> |
#include <sys/uio.h> |
| |
#include <stdint.h> |
| |
|
| |
|
| /* criteria type */ |
/* criteria type */ |
|
Line 96 struct sched_HooksTask {
|
Line 97 struct sched_HooksTask {
|
| sched_hook_func_t run; |
sched_hook_func_t run; |
| /* fetch(sched_root_task_t *root, NULL) -> sched_task_t* */ |
/* fetch(sched_root_task_t *root, NULL) -> sched_task_t* */ |
| sched_hook_func_t fetch; |
sched_hook_func_t fetch; |
| |
/* exception(sched_root_task_t *root, NULL) -> int */ |
| |
sched_hook_func_t exception; |
| } hook_exec; |
} hook_exec; |
| struct { |
struct { |
| /* init(sched_root_task_t *root, void *data) -> int */ |
/* init(sched_root_task_t *root, void *data) -> int */ |
| sched_hook_func_t init; |
sched_hook_func_t init; |
| /* fini(sched_root_task_t *root, NULL) -> int */ |
/* fini(sched_root_task_t *root, NULL) -> int */ |
| sched_hook_func_t fini; |
sched_hook_func_t fini; |
| |
/* error(sched_root_task_t *root, int errno) -> int */ |
| |
sched_hook_func_t error; |
| } hook_root; |
} hook_root; |
| }; |
}; |
| typedef struct sched_HooksTask hooks_task_t; |
typedef struct sched_HooksTask hooks_task_t; |
|
Line 109 typedef struct sched_HooksTask hooks_task_t;
|
Line 114 typedef struct sched_HooksTask hooks_task_t;
|
| /* task callback, like pthread callback! */ |
/* task callback, like pthread callback! */ |
| typedef void *(*sched_task_func_t)(sched_task_t * /* current task data*/); |
typedef void *(*sched_task_func_t)(sched_task_t * /* current task data*/); |
| |
|
| |
/* task lock helpers */ |
| |
#define TASK_LOCK(x) ((x)->task_lock++) |
| |
#define TASK_UNLOCK(x) ((x)->task_lock ^= (x)->task_lock) |
| |
#define TASK_ISLOCKED(x) ((x)->task_lock) |
| |
|
| /* task & queue */ |
/* task & queue */ |
| struct sched_Task { |
struct sched_Task { |
| |
volatile int task_lock; |
| unsigned int task_id; |
unsigned int task_id; |
| sched_task_type_t task_type; |
sched_task_type_t task_type; |
| |
|
|
Line 121 struct sched_Task {
|
Line 132 struct sched_Task {
|
| void *task_arg; |
void *task_arg; |
| union { |
union { |
| unsigned long v; |
unsigned long v; |
| int fd; | intptr_t fd; |
| struct timeval tv; |
struct timeval tv; |
| } task_val; |
} task_val; |
| #define TASK_ARG(x) (x)->task_arg |
#define TASK_ARG(x) (x)->task_arg |
|
Line 160 struct sched_RootTask {
|
Line 171 struct sched_RootTask {
|
| |
|
| inline int sched_GetErrno(); |
inline int sched_GetErrno(); |
| inline const char *sched_GetError(); |
inline const char *sched_GetError(); |
| inline void sched_SetErr(int, char *, ...); |
|
| |
|
| |
|
| /* |
/* |
|
Line 215 int schedCancel(sched_task_t * __restrict task);
|
Line 225 int schedCancel(sched_task_t * __restrict task);
|
| * @criteria = find task by criteria [CRITERIA_CALL|CRITERIA_ARG|CRITERIA_FD|CRITERIA_VAL|CRITERIA_TV] |
* @criteria = find task by criteria [CRITERIA_CALL|CRITERIA_ARG|CRITERIA_FD|CRITERIA_VAL|CRITERIA_TV] |
| * @param = search parameter |
* @param = search parameter |
| * @hook = custom cleanup hook function, may be NULL |
* @hook = custom cleanup hook function, may be NULL |
| * return: -1 error or 0 ok | * return: -1 error, -2 error in sub-stage cancel execution, -3 error from custom hook or 0 ok |
| */ |
*/ |
| int schedCancelby(sched_root_task_t * __restrict root, sched_queue_t * __restrict queue, |
int schedCancelby(sched_root_task_t * __restrict root, sched_queue_t * __restrict queue, |
| u_char criteria, void *param, sched_hook_func_t hook); |
u_char criteria, void *param, sched_hook_func_t hook); |
|
Line 244 sched_task_t *schedWrite(sched_root_task_t * __restric
|
Line 254 sched_task_t *schedWrite(sched_root_task_t * __restric
|
| * @root = root task |
* @root = root task |
| * @func = task execution function |
* @func = task execution function |
| * @arg = 1st func argument |
* @arg = 1st func argument |
| * @ms = arguments in microSecs, define period 1sec == 1000000 | * @tv = timeout argument structure |
| * return: NULL error or !=NULL new queued task |
* return: NULL error or !=NULL new queued task |
| */ |
*/ |
| sched_task_t *schedTimer(sched_root_task_t * __restrict root, sched_task_func_t func, void *arg, unsigned int ms); | sched_task_t *schedTimer(sched_root_task_t * __restrict root, sched_task_func_t func, void *arg, struct timeval tv); |
| /* |
/* |
| * schedEvent() - Add EVENT task to scheduler queue |
* schedEvent() - Add EVENT task to scheduler queue |
| * @root = root task |
* @root = root task |