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 14d38ea87aSPeter Maydell #include "qemu/osdep.h" 15be8d8537SStefan Hajnoczi #include "qom/object.h" 16be8d8537SStefan Hajnoczi #include "qom/object_interfaces.h" 17be8d8537SStefan Hajnoczi #include "qemu/module.h" 18be8d8537SStefan Hajnoczi #include "block/aio.h" 19be8d8537SStefan Hajnoczi #include "sysemu/iothread.h" 20dc3dd0d2SStefan Hajnoczi #include "qmp-commands.h" 212f78e491SChrysostomos Nanakos #include "qemu/error-report.h" 22ab28bd23SPaolo Bonzini #include "qemu/rcu.h" 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; 34da5e1de9SStefan Hajnoczi bool blocking; 35be8d8537SStefan Hajnoczi 36ab28bd23SPaolo Bonzini rcu_register_thread(); 37ab28bd23SPaolo Bonzini 3888eb7c29SStefan Hajnoczi qemu_mutex_lock(&iothread->init_done_lock); 3988eb7c29SStefan Hajnoczi iothread->thread_id = qemu_get_thread_id(); 4088eb7c29SStefan Hajnoczi qemu_cond_signal(&iothread->init_done_cond); 4188eb7c29SStefan Hajnoczi qemu_mutex_unlock(&iothread->init_done_lock); 4288eb7c29SStefan Hajnoczi 43da5e1de9SStefan Hajnoczi while (!iothread->stopping) { 44da5e1de9SStefan Hajnoczi aio_context_acquire(iothread->ctx); 45da5e1de9SStefan Hajnoczi blocking = true; 46da5e1de9SStefan Hajnoczi while (!iothread->stopping && aio_poll(iothread->ctx, blocking)) { 47da5e1de9SStefan Hajnoczi /* Progress was made, keep going */ 48da5e1de9SStefan Hajnoczi blocking = false; 49da5e1de9SStefan Hajnoczi } 50da5e1de9SStefan Hajnoczi aio_context_release(iothread->ctx); 51be8d8537SStefan Hajnoczi } 52ab28bd23SPaolo Bonzini 53ab28bd23SPaolo Bonzini rcu_unregister_thread(); 54be8d8537SStefan Hajnoczi return NULL; 55be8d8537SStefan Hajnoczi } 56be8d8537SStefan Hajnoczi 57*dce8921bSFam Zheng static int iothread_stop(Object *object, void *opaque) 58be8d8537SStefan Hajnoczi { 59*dce8921bSFam Zheng IOThread *iothread; 60be8d8537SStefan Hajnoczi 61*dce8921bSFam Zheng iothread = (IOThread *)object_dynamic_cast(object, TYPE_IOTHREAD); 62*dce8921bSFam Zheng if (!iothread || !iothread->ctx) { 63*dce8921bSFam Zheng return 0; 642f78e491SChrysostomos Nanakos } 65be8d8537SStefan Hajnoczi iothread->stopping = true; 66be8d8537SStefan Hajnoczi aio_notify(iothread->ctx); 67be8d8537SStefan Hajnoczi qemu_thread_join(&iothread->thread); 68*dce8921bSFam Zheng return 0; 69*dce8921bSFam Zheng } 70*dce8921bSFam Zheng 71*dce8921bSFam Zheng static void iothread_instance_finalize(Object *obj) 72*dce8921bSFam Zheng { 73*dce8921bSFam Zheng IOThread *iothread = IOTHREAD(obj); 74*dce8921bSFam Zheng 75*dce8921bSFam Zheng iothread_stop(obj, NULL); 7688eb7c29SStefan Hajnoczi qemu_cond_destroy(&iothread->init_done_cond); 7788eb7c29SStefan Hajnoczi qemu_mutex_destroy(&iothread->init_done_lock); 78be8d8537SStefan Hajnoczi aio_context_unref(iothread->ctx); 79be8d8537SStefan Hajnoczi } 80be8d8537SStefan Hajnoczi 81be8d8537SStefan Hajnoczi static void iothread_complete(UserCreatable *obj, Error **errp) 82be8d8537SStefan Hajnoczi { 832f78e491SChrysostomos Nanakos Error *local_error = NULL; 84be8d8537SStefan Hajnoczi IOThread *iothread = IOTHREAD(obj); 85d21e8776SPaolo Bonzini char *name, *thread_name; 86be8d8537SStefan Hajnoczi 87be8d8537SStefan Hajnoczi iothread->stopping = false; 8888eb7c29SStefan Hajnoczi iothread->thread_id = -1; 892f78e491SChrysostomos Nanakos iothread->ctx = aio_context_new(&local_error); 902f78e491SChrysostomos Nanakos if (!iothread->ctx) { 912f78e491SChrysostomos Nanakos error_propagate(errp, local_error); 922f78e491SChrysostomos Nanakos return; 932f78e491SChrysostomos Nanakos } 9488eb7c29SStefan Hajnoczi 9588eb7c29SStefan Hajnoczi qemu_mutex_init(&iothread->init_done_lock); 9688eb7c29SStefan Hajnoczi qemu_cond_init(&iothread->init_done_cond); 97be8d8537SStefan Hajnoczi 98be8d8537SStefan Hajnoczi /* This assumes we are called from a thread with useful CPU affinity for us 99be8d8537SStefan Hajnoczi * to inherit. 100be8d8537SStefan Hajnoczi */ 101d21e8776SPaolo Bonzini name = object_get_canonical_path_component(OBJECT(obj)); 102d21e8776SPaolo Bonzini thread_name = g_strdup_printf("IO %s", name); 103d21e8776SPaolo Bonzini qemu_thread_create(&iothread->thread, thread_name, iothread_run, 104be8d8537SStefan Hajnoczi iothread, QEMU_THREAD_JOINABLE); 105d21e8776SPaolo Bonzini g_free(thread_name); 106d21e8776SPaolo Bonzini g_free(name); 10788eb7c29SStefan Hajnoczi 10888eb7c29SStefan Hajnoczi /* Wait for initialization to complete */ 10988eb7c29SStefan Hajnoczi qemu_mutex_lock(&iothread->init_done_lock); 11088eb7c29SStefan Hajnoczi while (iothread->thread_id == -1) { 11188eb7c29SStefan Hajnoczi qemu_cond_wait(&iothread->init_done_cond, 11288eb7c29SStefan Hajnoczi &iothread->init_done_lock); 11388eb7c29SStefan Hajnoczi } 11488eb7c29SStefan Hajnoczi qemu_mutex_unlock(&iothread->init_done_lock); 115be8d8537SStefan Hajnoczi } 116be8d8537SStefan Hajnoczi 117be8d8537SStefan Hajnoczi static void iothread_class_init(ObjectClass *klass, void *class_data) 118be8d8537SStefan Hajnoczi { 119be8d8537SStefan Hajnoczi UserCreatableClass *ucc = USER_CREATABLE_CLASS(klass); 120be8d8537SStefan Hajnoczi ucc->complete = iothread_complete; 121be8d8537SStefan Hajnoczi } 122be8d8537SStefan Hajnoczi 123be8d8537SStefan Hajnoczi static const TypeInfo iothread_info = { 124be8d8537SStefan Hajnoczi .name = TYPE_IOTHREAD, 125be8d8537SStefan Hajnoczi .parent = TYPE_OBJECT, 126be8d8537SStefan Hajnoczi .class_init = iothread_class_init, 127be8d8537SStefan Hajnoczi .instance_size = sizeof(IOThread), 128be8d8537SStefan Hajnoczi .instance_finalize = iothread_instance_finalize, 129be8d8537SStefan Hajnoczi .interfaces = (InterfaceInfo[]) { 130be8d8537SStefan Hajnoczi {TYPE_USER_CREATABLE}, 131be8d8537SStefan Hajnoczi {} 132be8d8537SStefan Hajnoczi }, 133be8d8537SStefan Hajnoczi }; 134be8d8537SStefan Hajnoczi 135be8d8537SStefan Hajnoczi static void iothread_register_types(void) 136be8d8537SStefan Hajnoczi { 137be8d8537SStefan Hajnoczi type_register_static(&iothread_info); 138be8d8537SStefan Hajnoczi } 139be8d8537SStefan Hajnoczi 140be8d8537SStefan Hajnoczi type_init(iothread_register_types) 141be8d8537SStefan Hajnoczi 142be8d8537SStefan Hajnoczi char *iothread_get_id(IOThread *iothread) 143be8d8537SStefan Hajnoczi { 144be8d8537SStefan Hajnoczi return object_get_canonical_path_component(OBJECT(iothread)); 145be8d8537SStefan Hajnoczi } 146be8d8537SStefan Hajnoczi 147be8d8537SStefan Hajnoczi AioContext *iothread_get_aio_context(IOThread *iothread) 148be8d8537SStefan Hajnoczi { 149be8d8537SStefan Hajnoczi return iothread->ctx; 150be8d8537SStefan Hajnoczi } 151dc3dd0d2SStefan Hajnoczi 152dc3dd0d2SStefan Hajnoczi static int query_one_iothread(Object *object, void *opaque) 153dc3dd0d2SStefan Hajnoczi { 154dc3dd0d2SStefan Hajnoczi IOThreadInfoList ***prev = opaque; 155dc3dd0d2SStefan Hajnoczi IOThreadInfoList *elem; 156dc3dd0d2SStefan Hajnoczi IOThreadInfo *info; 157dc3dd0d2SStefan Hajnoczi IOThread *iothread; 158dc3dd0d2SStefan Hajnoczi 159dc3dd0d2SStefan Hajnoczi iothread = (IOThread *)object_dynamic_cast(object, TYPE_IOTHREAD); 160dc3dd0d2SStefan Hajnoczi if (!iothread) { 161dc3dd0d2SStefan Hajnoczi return 0; 162dc3dd0d2SStefan Hajnoczi } 163dc3dd0d2SStefan Hajnoczi 164dc3dd0d2SStefan Hajnoczi info = g_new0(IOThreadInfo, 1); 165dc3dd0d2SStefan Hajnoczi info->id = iothread_get_id(iothread); 166dc3dd0d2SStefan Hajnoczi info->thread_id = iothread->thread_id; 167dc3dd0d2SStefan Hajnoczi 168dc3dd0d2SStefan Hajnoczi elem = g_new0(IOThreadInfoList, 1); 169dc3dd0d2SStefan Hajnoczi elem->value = info; 170dc3dd0d2SStefan Hajnoczi elem->next = NULL; 171dc3dd0d2SStefan Hajnoczi 172dc3dd0d2SStefan Hajnoczi **prev = elem; 173dc3dd0d2SStefan Hajnoczi *prev = &elem->next; 174dc3dd0d2SStefan Hajnoczi return 0; 175dc3dd0d2SStefan Hajnoczi } 176dc3dd0d2SStefan Hajnoczi 177dc3dd0d2SStefan Hajnoczi IOThreadInfoList *qmp_query_iothreads(Error **errp) 178dc3dd0d2SStefan Hajnoczi { 179dc3dd0d2SStefan Hajnoczi IOThreadInfoList *head = NULL; 180dc3dd0d2SStefan Hajnoczi IOThreadInfoList **prev = &head; 181bc2256c4SDaniel P. Berrange Object *container = object_get_objects_root(); 182dc3dd0d2SStefan Hajnoczi 183dc3dd0d2SStefan Hajnoczi object_child_foreach(container, query_one_iothread, &prev); 184dc3dd0d2SStefan Hajnoczi return head; 185dc3dd0d2SStefan Hajnoczi } 186*dce8921bSFam Zheng 187*dce8921bSFam Zheng void iothread_stop_all(void) 188*dce8921bSFam Zheng { 189*dce8921bSFam Zheng Object *container = object_get_objects_root(); 190*dce8921bSFam Zheng 191*dce8921bSFam Zheng object_child_foreach(container, iothread_stop, NULL); 192*dce8921bSFam Zheng } 193