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