|
|
| version 1.11.2.2, 2012/08/01 12:49:26 | version 1.12.2.1, 2012/08/08 08:15:23 |
|---|---|
| Line 140 schedInit(void ** __restrict data, size_t datlen) | Line 140 schedInit(void ** __restrict data, size_t datlen) |
| } else { | } else { |
| memset(root, 0, sizeof(sched_root_task_t)); | memset(root, 0, sizeof(sched_root_task_t)); |
| /* set default maximum regular task hit misses */ | |
| root->root_miss = MAX_TASK_MISS; | |
| /* INFINIT polling period by default */ | /* INFINIT polling period by default */ |
| sched_timespecinf(&root->root_poll); | sched_timespecinf(&root->root_poll); |
| Line 165 schedInit(void ** __restrict data, size_t datlen) | Line 168 schedInit(void ** __restrict data, size_t datlen) |
| TAILQ_INIT(&root->root_proc); | TAILQ_INIT(&root->root_proc); |
| TAILQ_INIT(&root->root_signal); | TAILQ_INIT(&root->root_signal); |
| TAILQ_INIT(&root->root_aio); | TAILQ_INIT(&root->root_aio); |
| TAILQ_INIT(&root->root_lio); | |
| TAILQ_INIT(&root->root_user); | TAILQ_INIT(&root->root_user); |
| TAILQ_INIT(&root->root_event); | TAILQ_INIT(&root->root_event); |
| TAILQ_INIT(&root->root_eventlo); | TAILQ_INIT(&root->root_task); |
| TAILQ_INIT(&root->root_suspend); | TAILQ_INIT(&root->root_suspend); |
| TAILQ_INIT(&root->root_ready); | TAILQ_INIT(&root->root_ready); |
| TAILQ_INIT(&root->root_unuse); | TAILQ_INIT(&root->root_unuse); |
| Line 228 schedEnd(sched_root_task_t ** __restrict root) | Line 232 schedEnd(sched_root_task_t ** __restrict root) |
| schedCancel(task); | schedCancel(task); |
| TAILQ_FOREACH_SAFE(task, &(*root)->root_aio, task_node, tmp) | TAILQ_FOREACH_SAFE(task, &(*root)->root_aio, task_node, tmp) |
| schedCancel(task); | schedCancel(task); |
| TAILQ_FOREACH_SAFE(task, &(*root)->root_lio, task_node, tmp) | |
| schedCancel(task); | |
| TAILQ_FOREACH_SAFE(task, &(*root)->root_user, task_node, tmp) | TAILQ_FOREACH_SAFE(task, &(*root)->root_user, task_node, tmp) |
| schedCancel(task); | schedCancel(task); |
| TAILQ_FOREACH_SAFE(task, &(*root)->root_event, task_node, tmp) | TAILQ_FOREACH_SAFE(task, &(*root)->root_event, task_node, tmp) |
| schedCancel(task); | schedCancel(task); |
| TAILQ_FOREACH_SAFE(task, &(*root)->root_eventlo, task_node, tmp) | TAILQ_FOREACH_SAFE(task, &(*root)->root_task, task_node, tmp) |
| schedCancel(task); | schedCancel(task); |
| TAILQ_FOREACH_SAFE(task, &(*root)->root_suspend, task_node, tmp) | TAILQ_FOREACH_SAFE(task, &(*root)->root_suspend, task_node, tmp) |
| schedCancel(task); | schedCancel(task); |
| Line 384 schedCancel(sched_task_t * __restrict task) | Line 390 schedCancel(sched_task_t * __restrict task) |
| case taskAIO: | case taskAIO: |
| queue = &TASK_ROOT(task)->root_aio; | queue = &TASK_ROOT(task)->root_aio; |
| break; | break; |
| case taskLIO: | |
| queue = &TASK_ROOT(task)->root_lio; | |
| break; | |
| case taskUSER: | case taskUSER: |
| queue = &TASK_ROOT(task)->root_user; | queue = &TASK_ROOT(task)->root_user; |
| break; | break; |
| case taskEVENT: | case taskEVENT: |
| queue = &TASK_ROOT(task)->root_event; | queue = &TASK_ROOT(task)->root_event; |
| break; | break; |
| case taskEVENTLO: | case taskTASK: |
| queue = &TASK_ROOT(task)->root_eventlo; | queue = &TASK_ROOT(task)->root_task; |
| break; | break; |
| case taskSUSPEND: | case taskSUSPEND: |
| queue = &TASK_ROOT(task)->root_suspend; | queue = &TASK_ROOT(task)->root_suspend; |
| Line 456 schedCancelby(sched_root_task_t * __restrict root, sch | Line 465 schedCancelby(sched_root_task_t * __restrict root, sch |
| return -2; | return -2; |
| if (schedCancelby(root, taskAIO, criteria, param, hook)) | if (schedCancelby(root, taskAIO, criteria, param, hook)) |
| return -2; | return -2; |
| if (schedCancelby(root, taskLIO, criteria, param, hook)) | |
| return -2; | |
| if (schedCancelby(root, taskUSER, criteria, param, hook)) | if (schedCancelby(root, taskUSER, criteria, param, hook)) |
| return -2; | return -2; |
| if (schedCancelby(root, taskEVENT, criteria, param, hook)) | if (schedCancelby(root, taskEVENT, criteria, param, hook)) |
| return -2; | return -2; |
| if (schedCancelby(root, taskEVENTLO, criteria, param, hook)) | if (schedCancelby(root, taskTASK, criteria, param, hook)) |
| return -2; | return -2; |
| if (schedCancelby(root, taskSUSPEND, criteria, param, hook)) | if (schedCancelby(root, taskSUSPEND, criteria, param, hook)) |
| return -2; | return -2; |
| Line 494 schedCancelby(sched_root_task_t * __restrict root, sch | Line 505 schedCancelby(sched_root_task_t * __restrict root, sch |
| case taskAIO: | case taskAIO: |
| queue = &root->root_aio; | queue = &root->root_aio; |
| break; | break; |
| case taskLIO: | |
| queue = &root->root_lio; | |
| break; | |
| case taskUSER: | case taskUSER: |
| queue = &root->root_user; | queue = &root->root_user; |
| break; | break; |
| case taskEVENT: | case taskEVENT: |
| queue = &root->root_event; | queue = &root->root_event; |
| break; | break; |
| case taskEVENTLO: | case taskTASK: |
| queue = &root->root_eventlo; | queue = &root->root_task; |
| break; | break; |
| case taskSUSPEND: | case taskSUSPEND: |
| queue = &root->root_suspend; | queue = &root->root_suspend; |
| Line 654 schedPolling(sched_root_task_t * __restrict root, stru | Line 668 schedPolling(sched_root_task_t * __restrict root, stru |
| * | * |
| * @root = root task | * @root = root task |
| * @condValue = condition value, kill schedRun() if condValue == killState | * @condValue = condition value, kill schedRun() if condValue == killState |
| * return: -1 error ok 0 ok | * return: -1 error or 0 ok |
| */ | */ |
| inline int | inline int |
| schedTermCondition(sched_root_task_t * __restrict root, intptr_t condValue) | schedTermCondition(sched_root_task_t * __restrict root, intptr_t condValue) |
| Line 664 schedTermCondition(sched_root_task_t * __restrict root | Line 678 schedTermCondition(sched_root_task_t * __restrict root |
| root->root_cond = condValue; | root->root_cond = condValue; |
| root->root_hooks.hook_exec.condition = sched_hook_condition; | root->root_hooks.hook_exec.condition = sched_hook_condition; |
| return 0; | |
| } | |
| /* | |
| * schedMissEvents() - Set new miss events rate for regular tasks | |
| * | |
| * @root = root task | |
| * @missEvents = maximum number of missed events before firing tasks | |
| * return: -1 error or 0 ok | |
| */ | |
| inline int | |
| schedMissEvents(sched_root_task_t * __restrict root, u_int missEvents) | |
| { | |
| if (!root) | |
| return -1; | |
| root->root_miss = missEvents; | |
| return 0; | return 0; |
| } | } |