use KVM_UPSTREAM for ppc.
[qemu-kvm/fedora.git] / compatfd.c
blob36e37e5d10419f76875141ba358e9c33f6212831
1 /*
2 * signalfd/eventfd compatibility
4 * Copyright IBM, Corp. 2008
6 * Authors:
7 * Anthony Liguori <aliguori@us.ibm.com>
9 * This work is licensed under the terms of the GNU GPL, version 2. See
10 * the COPYING file in the top-level directory.
14 #include "qemu-common.h"
15 #include "compatfd.h"
17 #include <sys/syscall.h>
18 #include <pthread.h>
20 struct sigfd_compat_info
22 sigset_t mask;
23 int fd;
26 static void *sigwait_compat(void *opaque)
28 struct sigfd_compat_info *info = opaque;
29 int err;
30 sigset_t all;
32 sigfillset(&all);
33 sigprocmask(SIG_BLOCK, &all, NULL);
35 do {
36 siginfo_t siginfo;
38 err = sigwaitinfo(&info->mask, &siginfo);
39 if (err == -1 && errno == EINTR) {
40 err = 0;
41 continue;
44 if (err > 0) {
45 char buffer[128];
46 size_t offset = 0;
48 memcpy(buffer, &err, sizeof(err));
49 while (offset < sizeof(buffer)) {
50 ssize_t len;
52 len = write(info->fd, buffer + offset,
53 sizeof(buffer) - offset);
54 if (len == -1 && errno == EINTR)
55 continue;
57 if (len <= 0) {
58 err = -1;
59 break;
62 offset += len;
65 } while (err >= 0);
67 return NULL;
70 static int qemu_signalfd_compat(const sigset_t *mask)
72 pthread_attr_t attr;
73 pthread_t tid;
74 struct sigfd_compat_info *info;
75 int fds[2];
77 info = malloc(sizeof(*info));
78 if (info == NULL) {
79 errno = ENOMEM;
80 return -1;
83 if (pipe(fds) == -1) {
84 free(info);
85 return -1;
88 memcpy(&info->mask, mask, sizeof(*mask));
89 info->fd = fds[1];
91 pthread_attr_init(&attr);
92 pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);
94 pthread_create(&tid, &attr, sigwait_compat, info);
96 pthread_attr_destroy(&attr);
98 return fds[0];
101 int qemu_signalfd(const sigset_t *mask)
103 #if defined(CONFIG_signalfd)
104 int ret;
106 ret = syscall(SYS_signalfd, -1, mask, _NSIG / 8);
107 if (ret != -1)
108 return ret;
109 #endif
111 return qemu_signalfd_compat(mask);
114 int qemu_eventfd(int *fds)
116 #if defined(CONFIG_eventfd)
117 int ret;
119 ret = syscall(SYS_eventfd, 0);
120 if (ret >= 0) {
121 fds[0] = ret;
122 if ((fds[1] = dup(ret)) == -1) {
123 close(ret);
124 return -1;
126 return 0;
128 #endif
130 return pipe(fds);