version 1.14.2.1, 2012/08/21 11:07:16
|
version 1.16.2.1, 2012/08/31 13:00:41
|
Line 108 schedRegisterHooks(sched_root_task_t * __restrict root
|
Line 108 schedRegisterHooks(sched_root_task_t * __restrict root
|
#ifdef EVFILT_USER |
#ifdef EVFILT_USER |
root->root_hooks.hook_add.user = sched_hook_user; |
root->root_hooks.hook_add.user = sched_hook_user; |
#endif |
#endif |
|
#ifdef HAVE_LIBPTHREAD |
|
root->root_hooks.hook_add.thread = sched_hook_thread; |
|
#endif |
|
|
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; |
Line 148 schedInit(void ** __restrict data, size_t datlen)
|
Line 151 schedInit(void ** __restrict data, size_t datlen)
|
|
|
#ifdef HAVE_LIBPTHREAD |
#ifdef HAVE_LIBPTHREAD |
for (i = 0; i < taskMAX; i++) |
for (i = 0; i < taskMAX; i++) |
if (pthread_mutex_init(&root->root_mtx[i], NULL)) { | if ((errno = pthread_mutex_init(&root->root_mtx[i], NULL))) { |
LOGERR; |
LOGERR; |
while (i) |
while (i) |
pthread_mutex_destroy(&root->root_mtx[--i]); |
pthread_mutex_destroy(&root->root_mtx[--i]); |
Line 239 schedEnd(sched_root_task_t ** __restrict root)
|
Line 242 schedEnd(sched_root_task_t ** __restrict root)
|
schedCancel(task); |
schedCancel(task); |
TAILQ_FOREACH_SAFE(task, &(*root)->root_event, task_node, tmp) |
TAILQ_FOREACH_SAFE(task, &(*root)->root_event, task_node, tmp) |
schedCancel(task); |
schedCancel(task); |
TAILQ_FOREACH_SAFE(task, &(*root)->root_task, task_node, tmp) |
|
schedCancel(task); |
|
TAILQ_FOREACH_SAFE(task, &(*root)->root_suspend, task_node, tmp) |
TAILQ_FOREACH_SAFE(task, &(*root)->root_suspend, task_node, tmp) |
schedCancel(task); |
schedCancel(task); |
TAILQ_FOREACH_SAFE(task, &(*root)->root_ready, task_node, tmp) |
TAILQ_FOREACH_SAFE(task, &(*root)->root_ready, task_node, tmp) |
schedCancel(task); |
schedCancel(task); |
TAILQ_FOREACH_SAFE(task, &(*root)->root_thread, task_node, tmp) |
TAILQ_FOREACH_SAFE(task, &(*root)->root_thread, task_node, tmp) |
schedCancel(task); |
schedCancel(task); |
|
TAILQ_FOREACH_SAFE(task, &(*root)->root_task, task_node, tmp) |
|
schedCancel(task); |
|
|
#ifdef HAVE_LIBPTHREAD |
#ifdef HAVE_LIBPTHREAD |
pthread_mutex_lock(&(*root)->root_mtx[taskUNUSE]); |
pthread_mutex_lock(&(*root)->root_mtx[taskUNUSE]); |
Line 427 schedCancel(sched_task_t * __restrict task)
|
Line 430 schedCancel(sched_task_t * __restrict task)
|
#endif |
#endif |
} |
} |
if (TASK_TYPE(task) != taskUNUSE) |
if (TASK_TYPE(task) != taskUNUSE) |
_sched_unuseTask(task); | sched_unuseTask(task); |
|
|
return 0; |
return 0; |
} |
} |
Line 594 schedCancelby(sched_root_task_t * __restrict root, sch
|
Line 597 schedCancelby(sched_root_task_t * __restrict root, sch
|
|
|
TAILQ_REMOVE(queue, task, task_node); |
TAILQ_REMOVE(queue, task, task_node); |
if (TASK_TYPE(task) != taskUNUSE) |
if (TASK_TYPE(task) != taskUNUSE) |
_sched_unuseTask(task); | sched_unuseTask(task); |
|
|
flg ^= flg; /* ok */ |
flg ^= flg; /* ok */ |
} |
} |