--- libaitsched/src/aitsched.c 2012/08/02 13:56:19 1.12 +++ libaitsched/src/aitsched.c 2012/08/08 08:25:39 1.13 @@ -3,7 +3,7 @@ * by Michael Pounov * * $Author: misho $ -* $Id: aitsched.c,v 1.12 2012/08/02 13:56:19 misho Exp $ +* $Id: aitsched.c,v 1.13 2012/08/08 08:25:39 misho Exp $ * ************************************************************************** The ELWIX and AITNET software is distributed under the following @@ -140,6 +140,9 @@ schedInit(void ** __restrict data, size_t datlen) } else { 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 */ sched_timespecinf(&root->root_poll); @@ -168,7 +171,7 @@ schedInit(void ** __restrict data, size_t datlen) TAILQ_INIT(&root->root_lio); TAILQ_INIT(&root->root_user); TAILQ_INIT(&root->root_event); - TAILQ_INIT(&root->root_eventlo); + TAILQ_INIT(&root->root_task); TAILQ_INIT(&root->root_suspend); TAILQ_INIT(&root->root_ready); TAILQ_INIT(&root->root_unuse); @@ -235,7 +238,7 @@ schedEnd(sched_root_task_t ** __restrict root) schedCancel(task); TAILQ_FOREACH_SAFE(task, &(*root)->root_event, task_node, tmp) schedCancel(task); - TAILQ_FOREACH_SAFE(task, &(*root)->root_eventlo, task_node, tmp) + TAILQ_FOREACH_SAFE(task, &(*root)->root_task, task_node, tmp) schedCancel(task); TAILQ_FOREACH_SAFE(task, &(*root)->root_suspend, task_node, tmp) schedCancel(task); @@ -396,8 +399,8 @@ schedCancel(sched_task_t * __restrict task) case taskEVENT: queue = &TASK_ROOT(task)->root_event; break; - case taskEVENTLO: - queue = &TASK_ROOT(task)->root_eventlo; + case taskTASK: + queue = &TASK_ROOT(task)->root_task; break; case taskSUSPEND: queue = &TASK_ROOT(task)->root_suspend; @@ -468,7 +471,7 @@ schedCancelby(sched_root_task_t * __restrict root, sch return -2; if (schedCancelby(root, taskEVENT, criteria, param, hook)) return -2; - if (schedCancelby(root, taskEVENTLO, criteria, param, hook)) + if (schedCancelby(root, taskTASK, criteria, param, hook)) return -2; if (schedCancelby(root, taskSUSPEND, criteria, param, hook)) return -2; @@ -511,8 +514,8 @@ schedCancelby(sched_root_task_t * __restrict root, sch case taskEVENT: queue = &root->root_event; break; - case taskEVENTLO: - queue = &root->root_eventlo; + case taskTASK: + queue = &root->root_task; break; case taskSUSPEND: queue = &root->root_suspend; @@ -665,7 +668,7 @@ schedPolling(sched_root_task_t * __restrict root, stru * * @root = root task * @condValue = condition value, kill schedRun() if condValue == killState - * return: -1 error ok 0 ok + * return: -1 error or 0 ok */ inline int schedTermCondition(sched_root_task_t * __restrict root, intptr_t condValue) @@ -675,6 +678,23 @@ schedTermCondition(sched_root_task_t * __restrict root root->root_cond = condValue; 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; }