[qemu.git] / include / qemu / coroutine_int.h

/*
 * Coroutine internals
 *
 * Copyright (c) 2011 Kevin Wolf <[email protected]>
 *
 * Permission is hereby granted, free of charge, to any person obtaining a copy
 * of this software and associated documentation files (the "Software"), to deal
 * in the Software without restriction, including without limitation the rights
 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
 * copies of the Software, and to permit persons to whom the Software is
 * furnished to do so, subject to the following conditions:
 *
 * The above copyright notice and this permission notice shall be included in
 * all copies or substantial portions of the Software.
 *
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
 * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
 * THE SOFTWARE.
 */

#ifndef QEMU_COROUTINE_INT_H
#define QEMU_COROUTINE_INT_H

#include "qemu/queue.h"
#include "qemu/coroutine.h"

#define COROUTINE_STACK_SIZE (1 << 20)

typedef enum {
    COROUTINE_YIELD = 1,
    COROUTINE_TERMINATE = 2,
    COROUTINE_ENTER = 3,
} CoroutineAction;

struct Coroutine {
    CoroutineEntry *entry;
    void *entry_arg;
    Coroutine *caller;
    QSLIST_ENTRY(Coroutine) pool_next;
    size_t locks_held;

    /* Coroutines that should be woken up when we yield or terminate */
    QSIMPLEQ_HEAD(, Coroutine) co_queue_wakeup;
    QSIMPLEQ_ENTRY(Coroutine) co_queue_next;
};

Coroutine *qemu_coroutine_new(void);
void qemu_coroutine_delete(Coroutine *co);
CoroutineAction qemu_coroutine_switch(Coroutine *from, Coroutine *to,
                                      CoroutineAction action);
void coroutine_fn qemu_co_queue_run_restart(Coroutine *co);

#endif
Commit	Line	Data
00dccaf1 KW	1	/*
	2	* Coroutine internals
	3	*
	4	* Copyright (c) 2011 Kevin Wolf <[email protected]>
	5	*
	6	* Permission is hereby granted, free of charge, to any person obtaining a copy
	7	* of this software and associated documentation files (the "Software"), to deal
	8	* in the Software without restriction, including without limitation the rights
	9	* to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
	10	* copies of the Software, and to permit persons to whom the Software is
	11	* furnished to do so, subject to the following conditions:
	12	*
	13	* The above copyright notice and this permission notice shall be included in
	14	* all copies or substantial portions of the Software.
	15	*
	16	* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
	17	* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
	18	* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
	19	* THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
	20	* LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
	21	* OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
	22	* THE SOFTWARE.
	23	*/
	24
	25	#ifndef QEMU_COROUTINE_INT_H
	26	#define QEMU_COROUTINE_INT_H
	27
1de7afc9	28	#include "qemu/queue.h"
10817bf0	29	#include "qemu/coroutine.h"
00dccaf1	30
8adcd6fb PL	31	#define COROUTINE_STACK_SIZE (1 << 20)
8adcd6fb PL	32
00dccaf1 KW	33	typedef enum {
	34	COROUTINE_YIELD = 1,
	35	COROUTINE_TERMINATE = 2,
cd12bb56	36	COROUTINE_ENTER = 3,
00dccaf1 KW	37	} CoroutineAction;
	38
	39	struct Coroutine {
	40	CoroutineEntry *entry;
	41	void *entry_arg;
	42	Coroutine *caller;
1bbbdabd	43	QSLIST_ENTRY(Coroutine) pool_next;
1b7f01d9	44	size_t locks_held;
02ffb504 SH	45
02ffb504 SH	46	/* Coroutines that should be woken up when we yield or terminate */
7d9c8581 PB	47	QSIMPLEQ_HEAD(, Coroutine) co_queue_wakeup;
7d9c8581 PB	48	QSIMPLEQ_ENTRY(Coroutine) co_queue_next;
00dccaf1 KW	49	};
	50
	51	Coroutine *qemu_coroutine_new(void);
	52	void qemu_coroutine_delete(Coroutine *co);
	53	CoroutineAction qemu_coroutine_switch(Coroutine from, Coroutine to,
	54	CoroutineAction action);
02ffb504	55	void coroutine_fn qemu_co_queue_run_restart(Coroutine *co);
00dccaf1 KW	56
00dccaf1 KW	57	#endif