version 1.32, 2023/07/27 20:51:28
|
version 1.32.2.1, 2023/08/03 23:20:22
|
Line 211 schedInit(void ** __restrict data, size_t datlen)
|
Line 211 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; |
sigset_t ss; |
|
#endif |
#ifdef HAVE_LIBPTHREAD |
#ifdef HAVE_LIBPTHREAD |
register int i; |
register int i; |
#endif |
#endif |
Line 270 schedInit(void ** __restrict data, size_t datlen)
|
Line 272 schedInit(void ** __restrict data, size_t datlen)
|
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); |
sigfillset(&ss); |
pthread_sigmask(SIG_BLOCK, &ss, &root->root_oldset); |
pthread_sigmask(SIG_BLOCK, &ss, &root->root_oldset); |
#else |
#else |
|
pthread_sigmask(SIG_BLOCK, NULL, &root->root_oldset); |
|
#endif |
|
#else |
|
#if SUP_ENABLE == KQ_SUPPORT |
sigprocmask(SIG_BLOCK, &ss, &root->root_oldset); |
sigprocmask(SIG_BLOCK, &ss, &root->root_oldset); |
|
#else |
|
sigprocmask(SIG_BLOCK, NULL, &root->root_oldset); |
#endif |
#endif |
|
#endif |
|
|
if (data && *data) { |
if (data && *data) { |
if (datlen) { |
if (datlen) { |
Line 1188 _sched_sigDisp(void *arg)
|
Line 1198 _sched_sigDisp(void *arg)
|
int |
int |
schedSignalDispatch(sched_root_task_t * __restrict root, int on) |
schedSignalDispatch(sched_root_task_t * __restrict root, int on) |
{ |
{ |
|
sigset_t ss; |
struct timespec ts = { .tv_sec = 1, .tv_nsec = 0 }; |
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"); |
Line 1222 schedSignalDispatch(sched_root_task_t * __restrict roo
|
Line 1233 schedSignalDispatch(sched_root_task_t * __restrict roo
|
pthread_attr_setschedpolicy(&attr, SCHED_OTHER); |
pthread_attr_setschedpolicy(&attr, SCHED_OTHER); |
#endif |
#endif |
|
|
|
sigfillset(&ss); |
|
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 1230 schedSignalDispatch(sched_root_task_t * __restrict roo
|
Line 1244 schedSignalDispatch(sched_root_task_t * __restrict roo
|
#else |
#else |
root->root_sigthr = NULL; |
root->root_sigthr = NULL; |
#endif |
#endif |
|
pthread_sigmask(SIG_SETMASK, &root->root_oldset, NULL); |
return -1; |
return -1; |
} |
} |
|
|