| #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; |
| int pipelen; |
| int nreaders; |
| int nwriters; |
| wait_queue_head_t waitq; |
| #define RPC_PIPE_WAIT_FOR_OPEN 1 |
| int flags; |
| struct rpc_pipe_ops *ops; |
| struct work_struct 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(struct dentry *, char *, struct rpc_clnt *); |
| extern void rpc_rmdir(struct dentry *); |
| extern struct dentry *rpc_mkpipe(struct dentry *, char *, void *, |
| struct rpc_pipe_ops *, int flags); |
| extern void rpc_unlink(struct dentry *); |
| |
| #endif |
| #endif |