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>
15 struct svc_xprt
*(*xpo_create
)(struct svc_serv
*,
17 struct sockaddr
*, int,
19 struct svc_xprt
*(*xpo_accept
)(struct svc_xprt
*);
20 int (*xpo_has_wspace
)(struct svc_xprt
*);
21 int (*xpo_recvfrom
)(struct svc_rqst
*);
22 void (*xpo_prep_reply_hdr
)(struct svc_rqst
*);
23 int (*xpo_sendto
)(struct svc_rqst
*);
24 void (*xpo_release_rqst
)(struct svc_rqst
*);
25 void (*xpo_detach
)(struct svc_xprt
*);
26 void (*xpo_free
)(struct svc_xprt
*);
27 int (*xpo_secure_port
)(struct svc_rqst
*);
30 struct svc_xprt_class
{
32 struct module
*xcl_owner
;
33 struct svc_xprt_ops
*xcl_ops
;
34 struct list_head xcl_list
;
39 * This is embedded in an object that wants a callback before deleting
40 * an xprt; intended for use by NFSv4.1, which needs to know when a
41 * client's tcp connection (and hence possibly a backchannel) goes away.
44 struct list_head list
;
45 void (*callback
)(struct svc_xpt_user
*);
49 struct svc_xprt_class
*xpt_class
;
50 struct svc_xprt_ops
*xpt_ops
;
52 struct list_head xpt_list
;
53 struct list_head xpt_ready
;
54 unsigned long xpt_flags
;
55 #define XPT_BUSY 0 /* enqueued/receiving */
56 #define XPT_CONN 1 /* conn pending */
57 #define XPT_CLOSE 2 /* dead or dying */
58 #define XPT_DATA 3 /* data pending */
59 #define XPT_TEMP 4 /* connected transport */
60 #define XPT_DEAD 6 /* transport closed */
61 #define XPT_CHNGBUF 7 /* need to change snd/rcv buf sizes */
62 #define XPT_DEFERRED 8 /* deferred request pending */
63 #define XPT_OLD 9 /* used for xprt aging mark+sweep */
64 #define XPT_DETACHED 10 /* detached from tempsocks list */
65 #define XPT_LISTENER 11 /* listening endpoint */
66 #define XPT_CACHE_AUTH 12 /* cache auth info */
68 struct svc_serv
*xpt_server
; /* service for transport */
69 atomic_t xpt_reserved
; /* space on outq that is rsvd */
70 struct mutex xpt_mutex
; /* to serialize sending data */
71 spinlock_t xpt_lock
; /* protects sk_deferred
72 * and xpt_auth_cache */
73 void *xpt_auth_cache
;/* auth cache */
74 struct list_head xpt_deferred
; /* deferred requests that need
76 struct sockaddr_storage xpt_local
; /* local address */
77 size_t xpt_locallen
; /* length of address */
78 struct sockaddr_storage xpt_remote
; /* remote peer's address */
79 size_t xpt_remotelen
; /* length of address */
80 struct rpc_wait_queue xpt_bc_pending
; /* backchannel wait queue */
81 struct list_head xpt_users
; /* callbacks on free */
84 struct rpc_xprt
*xpt_bc_xprt
; /* NFSv4.1 backchannel */
87 static inline void unregister_xpt_user(struct svc_xprt
*xpt
, struct svc_xpt_user
*u
)
89 spin_lock(&xpt
->xpt_lock
);
90 list_del_init(&u
->list
);
91 spin_unlock(&xpt
->xpt_lock
);
94 static inline int register_xpt_user(struct svc_xprt
*xpt
, struct svc_xpt_user
*u
)
96 spin_lock(&xpt
->xpt_lock
);
97 if (test_bit(XPT_CLOSE
, &xpt
->xpt_flags
)) {
99 * The connection is about to be deleted soon (or,
100 * worse, may already be deleted--in which case we've
101 * already notified the xpt_users).
103 spin_unlock(&xpt
->xpt_lock
);
106 list_add(&u
->list
, &xpt
->xpt_users
);
107 spin_unlock(&xpt
->xpt_lock
);
111 int svc_reg_xprt_class(struct svc_xprt_class
*);
112 void svc_unreg_xprt_class(struct svc_xprt_class
*);
113 void svc_xprt_init(struct net
*, struct svc_xprt_class
*, struct svc_xprt
*,
115 int svc_create_xprt(struct svc_serv
*, const char *, struct net
*,
116 const int, const unsigned short, int);
117 void svc_xprt_enqueue(struct svc_xprt
*xprt
);
118 void svc_xprt_put(struct svc_xprt
*xprt
);
119 void svc_xprt_copy_addrs(struct svc_rqst
*rqstp
, struct svc_xprt
*xprt
);
120 void svc_close_xprt(struct svc_xprt
*xprt
);
121 int svc_port_is_privileged(struct sockaddr
*sin
);
122 int svc_print_xprts(char *buf
, int maxlen
);
123 struct svc_xprt
*svc_find_xprt(struct svc_serv
*serv
, const char *xcl_name
,
124 struct net
*net
, const sa_family_t af
,
125 const unsigned short port
);
126 int svc_xprt_names(struct svc_serv
*serv
, char *buf
, const int buflen
);
127 void svc_add_new_perm_xprt(struct svc_serv
*serv
, struct svc_xprt
*xprt
);
129 static inline void svc_xprt_get(struct svc_xprt
*xprt
)
131 kref_get(&xprt
->xpt_ref
);
133 static inline void svc_xprt_set_local(struct svc_xprt
*xprt
,
134 const struct sockaddr
*sa
,
137 memcpy(&xprt
->xpt_local
, sa
, salen
);
138 xprt
->xpt_locallen
= salen
;
140 static inline void svc_xprt_set_remote(struct svc_xprt
*xprt
,
141 const struct sockaddr
*sa
,
144 memcpy(&xprt
->xpt_remote
, sa
, salen
);
145 xprt
->xpt_remotelen
= salen
;
147 static inline unsigned short svc_addr_port(const struct sockaddr
*sa
)
149 const struct sockaddr_in
*sin
= (const struct sockaddr_in
*)sa
;
150 const struct sockaddr_in6
*sin6
= (const struct sockaddr_in6
*)sa
;
152 switch (sa
->sa_family
) {
154 return ntohs(sin
->sin_port
);
156 return ntohs(sin6
->sin6_port
);
162 static inline size_t svc_addr_len(const struct sockaddr
*sa
)
164 switch (sa
->sa_family
) {
166 return sizeof(struct sockaddr_in
);
168 return sizeof(struct sockaddr_in6
);
173 static inline unsigned short svc_xprt_local_port(const struct svc_xprt
*xprt
)
175 return svc_addr_port((const struct sockaddr
*)&xprt
->xpt_local
);
178 static inline unsigned short svc_xprt_remote_port(const struct svc_xprt
*xprt
)
180 return svc_addr_port((const struct sockaddr
*)&xprt
->xpt_remote
);
183 static inline char *__svc_print_addr(const struct sockaddr
*addr
,
184 char *buf
, const size_t len
)
186 const struct sockaddr_in
*sin
= (const struct sockaddr_in
*)addr
;
187 const struct sockaddr_in6
*sin6
= (const struct sockaddr_in6
*)addr
;
189 switch (addr
->sa_family
) {
191 snprintf(buf
, len
, "%pI4, port=%u", &sin
->sin_addr
,
192 ntohs(sin
->sin_port
));
196 snprintf(buf
, len
, "%pI6, port=%u",
198 ntohs(sin6
->sin6_port
));
202 snprintf(buf
, len
, "unknown address type: %d", addr
->sa_family
);
208 #endif /* SUNRPC_SVC_XPRT_H */