]> git.proxmox.com Git - mirror_qemu.git/blob - util/event_notifier-posix.c
Merge remote-tracking branch 'mst/tags/for_anthony' into staging
[mirror_qemu.git] / util / event_notifier-posix.c
1 /*
2 * event notifier support
3 *
4 * Copyright Red Hat, Inc. 2010
5 *
6 * Authors:
7 * Michael S. Tsirkin <mst@redhat.com>
8 *
9 * This work is licensed under the terms of the GNU GPL, version 2 or later.
10 * See the COPYING file in the top-level directory.
11 */
12
13 #include "qemu-common.h"
14 #include "qemu/event_notifier.h"
15 #include "char/char.h"
16 #include "qemu/main-loop.h"
17
18 #ifdef CONFIG_EVENTFD
19 #include <sys/eventfd.h>
20 #endif
21
22 void event_notifier_init_fd(EventNotifier *e, int fd)
23 {
24 e->rfd = fd;
25 e->wfd = fd;
26 }
27
28 int event_notifier_init(EventNotifier *e, int active)
29 {
30 int fds[2];
31 int ret;
32
33 #ifdef CONFIG_EVENTFD
34 ret = eventfd(0, EFD_NONBLOCK | EFD_CLOEXEC);
35 #else
36 ret = -1;
37 errno = ENOSYS;
38 #endif
39 if (ret >= 0) {
40 e->rfd = e->wfd = ret;
41 } else {
42 if (errno != ENOSYS) {
43 return -errno;
44 }
45 if (qemu_pipe(fds) < 0) {
46 return -errno;
47 }
48 ret = fcntl_setfl(fds[0], O_NONBLOCK);
49 if (ret < 0) {
50 ret = -errno;
51 goto fail;
52 }
53 ret = fcntl_setfl(fds[1], O_NONBLOCK);
54 if (ret < 0) {
55 ret = -errno;
56 goto fail;
57 }
58 e->rfd = fds[0];
59 e->wfd = fds[1];
60 }
61 if (active) {
62 event_notifier_set(e);
63 }
64 return 0;
65
66 fail:
67 close(fds[0]);
68 close(fds[1]);
69 return ret;
70 }
71
72 void event_notifier_cleanup(EventNotifier *e)
73 {
74 if (e->rfd != e->wfd) {
75 close(e->rfd);
76 }
77 close(e->wfd);
78 }
79
80 int event_notifier_get_fd(EventNotifier *e)
81 {
82 return e->rfd;
83 }
84
85 int event_notifier_set_handler(EventNotifier *e,
86 EventNotifierHandler *handler)
87 {
88 return qemu_set_fd_handler(e->rfd, (IOHandler *)handler, NULL, e);
89 }
90
91 int event_notifier_set(EventNotifier *e)
92 {
93 static const uint64_t value = 1;
94 ssize_t ret;
95
96 do {
97 ret = write(e->wfd, &value, sizeof(value));
98 } while (ret < 0 && errno == EINTR);
99
100 /* EAGAIN is fine, a read must be pending. */
101 if (ret < 0 && errno != EAGAIN) {
102 return -errno;
103 }
104 return 0;
105 }
106
107 int event_notifier_test_and_clear(EventNotifier *e)
108 {
109 int value;
110 ssize_t len;
111 char buffer[512];
112
113 /* Drain the notify pipe. For eventfd, only 8 bytes will be read. */
114 value = 0;
115 do {
116 len = read(e->rfd, buffer, sizeof(buffer));
117 value |= (len > 0);
118 } while ((len == -1 && errno == EINTR) || len == sizeof(buffer));
119
120 return value;
121 }