version 1.29.8.2, 2023/02/23 15:31:17
|
version 1.31, 2023/02/25 15:55:01
|
Line 181 schedRegisterHooks(sched_root_task_t * __restrict root
|
Line 181 schedRegisterHooks(sched_root_task_t * __restrict root
|
root->root_hooks.hook_add.alarm = sched_hook_alarm; |
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; |
|
#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 |
Line 189 schedRegisterHooks(sched_root_task_t * __restrict root
|
Line 188 schedRegisterHooks(sched_root_task_t * __restrict root
|
#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 |
|
root->root_hooks.hook_add.signal = sched_hook_signal; |
|
|
root->root_hooks.hook_exec.cancel = sched_hook_cancel; |
root->root_hooks.hook_exec.cancel = sched_hook_cancel; |
root->root_hooks.hook_exec.fetch = sched_hook_fetch; |
root->root_hooks.hook_exec.fetch = sched_hook_fetch; |
Line 228 schedInit(void ** __restrict data, size_t datlen)
|
Line 228 schedInit(void ** __restrict data, size_t datlen)
|
sched_timespecinf(&root->root_poll); |
sched_timespecinf(&root->root_poll); |
|
|
#ifdef HAVE_LIBPTHREAD |
#ifdef HAVE_LIBPTHREAD |
|
if (pthread_mutex_init(&root->root_sigmtx, NULL)) { |
|
LOGERR; |
|
e_free(root); |
|
return NULL; |
|
} |
|
|
for (i = 0; i < taskMAX; i++) |
for (i = 0; i < taskMAX; i++) |
if ((errno = pthread_mutex_init(&root->root_mtx[i], NULL))) { |
if ((errno = pthread_mutex_init(&root->root_mtx[i], NULL))) { |
LOGERR; |
LOGERR; |
Line 389 schedEnd(sched_root_task_t ** __restrict root)
|
Line 395 schedEnd(sched_root_task_t ** __restrict root)
|
|
|
if ((*root)->root_sigthr) { |
if ((*root)->root_sigthr) { |
pthread_cancel((*root)->root_sigthr); |
pthread_cancel((*root)->root_sigthr); |
(*root)->root_sigthr ^= (*root)->root_sigthr; | #ifdef __linux__ |
| (*root)->root_sigthr = 0L; |
| #else |
| (*root)->root_sigthr = NULL; |
| #endif |
| pthread_sigmask(SIG_SETMASK, &(*root)->root_oldset, NULL); |
| pthread_mutex_unlock(&(*root)->root_sigmtx); |
} |
} |
|
pthread_mutex_destroy(&(*root)->root_sigmtx); |
#endif |
#endif |
|
|
e_free(*root); |
e_free(*root); |
Line 1119 schedResumeby(sched_root_task_t * __restrict root, u_c
|
Line 1132 schedResumeby(sched_root_task_t * __restrict root, u_c
|
static void * |
static void * |
_sched_sigDisp(void *arg) |
_sched_sigDisp(void *arg) |
{ |
{ |
sched_root_task_t *sched = arg; | sched_root_task_t *root = arg; |
| sched_task_t *task, *tmp; |
| int sig, flg; |
sigset_t ss; |
sigset_t ss; |
int sig; |
|
|
|
sigfillset(&ss); |
sigfillset(&ss); |
while (sched->root_sigthr) { | while (root->root_sigthr) { |
sigwait(&ss, &sig); | if (sigwait(&ss, &sig)) |
| continue; |
|
|
|
pthread_mutex_lock(&root->root_sigmtx); |
|
if (!sigismember(&root->root_sigset, sig)) { |
|
pthread_mutex_unlock(&root->root_sigmtx); |
|
continue; |
|
} |
|
|
|
flg = 0; |
|
TAILQ_FOREACH_SAFE(task, &root->root_signal, task_node, tmp) { |
|
if (TASK_VAL(task) == (uintptr_t) sig) { |
|
if (!flg) { |
|
TASK_RET(task) = 0; |
|
TASK_FLAG(task) = 0; |
|
|
|
/* remove signal handle */ |
|
transit_task2ready(task, &root->root_signal); |
|
} |
|
flg++; |
|
} |
|
} |
|
if (flg < 2) |
|
sigdelset(&root->root_sigset, sig); |
|
|
|
pthread_mutex_unlock(&root->root_sigmtx); |
} |
} |
|
|
return NULL; |
return NULL; |
Line 1150 schedSignalDispatch(sched_root_task_t * __restrict roo
|
Line 1188 schedSignalDispatch(sched_root_task_t * __restrict roo
|
pthread_attr_t attr; |
pthread_attr_t attr; |
#endif |
#endif |
|
|
|
#if SUP_ENABLE == KQ_SUPPORT |
|
return 0; |
|
#endif |
|
|
if (!on) { |
if (!on) { |
pthread_cancel(root->root_sigthr); |
pthread_cancel(root->root_sigthr); |
root->root_sigthr ^= root->root_sigthr; | #ifdef __linux__ |
| root->root_sigthr = 0L; |
| #else |
| root->root_sigthr = NULL; |
| #endif |
| pthread_sigmask(SIG_SETMASK, &root->root_oldset, NULL); |
| |
| pthread_mutex_unlock(&root->root_sigmtx); |
return 0; |
return 0; |
} |
} |
|
|
Line 1165 schedSignalDispatch(sched_root_task_t * __restrict roo
|
Line 1214 schedSignalDispatch(sched_root_task_t * __restrict roo
|
#endif |
#endif |
|
|
sigfillset(&ss); |
sigfillset(&ss); |
pthread_sigmask(SIG_BLOCK, &ss, NULL); | pthread_sigmask(SIG_BLOCK, &ss, &root->root_oldset); |
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)); |
|
#ifdef __linux__ |
|
root->root_sigthr = 0L; |
|
#else |
|
root->root_sigthr = NULL; |
|
#endif |
|
pthread_sigmask(SIG_SETMASK, &root->root_oldset, NULL); |
return -1; |
return -1; |
} |
} |
|
|