1/*
2 * Event loop thread
3 *
4 * Copyright Red Hat Inc., 2013
5 *
6 * Authors:
7 * Stefan Hajnoczi <stefanha@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
14#ifndef IOTHREAD_H
15#define IOTHREAD_H
16
17#include "block/aio.h"
18#include "qemu/thread.h"
19#include "qom/object.h"
20
21#define TYPE_IOTHREAD "iothread"
22
23typedef struct {
24 Object parent_obj;
25
26 QemuThread thread;
27 AioContext *ctx;
28 bool run_gcontext; /* whether we should run gcontext */
29 GMainContext *worker_context;
30 GMainLoop *main_loop;
31 QemuSemaphore init_done_sem; /* is thread init done? */
32 bool stopping; /* has iothread_stop() been called? */
33 bool running; /* should iothread_run() continue? */
34 int thread_id;
35
36 /* AioContext poll parameters */
37 int64_t poll_max_ns;
38 int64_t poll_grow;
39 int64_t poll_shrink;
40} IOThread;
41
42#define IOTHREAD(obj) \
43 OBJECT_CHECK(IOThread, obj, TYPE_IOTHREAD)
44
45char *iothread_get_id(IOThread *iothread);
46IOThread *iothread_by_id(const char *id);
47AioContext *iothread_get_aio_context(IOThread *iothread);
48GMainContext *iothread_get_g_main_context(IOThread *iothread);
49
50/*
51 * Helpers used to allocate iothreads for internal use. These
52 * iothreads will not be seen by monitor clients when query using
53 * "query-iothreads".
54 */
55IOThread *iothread_create(const char *id, Error **errp);
56void iothread_stop(IOThread *iothread);
57void iothread_destroy(IOThread *iothread);
58
59#endif /* IOTHREAD_H */
60