[qemu.git] / hw / 9pfs / coth.h

/*
 * 9p backend
 *
 * Copyright IBM, Corp. 2010
 *
 * Authors:
 *  Harsh Prateek Bora <[email protected]>
 *  Venkateswararao Jujjuri(JV) <[email protected]>
 *
 * This work is licensed under the terms of the GNU GPL, version 2.  See
 * the COPYING file in the top-level directory.
 *
 */

#ifndef QEMU_9P_COTH_H
#define QEMU_9P_COTH_H

#include "qemu/thread.h"
#include "qemu/coroutine.h"
#include "qemu/main-loop.h"
#include "9p.h"

/*
 * we want to use bottom half because we want to make sure the below
 * sequence of events.
 *
 *   1. Yield the coroutine in the QEMU thread.
 *   2. Submit the coroutine to a worker thread.
 *   3. Enter the coroutine in the worker thread.
 * we cannot swap step 1 and 2, because that would imply worker thread
 * can enter coroutine while step1 is still running
 */
#define v9fs_co_run_in_worker(code_block)                               \
    do {                                                                \
        QEMUBH *co_bh;                                                  \
        co_bh = qemu_bh_new(co_run_in_worker_bh,                        \
                            qemu_coroutine_self());                     \
        qemu_bh_schedule(co_bh);                                        \
        /*                                                              \
         * yield in qemu thread and re-enter back                       \
         * in worker thread                                             \
         */                                                             \
        qemu_coroutine_yield();                                         \
        qemu_bh_delete(co_bh);                                          \
        code_block;                                                     \
        /* re-enter back to qemu thread */                              \
        qemu_coroutine_yield();                                         \
    } while (0)

void co_run_in_worker_bh(void *);
int coroutine_fn v9fs_co_readlink(V9fsPDU *, V9fsPath *, V9fsString *);
int coroutine_fn v9fs_co_readdir(V9fsPDU *, V9fsFidState *, struct dirent **);
off_t coroutine_fn v9fs_co_telldir(V9fsPDU *, V9fsFidState *);
void coroutine_fn v9fs_co_seekdir(V9fsPDU *, V9fsFidState *, off_t);
void coroutine_fn v9fs_co_rewinddir(V9fsPDU *, V9fsFidState *);
int coroutine_fn v9fs_co_statfs(V9fsPDU *, V9fsPath *, struct statfs *);
int coroutine_fn v9fs_co_lstat(V9fsPDU *, V9fsPath *, struct stat *);
int coroutine_fn v9fs_co_chmod(V9fsPDU *, V9fsPath *, mode_t);
int coroutine_fn v9fs_co_utimensat(V9fsPDU *, V9fsPath *, struct timespec [2]);
int coroutine_fn v9fs_co_chown(V9fsPDU *, V9fsPath *, uid_t, gid_t);
int coroutine_fn v9fs_co_truncate(V9fsPDU *, V9fsPath *, off_t);
int coroutine_fn v9fs_co_llistxattr(V9fsPDU *, V9fsPath *, void *, size_t);
int coroutine_fn v9fs_co_lgetxattr(V9fsPDU *, V9fsPath *,
                                   V9fsString *, void *, size_t);
int coroutine_fn v9fs_co_mknod(V9fsPDU *, V9fsFidState *, V9fsString *, uid_t,
                               gid_t, dev_t, mode_t, struct stat *);
int coroutine_fn v9fs_co_mkdir(V9fsPDU *, V9fsFidState *, V9fsString *,
                               mode_t, uid_t, gid_t, struct stat *);
int coroutine_fn v9fs_co_remove(V9fsPDU *, V9fsPath *);
int coroutine_fn v9fs_co_rename(V9fsPDU *, V9fsPath *, V9fsPath *);
int coroutine_fn v9fs_co_unlinkat(V9fsPDU *, V9fsPath *, V9fsString *,
                                  int flags);
int coroutine_fn v9fs_co_renameat(V9fsPDU *, V9fsPath *, V9fsString *,
                                  V9fsPath *, V9fsString *);
int coroutine_fn v9fs_co_fstat(V9fsPDU *, V9fsFidState *, struct stat *);
int coroutine_fn v9fs_co_opendir(V9fsPDU *, V9fsFidState *);
int coroutine_fn v9fs_co_open(V9fsPDU *, V9fsFidState *, int);
int coroutine_fn v9fs_co_open2(V9fsPDU *, V9fsFidState *, V9fsString *,
                               gid_t, int, int, struct stat *);
int coroutine_fn v9fs_co_lsetxattr(V9fsPDU *, V9fsPath *, V9fsString *,
                                   void *, size_t, int);
int coroutine_fn v9fs_co_lremovexattr(V9fsPDU *, V9fsPath *, V9fsString *);
int coroutine_fn v9fs_co_closedir(V9fsPDU *, V9fsFidOpenState *);
int coroutine_fn v9fs_co_close(V9fsPDU *, V9fsFidOpenState *);
int coroutine_fn v9fs_co_fsync(V9fsPDU *, V9fsFidState *, int);
int coroutine_fn v9fs_co_symlink(V9fsPDU *, V9fsFidState *, V9fsString *,
                                 const char *, gid_t, struct stat *);
int coroutine_fn v9fs_co_link(V9fsPDU *, V9fsFidState *,
                              V9fsFidState *, V9fsString *);
int coroutine_fn v9fs_co_pwritev(V9fsPDU *, V9fsFidState *,
                                 struct iovec *, int, int64_t);
int coroutine_fn v9fs_co_preadv(V9fsPDU *, V9fsFidState *,
                                struct iovec *, int, int64_t);
int coroutine_fn v9fs_co_name_to_path(V9fsPDU *, V9fsPath *,
                                      const char *, V9fsPath *);
int coroutine_fn v9fs_co_st_gen(V9fsPDU *pdu, V9fsPath *path, mode_t,
                                V9fsStatDotl *v9stat);

#endif
Commit	Line	Data
39c0564e	1	/*
fe52840c	2	* 9p backend
39c0564e VJ	3	*
	4	* Copyright IBM, Corp. 2010
	5	*
	6	* Authors:
	7	* Harsh Prateek Bora <[email protected]>
	8	* Venkateswararao Jujjuri(JV) <[email protected]>
	9	*
	10	* This work is licensed under the terms of the GNU GPL, version 2. See
	11	* the COPYING file in the top-level directory.
	12	*
	13	*/
	14
2a6a4076 MA	15	#ifndef QEMU_9P_COTH_H
2a6a4076 MA	16	#define QEMU_9P_COTH_H
39c0564e	17
1de7afc9	18	#include "qemu/thread.h"
10817bf0	19	#include "qemu/coroutine.h"
af8b38b0 GK	20	#include "qemu/main-loop.h"
af8b38b0 GK	21	#include "9p.h"
39c0564e VJ	22
	23	/*
	24	* we want to use bottom half because we want to make sure the below
	25	* sequence of events.
	26	*
	27	* 1. Yield the coroutine in the QEMU thread.
	28	* 2. Submit the coroutine to a worker thread.
	29	* 3. Enter the coroutine in the worker thread.
	30	* we cannot swap step 1 and 2, because that would imply worker thread
	31	* can enter coroutine while step1 is still running
	32	*/
	33	#define v9fs_co_run_in_worker(code_block) \
	34	do { \
	35	QEMUBH *co_bh; \
	36	co_bh = qemu_bh_new(co_run_in_worker_bh, \
	37	qemu_coroutine_self()); \
	38	qemu_bh_schedule(co_bh); \
	39	/* \
66a0a2cb	40	* yield in qemu thread and re-enter back \
ebac1202	41	* in worker thread \
39c0564e VJ	42	*/ \
	43	qemu_coroutine_yield(); \
	44	qemu_bh_delete(co_bh); \
	45	code_block; \
	46	/* re-enter back to qemu thread */ \
	47	qemu_coroutine_yield(); \
	48	} while (0)
	49
bc70a592	50	void co_run_in_worker_bh(void *);
5bdade66 GK	51	int coroutine_fn v9fs_co_readlink(V9fsPDU , V9fsPath , V9fsString *);
	52	int coroutine_fn v9fs_co_readdir(V9fsPDU , V9fsFidState , struct dirent **);
	53	off_t coroutine_fn v9fs_co_telldir(V9fsPDU , V9fsFidState );
	54	void coroutine_fn v9fs_co_seekdir(V9fsPDU , V9fsFidState , off_t);
	55	void coroutine_fn v9fs_co_rewinddir(V9fsPDU , V9fsFidState );
	56	int coroutine_fn v9fs_co_statfs(V9fsPDU , V9fsPath , struct statfs *);
	57	int coroutine_fn v9fs_co_lstat(V9fsPDU , V9fsPath , struct stat *);
	58	int coroutine_fn v9fs_co_chmod(V9fsPDU , V9fsPath , mode_t);
	59	int coroutine_fn v9fs_co_utimensat(V9fsPDU , V9fsPath , struct timespec [2]);
	60	int coroutine_fn v9fs_co_chown(V9fsPDU , V9fsPath , uid_t, gid_t);
	61	int coroutine_fn v9fs_co_truncate(V9fsPDU , V9fsPath , off_t);
	62	int coroutine_fn v9fs_co_llistxattr(V9fsPDU , V9fsPath , void *, size_t);
	63	int coroutine_fn v9fs_co_lgetxattr(V9fsPDU , V9fsPath ,
	64	V9fsString , void , size_t);
	65	int coroutine_fn v9fs_co_mknod(V9fsPDU , V9fsFidState , V9fsString *, uid_t,
	66	gid_t, dev_t, mode_t, struct stat *);
	67	int coroutine_fn v9fs_co_mkdir(V9fsPDU , V9fsFidState , V9fsString *,
	68	mode_t, uid_t, gid_t, struct stat *);
	69	int coroutine_fn v9fs_co_remove(V9fsPDU , V9fsPath );
	70	int coroutine_fn v9fs_co_rename(V9fsPDU , V9fsPath , V9fsPath *);
	71	int coroutine_fn v9fs_co_unlinkat(V9fsPDU , V9fsPath , V9fsString *,
	72	int flags);
	73	int coroutine_fn v9fs_co_renameat(V9fsPDU , V9fsPath , V9fsString *,
	74	V9fsPath , V9fsString );
	75	int coroutine_fn v9fs_co_fstat(V9fsPDU , V9fsFidState , struct stat *);
	76	int coroutine_fn v9fs_co_opendir(V9fsPDU , V9fsFidState );
	77	int coroutine_fn v9fs_co_open(V9fsPDU , V9fsFidState , int);
	78	int coroutine_fn v9fs_co_open2(V9fsPDU , V9fsFidState , V9fsString *,
	79	gid_t, int, int, struct stat *);
	80	int coroutine_fn v9fs_co_lsetxattr(V9fsPDU , V9fsPath , V9fsString *,
	81	void *, size_t, int);
	82	int coroutine_fn v9fs_co_lremovexattr(V9fsPDU , V9fsPath , V9fsString *);
	83	int coroutine_fn v9fs_co_closedir(V9fsPDU , V9fsFidOpenState );
	84	int coroutine_fn v9fs_co_close(V9fsPDU , V9fsFidOpenState );
	85	int coroutine_fn v9fs_co_fsync(V9fsPDU , V9fsFidState , int);
	86	int coroutine_fn v9fs_co_symlink(V9fsPDU , V9fsFidState , V9fsString *,
	87	const char , gid_t, struct stat );
	88	int coroutine_fn v9fs_co_link(V9fsPDU , V9fsFidState ,
	89	V9fsFidState , V9fsString );
	90	int coroutine_fn v9fs_co_pwritev(V9fsPDU , V9fsFidState ,
	91	struct iovec *, int, int64_t);
	92	int coroutine_fn v9fs_co_preadv(V9fsPDU , V9fsFidState ,
	93	struct iovec *, int, int64_t);
	94	int coroutine_fn v9fs_co_name_to_path(V9fsPDU , V9fsPath ,
	95	const char , V9fsPath );
	96	int coroutine_fn v9fs_co_st_gen(V9fsPDU pdu, V9fsPath path, mode_t,
	97	V9fsStatDotl *v9stat);
e06a765e	98
39c0564e	99	#endif