|
version 1.1.1.1.2.5, 2011/09/09 14:14:33
|
version 1.2.2.4, 2011/10/04 20:31:39
|
|
Line 104 schedRegisterHooks(sched_root_task_t * __restrict root
|
Line 104 schedRegisterHooks(sched_root_task_t * __restrict root
|
| |
|
| root->root_hooks.hook_exec.cancel = sched_hook_cancel; |
root->root_hooks.hook_exec.cancel = sched_hook_cancel; |
| root->root_hooks.hook_exec.fetch = sched_hook_fetch; |
root->root_hooks.hook_exec.fetch = sched_hook_fetch; |
| |
root->root_hooks.hook_exec.exception = sched_hook_exception; |
| |
|
| root->root_hooks.hook_root.init = sched_hook_init; |
root->root_hooks.hook_root.init = sched_hook_init; |
| root->root_hooks.hook_root.fini = sched_hook_fini; |
root->root_hooks.hook_root.fini = sched_hook_fini; |
|
Line 322 schedCancelby(sched_root_task_t * __restrict root, sch
|
Line 323 schedCancelby(sched_root_task_t * __restrict root, sch
|
| break; |
break; |
| } |
} |
| } else if (criteria == CRITERIA_FD) { |
} else if (criteria == CRITERIA_FD) { |
| if (TASK_FD(task) == (u_long) param) { | if (TASK_FD(task) == (int) param) { |
| flg++; |
flg++; |
| break; |
break; |
| } |
} |
|
Line 332 schedCancelby(sched_root_task_t * __restrict root, sch
|
Line 333 schedCancelby(sched_root_task_t * __restrict root, sch
|
| break; |
break; |
| } |
} |
| } else if (criteria == CRITERIA_TV) { |
} else if (criteria == CRITERIA_TV) { |
| if (&TASK_TV(task) == (struct timeval*) param) { | if (!memcmp(&TASK_TV(task), param, sizeof(struct timeval))) { |
| flg++; |
flg++; |
| break; |
break; |
| } |
} |
|
Line 362 schedCancelby(sched_root_task_t * __restrict root, sch
|
Line 363 schedCancelby(sched_root_task_t * __restrict root, sch
|
| /* |
/* |
| * schedRun() - Scheduler *run loop* |
* schedRun() - Scheduler *run loop* |
| * @root = root task |
* @root = root task |
| |
* @killState = kill condition variable, if !=0 stop scheduler loop |
| * return: -1 error or 0 ok |
* return: -1 error or 0 ok |
| */ |
*/ |
| int |
int |
| schedRun(sched_root_task_t * __restrict root) | schedRun(sched_root_task_t * __restrict root, volatile intptr_t * __restrict killState) |
| { |
{ |
| sched_task_t *task; |
sched_task_t *task; |
| |
|
|
Line 375 schedRun(sched_root_task_t * __restrict root)
|
Line 377 schedRun(sched_root_task_t * __restrict root)
|
| if (root->root_hooks.hook_exec.run) |
if (root->root_hooks.hook_exec.run) |
| if (root->root_hooks.hook_exec.run(root, NULL)) |
if (root->root_hooks.hook_exec.run(root, NULL)) |
| return -1; |
return -1; |
| if (root->root_hooks.hook_exec.fetch) | if (root->root_hooks.hook_exec.fetch) { |
| while ((task = root->root_hooks.hook_exec.fetch(root, NULL))) | if (killState) |
| schedCall(task); | while (!*killState) { |
| | if ((task = root->root_hooks.hook_exec.fetch(root, NULL))) |
| | schedCall(task); |
| | } |
| | else |
| | while ((task = root->root_hooks.hook_exec.fetch(root, NULL))) |
| | schedCall(task); |
| | } |
| |
|
| return 0; |
return 0; |
| } |
} |