1be8d8537SStefan Hajnoczi /* 2be8d8537SStefan Hajnoczi * Event loop thread 3be8d8537SStefan Hajnoczi * 4be8d8537SStefan Hajnoczi * Copyright Red Hat Inc., 2013 5be8d8537SStefan Hajnoczi * 6be8d8537SStefan Hajnoczi * Authors: 7be8d8537SStefan Hajnoczi * Stefan Hajnoczi <stefanha@redhat.com> 8be8d8537SStefan Hajnoczi * 9be8d8537SStefan Hajnoczi * This work is licensed under the terms of the GNU GPL, version 2 or later. 10be8d8537SStefan Hajnoczi * See the COPYING file in the top-level directory. 11be8d8537SStefan Hajnoczi * 12be8d8537SStefan Hajnoczi */ 13be8d8537SStefan Hajnoczi 14be8d8537SStefan Hajnoczi #include "qom/object.h" 15be8d8537SStefan Hajnoczi #include "qom/object_interfaces.h" 16be8d8537SStefan Hajnoczi #include "qemu/module.h" 17be8d8537SStefan Hajnoczi #include "qemu/thread.h" 18be8d8537SStefan Hajnoczi #include "block/aio.h" 19be8d8537SStefan Hajnoczi #include "sysemu/iothread.h" 20*dc3dd0d2SStefan Hajnoczi #include "qmp-commands.h" 21be8d8537SStefan Hajnoczi 22be8d8537SStefan Hajnoczi #define IOTHREADS_PATH "/objects" 23be8d8537SStefan Hajnoczi 24be8d8537SStefan Hajnoczi typedef ObjectClass IOThreadClass; 25be8d8537SStefan Hajnoczi struct IOThread { 26be8d8537SStefan Hajnoczi Object parent_obj; 27be8d8537SStefan Hajnoczi 28be8d8537SStefan Hajnoczi QemuThread thread; 29be8d8537SStefan Hajnoczi AioContext *ctx; 3088eb7c29SStefan Hajnoczi QemuMutex init_done_lock; 3188eb7c29SStefan Hajnoczi QemuCond init_done_cond; /* is thread initialization done? */ 32be8d8537SStefan Hajnoczi bool stopping; 3388eb7c29SStefan Hajnoczi int thread_id; 34be8d8537SStefan Hajnoczi }; 35be8d8537SStefan Hajnoczi 36be8d8537SStefan Hajnoczi #define IOTHREAD_GET_CLASS(obj) \ 37be8d8537SStefan Hajnoczi OBJECT_GET_CLASS(IOThreadClass, obj, TYPE_IOTHREAD) 38be8d8537SStefan Hajnoczi #define IOTHREAD_CLASS(klass) \ 39be8d8537SStefan Hajnoczi OBJECT_CLASS_CHECK(IOThreadClass, klass, TYPE_IOTHREAD) 40be8d8537SStefan Hajnoczi 41be8d8537SStefan Hajnoczi static void *iothread_run(void *opaque) 42be8d8537SStefan Hajnoczi { 43be8d8537SStefan Hajnoczi IOThread *iothread = opaque; 44be8d8537SStefan Hajnoczi 4588eb7c29SStefan Hajnoczi qemu_mutex_lock(&iothread->init_done_lock); 4688eb7c29SStefan Hajnoczi iothread->thread_id = qemu_get_thread_id(); 4788eb7c29SStefan Hajnoczi qemu_cond_signal(&iothread->init_done_cond); 4888eb7c29SStefan Hajnoczi qemu_mutex_unlock(&iothread->init_done_lock); 4988eb7c29SStefan Hajnoczi 50be8d8537SStefan Hajnoczi while (!iothread->stopping) { 51be8d8537SStefan Hajnoczi aio_context_acquire(iothread->ctx); 52be8d8537SStefan Hajnoczi while (!iothread->stopping && aio_poll(iothread->ctx, true)) { 53be8d8537SStefan Hajnoczi /* Progress was made, keep going */ 54be8d8537SStefan Hajnoczi } 55be8d8537SStefan Hajnoczi aio_context_release(iothread->ctx); 56be8d8537SStefan Hajnoczi } 57be8d8537SStefan Hajnoczi return NULL; 58be8d8537SStefan Hajnoczi } 59be8d8537SStefan Hajnoczi 60be8d8537SStefan Hajnoczi static void iothread_instance_finalize(Object *obj) 61be8d8537SStefan Hajnoczi { 62be8d8537SStefan Hajnoczi IOThread *iothread = IOTHREAD(obj); 63be8d8537SStefan Hajnoczi 64be8d8537SStefan Hajnoczi iothread->stopping = true; 65be8d8537SStefan Hajnoczi aio_notify(iothread->ctx); 66be8d8537SStefan Hajnoczi qemu_thread_join(&iothread->thread); 6788eb7c29SStefan Hajnoczi qemu_cond_destroy(&iothread->init_done_cond); 6888eb7c29SStefan Hajnoczi qemu_mutex_destroy(&iothread->init_done_lock); 69be8d8537SStefan Hajnoczi aio_context_unref(iothread->ctx); 70be8d8537SStefan Hajnoczi } 71be8d8537SStefan Hajnoczi 72be8d8537SStefan Hajnoczi static void iothread_complete(UserCreatable *obj, Error **errp) 73be8d8537SStefan Hajnoczi { 74be8d8537SStefan Hajnoczi IOThread *iothread = IOTHREAD(obj); 75be8d8537SStefan Hajnoczi 76be8d8537SStefan Hajnoczi iothread->stopping = false; 77be8d8537SStefan Hajnoczi iothread->ctx = aio_context_new(); 7888eb7c29SStefan Hajnoczi iothread->thread_id = -1; 7988eb7c29SStefan Hajnoczi 8088eb7c29SStefan Hajnoczi qemu_mutex_init(&iothread->init_done_lock); 8188eb7c29SStefan Hajnoczi qemu_cond_init(&iothread->init_done_cond); 82be8d8537SStefan Hajnoczi 83be8d8537SStefan Hajnoczi /* This assumes we are called from a thread with useful CPU affinity for us 84be8d8537SStefan Hajnoczi * to inherit. 85be8d8537SStefan Hajnoczi */ 86be8d8537SStefan Hajnoczi qemu_thread_create(&iothread->thread, "iothread", iothread_run, 87be8d8537SStefan Hajnoczi iothread, QEMU_THREAD_JOINABLE); 8888eb7c29SStefan Hajnoczi 8988eb7c29SStefan Hajnoczi /* Wait for initialization to complete */ 9088eb7c29SStefan Hajnoczi qemu_mutex_lock(&iothread->init_done_lock); 9188eb7c29SStefan Hajnoczi while (iothread->thread_id == -1) { 9288eb7c29SStefan Hajnoczi qemu_cond_wait(&iothread->init_done_cond, 9388eb7c29SStefan Hajnoczi &iothread->init_done_lock); 9488eb7c29SStefan Hajnoczi } 9588eb7c29SStefan Hajnoczi qemu_mutex_unlock(&iothread->init_done_lock); 96be8d8537SStefan Hajnoczi } 97be8d8537SStefan Hajnoczi 98be8d8537SStefan Hajnoczi static void iothread_class_init(ObjectClass *klass, void *class_data) 99be8d8537SStefan Hajnoczi { 100be8d8537SStefan Hajnoczi UserCreatableClass *ucc = USER_CREATABLE_CLASS(klass); 101be8d8537SStefan Hajnoczi ucc->complete = iothread_complete; 102be8d8537SStefan Hajnoczi } 103be8d8537SStefan Hajnoczi 104be8d8537SStefan Hajnoczi static const TypeInfo iothread_info = { 105be8d8537SStefan Hajnoczi .name = TYPE_IOTHREAD, 106be8d8537SStefan Hajnoczi .parent = TYPE_OBJECT, 107be8d8537SStefan Hajnoczi .class_init = iothread_class_init, 108be8d8537SStefan Hajnoczi .instance_size = sizeof(IOThread), 109be8d8537SStefan Hajnoczi .instance_finalize = iothread_instance_finalize, 110be8d8537SStefan Hajnoczi .interfaces = (InterfaceInfo[]) { 111be8d8537SStefan Hajnoczi {TYPE_USER_CREATABLE}, 112be8d8537SStefan Hajnoczi {} 113be8d8537SStefan Hajnoczi }, 114be8d8537SStefan Hajnoczi }; 115be8d8537SStefan Hajnoczi 116be8d8537SStefan Hajnoczi static void iothread_register_types(void) 117be8d8537SStefan Hajnoczi { 118be8d8537SStefan Hajnoczi type_register_static(&iothread_info); 119be8d8537SStefan Hajnoczi } 120be8d8537SStefan Hajnoczi 121be8d8537SStefan Hajnoczi type_init(iothread_register_types) 122be8d8537SStefan Hajnoczi 123be8d8537SStefan Hajnoczi IOThread *iothread_find(const char *id) 124be8d8537SStefan Hajnoczi { 125be8d8537SStefan Hajnoczi Object *container = container_get(object_get_root(), IOTHREADS_PATH); 126be8d8537SStefan Hajnoczi Object *child; 127be8d8537SStefan Hajnoczi 128be8d8537SStefan Hajnoczi child = object_property_get_link(container, id, NULL); 129be8d8537SStefan Hajnoczi if (!child) { 130be8d8537SStefan Hajnoczi return NULL; 131be8d8537SStefan Hajnoczi } 132be8d8537SStefan Hajnoczi return (IOThread *)object_dynamic_cast(child, TYPE_IOTHREAD); 133be8d8537SStefan Hajnoczi } 134be8d8537SStefan Hajnoczi 135be8d8537SStefan Hajnoczi char *iothread_get_id(IOThread *iothread) 136be8d8537SStefan Hajnoczi { 137be8d8537SStefan Hajnoczi return object_get_canonical_path_component(OBJECT(iothread)); 138be8d8537SStefan Hajnoczi } 139be8d8537SStefan Hajnoczi 140be8d8537SStefan Hajnoczi AioContext *iothread_get_aio_context(IOThread *iothread) 141be8d8537SStefan Hajnoczi { 142be8d8537SStefan Hajnoczi return iothread->ctx; 143be8d8537SStefan Hajnoczi } 144*dc3dd0d2SStefan Hajnoczi 145*dc3dd0d2SStefan Hajnoczi static int query_one_iothread(Object *object, void *opaque) 146*dc3dd0d2SStefan Hajnoczi { 147*dc3dd0d2SStefan Hajnoczi IOThreadInfoList ***prev = opaque; 148*dc3dd0d2SStefan Hajnoczi IOThreadInfoList *elem; 149*dc3dd0d2SStefan Hajnoczi IOThreadInfo *info; 150*dc3dd0d2SStefan Hajnoczi IOThread *iothread; 151*dc3dd0d2SStefan Hajnoczi 152*dc3dd0d2SStefan Hajnoczi iothread = (IOThread *)object_dynamic_cast(object, TYPE_IOTHREAD); 153*dc3dd0d2SStefan Hajnoczi if (!iothread) { 154*dc3dd0d2SStefan Hajnoczi return 0; 155*dc3dd0d2SStefan Hajnoczi } 156*dc3dd0d2SStefan Hajnoczi 157*dc3dd0d2SStefan Hajnoczi info = g_new0(IOThreadInfo, 1); 158*dc3dd0d2SStefan Hajnoczi info->id = iothread_get_id(iothread); 159*dc3dd0d2SStefan Hajnoczi info->thread_id = iothread->thread_id; 160*dc3dd0d2SStefan Hajnoczi 161*dc3dd0d2SStefan Hajnoczi elem = g_new0(IOThreadInfoList, 1); 162*dc3dd0d2SStefan Hajnoczi elem->value = info; 163*dc3dd0d2SStefan Hajnoczi elem->next = NULL; 164*dc3dd0d2SStefan Hajnoczi 165*dc3dd0d2SStefan Hajnoczi **prev = elem; 166*dc3dd0d2SStefan Hajnoczi *prev = &elem->next; 167*dc3dd0d2SStefan Hajnoczi return 0; 168*dc3dd0d2SStefan Hajnoczi } 169*dc3dd0d2SStefan Hajnoczi 170*dc3dd0d2SStefan Hajnoczi IOThreadInfoList *qmp_query_iothreads(Error **errp) 171*dc3dd0d2SStefan Hajnoczi { 172*dc3dd0d2SStefan Hajnoczi IOThreadInfoList *head = NULL; 173*dc3dd0d2SStefan Hajnoczi IOThreadInfoList **prev = &head; 174*dc3dd0d2SStefan Hajnoczi Object *container = container_get(object_get_root(), IOTHREADS_PATH); 175*dc3dd0d2SStefan Hajnoczi 176*dc3dd0d2SStefan Hajnoczi object_child_foreach(container, query_one_iothread, &prev); 177*dc3dd0d2SStefan Hajnoczi return head; 178*dc3dd0d2SStefan Hajnoczi } 179