1/* 2 * linux/include/linux/sunrpc/svcsock.h 3 * 4 * RPC server socket I/O. 5 * 6 * Copyright (C) 1995, 1996 Olaf Kirch <okir@monad.swb.de> 7 */ 8 9#ifndef SUNRPC_SVCSOCK_H 10#define SUNRPC_SVCSOCK_H 11 12#include <linux/sunrpc/svc.h> 13#include <linux/sunrpc/svc_xprt.h> 14 15/* 16 * RPC server socket. 17 */ 18struct svc_sock { 19 struct svc_xprt sk_xprt; 20 struct socket * sk_sock; /* berkeley socket layer */ 21 struct sock * sk_sk; /* INET layer */ 22 23 /* We keep the old state_change and data_ready CB's here */ 24 void (*sk_ostate)(struct sock *); 25 void (*sk_odata)(struct sock *); 26 void (*sk_owspace)(struct sock *); 27 28 /* private TCP part */ 29 /* On-the-wire fragment header: */ 30 __be32 sk_reclen; 31 /* As we receive a record, this includes the length received so 32 * far (including the fragment header): */ 33 u32 sk_tcplen; 34 /* Total length of the data (not including fragment headers) 35 * received so far in the fragments making up this rpc: */ 36 u32 sk_datalen; 37 38 struct page * sk_pages[RPCSVC_MAXPAGES]; /* received data */ 39}; 40 41static inline u32 svc_sock_reclen(struct svc_sock *svsk) 42{ 43 return ntohl(svsk->sk_reclen) & RPC_FRAGMENT_SIZE_MASK; 44} 45 46static inline u32 svc_sock_final_rec(struct svc_sock *svsk) 47{ 48 return ntohl(svsk->sk_reclen) & RPC_LAST_STREAM_FRAGMENT; 49} 50 51/* 52 * Function prototypes. 53 */ 54void svc_close_net(struct svc_serv *, struct net *); 55int svc_recv(struct svc_rqst *, long); 56int svc_send(struct svc_rqst *); 57void svc_drop(struct svc_rqst *); 58void svc_sock_update_bufs(struct svc_serv *serv); 59bool svc_alien_sock(struct net *net, int fd); 60int svc_addsock(struct svc_serv *serv, const int fd, 61 char *name_return, const size_t len); 62void svc_init_xprt_sock(void); 63void svc_cleanup_xprt_sock(void); 64struct svc_xprt *svc_sock_create(struct svc_serv *serv, int prot); 65void svc_sock_destroy(struct svc_xprt *); 66 67/* 68 * svc_makesock socket characteristics 69 */ 70#define SVC_SOCK_DEFAULTS (0U) 71#define SVC_SOCK_ANONYMOUS (1U << 0) /* don't register with pmap */ 72#define SVC_SOCK_TEMPORARY (1U << 1) /* flag socket as temporary */ 73 74#endif /* SUNRPC_SVCSOCK_H */ 75