-
Notifications
You must be signed in to change notification settings - Fork 1
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
This is a stand-in for Michael Roth's QContext. I expect this to be replaced once QContext is completed. The IOThread object is an AioContext event loop thread. This patch adds the concept of multiple event loop threads, allowing users to define them. When SMP guests run on SMP hosts it makes sense to instantiate multiple IOThreads. This spreads event loop processing across multiple cores. Note that additional patches are required to actually bind a device to an IOThread. [Andreas Färber <[email protected]> pointed out that the embedded parent object instance should be called "parent_obj" and have a newline afterwards. This patch has been changed to reflect this. -- Stefan] Signed-off-by: Stefan Hajnoczi <[email protected]>
- Loading branch information
1 parent
98563fc
commit be8d853
Showing
3 changed files
with
151 additions
and
0 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,30 @@ | ||
/* | ||
* Event loop thread | ||
* | ||
* Copyright Red Hat Inc., 2013 | ||
* | ||
* Authors: | ||
* Stefan Hajnoczi <[email protected]> | ||
* | ||
* This work is licensed under the terms of the GNU GPL, version 2 or later. | ||
* See the COPYING file in the top-level directory. | ||
* | ||
*/ | ||
|
||
#ifndef IOTHREAD_H | ||
#define IOTHREAD_H | ||
|
||
#include "block/aio.h" | ||
|
||
#define TYPE_IOTHREAD "iothread" | ||
|
||
typedef struct IOThread IOThread; | ||
|
||
#define IOTHREAD(obj) \ | ||
OBJECT_CHECK(IOThread, obj, TYPE_IOTHREAD) | ||
|
||
IOThread *iothread_find(const char *id); | ||
char *iothread_get_id(IOThread *iothread); | ||
AioContext *iothread_get_aio_context(IOThread *iothread); | ||
|
||
#endif /* IOTHREAD_H */ |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,120 @@ | ||
/* | ||
* Event loop thread | ||
* | ||
* Copyright Red Hat Inc., 2013 | ||
* | ||
* Authors: | ||
* Stefan Hajnoczi <[email protected]> | ||
* | ||
* This work is licensed under the terms of the GNU GPL, version 2 or later. | ||
* See the COPYING file in the top-level directory. | ||
* | ||
*/ | ||
|
||
#include "qom/object.h" | ||
#include "qom/object_interfaces.h" | ||
#include "qemu/module.h" | ||
#include "qemu/thread.h" | ||
#include "block/aio.h" | ||
#include "sysemu/iothread.h" | ||
|
||
#define IOTHREADS_PATH "/objects" | ||
|
||
typedef ObjectClass IOThreadClass; | ||
struct IOThread { | ||
Object parent_obj; | ||
|
||
QemuThread thread; | ||
AioContext *ctx; | ||
bool stopping; | ||
}; | ||
|
||
#define IOTHREAD_GET_CLASS(obj) \ | ||
OBJECT_GET_CLASS(IOThreadClass, obj, TYPE_IOTHREAD) | ||
#define IOTHREAD_CLASS(klass) \ | ||
OBJECT_CLASS_CHECK(IOThreadClass, klass, TYPE_IOTHREAD) | ||
|
||
static void *iothread_run(void *opaque) | ||
{ | ||
IOThread *iothread = opaque; | ||
|
||
while (!iothread->stopping) { | ||
aio_context_acquire(iothread->ctx); | ||
while (!iothread->stopping && aio_poll(iothread->ctx, true)) { | ||
/* Progress was made, keep going */ | ||
} | ||
aio_context_release(iothread->ctx); | ||
} | ||
return NULL; | ||
} | ||
|
||
static void iothread_instance_finalize(Object *obj) | ||
{ | ||
IOThread *iothread = IOTHREAD(obj); | ||
|
||
iothread->stopping = true; | ||
aio_notify(iothread->ctx); | ||
qemu_thread_join(&iothread->thread); | ||
aio_context_unref(iothread->ctx); | ||
} | ||
|
||
static void iothread_complete(UserCreatable *obj, Error **errp) | ||
{ | ||
IOThread *iothread = IOTHREAD(obj); | ||
|
||
iothread->stopping = false; | ||
iothread->ctx = aio_context_new(); | ||
|
||
/* This assumes we are called from a thread with useful CPU affinity for us | ||
* to inherit. | ||
*/ | ||
qemu_thread_create(&iothread->thread, "iothread", iothread_run, | ||
iothread, QEMU_THREAD_JOINABLE); | ||
} | ||
|
||
static void iothread_class_init(ObjectClass *klass, void *class_data) | ||
{ | ||
UserCreatableClass *ucc = USER_CREATABLE_CLASS(klass); | ||
ucc->complete = iothread_complete; | ||
} | ||
|
||
static const TypeInfo iothread_info = { | ||
.name = TYPE_IOTHREAD, | ||
.parent = TYPE_OBJECT, | ||
.class_init = iothread_class_init, | ||
.instance_size = sizeof(IOThread), | ||
.instance_finalize = iothread_instance_finalize, | ||
.interfaces = (InterfaceInfo[]) { | ||
{TYPE_USER_CREATABLE}, | ||
{} | ||
}, | ||
}; | ||
|
||
static void iothread_register_types(void) | ||
{ | ||
type_register_static(&iothread_info); | ||
} | ||
|
||
type_init(iothread_register_types) | ||
|
||
IOThread *iothread_find(const char *id) | ||
{ | ||
Object *container = container_get(object_get_root(), IOTHREADS_PATH); | ||
Object *child; | ||
|
||
child = object_property_get_link(container, id, NULL); | ||
if (!child) { | ||
return NULL; | ||
} | ||
return (IOThread *)object_dynamic_cast(child, TYPE_IOTHREAD); | ||
} | ||
|
||
char *iothread_get_id(IOThread *iothread) | ||
{ | ||
return object_get_canonical_path_component(OBJECT(iothread)); | ||
} | ||
|
||
AioContext *iothread_get_aio_context(IOThread *iothread) | ||
{ | ||
return iothread->ctx; | ||
} |