[linux-2.6-block.git] / include / linux / sunrpc / rpc_pipe_fs.h

#ifndef _LINUX_SUNRPC_RPC_PIPE_FS_H
#define _LINUX_SUNRPC_RPC_PIPE_FS_H

#ifdef __KERNEL__

struct rpc_pipe_msg {
	struct list_head list;
	void *data;
	size_t len;
	size_t copied;
	int errno;
};

struct rpc_pipe_ops {
	ssize_t (*upcall)(struct file *, struct rpc_pipe_msg *, char __user *, size_t);
	ssize_t (*downcall)(struct file *, const char __user *, size_t);
	void (*release_pipe)(struct inode *);
	void (*destroy_msg)(struct rpc_pipe_msg *);
};

struct rpc_inode {
	struct inode vfs_inode;
	void *private;
	struct list_head pipe;
	struct list_head in_upcall;
	struct list_head in_downcall;
	int pipelen;
	int nreaders;
	int nwriters;
	int nkern_readwriters;
	wait_queue_head_t waitq;
#define RPC_PIPE_WAIT_FOR_OPEN	1
	int flags;
	struct rpc_pipe_ops *ops;
	struct delayed_work queue_timeout;
};

static inline struct rpc_inode *
RPC_I(struct inode *inode)
{
	return container_of(inode, struct rpc_inode, vfs_inode);
}

extern int rpc_queue_upcall(struct inode *, struct rpc_pipe_msg *);

extern struct dentry *rpc_mkdir(char *, struct rpc_clnt *);
extern int rpc_rmdir(struct dentry *);
extern struct dentry *rpc_mkpipe(struct dentry *, const char *, void *, struct rpc_pipe_ops *, int flags);
extern int rpc_unlink(struct dentry *);
extern struct vfsmount *rpc_get_mount(void);
extern void rpc_put_mount(void);
extern int register_rpc_pipefs(void);
extern void unregister_rpc_pipefs(void);

#endif
#endif
Commit	Line	Data
1da177e4 LT	1	#ifndef _LINUX_SUNRPC_RPC_PIPE_FS_H
	2	#define _LINUX_SUNRPC_RPC_PIPE_FS_H
	3
	4	#ifdef __KERNEL__
	5
	6	struct rpc_pipe_msg {
	7	struct list_head list;
	8	void *data;
	9	size_t len;
	10	size_t copied;
	11	int errno;
	12	};
	13
	14	struct rpc_pipe_ops {
	15	ssize_t (upcall)(struct file , struct rpc_pipe_msg , char __user , size_t);
	16	ssize_t (downcall)(struct file , const char __user *, size_t);
	17	void (release_pipe)(struct inode );
	18	void (destroy_msg)(struct rpc_pipe_msg );
	19	};
	20
	21	struct rpc_inode {
	22	struct inode vfs_inode;
	23	void *private;
	24	struct list_head pipe;
	25	struct list_head in_upcall;
6e84c7b6	26	struct list_head in_downcall;
1da177e4 LT	27	int pipelen;
	28	int nreaders;
	29	int nwriters;
03a1256f	30	int nkern_readwriters;
1da177e4 LT	31	wait_queue_head_t waitq;
	32	#define RPC_PIPE_WAIT_FOR_OPEN 1
	33	int flags;
	34	struct rpc_pipe_ops *ops;
52bad64d	35	struct delayed_work queue_timeout;
1da177e4 LT	36	};
	37
	38	static inline struct rpc_inode *
	39	RPC_I(struct inode *inode)
	40	{
	41	return container_of(inode, struct rpc_inode, vfs_inode);
	42	}
	43
	44	extern int rpc_queue_upcall(struct inode , struct rpc_pipe_msg );
	45
	46	extern struct dentry rpc_mkdir(char , struct rpc_clnt *);
dff02cc1	47	extern int rpc_rmdir(struct dentry *);
158998b6	48	extern struct dentry rpc_mkpipe(struct dentry , const char , void , struct rpc_pipe_ops *, int flags);
5d67476f	49	extern int rpc_unlink(struct dentry *);
54281548 TM	50	extern struct vfsmount *rpc_get_mount(void);
54281548 TM	51	extern void rpc_put_mount(void);
7531d692 TM	52	extern int register_rpc_pipefs(void);
7531d692 TM	53	extern void unregister_rpc_pipefs(void);
1da177e4 LT	54
	55	#endif
	56	#endif