2 * linux/include/linux/sunrpc/svc_xprt.h
4 * RPC server transport I/O
7 #ifndef SUNRPC_SVC_XPRT_H
8 #define SUNRPC_SVC_XPRT_H
10 #include <linux/sunrpc/svc.h>
11 #include <linux/module.h>
14 struct svc_xprt *(*xpo_create)(struct svc_serv *,
15 struct sockaddr *, int,
17 struct svc_xprt *(*xpo_accept)(struct svc_xprt *);
18 int (*xpo_has_wspace)(struct svc_xprt *);
19 int (*xpo_recvfrom)(struct svc_rqst *);
20 void (*xpo_prep_reply_hdr)(struct svc_rqst *);
21 int (*xpo_sendto)(struct svc_rqst *);
22 void (*xpo_release_rqst)(struct svc_rqst *);
23 void (*xpo_detach)(struct svc_xprt *);
24 void (*xpo_free)(struct svc_xprt *);
27 struct svc_xprt_class {
29 struct module *xcl_owner;
30 struct svc_xprt_ops *xcl_ops;
31 struct list_head xcl_list;
36 struct svc_xprt_class *xpt_class;
37 struct svc_xprt_ops *xpt_ops;
39 struct list_head xpt_list;
40 struct list_head xpt_ready;
41 unsigned long xpt_flags;
42 #define XPT_BUSY 0 /* enqueued/receiving */
43 #define XPT_CONN 1 /* conn pending */
44 #define XPT_CLOSE 2 /* dead or dying */
45 #define XPT_DATA 3 /* data pending */
46 #define XPT_TEMP 4 /* connected transport */
47 #define XPT_DEAD 6 /* transport closed */
48 #define XPT_CHNGBUF 7 /* need to change snd/rcv buf sizes */
49 #define XPT_DEFERRED 8 /* deferred request pending */
50 #define XPT_OLD 9 /* used for xprt aging mark+sweep */
51 #define XPT_DETACHED 10 /* detached from tempsocks list */
52 #define XPT_LISTENER 11 /* listening endpoint */
53 #define XPT_CACHE_AUTH 12 /* cache auth info */
55 struct svc_pool *xpt_pool; /* current pool iff queued */
56 struct svc_serv *xpt_server; /* service for transport */
57 atomic_t xpt_reserved; /* space on outq that is rsvd */
58 struct mutex xpt_mutex; /* to serialize sending data */
59 spinlock_t xpt_lock; /* protects sk_deferred
60 * and xpt_auth_cache */
61 void *xpt_auth_cache;/* auth cache */
62 struct list_head xpt_deferred; /* deferred requests that need
64 struct sockaddr_storage xpt_local; /* local address */
65 size_t xpt_locallen; /* length of address */
66 struct sockaddr_storage xpt_remote; /* remote peer's address */
67 size_t xpt_remotelen; /* length of address */
70 int svc_reg_xprt_class(struct svc_xprt_class *);
71 void svc_unreg_xprt_class(struct svc_xprt_class *);
72 void svc_xprt_init(struct svc_xprt_class *, struct svc_xprt *,
74 int svc_create_xprt(struct svc_serv *, char *, unsigned short, int);
75 void svc_xprt_received(struct svc_xprt *);
76 void svc_xprt_put(struct svc_xprt *xprt);
77 void svc_xprt_copy_addrs(struct svc_rqst *rqstp, struct svc_xprt *xprt);
78 static inline void svc_xprt_get(struct svc_xprt *xprt)
80 kref_get(&xprt->xpt_ref);
82 static inline void svc_xprt_set_local(struct svc_xprt *xprt,
83 struct sockaddr *sa, int salen)
85 memcpy(&xprt->xpt_local, sa, salen);
86 xprt->xpt_locallen = salen;
88 static inline void svc_xprt_set_remote(struct svc_xprt *xprt,
89 struct sockaddr *sa, int salen)
91 memcpy(&xprt->xpt_remote, sa, salen);
92 xprt->xpt_remotelen = salen;
94 static inline unsigned short svc_addr_port(struct sockaddr *sa)
96 unsigned short ret = 0;
97 switch (sa->sa_family) {
99 ret = ntohs(((struct sockaddr_in *)sa)->sin_port);
102 ret = ntohs(((struct sockaddr_in6 *)sa)->sin6_port);
108 static inline size_t svc_addr_len(struct sockaddr *sa)
110 switch (sa->sa_family) {
112 return sizeof(struct sockaddr_in);
114 return sizeof(struct sockaddr_in6);
116 return -EAFNOSUPPORT;
119 static inline unsigned short svc_xprt_local_port(struct svc_xprt *xprt)
121 return svc_addr_port((struct sockaddr *)&xprt->xpt_local);
124 static inline unsigned short svc_xprt_remote_port(struct svc_xprt *xprt)
126 return svc_addr_port((struct sockaddr *)&xprt->xpt_remote);
129 #endif /* SUNRPC_SVC_XPRT_H */