version 1.2.2.5, 2011/10/04 23:12:33
|
version 1.4, 2012/01/08 00:51:17
|
Line 140 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 203 schedEnd(sched_root_task_t ** __restrict root)
|
Line 204 schedEnd(sched_root_task_t ** __restrict root)
|
inline void * |
inline void * |
schedCall(sched_task_t * __restrict task) |
schedCall(sched_task_t * __restrict task) |
{ |
{ |
|
void *ptr = (void*) -1; |
|
|
if (!task) |
if (!task) |
return (void*) -1; | return ptr; |
|
|
|
if (!TASK_ISLOCKED(task)) |
|
TASK_LOCK(task); |
|
|
task->task_id++; |
task->task_id++; |
return task->task_func(task); | ptr = task->task_func(task); |
| |
| TASK_UNLOCK(task); |
| return ptr; |
} |
} |
|
|
/* |
/* |
Line 269 schedCancel(sched_task_t * __restrict task)
|
Line 278 schedCancel(sched_task_t * __restrict task)
|
} |
} |
if (queue) |
if (queue) |
TAILQ_REMOVE(queue, task, task_node); |
TAILQ_REMOVE(queue, task, task_node); |
if (task->task_type != taskUNUSE) { | if (task->task_type != taskUNUSE) |
task->task_type = taskUNUSE; | _sched_unuseTask(task); |
TAILQ_INSERT_TAIL(&task->task_root->root_unuse, task, task_node); | |
} | |
|
|
return 0; |
return 0; |
} |
} |
Line 284 schedCancel(sched_task_t * __restrict task)
|
Line 291 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 353 schedCancelby(sched_root_task_t * __restrict root, sch
|
Line 360 schedCancelby(sched_root_task_t * __restrict root, sch
|
|
|
TAILQ_REMOVE(queue, task, task_node); |
TAILQ_REMOVE(queue, task, task_node); |
|
|
if (task->task_type != taskUNUSE) { | if (task->task_type != taskUNUSE) |
task->task_type = taskUNUSE; | _sched_unuseTask(task); |
TAILQ_INSERT_TAIL(&task->task_root->root_unuse, task, task_node); | |
} | |
return 0; |
return 0; |
} |
} |
|
|