version 1.16, 2012/08/23 02:33:12
|
version 1.19, 2013/08/15 19:10:48
|
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; |
|
#if defined(HAVE_TIMER_CREATE) && defined(HAVE_TIMER_SETTIME) |
|
root->root_hooks.hook_add.rtc = sched_hook_rtc; |
|
#endif |
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 154 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 170 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 228 schedEnd(sched_root_task_t ** __restrict root)
|
Line 232 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 281 schedEnd(sched_root_task_t ** __restrict root)
|
Line 287 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 304 schedCall(sched_task_t * __restrict task)
|
Line 310 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 384 schedCancel(sched_task_t * __restrict task)
|
Line 390 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 466 schedCancelby(sched_root_task_t * __restrict root, sch
|
Line 475 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 504 schedCancelby(sched_root_task_t * __restrict root, sch
|
Line 515 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 659 schedRun(sched_root_task_t *root, volatile intptr_t *
|
Line 673 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 684 schedPolling(sched_root_task_t * __restrict root, stru
|
Line 698 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) |