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; |
} |
} |
|
|