version 1.25.2.3, 2014/05/21 22:09:01
|
version 1.26.2.1, 2015/07/02 22:43:30
|
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 - 2014 | Copyright 2004 - 2015 |
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 174 schedRegisterHooks(sched_root_task_t * __restrict root
|
Line 174 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; |
|
#if defined(HAVE_TIMER_CREATE) && defined(HAVE_TIMER_SETTIME) && defined(HAVE_TIMER_DELETE) |
#if defined(HAVE_TIMER_CREATE) && defined(HAVE_TIMER_SETTIME) && defined(HAVE_TIMER_DELETE) |
root->root_hooks.hook_add.rtc = sched_hook_rtc; |
root->root_hooks.hook_add.rtc = sched_hook_rtc; |
#endif |
#endif |
|
#if SUP_ENABLE == KQ_SUPPORT |
|
root->root_hooks.hook_add.alarm = sched_hook_alarm; |
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; |
#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 |
|
#endif /* KQ_SUPPORT */ |
#ifdef HAVE_LIBPTHREAD |
#ifdef HAVE_LIBPTHREAD |
root->root_hooks.hook_add.thread = sched_hook_thread; |
root->root_hooks.hook_add.thread = sched_hook_thread; |
#endif |
#endif |
Line 297 schedEnd(sched_root_task_t ** __restrict root)
|
Line 299 schedEnd(sched_root_task_t ** __restrict root)
|
if (!root || !*root) |
if (!root || !*root) |
return -1; |
return -1; |
|
|
|
#if 0 |
TAILQ_FOREACH_SAFE(task, &(*root)->root_read, task_node, tmp) |
TAILQ_FOREACH_SAFE(task, &(*root)->root_read, task_node, tmp) |
|
printf("read=%p\n", task); |
|
TAILQ_FOREACH_SAFE(task, &(*root)->root_write, task_node, tmp) |
|
printf("write=%p\n", task); |
|
TAILQ_FOREACH_SAFE(task, &(*root)->root_timer, task_node, tmp) |
|
printf("timer=%p\n", task); |
|
TAILQ_FOREACH_SAFE(task, &(*root)->root_alarm, task_node, tmp) |
|
printf("alarm=%p\n", task); |
|
TAILQ_FOREACH_SAFE(task, &(*root)->root_rtc, task_node, tmp) |
|
printf("rtc=%p\n", task); |
|
TAILQ_FOREACH_SAFE(task, &(*root)->root_node, task_node, tmp) |
|
printf("node=%p\n", task); |
|
TAILQ_FOREACH_SAFE(task, &(*root)->root_proc, task_node, tmp) |
|
printf("proc=%p\n", task); |
|
TAILQ_FOREACH_SAFE(task, &(*root)->root_signal, task_node, tmp) |
|
printf("signal=%p\n", task); |
|
TAILQ_FOREACH_SAFE(task, &(*root)->root_aio, task_node, tmp) |
|
printf("aio=%p\n", task); |
|
TAILQ_FOREACH_SAFE(task, &(*root)->root_lio, task_node, tmp) |
|
printf("lio=%p\n", task); |
|
TAILQ_FOREACH_SAFE(task, &(*root)->root_user, task_node, tmp) |
|
printf("user=%p\n", task); |
|
TAILQ_FOREACH_SAFE(task, &(*root)->root_event, task_node, tmp) |
|
printf("event=%p\n", task); |
|
TAILQ_FOREACH_SAFE(task, &(*root)->root_suspend, task_node, tmp) |
|
printf("suspend=%p\n", task); |
|
TAILQ_FOREACH_SAFE(task, &(*root)->root_ready, task_node, tmp) |
|
printf("ready=%p\n", task); |
|
TAILQ_FOREACH_SAFE(task, &(*root)->root_thread, task_node, tmp) |
|
printf("thread=%p\n", task); |
|
TAILQ_FOREACH_SAFE(task, &(*root)->root_task, task_node, tmp) |
|
printf("task=%p\n", task); |
|
TAILQ_FOREACH_SAFE(task, &(*root)->root_unuse, task_node, tmp) |
|
printf("unuse=%p\n", task); |
|
fflush(stdout); |
|
#endif |
|
|
|
TAILQ_FOREACH_SAFE(task, &(*root)->root_read, task_node, tmp) |
schedCancel(task); |
schedCancel(task); |
TAILQ_FOREACH_SAFE(task, &(*root)->root_write, task_node, tmp) |
TAILQ_FOREACH_SAFE(task, &(*root)->root_write, task_node, tmp) |
schedCancel(task); |
schedCancel(task); |
Line 330 schedEnd(sched_root_task_t ** __restrict root)
|
Line 370 schedEnd(sched_root_task_t ** __restrict root)
|
TAILQ_FOREACH_SAFE(task, &(*root)->root_task, task_node, tmp) |
TAILQ_FOREACH_SAFE(task, &(*root)->root_task, task_node, tmp) |
schedCancel(task); |
schedCancel(task); |
|
|
#ifdef HAVE_LIBPTHREAD | SCHED_QLOCK((*root), taskUNUSE); |
pthread_mutex_lock(&(*root)->root_mtx[taskUNUSE]); | |
#endif | |
TAILQ_FOREACH_SAFE(task, &(*root)->root_unuse, task_node, tmp) { |
TAILQ_FOREACH_SAFE(task, &(*root)->root_unuse, task_node, tmp) { |
TAILQ_REMOVE(&(*root)->root_unuse, task, task_node); |
TAILQ_REMOVE(&(*root)->root_unuse, task, task_node); |
free(task); |
free(task); |
} |
} |
#ifdef HAVE_LIBPTHREAD | SCHED_QUNLOCK((*root), taskUNUSE); |
pthread_mutex_unlock(&(*root)->root_mtx[taskUNUSE]); | |
#endif | |
|
|
if ((*root)->root_hooks.hook_root.fini) |
if ((*root)->root_hooks.hook_root.fini) |
(*root)->root_hooks.hook_root.fini(*root, NULL); |
(*root)->root_hooks.hook_root.fini(*root, NULL); |
|
|
#ifdef HAVE_LIBPTHREAD |
#ifdef HAVE_LIBPTHREAD |
for (i = 0; i < taskMAX; i++) | for (i = 0; i < taskMAX; i++) { |
| SCHED_QUNLOCK(*root, i); |
pthread_mutex_destroy(&(*root)->root_mtx[i]); |
pthread_mutex_destroy(&(*root)->root_mtx[i]); |
|
} |
#endif |
#endif |
|
|
free(*root); |
free(*root); |
Line 737 schedCancel(sched_task_t * __restrict task)
|
Line 775 schedCancel(sched_task_t * __restrict task)
|
default: |
default: |
queue = NULL; |
queue = NULL; |
} |
} |
if (queue) { | if (queue) |
#ifdef HAVE_LIBPTHREAD | remove_task_from(task, queue); |
pthread_mutex_lock(&TASK_ROOT(task)->root_mtx[TASK_TYPE(task)]); | |
#endif | |
TAILQ_REMOVE(queue, TASK_ID(task), task_node); | |
#ifdef HAVE_LIBPTHREAD | |
pthread_mutex_unlock(&TASK_ROOT(task)->root_mtx[TASK_TYPE(task)]); | |
#endif | |
} | |
if (TASK_TYPE(task) != taskUNUSE) |
if (TASK_TYPE(task) != taskUNUSE) |
sched_unuseTask(task); |
sched_unuseTask(task); |
|
|
Line 864 schedCancelby(sched_root_task_t * __restrict root, sch
|
Line 895 schedCancelby(sched_root_task_t * __restrict root, sch
|
return 0; |
return 0; |
} |
} |
|
|
#ifdef HAVE_LIBPTHREAD | SCHED_QLOCK(root, type); |
pthread_mutex_lock(&root->root_mtx[type]); | |
#endif | |
TAILQ_FOREACH_SAFE(task, queue, task_node, tmp) { |
TAILQ_FOREACH_SAFE(task, queue, task_node, tmp) { |
flg ^= flg; |
flg ^= flg; |
switch (criteria) { |
switch (criteria) { |
Line 929 schedCancelby(sched_root_task_t * __restrict root, sch
|
Line 958 schedCancelby(sched_root_task_t * __restrict root, sch
|
flg ^= flg; /* ok */ |
flg ^= flg; /* ok */ |
} |
} |
} |
} |
#ifdef HAVE_LIBPTHREAD | SCHED_QUNLOCK(root, type); |
pthread_mutex_unlock(&root->root_mtx[type]); | |
#endif | |
return flg; |
return flg; |
} |
} |
|
|
Line 1012 schedPolling(sched_root_task_t * __restrict root, stru
|
Line 1040 schedPolling(sched_root_task_t * __restrict root, stru
|
* return: -1 error or 0 ok |
* return: -1 error or 0 ok |
*/ |
*/ |
int |
int |
schedTermCondition(sched_root_task_t * __restrict root, intptr_t condValue) | schedTermCondition(sched_root_task_t * __restrict root, intptr_t * __restrict condValue) |
{ |
{ |
if (!root) | if (!root && !condValue) |
return -1; |
return -1; |
|
|
root->root_cond = condValue; | *root->root_cond = *condValue; |
root->root_hooks.hook_exec.condition = sched_hook_condition; |
root->root_hooks.hook_exec.condition = sched_hook_condition; |
return 0; |
return 0; |
} |
} |
Line 1040 schedResumeby(sched_root_task_t * __restrict root, u_c
|
Line 1068 schedResumeby(sched_root_task_t * __restrict root, u_c
|
if (!root) |
if (!root) |
return -1; |
return -1; |
|
|
#ifdef HAVE_LIBPTHREAD | SCHED_QLOCK(root, taskSUSPEND); |
pthread_mutex_lock(&root->root_mtx[taskSUSPEND]); | |
#endif | |
TAILQ_FOREACH_SAFE(task, &root->root_suspend, task_node, tmp) { |
TAILQ_FOREACH_SAFE(task, &root->root_suspend, task_node, tmp) { |
flg ^= flg; |
flg ^= flg; |
switch (criteria) { |
switch (criteria) { |
Line 1075 schedResumeby(sched_root_task_t * __restrict root, u_c
|
Line 1101 schedResumeby(sched_root_task_t * __restrict root, u_c
|
TAILQ_REMOVE(&root->root_suspend, task, task_node); |
TAILQ_REMOVE(&root->root_suspend, task, task_node); |
|
|
task->task_type = taskREADY; |
task->task_type = taskREADY; |
#ifdef HAVE_LIBPTHREAD | insert_task_to(task, &root->root_ready); |
pthread_mutex_lock(&root->root_mtx[taskREADY]); | |
#endif | |
TAILQ_INSERT_TAIL(&root->root_ready, task, task_node); | |
#ifdef HAVE_LIBPTHREAD | |
pthread_mutex_unlock(&root->root_mtx[taskREADY]); | |
#endif | |
|
|
flg ^= flg; /* ok */ |
flg ^= flg; /* ok */ |
} |
} |
} |
} |
#ifdef HAVE_LIBPTHREAD | SCHED_QUNLOCK(root, taskSUSPEND); |
pthread_mutex_unlock(&root->root_mtx[taskSUSPEND]); | |
#endif | |
|
|
return flg; |
return flg; |
} |
} |