|
|
| version 1.15.2.1, 2013/05/26 20:14:02 | version 1.18.2.2, 2013/08/26 07:40:06 |
|---|---|
| Line 152 _sched_threadWrapper(sched_task_t *t) | Line 152 _sched_threadWrapper(sched_task_t *t) |
| } | } |
| #endif | #endif |
| #if defined(HAVE_TIMER_CREATE) && defined(HAVE_TIMER_SETTIME) | |
| void * | |
| _sched_rtcWrapper(sched_task_t *t) | |
| { | |
| void *ret = NULL; | |
| sched_task_func_t func; | |
| sched_task_t *task; | |
| if (!t || !TASK_ROOT(t) || !TASK_DATA(t)) | |
| return NULL; | |
| else { | |
| task = (sched_task_t*) TASK_DATA(t); | |
| func = TASK_FUNC(task); | |
| } | |
| ret = func(task); | |
| timer_delete((timer_t) TASK_DATLEN(t)); | |
| return ret; | |
| } | |
| #endif | |
| #pragma GCC visibility pop | #pragma GCC visibility pop |
| /* | /* |
| Line 511 schedSignal(sched_root_task_t * __restrict root, sched | Line 532 schedSignal(sched_root_task_t * __restrict root, sched |
| * @func = task execution function | * @func = task execution function |
| * @arg = 1st func argument | * @arg = 1st func argument |
| * @ts = timeout argument structure, minimum alarm timer resolution is 1msec! | * @ts = timeout argument structure, minimum alarm timer resolution is 1msec! |
| * @opt_data = Optional data | * @opt_data = Alarm timer ID |
| * @opt_dlen = Optional data length | * @opt_dlen = Optional data length |
| * return: NULL error or !=NULL new queued task | * return: NULL error or !=NULL new queued task |
| */ | */ |
| Line 1322 schedThread(sched_root_task_t * __restrict root, sched | Line 1343 schedThread(sched_root_task_t * __restrict root, sched |
| return task; | return task; |
| } | } |
| /* | |
| * schedRTC() - Add RTC task to scheduler queue | |
| * | |
| * @root = root task | |
| * @func = task execution function | |
| * @arg = 1st func argument | |
| * @ts = timeout argument structure, minimum alarm timer resolution is 1msec! | |
| * @opt_data = Optional RTC ID | |
| * @opt_dlen = Optional data length | |
| * return: NULL error or !=NULL new queued task | |
| */ | |
| sched_task_t * | |
| schedRTC(sched_root_task_t * __restrict root, sched_task_func_t func, void *arg, struct timespec ts, | |
| void *opt_data, size_t opt_dlen) | |
| { | |
| #if defined(HAVE_TIMER_CREATE) && defined(HAVE_TIMER_SETTIME) | |
| sched_task_t *task; | |
| void *ptr; | |
| if (!root || !func) | |
| return NULL; | |
| /* get new task */ | |
| if (!(task = sched_useTask(root))) | |
| return NULL; | |
| task->task_func = func; | |
| TASK_TYPE(task) = taskRTC; | |
| TASK_ROOT(task) = root; | |
| TASK_ARG(task) = arg; | |
| TASK_TS(task) = ts; | |
| TASK_DATA(task) = opt_data; | |
| TASK_DATLEN(task) = opt_dlen; | |
| if (root->root_hooks.hook_add.rtc) | |
| ptr = root->root_hooks.hook_add.rtc(task, NULL); | |
| else | |
| ptr = NULL; | |
| if (!ptr) { | |
| #ifdef HAVE_LIBPTHREAD | |
| pthread_mutex_lock(&root->root_mtx[taskRTC]); | |
| #endif | |
| TAILQ_INSERT_TAIL(&root->root_rtc, TASK_ID(task), task_node); | |
| #ifdef HAVE_LIBPTHREAD | |
| pthread_mutex_unlock(&root->root_mtx[taskRTC]); | |
| #endif | |
| } else | |
| task = sched_unuseTask(task); | |
| return task; | |
| #else | |
| sched_SetErr(ENOTSUP, "Not supported realtime clock extensions"); | |
| return NULL; | |
| #endif | |
| } |