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 23 struct IOThread { 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 41 /* AioContext AIO engine parameters */ 42 int64_t aio_max_batch; 43 }; 44 typedef struct IOThread IOThread; 45 46 DECLARE_INSTANCE_CHECKER(IOThread, IOTHREAD, 47 TYPE_IOTHREAD) 48 49 char *iothread_get_id(IOThread *iothread); 50 IOThread *iothread_by_id(const char *id); 51 AioContext *iothread_get_aio_context(IOThread *iothread); 52 GMainContext *iothread_get_g_main_context(IOThread *iothread); 53 54 /* 55 * Helpers used to allocate iothreads for internal use. These 56 * iothreads will not be seen by monitor clients when query using 57 * "query-iothreads". 58 */ 59 IOThread *iothread_create(const char *id, Error **errp); 60 void iothread_stop(IOThread *iothread); 61 void iothread_destroy(IOThread *iothread); 62 63 /* 64 * Returns true if executing withing IOThread context, 65 * false otherwise. 66 */ 67 bool qemu_in_iothread(void); 68 69 #endif /* IOTHREAD_H */ 70