version 1.15.2.1, 2012/08/22 10:33:45
|
version 1.18.6.1, 2013/08/15 17:58:31
|
Line 12 terms:
|
Line 12 terms:
|
All of the documentation and software included in the ELWIX and AITNET |
All of the documentation and software included in the ELWIX and AITNET |
Releases is copyrighted by ELWIX - Sofia/Bulgaria <info@elwix.org> |
Releases is copyrighted by ELWIX - Sofia/Bulgaria <info@elwix.org> |
|
|
Copyright 2004, 2005, 2006, 2007, 2008, 2009, 2010, 2011, 2012 | Copyright 2004, 2005, 2006, 2007, 2008, 2009, 2010, 2011, 2012, 2013 |
by Michael Pounov <misho@elwix.org>. All rights reserved. |
by Michael Pounov <misho@elwix.org>. All rights reserved. |
|
|
Redistribution and use in source and binary forms, with or without |
Redistribution and use in source and binary forms, with or without |
Line 56 char sched_Error[STRSIZ];
|
Line 56 char sched_Error[STRSIZ];
|
|
|
|
|
// sched_GetErrno() Get error code of last operation |
// sched_GetErrno() Get error code of last operation |
inline int | int |
sched_GetErrno() |
sched_GetErrno() |
{ |
{ |
return sched_Errno; |
return sched_Errno; |
} |
} |
|
|
// sched_GetError() Get error text of last operation |
// sched_GetError() Get error text of last operation |
inline const char * | const char * |
sched_GetError() |
sched_GetError() |
{ |
{ |
return sched_Error; |
return sched_Error; |
} |
} |
|
|
// sched_SetErr() Set error to variables for internal use!!! |
// sched_SetErr() Set error to variables for internal use!!! |
inline void | void |
sched_SetErr(int eno, char *estr, ...) |
sched_SetErr(int eno, char *estr, ...) |
{ |
{ |
va_list lst; |
va_list lst; |
Line 102 schedRegisterHooks(sched_root_task_t * __restrict root
|
Line 102 schedRegisterHooks(sched_root_task_t * __restrict root
|
root->root_hooks.hook_add.read = sched_hook_read; |
root->root_hooks.hook_add.read = sched_hook_read; |
root->root_hooks.hook_add.write = sched_hook_write; |
root->root_hooks.hook_add.write = sched_hook_write; |
root->root_hooks.hook_add.alarm = sched_hook_alarm; |
root->root_hooks.hook_add.alarm = sched_hook_alarm; |
|
root->root_hooks.hook_add.rtc = sched_hook_rtc; |
root->root_hooks.hook_add.node = sched_hook_node; |
root->root_hooks.hook_add.node = sched_hook_node; |
root->root_hooks.hook_add.proc = sched_hook_proc; |
root->root_hooks.hook_add.proc = sched_hook_proc; |
root->root_hooks.hook_add.signal = sched_hook_signal; |
root->root_hooks.hook_add.signal = sched_hook_signal; |
Line 151 schedInit(void ** __restrict data, size_t datlen)
|
Line 152 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 167 schedInit(void ** __restrict data, size_t datlen)
|
Line 168 schedInit(void ** __restrict data, size_t datlen)
|
TAILQ_INIT(&root->root_write); |
TAILQ_INIT(&root->root_write); |
TAILQ_INIT(&root->root_timer); |
TAILQ_INIT(&root->root_timer); |
TAILQ_INIT(&root->root_alarm); |
TAILQ_INIT(&root->root_alarm); |
|
TAILQ_INIT(&root->root_rtc); |
TAILQ_INIT(&root->root_node); |
TAILQ_INIT(&root->root_node); |
TAILQ_INIT(&root->root_proc); |
TAILQ_INIT(&root->root_proc); |
TAILQ_INIT(&root->root_signal); |
TAILQ_INIT(&root->root_signal); |
Line 215 schedEnd(sched_root_task_t ** __restrict root)
|
Line 217 schedEnd(sched_root_task_t ** __restrict root)
|
sched_task_t *task, *tmp; |
sched_task_t *task, *tmp; |
#ifdef HAVE_LIBPTHREAD |
#ifdef HAVE_LIBPTHREAD |
register int i; |
register int i; |
pthread_t tid; |
|
#endif |
#endif |
|
|
if (!root || !*root) |
if (!root || !*root) |
Line 229 schedEnd(sched_root_task_t ** __restrict root)
|
Line 230 schedEnd(sched_root_task_t ** __restrict root)
|
schedCancel(task); |
schedCancel(task); |
TAILQ_FOREACH_SAFE(task, &(*root)->root_alarm, task_node, tmp) |
TAILQ_FOREACH_SAFE(task, &(*root)->root_alarm, task_node, tmp) |
schedCancel(task); |
schedCancel(task); |
|
TAILQ_FOREACH_SAFE(task, &(*root)->root_rtc, task_node, tmp) |
|
schedCancel(task); |
TAILQ_FOREACH_SAFE(task, &(*root)->root_node, task_node, tmp) |
TAILQ_FOREACH_SAFE(task, &(*root)->root_node, task_node, tmp) |
schedCancel(task); |
schedCancel(task); |
TAILQ_FOREACH_SAFE(task, &(*root)->root_proc, task_node, tmp) |
TAILQ_FOREACH_SAFE(task, &(*root)->root_proc, task_node, tmp) |
Line 247 schedEnd(sched_root_task_t ** __restrict root)
|
Line 250 schedEnd(sched_root_task_t ** __restrict root)
|
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) |
tid = (pthread_t) TASK_VAL(task); | |
schedCancel(task); |
schedCancel(task); |
#ifdef HAVE_LIBPTHREAD |
|
if (TASK_FLAG(task) == PTHREAD_CREATE_JOINABLE) |
|
pthread_join(tid, NULL); |
|
#endif |
|
} |
|
TAILQ_FOREACH_SAFE(task, &(*root)->root_task, task_node, tmp) |
TAILQ_FOREACH_SAFE(task, &(*root)->root_task, task_node, tmp) |
schedCancel(task); |
schedCancel(task); |
|
|
Line 288 schedEnd(sched_root_task_t ** __restrict root)
|
Line 285 schedEnd(sched_root_task_t ** __restrict root)
|
* @task = current task |
* @task = current task |
* return: !=NULL error or =NULL ok |
* return: !=NULL error or =NULL ok |
*/ |
*/ |
inline void * | void * |
schedCall(sched_task_t * __restrict task) |
schedCall(sched_task_t * __restrict task) |
{ |
{ |
void *ptr = (void*) -1; |
void *ptr = (void*) -1; |
Line 311 schedCall(sched_task_t * __restrict task)
|
Line 308 schedCall(sched_task_t * __restrict task)
|
* @root = root task |
* @root = root task |
* return: =NULL error or !=NULL ready task |
* return: =NULL error or !=NULL ready task |
*/ |
*/ |
inline void * | void * |
schedFetch(sched_root_task_t * __restrict root) |
schedFetch(sched_root_task_t * __restrict root) |
{ |
{ |
void *ptr; |
void *ptr; |
Line 391 schedCancel(sched_task_t * __restrict task)
|
Line 388 schedCancel(sched_task_t * __restrict task)
|
case taskALARM: |
case taskALARM: |
queue = &TASK_ROOT(task)->root_alarm; |
queue = &TASK_ROOT(task)->root_alarm; |
break; |
break; |
|
case taskRTC: |
|
queue = &TASK_ROOT(task)->root_rtc; |
|
break; |
case taskNODE: |
case taskNODE: |
queue = &TASK_ROOT(task)->root_node; |
queue = &TASK_ROOT(task)->root_node; |
break; |
break; |
Line 473 schedCancelby(sched_root_task_t * __restrict root, sch
|
Line 473 schedCancelby(sched_root_task_t * __restrict root, sch
|
return -2; |
return -2; |
if (schedCancelby(root, taskALARM, criteria, param, hook)) |
if (schedCancelby(root, taskALARM, criteria, param, hook)) |
return -2; |
return -2; |
|
if (schedCancelby(root, taskRTC, criteria, param, hook)) |
|
return -2; |
if (schedCancelby(root, taskNODE, criteria, param, hook)) |
if (schedCancelby(root, taskNODE, criteria, param, hook)) |
return -2; |
return -2; |
if (schedCancelby(root, taskPROC, criteria, param, hook)) |
if (schedCancelby(root, taskPROC, criteria, param, hook)) |
Line 511 schedCancelby(sched_root_task_t * __restrict root, sch
|
Line 513 schedCancelby(sched_root_task_t * __restrict root, sch
|
case taskALARM: |
case taskALARM: |
queue = &root->root_alarm; |
queue = &root->root_alarm; |
break; |
break; |
|
case taskRTC: |
|
queue = &root->root_rtc; |
|
break; |
case taskNODE: |
case taskNODE: |
queue = &root->root_node; |
queue = &root->root_node; |
break; |
break; |
Line 666 schedRun(sched_root_task_t *root, volatile intptr_t *
|
Line 671 schedRun(sched_root_task_t *root, volatile intptr_t *
|
* @tsold = old timeout polling if !=NULL |
* @tsold = old timeout polling if !=NULL |
* return: -1 error or 0 ok |
* return: -1 error or 0 ok |
*/ |
*/ |
inline int | int |
schedPolling(sched_root_task_t * __restrict root, struct timespec * __restrict ts, |
schedPolling(sched_root_task_t * __restrict root, struct timespec * __restrict ts, |
struct timespec * __restrict tsold) |
struct timespec * __restrict tsold) |
{ |
{ |
Line 691 schedPolling(sched_root_task_t * __restrict root, stru
|
Line 696 schedPolling(sched_root_task_t * __restrict root, stru
|
* @condValue = condition value, kill schedRun() if condValue == killState |
* @condValue = condition value, kill schedRun() if condValue == killState |
* return: -1 error or 0 ok |
* return: -1 error or 0 ok |
*/ |
*/ |
inline int | int |
schedTermCondition(sched_root_task_t * __restrict root, intptr_t condValue) |
schedTermCondition(sched_root_task_t * __restrict root, intptr_t condValue) |
{ |
{ |
if (!root) |
if (!root) |