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

/*
 * Event loop thread
 *
 * Copyright Red Hat Inc., 2013
 *
 * Authors:
 *  Stefan Hajnoczi   <stefanha@redhat.com>
 *
 * 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;
    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);
AioContext *iothread_get_aio_context(IOThread *iothread);
void iothread_stop_all(void);
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_destroy(IOThread *iothread);

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