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 20 #define TYPE_IOTHREAD "iothread" 21 22 typedef struct { 23 Object parent_obj; 24 25 QemuThread thread; 26 AioContext *ctx; 27 GMainContext *worker_context; 28 GMainLoop *main_loop; 29 GOnce once; 30 QemuMutex init_done_lock; 31 QemuCond init_done_cond; /* is thread initialization done? */ 32 bool stopping; 33 int thread_id; 34 35 /* AioContext poll parameters */ 36 int64_t poll_max_ns; 37 int64_t poll_grow; 38 int64_t poll_shrink; 39 } IOThread; 40 41 #define IOTHREAD(obj) \ 42 OBJECT_CHECK(IOThread, obj, TYPE_IOTHREAD) 43 44 char *iothread_get_id(IOThread *iothread); 45 AioContext *iothread_get_aio_context(IOThread *iothread); 46 void iothread_stop_all(void); 47 GMainContext *iothread_get_g_main_context(IOThread *iothread); 48 49 /* 50 * Helpers used to allocate iothreads for internal use. These 51 * iothreads will not be seen by monitor clients when query using 52 * "query-iothreads". 53 */ 54 IOThread *iothread_create(const char *id, Error **errp); 55 void iothread_stop(IOThread *iothread); 56 void iothread_destroy(IOThread *iothread); 57 58 #endif /* IOTHREAD_H */ 59