--- libaitsched/src/tasks.c 2013/08/26 13:36:45 1.20 +++ libaitsched/src/tasks.c 2013/08/26 14:29:20 1.20.2.1 @@ -3,7 +3,7 @@ * by Michael Pounov * * $Author: misho $ -* $Id: tasks.c,v 1.20 2013/08/26 13:36:45 misho Exp $ +* $Id: tasks.c,v 1.20.2.1 2013/08/26 14:29:20 misho Exp $ * ************************************************************************** The ELWIX and AITNET software is distributed under the following @@ -117,47 +117,27 @@ _sched_threadCleanup(sched_task_t *t) if (TASK_FLAG(t) == PTHREAD_CREATE_JOINABLE) pthread_detach(pthread_self()); - - pthread_mutex_lock(&TASK_ROOT(t)->root_mtx[taskTHREAD]); - TAILQ_REMOVE(&TASK_ROOT(t)->root_thread, t, task_node); - pthread_mutex_unlock(&TASK_ROOT(t)->root_mtx[taskTHREAD]); - - sched_unuseTask(t); } void * _sched_threadWrapper(sched_task_t *t) { void *ret = NULL; sem_t *s = NULL; - sched_root_task_t *r; if (!t || !TASK_ROOT(t) || !TASK_RET(t)) pthread_exit(ret); - else { + else s = (sem_t*) TASK_RET(t); - r = TASK_ROOT(t); - } pthread_cleanup_push((void (*)(void*)) _sched_threadCleanup, t); pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, NULL); pthread_setcanceltype(PTHREAD_CANCEL_ASYNCHRONOUS, NULL); -#ifdef HAVE_LIBPTHREAD - pthread_mutex_lock(&r->root_mtx[taskTHREAD]); -#endif - TAILQ_REMOVE(&r->root_thread, t, task_node); -#ifdef HAVE_LIBPTHREAD - pthread_mutex_unlock(&r->root_mtx[taskTHREAD]); -#endif - t->task_type = taskUNUSE; -#ifdef HAVE_LIBPTHREAD - pthread_mutex_lock(&r->root_mtx[taskUNUSE]); -#endif - TAILQ_INSERT_TAIL(&r->root_unuse, t, task_node); -#ifdef HAVE_LIBPTHREAD - pthread_mutex_unlock(&r->root_mtx[taskUNUSE]); -#endif + pthread_mutex_lock(&TASK_ROOT(t)->root_mtx[taskTHREAD]); + TAILQ_REMOVE(&TASK_ROOT(t)->root_thread, t, task_node); + pthread_mutex_unlock(&TASK_ROOT(t)->root_mtx[taskTHREAD]); + sched_unuseTask(t); /* notify parent, thread is ready for execution */ sem_post(s); @@ -175,7 +155,6 @@ _sched_threadWrapper(sched_task_t *t) void * _sched_rtcWrapper(sched_task_t *t) { - void *ret = NULL; sched_task_func_t func; sched_task_t *task; sched_root_task_t *r; @@ -195,19 +174,11 @@ _sched_rtcWrapper(sched_task_t *t) #ifdef HAVE_LIBPTHREAD pthread_mutex_unlock(&r->root_mtx[taskRTC]); #endif - task->task_type = taskUNUSE; -#ifdef HAVE_LIBPTHREAD - pthread_mutex_lock(&r->root_mtx[taskUNUSE]); -#endif - TAILQ_INSERT_TAIL(&r->root_unuse, task, task_node); -#ifdef HAVE_LIBPTHREAD - pthread_mutex_unlock(&r->root_mtx[taskUNUSE]); -#endif + sched_unuseTask(task); - ret = func(task); - timer_delete((timer_t) TASK_DATLEN(t)); - return ret; + + return func(task); } #endif