.. | .. |
---|
2 | 2 | #ifndef _LINUX_SUNRPC_RPC_PIPE_FS_H |
---|
3 | 3 | #define _LINUX_SUNRPC_RPC_PIPE_FS_H |
---|
4 | 4 | |
---|
5 | | -#ifdef __KERNEL__ |
---|
6 | | - |
---|
7 | 5 | #include <linux/workqueue.h> |
---|
8 | 6 | |
---|
9 | 7 | struct rpc_pipe_dir_head { |
---|
.. | .. |
---|
94 | 92 | char __user *, size_t); |
---|
95 | 93 | extern int rpc_queue_upcall(struct rpc_pipe *, struct rpc_pipe_msg *); |
---|
96 | 94 | |
---|
| 95 | +/* returns true if the msg is in-flight, i.e., already eaten by the peer */ |
---|
| 96 | +static inline bool rpc_msg_is_inflight(const struct rpc_pipe_msg *msg) { |
---|
| 97 | + return (msg->copied != 0 && list_empty(&msg->list)); |
---|
| 98 | +} |
---|
| 99 | + |
---|
97 | 100 | struct rpc_clnt; |
---|
98 | 101 | extern struct dentry *rpc_create_client_dir(struct dentry *, const char *, struct rpc_clnt *); |
---|
99 | 102 | extern int rpc_remove_client_dir(struct rpc_clnt *); |
---|
.. | .. |
---|
132 | 135 | |
---|
133 | 136 | extern bool gssd_running(struct net *net); |
---|
134 | 137 | |
---|
135 | | -#endif |
---|
136 | 138 | #endif |
---|