diff options
Diffstat (limited to 'sysdeps/mach/hurd/sigwait.c')
-rw-r--r-- | sysdeps/mach/hurd/sigwait.c | 121 |
1 files changed, 9 insertions, 112 deletions
diff --git a/sysdeps/mach/hurd/sigwait.c b/sysdeps/mach/hurd/sigwait.c index 9d2dfe13ee..caf1aef933 100644 --- a/sysdeps/mach/hurd/sigwait.c +++ b/sysdeps/mach/hurd/sigwait.c @@ -1,4 +1,4 @@ -/* Copyright (C) 1996-2022 Free Software Foundation, Inc. +/* Copyright (C) 2022 Free Software Foundation, Inc. This file is part of the GNU C Library. The GNU C Library is free software; you can redistribute it and/or @@ -15,128 +15,25 @@ License along with the GNU C Library; if not, see <https://www.gnu.org/licenses/>. */ -#include <errno.h> +#include <signal.h> #include <hurd.h> -#include <hurd/signal.h> -#include <hurd/msg.h> -#include <hurd/sigpreempt.h> -#include <assert.h> -#include <sysdep-cancel.h> /* Select any of pending signals from SET or wait for any to arrive. */ int __sigwait (const sigset_t *set, int *sig) { - struct hurd_sigstate *ss; - sigset_t mask, ready, blocked; - int signo = 0; - struct hurd_signal_preemptor preemptor; - jmp_buf buf; - mach_port_t wait; - mach_msg_header_t msg; - int cancel_oldtype; + int ret; - sighandler_t - preempt_fun (struct hurd_signal_preemptor *pe, - struct hurd_sigstate *ss, - int *sigp, - struct hurd_signal_detail *detail) - { - if (signo) - /* We've already been run; don't interfere. */ - return SIG_ERR; + ret = __sigtimedwait (set, NULL, NULL); - signo = *sigp; + if (ret < 0) + return -1; - /* Make sure this is all kosher */ - assert (__sigismember (&mask, signo)); + if (!ret) + return __hurd_fail(EAGAIN); - /* Restore the blocking mask. */ - ss->blocked = blocked; - - return pe->handler; - } - - void - handler (int sig) - { - assert (sig == signo); - longjmp (buf, 1); - } - - wait = __mach_reply_port (); - - if (set != NULL) - /* Crash before locking */ - mask = *set; - else - __sigemptyset (&mask); - - ss = _hurd_self_sigstate (); - cancel_oldtype = LIBC_CANCEL_ASYNC(); - _hurd_sigstate_lock (ss); - - /* See if one of these signals is currently pending. */ - sigset_t pending = _hurd_sigstate_pending (ss); - __sigandset (&ready, &pending, &mask); - if (! __sigisemptyset (&ready)) - { - for (signo = 1; signo < NSIG; signo++) - if (__sigismember (&ready, signo)) - { - __sigdelset (&ready, signo); - goto all_done; - } - /* Huh? Where'd it go? */ - abort (); - } - - /* Wait for one of them to show up. */ - - if (!setjmp (buf)) - { - /* Make the preemptor */ - preemptor.signals = mask; - preemptor.first = 0; - preemptor.last = -1; - preemptor.preemptor = preempt_fun; - preemptor.handler = handler; - - /* Install this preemptor */ - preemptor.next = ss->preemptors; - ss->preemptors = &preemptor; - - /* Unblock the expected signals */ - blocked = ss->blocked; - ss->blocked &= ~mask; - - _hurd_sigstate_unlock (ss); - - /* Wait. */ - __mach_msg (&msg, MACH_RCV_MSG, 0, sizeof (msg), wait, - MACH_MSG_TIMEOUT_NONE, MACH_PORT_NULL); - abort (); - } - else - { - assert (signo); - - _hurd_sigstate_lock (ss); - - /* Delete our preemptor. */ - assert (ss->preemptors == &preemptor); - ss->preemptors = preemptor.next; - } - - -all_done: - _hurd_sigstate_unlock (ss); - LIBC_CANCEL_RESET (cancel_oldtype); - - __mach_port_destroy (__mach_task_self (), wait); - *sig = signo; + *sig = ret; return 0; } - libc_hidden_def (__sigwait) weak_alias (__sigwait, sigwait) |