version 1.2, 2011/10/04 12:34:33
|
version 1.3, 2011/12/08 08:02:23
|
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 139 schedInit(void ** __restrict data, size_t datlen)
|
Line 140 schedInit(void ** __restrict data, size_t datlen)
|
if (datlen) { |
if (datlen) { |
root->root_data.iov_base = *data; |
root->root_data.iov_base = *data; |
root->root_data.iov_len = datlen; |
root->root_data.iov_len = datlen; |
} else { | } else { /* if datlen == 0, switch to callbacks init mode */ |
| /* little hack :) for correct initialization of scheduler */ |
func = (int(*)(sched_root_task_t*)) data; |
func = (int(*)(sched_root_task_t*)) data; |
func(root); |
func(root); |
} |
} |
Line 283 schedCancel(sched_task_t * __restrict task)
|
Line 285 schedCancel(sched_task_t * __restrict task)
|
* @criteria = find task by criteria [CRITERIA_CALL|CRITERIA_ARG|CRITERIA_FD|CRITERIA_VAL|CRITERIA_TV] |
* @criteria = find task by criteria [CRITERIA_CALL|CRITERIA_ARG|CRITERIA_FD|CRITERIA_VAL|CRITERIA_TV] |
* @param = search parameter |
* @param = search parameter |
* @hook = custom cleanup hook function, may be NULL |
* @hook = custom cleanup hook function, may be NULL |
* return: -1 error or 0 ok | * return: -1 error, -2 error in sub-stage cancel execution, -3 error from custom hook or 0 ok |
*/ |
*/ |
int |
int |
schedCancelby(sched_root_task_t * __restrict root, sched_queue_t * __restrict queue, |
schedCancelby(sched_root_task_t * __restrict root, sched_queue_t * __restrict queue, |
Line 322 schedCancelby(sched_root_task_t * __restrict root, sch
|
Line 324 schedCancelby(sched_root_task_t * __restrict root, sch
|
break; |
break; |
} |
} |
} else if (criteria == CRITERIA_FD) { |
} else if (criteria == CRITERIA_FD) { |
if (TASK_FD(task) == (int) param) { | if (TASK_FD(task) == (intptr_t) param) { |
flg++; |
flg++; |
break; |
break; |
} |
} |
Line 332 schedCancelby(sched_root_task_t * __restrict root, sch
|
Line 334 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 (!timercmp(&TASK_TV(task), (struct timeval*) param, -)) { |
flg++; |
flg++; |
break; |
break; |
} |
} |
Line 378 schedRun(sched_root_task_t * __restrict root, volatile
|
Line 380 schedRun(sched_root_task_t * __restrict root, volatile
|
return -1; |
return -1; |
if (root->root_hooks.hook_exec.fetch) { |
if (root->root_hooks.hook_exec.fetch) { |
if (killState) |
if (killState) |
while (!*killState && (task = root->root_hooks.hook_exec.fetch(root, NULL))) | while (!*killState) { |
schedCall(task); | if ((task = root->root_hooks.hook_exec.fetch(root, NULL))) |
| schedCall(task); |
| } |
else |
else |
while ((task = root->root_hooks.hook_exec.fetch(root, NULL))) |
while ((task = root->root_hooks.hook_exec.fetch(root, NULL))) |
schedCall(task); |
schedCall(task); |