version 1.31, 2023/02/25 15:55:01
|
version 1.36.4.1, 2024/03/20 12:48:45
|
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 - 2023 | Copyright 2004 - 2024 |
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 54 char sched_Error[STRSIZ];
|
Line 54 char sched_Error[STRSIZ];
|
|
|
#pragma GCC visibility pop |
#pragma GCC visibility pop |
|
|
|
volatile pthread_t sched_sigThr; |
|
|
|
|
// sched_GetErrno() Get error code of last operation |
// sched_GetErrno() Get error code of last operation |
int |
int |
sched_GetErrno() |
sched_GetErrno() |
Line 211 schedInit(void ** __restrict data, size_t datlen)
|
Line 213 schedInit(void ** __restrict data, size_t datlen)
|
{ |
{ |
sched_root_task_t *root = NULL; |
sched_root_task_t *root = NULL; |
int (*func)(sched_root_task_t *); |
int (*func)(sched_root_task_t *); |
|
#if SUP_ENABLE == KQ_SUPPORT |
|
sigset_t ss; |
|
#endif |
#ifdef HAVE_LIBPTHREAD |
#ifdef HAVE_LIBPTHREAD |
register int i; |
register int i; |
#endif |
#endif |
Line 268 schedInit(void ** __restrict data, size_t datlen)
|
Line 273 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++) |
pthread_mutex_unlock(&root->root_mtx[i]); |
pthread_mutex_unlock(&root->root_mtx[i]); |
|
|
|
#if SUP_ENABLE == KQ_SUPPORT |
|
sigfillset(&ss); |
|
pthread_sigmask(SIG_BLOCK, &ss, &root->root_oldset); |
|
#else |
|
pthread_sigmask(SIG_BLOCK, NULL, &root->root_oldset); |
#endif |
#endif |
|
#else |
|
sigprocmask(SIG_BLOCK, NULL, &root->root_oldset); |
|
#endif |
|
|
if (data && *data) { |
if (data && *data) { |
if (datlen) { |
if (datlen) { |
Line 404 schedEnd(sched_root_task_t ** __restrict root)
|
Line 418 schedEnd(sched_root_task_t ** __restrict root)
|
pthread_mutex_unlock(&(*root)->root_sigmtx); |
pthread_mutex_unlock(&(*root)->root_sigmtx); |
} |
} |
pthread_mutex_destroy(&(*root)->root_sigmtx); |
pthread_mutex_destroy(&(*root)->root_sigmtx); |
|
#else |
|
sigprocmask(SIG_SETMASK, &(*root)->root_oldset, NULL); |
#endif |
#endif |
|
|
e_free(*root); |
e_free(*root); |
Line 1060 schedPolling(sched_root_task_t * __restrict root, stru
|
Line 1076 schedPolling(sched_root_task_t * __restrict root, stru
|
int |
int |
schedTermCondition(sched_root_task_t * __restrict root, intptr_t * __restrict condValue) |
schedTermCondition(sched_root_task_t * __restrict root, intptr_t * __restrict condValue) |
{ |
{ |
if (!root && !condValue) | if (!root || !condValue) |
return -1; |
return -1; |
|
|
*root->root_cond = *condValue; |
*root->root_cond = *condValue; |
Line 1175 _sched_sigDisp(void *arg)
|
Line 1191 _sched_sigDisp(void *arg)
|
* |
* |
* @root = root task |
* @root = root task |
* @on = Activate or =0 deactivate |
* @on = Activate or =0 deactivate |
* return: -1 error or 0 ok | * return: -1 error, 1 already started, 2 another thread already started or 0 ok |
*/ |
*/ |
int |
int |
schedSignalDispatch(sched_root_task_t * __restrict root, int on) |
schedSignalDispatch(sched_root_task_t * __restrict root, int on) |
{ |
{ |
sigset_t ss; |
sigset_t ss; |
|
struct timespec ts = { .tv_sec = 1, .tv_nsec = 0 }; |
#ifndef HAVE_LIBPTHREAD |
#ifndef HAVE_LIBPTHREAD |
sched_SetErr(ENOTSUP, "Library has not support pthreads"); |
sched_SetErr(ENOTSUP, "Library has not support pthreads"); |
return -1; |
return -1; |
Line 1193 schedSignalDispatch(sched_root_task_t * __restrict roo
|
Line 1210 schedSignalDispatch(sched_root_task_t * __restrict roo
|
#endif |
#endif |
|
|
if (!on) { |
if (!on) { |
pthread_cancel(root->root_sigthr); | if (root->root_sigthr) { |
| if (root->root_sigthr == sched_sigThr) { |
#ifdef __linux__ |
#ifdef __linux__ |
root->root_sigthr = 0L; | sched_sigThr = 0L; |
#else |
#else |
root->root_sigthr = NULL; | sched_sigThr = NULL; |
#endif |
#endif |
pthread_sigmask(SIG_SETMASK, &root->root_oldset, NULL); | } |
| pthread_cancel(root->root_sigthr); |
| #ifdef __linux__ |
| root->root_sigthr = 0L; |
| #else |
| root->root_sigthr = NULL; |
| #endif |
| } |
|
|
pthread_mutex_unlock(&root->root_sigmtx); |
|
return 0; |
return 0; |
} |
} |
|
|
|
/* if we have not using polling, then we must turn on */ |
|
if (sched_timespecisinf(&root->root_poll)) |
|
schedPolling(root, &ts, NULL); |
|
|
pthread_attr_init(&attr); |
pthread_attr_init(&attr); |
pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED); |
pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED); |
#ifdef SCHED_RR |
#ifdef SCHED_RR |
Line 1213 schedSignalDispatch(sched_root_task_t * __restrict roo
|
Line 1241 schedSignalDispatch(sched_root_task_t * __restrict roo
|
pthread_attr_setschedpolicy(&attr, SCHED_OTHER); |
pthread_attr_setschedpolicy(&attr, SCHED_OTHER); |
#endif |
#endif |
|
|
|
/* if we have already started signal thread, then skip routine */ |
|
if (root->root_sigthr) |
|
return 1; |
|
if (sched_sigThr) |
|
return 2; |
|
|
sigfillset(&ss); |
sigfillset(&ss); |
pthread_sigmask(SIG_BLOCK, &ss, &root->root_oldset); | pthread_sigmask(SIG_BLOCK, &ss, NULL); |
| |
if (pthread_create(&root->root_sigthr, &attr, _sched_sigDisp, root)) { |
if (pthread_create(&root->root_sigthr, &attr, _sched_sigDisp, root)) { |
sched_SetErr(errno, "pthread_create(SignalDispatch) #%d - %s", |
sched_SetErr(errno, "pthread_create(SignalDispatch) #%d - %s", |
errno, strerror(errno)); |
errno, strerror(errno)); |
Line 1225 schedSignalDispatch(sched_root_task_t * __restrict roo
|
Line 1260 schedSignalDispatch(sched_root_task_t * __restrict roo
|
#endif |
#endif |
pthread_sigmask(SIG_SETMASK, &root->root_oldset, NULL); |
pthread_sigmask(SIG_SETMASK, &root->root_oldset, NULL); |
return -1; |
return -1; |
} | } else |
| sched_sigThr = root->root_sigthr; |
|
|
return 0; |
return 0; |
} |
} |