[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 "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	20	#include "9p.h"
39c0564e VJ	21
	22	/*
	23	* we want to use bottom half because we want to make sure the below
	24	* sequence of events.
	25	*
	26	* 1. Yield the coroutine in the QEMU thread.
	27	* 2. Submit the coroutine to a worker thread.
	28	* 3. Enter the coroutine in the worker thread.
	29	* we cannot swap step 1 and 2, because that would imply worker thread
	30	* can enter coroutine while step1 is still running
	31	*/
	32	#define v9fs_co_run_in_worker(code_block) \
	33	do { \
	34	QEMUBH *co_bh; \
	35	co_bh = qemu_bh_new(co_run_in_worker_bh, \
	36	qemu_coroutine_self()); \
	37	qemu_bh_schedule(co_bh); \
	38	/* \
66a0a2cb	39	* yield in qemu thread and re-enter back \
ebac1202	40	* in worker thread \
39c0564e VJ	41	*/ \
	42	qemu_coroutine_yield(); \
	43	qemu_bh_delete(co_bh); \
	44	code_block; \
	45	/* re-enter back to qemu thread */ \
	46	qemu_coroutine_yield(); \
	47	} while (0)
	48
bc70a592	49	void co_run_in_worker_bh(void *);
5bdade66 GK	50	int coroutine_fn v9fs_co_readlink(V9fsPDU , V9fsPath , V9fsString *);
	51	int coroutine_fn v9fs_co_readdir(V9fsPDU , V9fsFidState , struct dirent **);
	52	off_t coroutine_fn v9fs_co_telldir(V9fsPDU , V9fsFidState );
	53	void coroutine_fn v9fs_co_seekdir(V9fsPDU , V9fsFidState , off_t);
	54	void coroutine_fn v9fs_co_rewinddir(V9fsPDU , V9fsFidState );
	55	int coroutine_fn v9fs_co_statfs(V9fsPDU , V9fsPath , struct statfs *);
	56	int coroutine_fn v9fs_co_lstat(V9fsPDU , V9fsPath , struct stat *);
	57	int coroutine_fn v9fs_co_chmod(V9fsPDU , V9fsPath , mode_t);
	58	int coroutine_fn v9fs_co_utimensat(V9fsPDU , V9fsPath , struct timespec [2]);
	59	int coroutine_fn v9fs_co_chown(V9fsPDU , V9fsPath , uid_t, gid_t);
	60	int coroutine_fn v9fs_co_truncate(V9fsPDU , V9fsPath , off_t);
	61	int coroutine_fn v9fs_co_llistxattr(V9fsPDU , V9fsPath , void *, size_t);
	62	int coroutine_fn v9fs_co_lgetxattr(V9fsPDU , V9fsPath ,
	63	V9fsString , void , size_t);
	64	int coroutine_fn v9fs_co_mknod(V9fsPDU , V9fsFidState , V9fsString *, uid_t,
	65	gid_t, dev_t, mode_t, struct stat *);
	66	int coroutine_fn v9fs_co_mkdir(V9fsPDU , V9fsFidState , V9fsString *,
	67	mode_t, uid_t, gid_t, struct stat *);
	68	int coroutine_fn v9fs_co_remove(V9fsPDU , V9fsPath );
	69	int coroutine_fn v9fs_co_rename(V9fsPDU , V9fsPath , V9fsPath *);
	70	int coroutine_fn v9fs_co_unlinkat(V9fsPDU , V9fsPath , V9fsString *,
	71	int flags);
	72	int coroutine_fn v9fs_co_renameat(V9fsPDU , V9fsPath , V9fsString *,
	73	V9fsPath , V9fsString );
	74	int coroutine_fn v9fs_co_fstat(V9fsPDU , V9fsFidState , struct stat *);
	75	int coroutine_fn v9fs_co_opendir(V9fsPDU , V9fsFidState );
	76	int coroutine_fn v9fs_co_open(V9fsPDU , V9fsFidState , int);
	77	int coroutine_fn v9fs_co_open2(V9fsPDU , V9fsFidState , V9fsString *,
	78	gid_t, int, int, struct stat *);
	79	int coroutine_fn v9fs_co_lsetxattr(V9fsPDU , V9fsPath , V9fsString *,
	80	void *, size_t, int);
	81	int coroutine_fn v9fs_co_lremovexattr(V9fsPDU , V9fsPath , V9fsString *);
	82	int coroutine_fn v9fs_co_closedir(V9fsPDU , V9fsFidOpenState );
	83	int coroutine_fn v9fs_co_close(V9fsPDU , V9fsFidOpenState );
	84	int coroutine_fn v9fs_co_fsync(V9fsPDU , V9fsFidState , int);
	85	int coroutine_fn v9fs_co_symlink(V9fsPDU , V9fsFidState , V9fsString *,
	86	const char , gid_t, struct stat );
	87	int coroutine_fn v9fs_co_link(V9fsPDU , V9fsFidState ,
	88	V9fsFidState , V9fsString );
	89	int coroutine_fn v9fs_co_pwritev(V9fsPDU , V9fsFidState ,
	90	struct iovec *, int, int64_t);
	91	int coroutine_fn v9fs_co_preadv(V9fsPDU , V9fsFidState ,
	92	struct iovec *, int, int64_t);
	93	int coroutine_fn v9fs_co_name_to_path(V9fsPDU , V9fsPath ,
	94	const char , V9fsPath );
	95	int coroutine_fn v9fs_co_st_gen(V9fsPDU pdu, V9fsPath path, mode_t,
	96	V9fsStatDotl *v9stat);
e06a765e	97
39c0564e	98	#endif