version 1.1.1.1.2.3, 2011/08/13 17:26:26
|
version 1.2.2.2, 2011/10/04 14:04:35
|
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 158 schedInit(void ** __restrict data, size_t datlen)
|
Line 159 schedInit(void ** __restrict data, size_t datlen)
|
* return: -1 error or 0 ok |
* return: -1 error or 0 ok |
*/ |
*/ |
int |
int |
schedEnd(sched_root_task_t * __restrict root) | schedEnd(sched_root_task_t ** __restrict root) |
{ |
{ |
sched_task_t *task; |
sched_task_t *task; |
|
|
if (!root) | if (!root || !*root) |
return -1; |
return -1; |
|
|
TAILQ_FOREACH(task, &root->root_read, task_node) { | TAILQ_FOREACH(task, &(*root)->root_read, task_node) { |
schedCancel(task); |
schedCancel(task); |
} |
} |
TAILQ_FOREACH(task, &root->root_write, task_node) { | TAILQ_FOREACH(task, &(*root)->root_write, task_node) { |
schedCancel(task); |
schedCancel(task); |
} |
} |
TAILQ_FOREACH(task, &root->root_timer, task_node) { | TAILQ_FOREACH(task, &(*root)->root_timer, task_node) { |
schedCancel(task); |
schedCancel(task); |
} |
} |
TAILQ_FOREACH(task, &root->root_event, task_node) { | TAILQ_FOREACH(task, &(*root)->root_event, task_node) { |
schedCancel(task); |
schedCancel(task); |
} |
} |
TAILQ_FOREACH(task, &root->root_ready, task_node) { | TAILQ_FOREACH(task, &(*root)->root_ready, task_node) { |
schedCancel(task); |
schedCancel(task); |
} |
} |
|
|
while ((task = TAILQ_FIRST(&root->root_unuse))) { | while ((task = TAILQ_FIRST(&(*root)->root_unuse))) { |
TAILQ_REMOVE(&root->root_unuse, task, task_node); | TAILQ_REMOVE(&(*root)->root_unuse, task, task_node); |
free(task); |
free(task); |
} |
} |
|
|
if (root->root_hooks.hook_root.fini) | if ((*root)->root_hooks.hook_root.fini) |
root->root_hooks.hook_root.fini(root, NULL); | (*root)->root_hooks.hook_root.fini(*root, NULL); |
|
|
free(root); | free(*root); |
| *root = NULL; |
return 0; |
return 0; |
} |
} |
|
|
Line 321 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 361 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 374 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) |
printf("task=%p\n", task); | while (!*killState) |
schedCall(task); | 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; |
} |
} |