|
|
| version 1.10.6.1, 2012/07/24 13:47:01 | version 1.11.2.2, 2012/08/01 12:49:26 |
|---|---|
| Line 76 typedef enum { | Line 76 typedef enum { |
| taskALARM, | taskALARM, |
| taskNODE, | taskNODE, |
| taskPROC, | taskPROC, |
| taskUSER, | |
| taskSIGNAL, | taskSIGNAL, |
| taskAIO, | |
| taskUSER, | |
| taskEVENT, | taskEVENT, |
| taskEVENTLO, | taskEVENTLO, |
| taskSUSPEND, | taskSUSPEND, |
| Line 102 struct sched_HooksTask { | Line 103 struct sched_HooksTask { |
| sched_hook_func_t node; | sched_hook_func_t node; |
| /* proc(sched_task_t *task, NULL) -> int */ | /* proc(sched_task_t *task, NULL) -> int */ |
| sched_hook_func_t proc; | sched_hook_func_t proc; |
| /* user(sched_task_t *task, NULL) -> int */ | |
| sched_hook_func_t user; | |
| /* signal(sched_task_t *task, NULL) -> int */ | /* signal(sched_task_t *task, NULL) -> int */ |
| sched_hook_func_t signal; | sched_hook_func_t signal; |
| /* aio(sched_task_t *task, NULL) -> int */ | |
| sched_hook_func_t aio; | |
| /* user(sched_task_t *task, NULL) -> int */ | |
| sched_hook_func_t user; | |
| /* event(sched_task_t *task, NULL) -> int */ | /* event(sched_task_t *task, NULL) -> int */ |
| sched_hook_func_t event; | sched_hook_func_t event; |
| /* eventlo(sched_task_t *task, NULL) -> int */ | /* eventlo(sched_task_t *task, NULL) -> int */ |
| Line 190 struct sched_RootTask { | Line 193 struct sched_RootTask { |
| struct timespec root_wait; | struct timespec root_wait; |
| struct timespec root_poll; | struct timespec root_poll; |
| intptr_t root_cond; | intptr_t root_cond; |
| void *root_ret; | |
| pthread_mutex_t root_mtx[taskMAX]; | pthread_mutex_t root_mtx[taskMAX]; |
| Line 199 struct sched_RootTask { | Line 203 struct sched_RootTask { |
| sched_queue_t root_alarm; | sched_queue_t root_alarm; |
| sched_queue_t root_node; | sched_queue_t root_node; |
| sched_queue_t root_proc; | sched_queue_t root_proc; |
| sched_queue_t root_user; | |
| sched_queue_t root_signal; | sched_queue_t root_signal; |
| sched_queue_t root_aio; | |
| sched_queue_t root_user; | |
| sched_queue_t root_event; | sched_queue_t root_event; |
| sched_queue_t root_eventlo; | sched_queue_t root_eventlo; |
| sched_queue_t root_suspend; | sched_queue_t root_suspend; |
| Line 214 struct sched_RootTask { | Line 219 struct sched_RootTask { |
| #define ROOT_DATLEN(x) (x)->root_data.iov_len | #define ROOT_DATLEN(x) (x)->root_data.iov_len |
| }; | }; |
| #define ROOT_QUEUE_EMPTY(x, _q) TAILQ_EMPTY(&((x)->root_##_q)) | #define ROOT_QUEUE_EMPTY(x, _q) TAILQ_EMPTY(&((x)->root_##_q)) |
| #define ROOT_RETURN(x) (x)->root_ret | |
| inline int sched_GetErrno(); | inline int sched_GetErrno(); |
| Line 394 sched_task_t *schedProc(sched_root_task_t * __restrict | Line 400 sched_task_t *schedProc(sched_root_task_t * __restrict |
| sched_task_t *schedSignal(sched_root_task_t * __restrict root, sched_task_func_t func, void *arg, | sched_task_t *schedSignal(sched_root_task_t * __restrict root, sched_task_func_t func, void *arg, |
| unsigned long sig, void *opt_data, size_t opt_dlen); | unsigned long sig, void *opt_data, size_t opt_dlen); |
| #define schedSignalSelf(x) schedSignal(TASK_ROOT((x)), TASK_FUNC((x)), TASK_ARG((x)), \ | #define schedSignalSelf(x) schedSignal(TASK_ROOT((x)), TASK_FUNC((x)), TASK_ARG((x)), \ |
| TASK_VAL((x)), TASK_DATA((x)), TASK_DATLEN((x))) | |
| /* | |
| * schedAIO() - Add AIO task to scheduler queue | |
| * | |
| * @root = root task | |
| * @func = task execution function | |
| * @arg = 1st func argument | |
| * @acb = AIO cb structure address | |
| * @opt_data = Optional data | |
| * @opt_dlen = Optional data length | |
| * return: NULL error or !=NULL new queued task | |
| */ | |
| sched_task_t *schedAIO(sched_root_task_t * __restrict root, sched_task_func_t func, void *arg, | |
| unsigned long acb, void *opt_data, size_t opt_dlen); | |
| #define schedAIOSelf(x) schedAIO(TASK_ROOT((x)), TASK_FUNC((x)), TASK_ARG((x)), \ | |
| TASK_VAL((x)), TASK_DATA((x)), TASK_DATLEN((x))) | TASK_VAL((x)), TASK_DATA((x)), TASK_DATLEN((x))) |
| /* | /* |