1c2b38b27SPaolo Bonzini /*
2c2b38b27SPaolo Bonzini * QEMU System Emulator
3c2b38b27SPaolo Bonzini *
4c2b38b27SPaolo Bonzini * Copyright (c) 2003-2008 Fabrice Bellard
5c2b38b27SPaolo Bonzini *
6c2b38b27SPaolo Bonzini * Permission is hereby granted, free of charge, to any person obtaining a copy
7c2b38b27SPaolo Bonzini * of this software and associated documentation files (the "Software"), to deal
8c2b38b27SPaolo Bonzini * in the Software without restriction, including without limitation the rights
9c2b38b27SPaolo Bonzini * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
10c2b38b27SPaolo Bonzini * copies of the Software, and to permit persons to whom the Software is
11c2b38b27SPaolo Bonzini * furnished to do so, subject to the following conditions:
12c2b38b27SPaolo Bonzini *
13c2b38b27SPaolo Bonzini * The above copyright notice and this permission notice shall be included in
14c2b38b27SPaolo Bonzini * all copies or substantial portions of the Software.
15c2b38b27SPaolo Bonzini *
16c2b38b27SPaolo Bonzini * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
17c2b38b27SPaolo Bonzini * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
18c2b38b27SPaolo Bonzini * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
19c2b38b27SPaolo Bonzini * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
20c2b38b27SPaolo Bonzini * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
21c2b38b27SPaolo Bonzini * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
22c2b38b27SPaolo Bonzini * THE SOFTWARE.
23c2b38b27SPaolo Bonzini */
24c2b38b27SPaolo Bonzini
25c2b38b27SPaolo Bonzini #include "qemu/osdep.h"
26c2b38b27SPaolo Bonzini #include "qapi/error.h"
27c2b38b27SPaolo Bonzini #include "qemu/cutils.h"
28c2b38b27SPaolo Bonzini #include "qemu/timer.h"
29740b1759SClaudio Fontana #include "sysemu/cpu-timers.h"
30d759c951SAlex Bennée #include "sysemu/replay.h"
31c2b38b27SPaolo Bonzini #include "qemu/main-loop.h"
32c2b38b27SPaolo Bonzini #include "block/aio.h"
3371ad4713SNicolas Saenz Julienne #include "block/thread-pool.h"
348297be80SAlistair Francis #include "qemu/error-report.h"
35e9ed92bdSPaolo Bonzini #include "qemu/queue.h"
3670ac26b9SNicolas Saenz Julienne #include "qom/object.h"
37e9ed92bdSPaolo Bonzini
38e9ed92bdSPaolo Bonzini #ifndef _WIN32
39e9ed92bdSPaolo Bonzini #include <sys/wait.h>
40e9ed92bdSPaolo Bonzini #endif
41c2b38b27SPaolo Bonzini
42c2b38b27SPaolo Bonzini #ifndef _WIN32
43c2b38b27SPaolo Bonzini
44c2b38b27SPaolo Bonzini /* If we have signalfd, we mask out the signals we want to handle and then
45c2b38b27SPaolo Bonzini * use signalfd to listen for them. We rely on whatever the current signal
46c2b38b27SPaolo Bonzini * handler is to dispatch the signals when we receive them.
47c2b38b27SPaolo Bonzini */
48c905a368SDaniele Buono /*
49c905a368SDaniele Buono * Disable CFI checks.
50*d02d06f8SMichael Tokarev * We are going to call a signal handler directly. Such handler may or may not
51c905a368SDaniele Buono * have been defined in our binary, so there's no guarantee that the pointer
52c905a368SDaniele Buono * used to set the handler is a cfi-valid pointer. Since the handlers are
53c905a368SDaniele Buono * stored in kernel memory, changing the handler to an attacker-defined
54c905a368SDaniele Buono * function requires being able to call a sigaction() syscall,
55c905a368SDaniele Buono * which is not as easy as overwriting a pointer in memory.
56c905a368SDaniele Buono */
57c905a368SDaniele Buono QEMU_DISABLE_CFI
sigfd_handler(void * opaque)58c2b38b27SPaolo Bonzini static void sigfd_handler(void *opaque)
59c2b38b27SPaolo Bonzini {
60c2b38b27SPaolo Bonzini int fd = (intptr_t)opaque;
61c2b38b27SPaolo Bonzini struct qemu_signalfd_siginfo info;
62c2b38b27SPaolo Bonzini struct sigaction action;
63c2b38b27SPaolo Bonzini ssize_t len;
64c2b38b27SPaolo Bonzini
65c2b38b27SPaolo Bonzini while (1) {
6637b0b24eSNikita Ivanov len = RETRY_ON_EINTR(read(fd, &info, sizeof(info)));
67c2b38b27SPaolo Bonzini
68c2b38b27SPaolo Bonzini if (len == -1 && errno == EAGAIN) {
69c2b38b27SPaolo Bonzini break;
70c2b38b27SPaolo Bonzini }
71c2b38b27SPaolo Bonzini
72c2b38b27SPaolo Bonzini if (len != sizeof(info)) {
73372a87a1SThomas Huth error_report("read from sigfd returned %zd: %s", len,
74372a87a1SThomas Huth g_strerror(errno));
75c2b38b27SPaolo Bonzini return;
76c2b38b27SPaolo Bonzini }
77c2b38b27SPaolo Bonzini
78c2b38b27SPaolo Bonzini sigaction(info.ssi_signo, NULL, &action);
79c2b38b27SPaolo Bonzini if ((action.sa_flags & SA_SIGINFO) && action.sa_sigaction) {
80d98d4072SPaolo Bonzini sigaction_invoke(&action, &info);
81c2b38b27SPaolo Bonzini } else if (action.sa_handler) {
82c2b38b27SPaolo Bonzini action.sa_handler(info.ssi_signo);
83c2b38b27SPaolo Bonzini }
84c2b38b27SPaolo Bonzini }
85c2b38b27SPaolo Bonzini }
86c2b38b27SPaolo Bonzini
qemu_signal_init(Error ** errp)8778524330SFei Li static int qemu_signal_init(Error **errp)
88c2b38b27SPaolo Bonzini {
89c2b38b27SPaolo Bonzini int sigfd;
90c2b38b27SPaolo Bonzini sigset_t set;
91c2b38b27SPaolo Bonzini
92c2b38b27SPaolo Bonzini /*
93c2b38b27SPaolo Bonzini * SIG_IPI must be blocked in the main thread and must not be caught
94c2b38b27SPaolo Bonzini * by sigwait() in the signal thread. Otherwise, the cpu thread will
95c2b38b27SPaolo Bonzini * not catch it reliably.
96c2b38b27SPaolo Bonzini */
97c2b38b27SPaolo Bonzini sigemptyset(&set);
98c2b38b27SPaolo Bonzini sigaddset(&set, SIG_IPI);
99c2b38b27SPaolo Bonzini sigaddset(&set, SIGIO);
100c2b38b27SPaolo Bonzini sigaddset(&set, SIGALRM);
101c2b38b27SPaolo Bonzini sigaddset(&set, SIGBUS);
102c2b38b27SPaolo Bonzini /* SIGINT cannot be handled via signalfd, so that ^C can be used
103c2b38b27SPaolo Bonzini * to interrupt QEMU when it is being run under gdb. SIGHUP and
104c2b38b27SPaolo Bonzini * SIGTERM are also handled asynchronously, even though it is not
105c2b38b27SPaolo Bonzini * strictly necessary, because they use the same handler as SIGINT.
106c2b38b27SPaolo Bonzini */
107c2b38b27SPaolo Bonzini pthread_sigmask(SIG_BLOCK, &set, NULL);
108c2b38b27SPaolo Bonzini
109c2b38b27SPaolo Bonzini sigdelset(&set, SIG_IPI);
110c2b38b27SPaolo Bonzini sigfd = qemu_signalfd(&set);
111c2b38b27SPaolo Bonzini if (sigfd == -1) {
11278524330SFei Li error_setg_errno(errp, errno, "failed to create signalfd");
113c2b38b27SPaolo Bonzini return -errno;
114c2b38b27SPaolo Bonzini }
115c2b38b27SPaolo Bonzini
1164d14cb0cSMarc-André Lureau g_unix_set_fd_nonblocking(sigfd, true, NULL);
117c2b38b27SPaolo Bonzini
118c2b38b27SPaolo Bonzini qemu_set_fd_handler(sigfd, sigfd_handler, NULL, (void *)(intptr_t)sigfd);
119c2b38b27SPaolo Bonzini
120c2b38b27SPaolo Bonzini return 0;
121c2b38b27SPaolo Bonzini }
122c2b38b27SPaolo Bonzini
123c2b38b27SPaolo Bonzini #else /* _WIN32 */
124c2b38b27SPaolo Bonzini
qemu_signal_init(Error ** errp)12578524330SFei Li static int qemu_signal_init(Error **errp)
126c2b38b27SPaolo Bonzini {
127c2b38b27SPaolo Bonzini return 0;
128c2b38b27SPaolo Bonzini }
129c2b38b27SPaolo Bonzini #endif
130c2b38b27SPaolo Bonzini
131c2b38b27SPaolo Bonzini static AioContext *qemu_aio_context;
132c2b38b27SPaolo Bonzini static QEMUBH *qemu_notify_bh;
133c2b38b27SPaolo Bonzini
notify_event_cb(void * opaque)134c2b38b27SPaolo Bonzini static void notify_event_cb(void *opaque)
135c2b38b27SPaolo Bonzini {
136c2b38b27SPaolo Bonzini /* No need to do anything; this bottom half is only used to
137c2b38b27SPaolo Bonzini * kick the kernel out of ppoll/poll/WaitForMultipleObjects.
138c2b38b27SPaolo Bonzini */
139c2b38b27SPaolo Bonzini }
140c2b38b27SPaolo Bonzini
qemu_get_aio_context(void)141c2b38b27SPaolo Bonzini AioContext *qemu_get_aio_context(void)
142c2b38b27SPaolo Bonzini {
143c2b38b27SPaolo Bonzini return qemu_aio_context;
144c2b38b27SPaolo Bonzini }
145c2b38b27SPaolo Bonzini
qemu_notify_event(void)146c2b38b27SPaolo Bonzini void qemu_notify_event(void)
147c2b38b27SPaolo Bonzini {
148c2b38b27SPaolo Bonzini if (!qemu_aio_context) {
149c2b38b27SPaolo Bonzini return;
150c2b38b27SPaolo Bonzini }
151c2b38b27SPaolo Bonzini qemu_bh_schedule(qemu_notify_bh);
152c2b38b27SPaolo Bonzini }
153c2b38b27SPaolo Bonzini
154c2b38b27SPaolo Bonzini static GArray *gpollfds;
155c2b38b27SPaolo Bonzini
qemu_init_main_loop(Error ** errp)156c2b38b27SPaolo Bonzini int qemu_init_main_loop(Error **errp)
157c2b38b27SPaolo Bonzini {
158c2b38b27SPaolo Bonzini int ret;
159c2b38b27SPaolo Bonzini GSource *src;
160c2b38b27SPaolo Bonzini
1613f53bc61SPaolo Bonzini init_clocks(qemu_timer_notify_cb);
162c2b38b27SPaolo Bonzini
16378524330SFei Li ret = qemu_signal_init(errp);
164c2b38b27SPaolo Bonzini if (ret) {
165c2b38b27SPaolo Bonzini return ret;
166c2b38b27SPaolo Bonzini }
167c2b38b27SPaolo Bonzini
168668f62ecSMarkus Armbruster qemu_aio_context = aio_context_new(errp);
169c2b38b27SPaolo Bonzini if (!qemu_aio_context) {
170c2b38b27SPaolo Bonzini return -EMFILE;
171c2b38b27SPaolo Bonzini }
1725f50be9bSPaolo Bonzini qemu_set_current_aio_context(qemu_aio_context);
173c2b38b27SPaolo Bonzini qemu_notify_bh = qemu_bh_new(notify_event_cb, NULL);
174c2b38b27SPaolo Bonzini gpollfds = g_array_new(FALSE, FALSE, sizeof(GPollFD));
175c2b38b27SPaolo Bonzini src = aio_get_g_source(qemu_aio_context);
176c2b38b27SPaolo Bonzini g_source_set_name(src, "aio-context");
177c2b38b27SPaolo Bonzini g_source_attach(src, NULL);
178c2b38b27SPaolo Bonzini g_source_unref(src);
179c2b38b27SPaolo Bonzini src = iohandler_get_g_source();
180c2b38b27SPaolo Bonzini g_source_set_name(src, "io-handler");
181c2b38b27SPaolo Bonzini g_source_attach(src, NULL);
182c2b38b27SPaolo Bonzini g_source_unref(src);
183c2b38b27SPaolo Bonzini return 0;
184c2b38b27SPaolo Bonzini }
185c2b38b27SPaolo Bonzini
main_loop_update_params(EventLoopBase * base,Error ** errp)18670ac26b9SNicolas Saenz Julienne static void main_loop_update_params(EventLoopBase *base, Error **errp)
18770ac26b9SNicolas Saenz Julienne {
18871ad4713SNicolas Saenz Julienne ERRP_GUARD();
18971ad4713SNicolas Saenz Julienne
19070ac26b9SNicolas Saenz Julienne if (!qemu_aio_context) {
19170ac26b9SNicolas Saenz Julienne error_setg(errp, "qemu aio context not ready");
19270ac26b9SNicolas Saenz Julienne return;
19370ac26b9SNicolas Saenz Julienne }
19470ac26b9SNicolas Saenz Julienne
19570ac26b9SNicolas Saenz Julienne aio_context_set_aio_params(qemu_aio_context, base->aio_max_batch, errp);
19671ad4713SNicolas Saenz Julienne if (*errp) {
19771ad4713SNicolas Saenz Julienne return;
19871ad4713SNicolas Saenz Julienne }
19971ad4713SNicolas Saenz Julienne
20071ad4713SNicolas Saenz Julienne aio_context_set_thread_pool_params(qemu_aio_context, base->thread_pool_min,
20171ad4713SNicolas Saenz Julienne base->thread_pool_max, errp);
20270ac26b9SNicolas Saenz Julienne }
20370ac26b9SNicolas Saenz Julienne
20470ac26b9SNicolas Saenz Julienne MainLoop *mloop;
20570ac26b9SNicolas Saenz Julienne
main_loop_init(EventLoopBase * base,Error ** errp)20670ac26b9SNicolas Saenz Julienne static void main_loop_init(EventLoopBase *base, Error **errp)
20770ac26b9SNicolas Saenz Julienne {
20870ac26b9SNicolas Saenz Julienne MainLoop *m = MAIN_LOOP(base);
20970ac26b9SNicolas Saenz Julienne
21070ac26b9SNicolas Saenz Julienne if (mloop) {
21170ac26b9SNicolas Saenz Julienne error_setg(errp, "only one main-loop instance allowed");
21270ac26b9SNicolas Saenz Julienne return;
21370ac26b9SNicolas Saenz Julienne }
21470ac26b9SNicolas Saenz Julienne
21570ac26b9SNicolas Saenz Julienne main_loop_update_params(base, errp);
21670ac26b9SNicolas Saenz Julienne
21770ac26b9SNicolas Saenz Julienne mloop = m;
21870ac26b9SNicolas Saenz Julienne return;
21970ac26b9SNicolas Saenz Julienne }
22070ac26b9SNicolas Saenz Julienne
main_loop_can_be_deleted(EventLoopBase * base)22170ac26b9SNicolas Saenz Julienne static bool main_loop_can_be_deleted(EventLoopBase *base)
22270ac26b9SNicolas Saenz Julienne {
22370ac26b9SNicolas Saenz Julienne return false;
22470ac26b9SNicolas Saenz Julienne }
22570ac26b9SNicolas Saenz Julienne
main_loop_class_init(ObjectClass * oc,void * class_data)22670ac26b9SNicolas Saenz Julienne static void main_loop_class_init(ObjectClass *oc, void *class_data)
22770ac26b9SNicolas Saenz Julienne {
22870ac26b9SNicolas Saenz Julienne EventLoopBaseClass *bc = EVENT_LOOP_BASE_CLASS(oc);
22970ac26b9SNicolas Saenz Julienne
23070ac26b9SNicolas Saenz Julienne bc->init = main_loop_init;
23170ac26b9SNicolas Saenz Julienne bc->update_params = main_loop_update_params;
23270ac26b9SNicolas Saenz Julienne bc->can_be_deleted = main_loop_can_be_deleted;
23370ac26b9SNicolas Saenz Julienne }
23470ac26b9SNicolas Saenz Julienne
23570ac26b9SNicolas Saenz Julienne static const TypeInfo main_loop_info = {
23670ac26b9SNicolas Saenz Julienne .name = TYPE_MAIN_LOOP,
23770ac26b9SNicolas Saenz Julienne .parent = TYPE_EVENT_LOOP_BASE,
23870ac26b9SNicolas Saenz Julienne .class_init = main_loop_class_init,
23970ac26b9SNicolas Saenz Julienne .instance_size = sizeof(MainLoop),
24070ac26b9SNicolas Saenz Julienne };
24170ac26b9SNicolas Saenz Julienne
main_loop_register_types(void)24270ac26b9SNicolas Saenz Julienne static void main_loop_register_types(void)
24370ac26b9SNicolas Saenz Julienne {
24470ac26b9SNicolas Saenz Julienne type_register_static(&main_loop_info);
24570ac26b9SNicolas Saenz Julienne }
24670ac26b9SNicolas Saenz Julienne
24770ac26b9SNicolas Saenz Julienne type_init(main_loop_register_types)
24870ac26b9SNicolas Saenz Julienne
249c2b38b27SPaolo Bonzini static int max_priority;
250c2b38b27SPaolo Bonzini
251c2b38b27SPaolo Bonzini #ifndef _WIN32
252c2b38b27SPaolo Bonzini static int glib_pollfds_idx;
253c2b38b27SPaolo Bonzini static int glib_n_poll_fds;
254c2b38b27SPaolo Bonzini
glib_pollfds_fill(int64_t * cur_timeout)255c2b38b27SPaolo Bonzini static void glib_pollfds_fill(int64_t *cur_timeout)
256c2b38b27SPaolo Bonzini {
257c2b38b27SPaolo Bonzini GMainContext *context = g_main_context_default();
258c2b38b27SPaolo Bonzini int timeout = 0;
259c2b38b27SPaolo Bonzini int64_t timeout_ns;
260c2b38b27SPaolo Bonzini int n;
261c2b38b27SPaolo Bonzini
262c2b38b27SPaolo Bonzini g_main_context_prepare(context, &max_priority);
263c2b38b27SPaolo Bonzini
264c2b38b27SPaolo Bonzini glib_pollfds_idx = gpollfds->len;
265c2b38b27SPaolo Bonzini n = glib_n_poll_fds;
266c2b38b27SPaolo Bonzini do {
267c2b38b27SPaolo Bonzini GPollFD *pfds;
268c2b38b27SPaolo Bonzini glib_n_poll_fds = n;
269c2b38b27SPaolo Bonzini g_array_set_size(gpollfds, glib_pollfds_idx + glib_n_poll_fds);
270c2b38b27SPaolo Bonzini pfds = &g_array_index(gpollfds, GPollFD, glib_pollfds_idx);
271c2b38b27SPaolo Bonzini n = g_main_context_query(context, max_priority, &timeout, pfds,
272c2b38b27SPaolo Bonzini glib_n_poll_fds);
273c2b38b27SPaolo Bonzini } while (n != glib_n_poll_fds);
274c2b38b27SPaolo Bonzini
275c2b38b27SPaolo Bonzini if (timeout < 0) {
276c2b38b27SPaolo Bonzini timeout_ns = -1;
277c2b38b27SPaolo Bonzini } else {
278c2b38b27SPaolo Bonzini timeout_ns = (int64_t)timeout * (int64_t)SCALE_MS;
279c2b38b27SPaolo Bonzini }
280c2b38b27SPaolo Bonzini
281c2b38b27SPaolo Bonzini *cur_timeout = qemu_soonest_timeout(timeout_ns, *cur_timeout);
282c2b38b27SPaolo Bonzini }
283c2b38b27SPaolo Bonzini
glib_pollfds_poll(void)284c2b38b27SPaolo Bonzini static void glib_pollfds_poll(void)
285c2b38b27SPaolo Bonzini {
286c2b38b27SPaolo Bonzini GMainContext *context = g_main_context_default();
287c2b38b27SPaolo Bonzini GPollFD *pfds = &g_array_index(gpollfds, GPollFD, glib_pollfds_idx);
288c2b38b27SPaolo Bonzini
289c2b38b27SPaolo Bonzini if (g_main_context_check(context, max_priority, pfds, glib_n_poll_fds)) {
290c2b38b27SPaolo Bonzini g_main_context_dispatch(context);
291c2b38b27SPaolo Bonzini }
292c2b38b27SPaolo Bonzini }
293c2b38b27SPaolo Bonzini
294c2b38b27SPaolo Bonzini #define MAX_MAIN_LOOP_SPIN (1000)
295c2b38b27SPaolo Bonzini
os_host_main_loop_wait(int64_t timeout)296c2b38b27SPaolo Bonzini static int os_host_main_loop_wait(int64_t timeout)
297c2b38b27SPaolo Bonzini {
298ecbddbb1SRichard W.M. Jones GMainContext *context = g_main_context_default();
299c2b38b27SPaolo Bonzini int ret;
300c2b38b27SPaolo Bonzini
301ecbddbb1SRichard W.M. Jones g_main_context_acquire(context);
302ecbddbb1SRichard W.M. Jones
303c2b38b27SPaolo Bonzini glib_pollfds_fill(&timeout);
304c2b38b27SPaolo Bonzini
305d759c951SAlex Bennée qemu_mutex_unlock_iothread();
306d759c951SAlex Bennée replay_mutex_unlock();
307c2b38b27SPaolo Bonzini
308c2b38b27SPaolo Bonzini ret = qemu_poll_ns((GPollFD *)gpollfds->data, gpollfds->len, timeout);
309c2b38b27SPaolo Bonzini
310d759c951SAlex Bennée replay_mutex_lock();
311c2b38b27SPaolo Bonzini qemu_mutex_lock_iothread();
312c2b38b27SPaolo Bonzini
313c2b38b27SPaolo Bonzini glib_pollfds_poll();
314ecbddbb1SRichard W.M. Jones
315ecbddbb1SRichard W.M. Jones g_main_context_release(context);
316ecbddbb1SRichard W.M. Jones
317c2b38b27SPaolo Bonzini return ret;
318c2b38b27SPaolo Bonzini }
319c2b38b27SPaolo Bonzini #else
320c2b38b27SPaolo Bonzini /***********************************************************/
321c2b38b27SPaolo Bonzini /* Polling handling */
322c2b38b27SPaolo Bonzini
323c2b38b27SPaolo Bonzini typedef struct PollingEntry {
324c2b38b27SPaolo Bonzini PollingFunc *func;
325c2b38b27SPaolo Bonzini void *opaque;
326c2b38b27SPaolo Bonzini struct PollingEntry *next;
327c2b38b27SPaolo Bonzini } PollingEntry;
328c2b38b27SPaolo Bonzini
329c2b38b27SPaolo Bonzini static PollingEntry *first_polling_entry;
330c2b38b27SPaolo Bonzini
331c2b38b27SPaolo Bonzini int qemu_add_polling_cb(PollingFunc *func, void *opaque)
332c2b38b27SPaolo Bonzini {
333c2b38b27SPaolo Bonzini PollingEntry **ppe, *pe;
334b21e2380SMarkus Armbruster pe = g_new0(PollingEntry, 1);
335c2b38b27SPaolo Bonzini pe->func = func;
336c2b38b27SPaolo Bonzini pe->opaque = opaque;
337c2b38b27SPaolo Bonzini for(ppe = &first_polling_entry; *ppe != NULL; ppe = &(*ppe)->next);
338c2b38b27SPaolo Bonzini *ppe = pe;
339c2b38b27SPaolo Bonzini return 0;
340c2b38b27SPaolo Bonzini }
341c2b38b27SPaolo Bonzini
342c2b38b27SPaolo Bonzini void qemu_del_polling_cb(PollingFunc *func, void *opaque)
343c2b38b27SPaolo Bonzini {
344c2b38b27SPaolo Bonzini PollingEntry **ppe, *pe;
345c2b38b27SPaolo Bonzini for(ppe = &first_polling_entry; *ppe != NULL; ppe = &(*ppe)->next) {
346c2b38b27SPaolo Bonzini pe = *ppe;
347c2b38b27SPaolo Bonzini if (pe->func == func && pe->opaque == opaque) {
348c2b38b27SPaolo Bonzini *ppe = pe->next;
349c2b38b27SPaolo Bonzini g_free(pe);
350c2b38b27SPaolo Bonzini break;
351c2b38b27SPaolo Bonzini }
352c2b38b27SPaolo Bonzini }
353c2b38b27SPaolo Bonzini }
354c2b38b27SPaolo Bonzini
355c2b38b27SPaolo Bonzini /***********************************************************/
356c2b38b27SPaolo Bonzini /* Wait objects support */
357c2b38b27SPaolo Bonzini typedef struct WaitObjects {
358c2b38b27SPaolo Bonzini int num;
3594f76b3d9SBin Meng int revents[MAXIMUM_WAIT_OBJECTS];
3604f76b3d9SBin Meng HANDLE events[MAXIMUM_WAIT_OBJECTS];
3614f76b3d9SBin Meng WaitObjectFunc *func[MAXIMUM_WAIT_OBJECTS];
3624f76b3d9SBin Meng void *opaque[MAXIMUM_WAIT_OBJECTS];
363c2b38b27SPaolo Bonzini } WaitObjects;
364c2b38b27SPaolo Bonzini
365c2b38b27SPaolo Bonzini static WaitObjects wait_objects = {0};
366c2b38b27SPaolo Bonzini
367c2b38b27SPaolo Bonzini int qemu_add_wait_object(HANDLE handle, WaitObjectFunc *func, void *opaque)
368c2b38b27SPaolo Bonzini {
369d393b0a1SBin Meng int i;
370c2b38b27SPaolo Bonzini WaitObjects *w = &wait_objects;
371d393b0a1SBin Meng
372c2b38b27SPaolo Bonzini if (w->num >= MAXIMUM_WAIT_OBJECTS) {
373c2b38b27SPaolo Bonzini return -1;
374c2b38b27SPaolo Bonzini }
375d393b0a1SBin Meng
376d393b0a1SBin Meng for (i = 0; i < w->num; i++) {
377d393b0a1SBin Meng /* check if the same handle is added twice */
378d393b0a1SBin Meng if (w->events[i] == handle) {
379d393b0a1SBin Meng return -1;
380d393b0a1SBin Meng }
381d393b0a1SBin Meng }
382d393b0a1SBin Meng
383c2b38b27SPaolo Bonzini w->events[w->num] = handle;
384c2b38b27SPaolo Bonzini w->func[w->num] = func;
385c2b38b27SPaolo Bonzini w->opaque[w->num] = opaque;
386c2b38b27SPaolo Bonzini w->revents[w->num] = 0;
387c2b38b27SPaolo Bonzini w->num++;
388c2b38b27SPaolo Bonzini return 0;
389c2b38b27SPaolo Bonzini }
390c2b38b27SPaolo Bonzini
391c2b38b27SPaolo Bonzini void qemu_del_wait_object(HANDLE handle, WaitObjectFunc *func, void *opaque)
392c2b38b27SPaolo Bonzini {
393c2b38b27SPaolo Bonzini int i, found;
394c2b38b27SPaolo Bonzini WaitObjects *w = &wait_objects;
395c2b38b27SPaolo Bonzini
396c2b38b27SPaolo Bonzini found = 0;
397c2b38b27SPaolo Bonzini for (i = 0; i < w->num; i++) {
398c2b38b27SPaolo Bonzini if (w->events[i] == handle) {
399c2b38b27SPaolo Bonzini found = 1;
400c2b38b27SPaolo Bonzini }
4014f76b3d9SBin Meng if (found && i < (MAXIMUM_WAIT_OBJECTS - 1)) {
402c2b38b27SPaolo Bonzini w->events[i] = w->events[i + 1];
403c2b38b27SPaolo Bonzini w->func[i] = w->func[i + 1];
404c2b38b27SPaolo Bonzini w->opaque[i] = w->opaque[i + 1];
405c2b38b27SPaolo Bonzini w->revents[i] = w->revents[i + 1];
406c2b38b27SPaolo Bonzini }
407c2b38b27SPaolo Bonzini }
408c2b38b27SPaolo Bonzini if (found) {
409c2b38b27SPaolo Bonzini w->num--;
410c2b38b27SPaolo Bonzini }
411c2b38b27SPaolo Bonzini }
412c2b38b27SPaolo Bonzini
413c2b38b27SPaolo Bonzini static int pollfds_fill(GArray *pollfds, fd_set *rfds, fd_set *wfds,
414c2b38b27SPaolo Bonzini fd_set *xfds)
415c2b38b27SPaolo Bonzini {
416c2b38b27SPaolo Bonzini int nfds = -1;
417c2b38b27SPaolo Bonzini int i;
418c2b38b27SPaolo Bonzini
419c2b38b27SPaolo Bonzini for (i = 0; i < pollfds->len; i++) {
420c2b38b27SPaolo Bonzini GPollFD *pfd = &g_array_index(pollfds, GPollFD, i);
421c2b38b27SPaolo Bonzini int fd = pfd->fd;
422c2b38b27SPaolo Bonzini int events = pfd->events;
423c2b38b27SPaolo Bonzini if (events & G_IO_IN) {
424c2b38b27SPaolo Bonzini FD_SET(fd, rfds);
425c2b38b27SPaolo Bonzini nfds = MAX(nfds, fd);
426c2b38b27SPaolo Bonzini }
427c2b38b27SPaolo Bonzini if (events & G_IO_OUT) {
428c2b38b27SPaolo Bonzini FD_SET(fd, wfds);
429c2b38b27SPaolo Bonzini nfds = MAX(nfds, fd);
430c2b38b27SPaolo Bonzini }
431c2b38b27SPaolo Bonzini if (events & G_IO_PRI) {
432c2b38b27SPaolo Bonzini FD_SET(fd, xfds);
433c2b38b27SPaolo Bonzini nfds = MAX(nfds, fd);
434c2b38b27SPaolo Bonzini }
435c2b38b27SPaolo Bonzini }
436c2b38b27SPaolo Bonzini return nfds;
437c2b38b27SPaolo Bonzini }
438c2b38b27SPaolo Bonzini
439c2b38b27SPaolo Bonzini static void pollfds_poll(GArray *pollfds, int nfds, fd_set *rfds,
440c2b38b27SPaolo Bonzini fd_set *wfds, fd_set *xfds)
441c2b38b27SPaolo Bonzini {
442c2b38b27SPaolo Bonzini int i;
443c2b38b27SPaolo Bonzini
444c2b38b27SPaolo Bonzini for (i = 0; i < pollfds->len; i++) {
445c2b38b27SPaolo Bonzini GPollFD *pfd = &g_array_index(pollfds, GPollFD, i);
446c2b38b27SPaolo Bonzini int fd = pfd->fd;
447c2b38b27SPaolo Bonzini int revents = 0;
448c2b38b27SPaolo Bonzini
449c2b38b27SPaolo Bonzini if (FD_ISSET(fd, rfds)) {
450c2b38b27SPaolo Bonzini revents |= G_IO_IN;
451c2b38b27SPaolo Bonzini }
452c2b38b27SPaolo Bonzini if (FD_ISSET(fd, wfds)) {
453c2b38b27SPaolo Bonzini revents |= G_IO_OUT;
454c2b38b27SPaolo Bonzini }
455c2b38b27SPaolo Bonzini if (FD_ISSET(fd, xfds)) {
456c2b38b27SPaolo Bonzini revents |= G_IO_PRI;
457c2b38b27SPaolo Bonzini }
458c2b38b27SPaolo Bonzini pfd->revents = revents & pfd->events;
459c2b38b27SPaolo Bonzini }
460c2b38b27SPaolo Bonzini }
461c2b38b27SPaolo Bonzini
462c2b38b27SPaolo Bonzini static int os_host_main_loop_wait(int64_t timeout)
463c2b38b27SPaolo Bonzini {
464c2b38b27SPaolo Bonzini GMainContext *context = g_main_context_default();
465c2b38b27SPaolo Bonzini GPollFD poll_fds[1024 * 2]; /* this is probably overkill */
466c2b38b27SPaolo Bonzini int select_ret = 0;
467c2b38b27SPaolo Bonzini int g_poll_ret, ret, i, n_poll_fds;
468c2b38b27SPaolo Bonzini PollingEntry *pe;
469c2b38b27SPaolo Bonzini WaitObjects *w = &wait_objects;
470c2b38b27SPaolo Bonzini gint poll_timeout;
471c2b38b27SPaolo Bonzini int64_t poll_timeout_ns;
472c2b38b27SPaolo Bonzini static struct timeval tv0;
473c2b38b27SPaolo Bonzini fd_set rfds, wfds, xfds;
474c2b38b27SPaolo Bonzini int nfds;
475c2b38b27SPaolo Bonzini
476ecbddbb1SRichard W.M. Jones g_main_context_acquire(context);
477ecbddbb1SRichard W.M. Jones
478c2b38b27SPaolo Bonzini /* XXX: need to suppress polling by better using win32 events */
479c2b38b27SPaolo Bonzini ret = 0;
480c2b38b27SPaolo Bonzini for (pe = first_polling_entry; pe != NULL; pe = pe->next) {
481c2b38b27SPaolo Bonzini ret |= pe->func(pe->opaque);
482c2b38b27SPaolo Bonzini }
483c2b38b27SPaolo Bonzini if (ret != 0) {
484ecbddbb1SRichard W.M. Jones g_main_context_release(context);
485c2b38b27SPaolo Bonzini return ret;
486c2b38b27SPaolo Bonzini }
487c2b38b27SPaolo Bonzini
488c2b38b27SPaolo Bonzini FD_ZERO(&rfds);
489c2b38b27SPaolo Bonzini FD_ZERO(&wfds);
490c2b38b27SPaolo Bonzini FD_ZERO(&xfds);
491c2b38b27SPaolo Bonzini nfds = pollfds_fill(gpollfds, &rfds, &wfds, &xfds);
492c2b38b27SPaolo Bonzini if (nfds >= 0) {
493c2b38b27SPaolo Bonzini select_ret = select(nfds + 1, &rfds, &wfds, &xfds, &tv0);
494c2b38b27SPaolo Bonzini if (select_ret != 0) {
495c2b38b27SPaolo Bonzini timeout = 0;
496c2b38b27SPaolo Bonzini }
497c2b38b27SPaolo Bonzini if (select_ret > 0) {
498c2b38b27SPaolo Bonzini pollfds_poll(gpollfds, nfds, &rfds, &wfds, &xfds);
499c2b38b27SPaolo Bonzini }
500c2b38b27SPaolo Bonzini }
501c2b38b27SPaolo Bonzini
502c2b38b27SPaolo Bonzini g_main_context_prepare(context, &max_priority);
503c2b38b27SPaolo Bonzini n_poll_fds = g_main_context_query(context, max_priority, &poll_timeout,
504c2b38b27SPaolo Bonzini poll_fds, ARRAY_SIZE(poll_fds));
5056512e34bSLidong Chen g_assert(n_poll_fds + w->num <= ARRAY_SIZE(poll_fds));
506c2b38b27SPaolo Bonzini
507c2b38b27SPaolo Bonzini for (i = 0; i < w->num; i++) {
508c2b38b27SPaolo Bonzini poll_fds[n_poll_fds + i].fd = (DWORD_PTR)w->events[i];
509c2b38b27SPaolo Bonzini poll_fds[n_poll_fds + i].events = G_IO_IN;
510c2b38b27SPaolo Bonzini }
511c2b38b27SPaolo Bonzini
512c2b38b27SPaolo Bonzini if (poll_timeout < 0) {
513c2b38b27SPaolo Bonzini poll_timeout_ns = -1;
514c2b38b27SPaolo Bonzini } else {
515c2b38b27SPaolo Bonzini poll_timeout_ns = (int64_t)poll_timeout * (int64_t)SCALE_MS;
516c2b38b27SPaolo Bonzini }
517c2b38b27SPaolo Bonzini
518c2b38b27SPaolo Bonzini poll_timeout_ns = qemu_soonest_timeout(poll_timeout_ns, timeout);
519c2b38b27SPaolo Bonzini
520c2b38b27SPaolo Bonzini qemu_mutex_unlock_iothread();
521d759c951SAlex Bennée
522d759c951SAlex Bennée replay_mutex_unlock();
523d759c951SAlex Bennée
524c2b38b27SPaolo Bonzini g_poll_ret = qemu_poll_ns(poll_fds, n_poll_fds + w->num, poll_timeout_ns);
525c2b38b27SPaolo Bonzini
526d759c951SAlex Bennée replay_mutex_lock();
527d759c951SAlex Bennée
528c2b38b27SPaolo Bonzini qemu_mutex_lock_iothread();
529c2b38b27SPaolo Bonzini if (g_poll_ret > 0) {
530c2b38b27SPaolo Bonzini for (i = 0; i < w->num; i++) {
531c2b38b27SPaolo Bonzini w->revents[i] = poll_fds[n_poll_fds + i].revents;
532c2b38b27SPaolo Bonzini }
533c2b38b27SPaolo Bonzini for (i = 0; i < w->num; i++) {
534c2b38b27SPaolo Bonzini if (w->revents[i] && w->func[i]) {
535c2b38b27SPaolo Bonzini w->func[i](w->opaque[i]);
536c2b38b27SPaolo Bonzini }
537c2b38b27SPaolo Bonzini }
538c2b38b27SPaolo Bonzini }
539c2b38b27SPaolo Bonzini
540c2b38b27SPaolo Bonzini if (g_main_context_check(context, max_priority, poll_fds, n_poll_fds)) {
541c2b38b27SPaolo Bonzini g_main_context_dispatch(context);
542c2b38b27SPaolo Bonzini }
543c2b38b27SPaolo Bonzini
544ecbddbb1SRichard W.M. Jones g_main_context_release(context);
545ecbddbb1SRichard W.M. Jones
546c2b38b27SPaolo Bonzini return select_ret || g_poll_ret;
547c2b38b27SPaolo Bonzini }
548c2b38b27SPaolo Bonzini #endif
549c2b38b27SPaolo Bonzini
5501ab67b98SMarc-André Lureau static NotifierList main_loop_poll_notifiers =
5511ab67b98SMarc-André Lureau NOTIFIER_LIST_INITIALIZER(main_loop_poll_notifiers);
5521ab67b98SMarc-André Lureau
main_loop_poll_add_notifier(Notifier * notify)5531ab67b98SMarc-André Lureau void main_loop_poll_add_notifier(Notifier *notify)
5541ab67b98SMarc-André Lureau {
5551ab67b98SMarc-André Lureau notifier_list_add(&main_loop_poll_notifiers, notify);
5561ab67b98SMarc-André Lureau }
5571ab67b98SMarc-André Lureau
main_loop_poll_remove_notifier(Notifier * notify)5581ab67b98SMarc-André Lureau void main_loop_poll_remove_notifier(Notifier *notify)
5591ab67b98SMarc-André Lureau {
5601ab67b98SMarc-André Lureau notifier_remove(notify);
5611ab67b98SMarc-André Lureau }
5621ab67b98SMarc-André Lureau
main_loop_wait(int nonblocking)563de5f852fSPeter Maydell void main_loop_wait(int nonblocking)
564c2b38b27SPaolo Bonzini {
5651ab67b98SMarc-André Lureau MainLoopPoll mlpoll = {
5661ab67b98SMarc-André Lureau .state = MAIN_LOOP_POLL_FILL,
5671ab67b98SMarc-André Lureau .timeout = UINT32_MAX,
5681ab67b98SMarc-André Lureau .pollfds = gpollfds,
5691ab67b98SMarc-André Lureau };
570c2b38b27SPaolo Bonzini int ret;
571c2b38b27SPaolo Bonzini int64_t timeout_ns;
572c2b38b27SPaolo Bonzini
573c2b38b27SPaolo Bonzini if (nonblocking) {
5741ab67b98SMarc-André Lureau mlpoll.timeout = 0;
575c2b38b27SPaolo Bonzini }
576c2b38b27SPaolo Bonzini
577c2b38b27SPaolo Bonzini /* poll any events */
578c2b38b27SPaolo Bonzini g_array_set_size(gpollfds, 0); /* reset for new iteration */
579c2b38b27SPaolo Bonzini /* XXX: separate device handlers from system ones */
5801ab67b98SMarc-André Lureau notifier_list_notify(&main_loop_poll_notifiers, &mlpoll);
581c2b38b27SPaolo Bonzini
5821ab67b98SMarc-André Lureau if (mlpoll.timeout == UINT32_MAX) {
583c2b38b27SPaolo Bonzini timeout_ns = -1;
584c2b38b27SPaolo Bonzini } else {
5851ab67b98SMarc-André Lureau timeout_ns = (uint64_t)mlpoll.timeout * (int64_t)(SCALE_MS);
586c2b38b27SPaolo Bonzini }
587c2b38b27SPaolo Bonzini
588c2b38b27SPaolo Bonzini timeout_ns = qemu_soonest_timeout(timeout_ns,
589c2b38b27SPaolo Bonzini timerlistgroup_deadline_ns(
590c2b38b27SPaolo Bonzini &main_loop_tlg));
591c2b38b27SPaolo Bonzini
592c2b38b27SPaolo Bonzini ret = os_host_main_loop_wait(timeout_ns);
5931ab67b98SMarc-André Lureau mlpoll.state = ret < 0 ? MAIN_LOOP_POLL_ERR : MAIN_LOOP_POLL_OK;
5941ab67b98SMarc-André Lureau notifier_list_notify(&main_loop_poll_notifiers, &mlpoll);
595c2b38b27SPaolo Bonzini
596740b1759SClaudio Fontana if (icount_enabled()) {
597740b1759SClaudio Fontana /*
598740b1759SClaudio Fontana * CPU thread can infinitely wait for event after
599740b1759SClaudio Fontana * missing the warp
600740b1759SClaudio Fontana */
6018191d368SClaudio Fontana icount_start_warp_timer();
602740b1759SClaudio Fontana }
603c2b38b27SPaolo Bonzini qemu_clock_run_all_timers();
604c2b38b27SPaolo Bonzini }
605c2b38b27SPaolo Bonzini
606c2b38b27SPaolo Bonzini /* Functions to operate on the main QEMU AioContext. */
607c2b38b27SPaolo Bonzini
qemu_bh_new_full(QEMUBHFunc * cb,void * opaque,const char * name,MemReentrancyGuard * reentrancy_guard)6089c86c97fSAlexander Bulekov QEMUBH *qemu_bh_new_full(QEMUBHFunc *cb, void *opaque, const char *name,
6099c86c97fSAlexander Bulekov MemReentrancyGuard *reentrancy_guard)
610c2b38b27SPaolo Bonzini {
6119c86c97fSAlexander Bulekov return aio_bh_new_full(qemu_aio_context, cb, opaque, name,
6129c86c97fSAlexander Bulekov reentrancy_guard);
613c2b38b27SPaolo Bonzini }
614e9ed92bdSPaolo Bonzini
615e9ed92bdSPaolo Bonzini /*
616e9ed92bdSPaolo Bonzini * Functions to operate on the I/O handler AioContext.
617e9ed92bdSPaolo Bonzini * This context runs on top of main loop. We can't reuse qemu_aio_context
618e9ed92bdSPaolo Bonzini * because iohandlers mustn't be polled by aio_poll(qemu_aio_context).
619e9ed92bdSPaolo Bonzini */
620e9ed92bdSPaolo Bonzini static AioContext *iohandler_ctx;
621e9ed92bdSPaolo Bonzini
iohandler_init(void)622e9ed92bdSPaolo Bonzini static void iohandler_init(void)
623e9ed92bdSPaolo Bonzini {
624e9ed92bdSPaolo Bonzini if (!iohandler_ctx) {
625e9ed92bdSPaolo Bonzini iohandler_ctx = aio_context_new(&error_abort);
626e9ed92bdSPaolo Bonzini }
627e9ed92bdSPaolo Bonzini }
628e9ed92bdSPaolo Bonzini
iohandler_get_aio_context(void)629e9ed92bdSPaolo Bonzini AioContext *iohandler_get_aio_context(void)
630e9ed92bdSPaolo Bonzini {
631e9ed92bdSPaolo Bonzini iohandler_init();
632e9ed92bdSPaolo Bonzini return iohandler_ctx;
633e9ed92bdSPaolo Bonzini }
634e9ed92bdSPaolo Bonzini
iohandler_get_g_source(void)635e9ed92bdSPaolo Bonzini GSource *iohandler_get_g_source(void)
636e9ed92bdSPaolo Bonzini {
637e9ed92bdSPaolo Bonzini iohandler_init();
638e9ed92bdSPaolo Bonzini return aio_get_g_source(iohandler_ctx);
639e9ed92bdSPaolo Bonzini }
640e9ed92bdSPaolo Bonzini
qemu_set_fd_handler(int fd,IOHandler * fd_read,IOHandler * fd_write,void * opaque)641e9ed92bdSPaolo Bonzini void qemu_set_fd_handler(int fd,
642e9ed92bdSPaolo Bonzini IOHandler *fd_read,
643e9ed92bdSPaolo Bonzini IOHandler *fd_write,
644e9ed92bdSPaolo Bonzini void *opaque)
645e9ed92bdSPaolo Bonzini {
646e9ed92bdSPaolo Bonzini iohandler_init();
64760f782b6SStefan Hajnoczi aio_set_fd_handler(iohandler_ctx, fd, fd_read, fd_write, NULL, NULL,
64860f782b6SStefan Hajnoczi opaque);
649e9ed92bdSPaolo Bonzini }
650e9ed92bdSPaolo Bonzini
event_notifier_set_handler(EventNotifier * e,EventNotifierHandler * handler)651e9ed92bdSPaolo Bonzini void event_notifier_set_handler(EventNotifier *e,
652e9ed92bdSPaolo Bonzini EventNotifierHandler *handler)
653e9ed92bdSPaolo Bonzini {
654e9ed92bdSPaolo Bonzini iohandler_init();
65560f782b6SStefan Hajnoczi aio_set_event_notifier(iohandler_ctx, e, handler, NULL, NULL);
656e9ed92bdSPaolo Bonzini }
657