| /* |
| * signalfd/eventfd compatibility |
| * |
| * Copyright IBM, Corp. 2008 |
| * |
| * Authors: |
| * Anthony Liguori <aliguori@us.ibm.com> |
| * |
| * This work is licensed under the terms of the GNU GPL, version 2. See |
| * the COPYING file in the top-level directory. |
| * |
| * Contributions after 2012-01-13 are licensed under the terms of the |
| * GNU GPL, version 2 or (at your option) any later version. |
| */ |
| |
| #include "qemu/osdep.h" |
| #include "qemu/thread.h" |
| |
| #include <sys/syscall.h> |
| |
| struct sigfd_compat_info |
| { |
| sigset_t mask; |
| int fd; |
| }; |
| |
| static void *sigwait_compat(void *opaque) |
| { |
| struct sigfd_compat_info *info = opaque; |
| |
| while (1) { |
| int sig; |
| int err; |
| |
| err = sigwait(&info->mask, &sig); |
| if (err != 0) { |
| if (errno == EINTR) { |
| continue; |
| } else { |
| return NULL; |
| } |
| } else { |
| struct qemu_signalfd_siginfo buffer; |
| size_t offset = 0; |
| |
| memset(&buffer, 0, sizeof(buffer)); |
| buffer.ssi_signo = sig; |
| |
| while (offset < sizeof(buffer)) { |
| ssize_t len; |
| |
| len = write(info->fd, (char *)&buffer + offset, |
| sizeof(buffer) - offset); |
| if (len == -1 && errno == EINTR) |
| continue; |
| |
| if (len <= 0) { |
| return NULL; |
| } |
| |
| offset += len; |
| } |
| } |
| } |
| } |
| |
| static int qemu_signalfd_compat(const sigset_t *mask) |
| { |
| struct sigfd_compat_info *info; |
| QemuThread thread; |
| int fds[2]; |
| |
| info = malloc(sizeof(*info)); |
| if (info == NULL) { |
| errno = ENOMEM; |
| return -1; |
| } |
| |
| if (pipe(fds) == -1) { |
| free(info); |
| return -1; |
| } |
| |
| qemu_set_cloexec(fds[0]); |
| qemu_set_cloexec(fds[1]); |
| |
| memcpy(&info->mask, mask, sizeof(*mask)); |
| info->fd = fds[1]; |
| |
| qemu_thread_create(&thread, "signalfd_compat", sigwait_compat, info, |
| QEMU_THREAD_DETACHED); |
| |
| return fds[0]; |
| } |
| |
| int qemu_signalfd(const sigset_t *mask) |
| { |
| #if defined(CONFIG_SIGNALFD) |
| int ret; |
| |
| ret = syscall(SYS_signalfd, -1, mask, _NSIG / 8); |
| if (ret != -1) { |
| qemu_set_cloexec(ret); |
| return ret; |
| } |
| #endif |
| |
| return qemu_signalfd_compat(mask); |
| } |