version 1.40, 2023/02/25 15:55:01
|
version 1.41, 2023/07/27 20:51:28
|
Line 362 sched_hook_cancel(void *task, void *arg __unused)
|
Line 362 sched_hook_cancel(void *task, void *arg __unused)
|
EV_SET(&chg[0], TASK_VAL(t), EVFILT_SIGNAL, flg < 2 ? EV_DELETE : 0, |
EV_SET(&chg[0], TASK_VAL(t), EVFILT_SIGNAL, flg < 2 ? EV_DELETE : 0, |
0, 0, (void*) TASK_VAL(t)); |
0, 0, (void*) TASK_VAL(t)); |
#endif |
#endif |
/* restore signal */ | #endif |
if (flg < 2) | |
signal(TASK_VAL(t), SIG_DFL); | |
#else | |
if (flg < 2) { |
if (flg < 2) { |
pthread_mutex_lock(&TASK_ROOT(t)->root_sigmtx); |
pthread_mutex_lock(&TASK_ROOT(t)->root_sigmtx); |
sigdelset(&TASK_ROOT(t)->root_sigset, TASK_VAL(t)); |
sigdelset(&TASK_ROOT(t)->root_sigset, TASK_VAL(t)); |
pthread_mutex_unlock(&TASK_ROOT(t)->root_sigmtx); |
pthread_mutex_unlock(&TASK_ROOT(t)->root_sigmtx); |
} |
} |
#endif |
|
break; |
break; |
#ifdef AIO_SUPPORT |
#ifdef AIO_SUPPORT |
case taskAIO: |
case taskAIO: |
Line 821 void *
|
Line 817 void *
|
sched_hook_signal(void *task, void *arg __unused) |
sched_hook_signal(void *task, void *arg __unused) |
{ |
{ |
sched_task_t *t = task; |
sched_task_t *t = task; |
|
|
#if SUP_ENABLE == KQ_SUPPORT |
#if SUP_ENABLE == KQ_SUPPORT |
struct kevent chg[1]; |
struct kevent chg[1]; |
struct timespec timeout = { 0, 0 }; |
struct timespec timeout = { 0, 0 }; |
|
#endif |
|
|
if (!t || !TASK_ROOT(t)) |
if (!t || !TASK_ROOT(t)) |
return (void*) -1; |
return (void*) -1; |
|
|
/* ignore signal */ | #if SUP_ENABLE == KQ_SUPPORT |
signal(TASK_VAL(t), SIG_IGN); | |
| |
#ifdef __NetBSD__ |
#ifdef __NetBSD__ |
EV_SET(&chg[0], TASK_VAL(t), EVFILT_SIGNAL, EV_ADD | EV_CLEAR, 0, 0, (intptr_t) TASK_VAL(t)); |
EV_SET(&chg[0], TASK_VAL(t), EVFILT_SIGNAL, EV_ADD | EV_CLEAR, 0, 0, (intptr_t) TASK_VAL(t)); |
#else |
#else |
Line 844 sched_hook_signal(void *task, void *arg __unused)
|
Line 838 sched_hook_signal(void *task, void *arg __unused)
|
LOGERR; |
LOGERR; |
return (void*) -1; |
return (void*) -1; |
} |
} |
#else | #endif |
| |
pthread_mutex_lock(&TASK_ROOT(t)->root_sigmtx); |
pthread_mutex_lock(&TASK_ROOT(t)->root_sigmtx); |
sigaddset(&TASK_ROOT(t)->root_sigset, TASK_VAL(t)); |
sigaddset(&TASK_ROOT(t)->root_sigset, TASK_VAL(t)); |
pthread_mutex_unlock(&TASK_ROOT(t)->root_sigmtx); |
pthread_mutex_unlock(&TASK_ROOT(t)->root_sigmtx); |
#endif |
|
|
|
return NULL; |
return NULL; |
} |
} |