[qemu.git] / include / sysemu / iothread.h

/*
 * 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"
#include "qemu/thread.h"

#define TYPE_IOTHREAD "iothread"

typedef struct {
    Object parent_obj;

    QemuThread thread;
    AioContext *ctx;
    GMainContext *worker_context;
    GMainLoop *main_loop;
    GOnce once;
    QemuMutex init_done_lock;
    QemuCond init_done_cond;    /* is thread initialization done? */
    bool stopping;              /* has iothread_stop() been called? */
    bool running;               /* should iothread_run() continue? */
    int thread_id;

    /* AioContext poll parameters */
    int64_t poll_max_ns;
    int64_t poll_grow;
    int64_t poll_shrink;
} IOThread;

#define IOTHREAD(obj) \
   OBJECT_CHECK(IOThread, obj, TYPE_IOTHREAD)

char *iothread_get_id(IOThread *iothread);
IOThread *iothread_by_id(const char *id);
AioContext *iothread_get_aio_context(IOThread *iothread);
GMainContext *iothread_get_g_main_context(IOThread *iothread);

/*
 * Helpers used to allocate iothreads for internal use.  These
 * iothreads will not be seen by monitor clients when query using
 * "query-iothreads".
 */
IOThread *iothread_create(const char *id, Error **errp);
void iothread_stop(IOThread *iothread);
void iothread_destroy(IOThread *iothread);

#endif /* IOTHREAD_H */
Commit	Line	Data
be8d8537 SH	1	/*
	2	* Event loop thread
	3	*
	4	* Copyright Red Hat Inc., 2013
	5	*
	6	* Authors:
	7	* Stefan Hajnoczi <[email protected]>
	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"
8c2664d8	18	#include "qemu/thread.h"
be8d8537 SH	19
	20	#define TYPE_IOTHREAD "iothread"
	21
8c2664d8 SH	22	typedef struct {
	23	Object parent_obj;
	24
	25	QemuThread thread;
	26	AioContext *ctx;
329163cb WY	27	GMainContext *worker_context;
	28	GMainLoop *main_loop;
	29	GOnce once;
8c2664d8 SH	30	QemuMutex init_done_lock;
8c2664d8 SH	31	QemuCond init_done_cond; /* is thread initialization done? */
2362a28e SH	32	bool stopping; /* has iothread_stop() been called? */
2362a28e SH	33	bool running; /* should iothread_run() continue? */
8c2664d8	34	int thread_id;
0d9d86fb SH	35
	36	/* AioContext poll parameters */
	37	int64_t poll_max_ns;
5e5db499 SH	38	int64_t poll_grow;
5e5db499 SH	39	int64_t poll_shrink;
8c2664d8	40	} IOThread;
be8d8537 SH	41
	42	#define IOTHREAD(obj) \
	43	OBJECT_CHECK(IOThread, obj, TYPE_IOTHREAD)
	44
be8d8537	45	char iothread_get_id(IOThread iothread);
fbcc6923	46	IOThread iothread_by_id(const char id);
be8d8537	47	AioContext iothread_get_aio_context(IOThread iothread);
329163cb	48	GMainContext iothread_get_g_main_context(IOThread iothread);
be8d8537	49
0173e21b PX	50	/*
	51	* Helpers used to allocate iothreads for internal use. These
	52	* iothreads will not be seen by monitor clients when query using
	53	* "query-iothreads".
	54	*/
	55	IOThread iothread_create(const char id, Error **errp);
82d90705	56	void iothread_stop(IOThread *iothread);
0173e21b PX	57	void iothread_destroy(IOThread *iothread);
0173e21b PX	58
be8d8537	59	#endif /* IOTHREAD_H */