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 "block/aio.h" 18be8d8537SStefan Hajnoczi #include "sysemu/iothread.h" 19dc3dd0d2SStefan Hajnoczi #include "qmp-commands.h" 20*2f78e491SChrysostomos Nanakos #include "qemu/error-report.h" 21be8d8537SStefan Hajnoczi 22be8d8537SStefan Hajnoczi #define IOTHREADS_PATH "/objects" 23be8d8537SStefan Hajnoczi 24be8d8537SStefan Hajnoczi typedef ObjectClass IOThreadClass; 25be8d8537SStefan Hajnoczi 26be8d8537SStefan Hajnoczi #define IOTHREAD_GET_CLASS(obj) \ 27be8d8537SStefan Hajnoczi OBJECT_GET_CLASS(IOThreadClass, obj, TYPE_IOTHREAD) 28be8d8537SStefan Hajnoczi #define IOTHREAD_CLASS(klass) \ 29be8d8537SStefan Hajnoczi OBJECT_CLASS_CHECK(IOThreadClass, klass, TYPE_IOTHREAD) 30be8d8537SStefan Hajnoczi 31be8d8537SStefan Hajnoczi static void *iothread_run(void *opaque) 32be8d8537SStefan Hajnoczi { 33be8d8537SStefan Hajnoczi IOThread *iothread = opaque; 34acfb23adSPaolo Bonzini bool blocking; 35be8d8537SStefan Hajnoczi 3688eb7c29SStefan Hajnoczi qemu_mutex_lock(&iothread->init_done_lock); 3788eb7c29SStefan Hajnoczi iothread->thread_id = qemu_get_thread_id(); 3888eb7c29SStefan Hajnoczi qemu_cond_signal(&iothread->init_done_cond); 3988eb7c29SStefan Hajnoczi qemu_mutex_unlock(&iothread->init_done_lock); 4088eb7c29SStefan Hajnoczi 41be8d8537SStefan Hajnoczi while (!iothread->stopping) { 42be8d8537SStefan Hajnoczi aio_context_acquire(iothread->ctx); 43acfb23adSPaolo Bonzini blocking = true; 44acfb23adSPaolo Bonzini while (!iothread->stopping && aio_poll(iothread->ctx, blocking)) { 45be8d8537SStefan Hajnoczi /* Progress was made, keep going */ 46acfb23adSPaolo Bonzini blocking = false; 47be8d8537SStefan Hajnoczi } 48be8d8537SStefan Hajnoczi aio_context_release(iothread->ctx); 49be8d8537SStefan Hajnoczi } 50be8d8537SStefan Hajnoczi return NULL; 51be8d8537SStefan Hajnoczi } 52be8d8537SStefan Hajnoczi 53be8d8537SStefan Hajnoczi static void iothread_instance_finalize(Object *obj) 54be8d8537SStefan Hajnoczi { 55be8d8537SStefan Hajnoczi IOThread *iothread = IOTHREAD(obj); 56be8d8537SStefan Hajnoczi 57*2f78e491SChrysostomos Nanakos if (!iothread->ctx) { 58*2f78e491SChrysostomos Nanakos return; 59*2f78e491SChrysostomos Nanakos } 60be8d8537SStefan Hajnoczi iothread->stopping = true; 61be8d8537SStefan Hajnoczi aio_notify(iothread->ctx); 62be8d8537SStefan Hajnoczi qemu_thread_join(&iothread->thread); 6388eb7c29SStefan Hajnoczi qemu_cond_destroy(&iothread->init_done_cond); 6488eb7c29SStefan Hajnoczi qemu_mutex_destroy(&iothread->init_done_lock); 65be8d8537SStefan Hajnoczi aio_context_unref(iothread->ctx); 66be8d8537SStefan Hajnoczi } 67be8d8537SStefan Hajnoczi 68be8d8537SStefan Hajnoczi static void iothread_complete(UserCreatable *obj, Error **errp) 69be8d8537SStefan Hajnoczi { 70*2f78e491SChrysostomos Nanakos Error *local_error = NULL; 71be8d8537SStefan Hajnoczi IOThread *iothread = IOTHREAD(obj); 72be8d8537SStefan Hajnoczi 73be8d8537SStefan Hajnoczi iothread->stopping = false; 7488eb7c29SStefan Hajnoczi iothread->thread_id = -1; 75*2f78e491SChrysostomos Nanakos iothread->ctx = aio_context_new(&local_error); 76*2f78e491SChrysostomos Nanakos if (!iothread->ctx) { 77*2f78e491SChrysostomos Nanakos error_propagate(errp, local_error); 78*2f78e491SChrysostomos Nanakos return; 79*2f78e491SChrysostomos Nanakos } 8088eb7c29SStefan Hajnoczi 8188eb7c29SStefan Hajnoczi qemu_mutex_init(&iothread->init_done_lock); 8288eb7c29SStefan Hajnoczi qemu_cond_init(&iothread->init_done_cond); 83be8d8537SStefan Hajnoczi 84be8d8537SStefan Hajnoczi /* This assumes we are called from a thread with useful CPU affinity for us 85be8d8537SStefan Hajnoczi * to inherit. 86be8d8537SStefan Hajnoczi */ 87be8d8537SStefan Hajnoczi qemu_thread_create(&iothread->thread, "iothread", iothread_run, 88be8d8537SStefan Hajnoczi iothread, QEMU_THREAD_JOINABLE); 8988eb7c29SStefan Hajnoczi 9088eb7c29SStefan Hajnoczi /* Wait for initialization to complete */ 9188eb7c29SStefan Hajnoczi qemu_mutex_lock(&iothread->init_done_lock); 9288eb7c29SStefan Hajnoczi while (iothread->thread_id == -1) { 9388eb7c29SStefan Hajnoczi qemu_cond_wait(&iothread->init_done_cond, 9488eb7c29SStefan Hajnoczi &iothread->init_done_lock); 9588eb7c29SStefan Hajnoczi } 9688eb7c29SStefan Hajnoczi qemu_mutex_unlock(&iothread->init_done_lock); 97be8d8537SStefan Hajnoczi } 98be8d8537SStefan Hajnoczi 99be8d8537SStefan Hajnoczi static void iothread_class_init(ObjectClass *klass, void *class_data) 100be8d8537SStefan Hajnoczi { 101be8d8537SStefan Hajnoczi UserCreatableClass *ucc = USER_CREATABLE_CLASS(klass); 102be8d8537SStefan Hajnoczi ucc->complete = iothread_complete; 103be8d8537SStefan Hajnoczi } 104be8d8537SStefan Hajnoczi 105be8d8537SStefan Hajnoczi static const TypeInfo iothread_info = { 106be8d8537SStefan Hajnoczi .name = TYPE_IOTHREAD, 107be8d8537SStefan Hajnoczi .parent = TYPE_OBJECT, 108be8d8537SStefan Hajnoczi .class_init = iothread_class_init, 109be8d8537SStefan Hajnoczi .instance_size = sizeof(IOThread), 110be8d8537SStefan Hajnoczi .instance_finalize = iothread_instance_finalize, 111be8d8537SStefan Hajnoczi .interfaces = (InterfaceInfo[]) { 112be8d8537SStefan Hajnoczi {TYPE_USER_CREATABLE}, 113be8d8537SStefan Hajnoczi {} 114be8d8537SStefan Hajnoczi }, 115be8d8537SStefan Hajnoczi }; 116be8d8537SStefan Hajnoczi 117be8d8537SStefan Hajnoczi static void iothread_register_types(void) 118be8d8537SStefan Hajnoczi { 119be8d8537SStefan Hajnoczi type_register_static(&iothread_info); 120be8d8537SStefan Hajnoczi } 121be8d8537SStefan Hajnoczi 122be8d8537SStefan Hajnoczi type_init(iothread_register_types) 123be8d8537SStefan Hajnoczi 124be8d8537SStefan Hajnoczi IOThread *iothread_find(const char *id) 125be8d8537SStefan Hajnoczi { 126be8d8537SStefan Hajnoczi Object *container = container_get(object_get_root(), IOTHREADS_PATH); 127be8d8537SStefan Hajnoczi Object *child; 128be8d8537SStefan Hajnoczi 129be8d8537SStefan Hajnoczi child = object_property_get_link(container, id, NULL); 130be8d8537SStefan Hajnoczi if (!child) { 131be8d8537SStefan Hajnoczi return NULL; 132be8d8537SStefan Hajnoczi } 133be8d8537SStefan Hajnoczi return (IOThread *)object_dynamic_cast(child, TYPE_IOTHREAD); 134be8d8537SStefan Hajnoczi } 135be8d8537SStefan Hajnoczi 136be8d8537SStefan Hajnoczi char *iothread_get_id(IOThread *iothread) 137be8d8537SStefan Hajnoczi { 138be8d8537SStefan Hajnoczi return object_get_canonical_path_component(OBJECT(iothread)); 139be8d8537SStefan Hajnoczi } 140be8d8537SStefan Hajnoczi 141be8d8537SStefan Hajnoczi AioContext *iothread_get_aio_context(IOThread *iothread) 142be8d8537SStefan Hajnoczi { 143be8d8537SStefan Hajnoczi return iothread->ctx; 144be8d8537SStefan Hajnoczi } 145dc3dd0d2SStefan Hajnoczi 146dc3dd0d2SStefan Hajnoczi static int query_one_iothread(Object *object, void *opaque) 147dc3dd0d2SStefan Hajnoczi { 148dc3dd0d2SStefan Hajnoczi IOThreadInfoList ***prev = opaque; 149dc3dd0d2SStefan Hajnoczi IOThreadInfoList *elem; 150dc3dd0d2SStefan Hajnoczi IOThreadInfo *info; 151dc3dd0d2SStefan Hajnoczi IOThread *iothread; 152dc3dd0d2SStefan Hajnoczi 153dc3dd0d2SStefan Hajnoczi iothread = (IOThread *)object_dynamic_cast(object, TYPE_IOTHREAD); 154dc3dd0d2SStefan Hajnoczi if (!iothread) { 155dc3dd0d2SStefan Hajnoczi return 0; 156dc3dd0d2SStefan Hajnoczi } 157dc3dd0d2SStefan Hajnoczi 158dc3dd0d2SStefan Hajnoczi info = g_new0(IOThreadInfo, 1); 159dc3dd0d2SStefan Hajnoczi info->id = iothread_get_id(iothread); 160dc3dd0d2SStefan Hajnoczi info->thread_id = iothread->thread_id; 161dc3dd0d2SStefan Hajnoczi 162dc3dd0d2SStefan Hajnoczi elem = g_new0(IOThreadInfoList, 1); 163dc3dd0d2SStefan Hajnoczi elem->value = info; 164dc3dd0d2SStefan Hajnoczi elem->next = NULL; 165dc3dd0d2SStefan Hajnoczi 166dc3dd0d2SStefan Hajnoczi **prev = elem; 167dc3dd0d2SStefan Hajnoczi *prev = &elem->next; 168dc3dd0d2SStefan Hajnoczi return 0; 169dc3dd0d2SStefan Hajnoczi } 170dc3dd0d2SStefan Hajnoczi 171dc3dd0d2SStefan Hajnoczi IOThreadInfoList *qmp_query_iothreads(Error **errp) 172dc3dd0d2SStefan Hajnoczi { 173dc3dd0d2SStefan Hajnoczi IOThreadInfoList *head = NULL; 174dc3dd0d2SStefan Hajnoczi IOThreadInfoList **prev = &head; 175dc3dd0d2SStefan Hajnoczi Object *container = container_get(object_get_root(), IOTHREADS_PATH); 176dc3dd0d2SStefan Hajnoczi 177dc3dd0d2SStefan Hajnoczi object_child_foreach(container, query_one_iothread, &prev); 178dc3dd0d2SStefan Hajnoczi return head; 179dc3dd0d2SStefan Hajnoczi } 180