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
*);
28 void (*xpo_adjust_wspace
)(struct svc_xprt
*);
31 struct svc_xprt_class
{
33 struct module
*xcl_owner
;
34 struct svc_xprt_ops
*xcl_ops
;
35 struct list_head xcl_list
;
41 * This is embedded in an object that wants a callback before deleting
42 * an xprt; intended for use by NFSv4.1, which needs to know when a
43 * client's tcp connection (and hence possibly a backchannel) goes away.
46 struct list_head list
;
47 void (*callback
)(struct svc_xpt_user
*);
51 struct svc_xprt_class
*xpt_class
;
52 struct svc_xprt_ops
*xpt_ops
;
54 struct list_head xpt_list
;
55 struct list_head xpt_ready
;
56 unsigned long xpt_flags
;
57 #define XPT_BUSY 0 /* enqueued/receiving */
58 #define XPT_CONN 1 /* conn pending */
59 #define XPT_CLOSE 2 /* dead or dying */
60 #define XPT_DATA 3 /* data pending */
61 #define XPT_TEMP 4 /* connected transport */
62 #define XPT_DEAD 6 /* transport closed */
63 #define XPT_CHNGBUF 7 /* need to change snd/rcv buf sizes */
64 #define XPT_DEFERRED 8 /* deferred request pending */
65 #define XPT_OLD 9 /* used for xprt aging mark+sweep */
66 #define XPT_LISTENER 10 /* listening endpoint */
67 #define XPT_CACHE_AUTH 11 /* cache auth info */
68 #define XPT_LOCAL 12 /* connection from loopback interface */
70 struct svc_serv
*xpt_server
; /* service for transport */
71 atomic_t xpt_reserved
; /* space on outq that is rsvd */
72 atomic_t xpt_nr_rqsts
; /* Number of requests */
73 struct mutex xpt_mutex
; /* to serialize sending data */
74 spinlock_t xpt_lock
; /* protects sk_deferred
75 * and xpt_auth_cache */
76 void *xpt_auth_cache
;/* auth cache */
77 struct list_head xpt_deferred
; /* deferred requests that need
79 struct sockaddr_storage xpt_local
; /* local address */
80 size_t xpt_locallen
; /* length of address */
81 struct sockaddr_storage xpt_remote
; /* remote peer's address */
82 size_t xpt_remotelen
; /* length of address */
83 struct rpc_wait_queue xpt_bc_pending
; /* backchannel wait queue */
84 struct list_head xpt_users
; /* callbacks on free */
87 struct rpc_xprt
*xpt_bc_xprt
; /* NFSv4.1 backchannel */
88 struct rpc_xprt_switch
*xpt_bc_xps
; /* NFSv4.1 backchannel */
91 static inline void unregister_xpt_user(struct svc_xprt
*xpt
, struct svc_xpt_user
*u
)
93 spin_lock(&xpt
->xpt_lock
);
94 list_del_init(&u
->list
);
95 spin_unlock(&xpt
->xpt_lock
);
98 static inline int register_xpt_user(struct svc_xprt
*xpt
, struct svc_xpt_user
*u
)
100 spin_lock(&xpt
->xpt_lock
);
101 if (test_bit(XPT_CLOSE
, &xpt
->xpt_flags
)) {
103 * The connection is about to be deleted soon (or,
104 * worse, may already be deleted--in which case we've
105 * already notified the xpt_users).
107 spin_unlock(&xpt
->xpt_lock
);
110 list_add(&u
->list
, &xpt
->xpt_users
);
111 spin_unlock(&xpt
->xpt_lock
);
115 int svc_reg_xprt_class(struct svc_xprt_class
*);
116 void svc_unreg_xprt_class(struct svc_xprt_class
*);
117 void svc_xprt_init(struct net
*, struct svc_xprt_class
*, struct svc_xprt
*,
119 int svc_create_xprt(struct svc_serv
*, const char *, struct net
*,
120 const int, const unsigned short, int);
121 void svc_xprt_do_enqueue(struct svc_xprt
*xprt
);
122 void svc_xprt_enqueue(struct svc_xprt
*xprt
);
123 void svc_xprt_put(struct svc_xprt
*xprt
);
124 void svc_xprt_copy_addrs(struct svc_rqst
*rqstp
, struct svc_xprt
*xprt
);
125 void svc_close_xprt(struct svc_xprt
*xprt
);
126 int svc_port_is_privileged(struct sockaddr
*sin
);
127 int svc_print_xprts(char *buf
, int maxlen
);
128 struct svc_xprt
*svc_find_xprt(struct svc_serv
*serv
, const char *xcl_name
,
129 struct net
*net
, const sa_family_t af
,
130 const unsigned short port
);
131 int svc_xprt_names(struct svc_serv
*serv
, char *buf
, const int buflen
);
132 void svc_add_new_perm_xprt(struct svc_serv
*serv
, struct svc_xprt
*xprt
);
133 void svc_age_temp_xprts_now(struct svc_serv
*, struct sockaddr
*);
135 static inline void svc_xprt_get(struct svc_xprt
*xprt
)
137 kref_get(&xprt
->xpt_ref
);
139 static inline void svc_xprt_set_local(struct svc_xprt
*xprt
,
140 const struct sockaddr
*sa
,
143 memcpy(&xprt
->xpt_local
, sa
, salen
);
144 xprt
->xpt_locallen
= salen
;
146 static inline void svc_xprt_set_remote(struct svc_xprt
*xprt
,
147 const struct sockaddr
*sa
,
150 memcpy(&xprt
->xpt_remote
, sa
, salen
);
151 xprt
->xpt_remotelen
= salen
;
153 static inline unsigned short svc_addr_port(const struct sockaddr
*sa
)
155 const struct sockaddr_in
*sin
= (const struct sockaddr_in
*)sa
;
156 const struct sockaddr_in6
*sin6
= (const struct sockaddr_in6
*)sa
;
158 switch (sa
->sa_family
) {
160 return ntohs(sin
->sin_port
);
162 return ntohs(sin6
->sin6_port
);
168 static inline size_t svc_addr_len(const struct sockaddr
*sa
)
170 switch (sa
->sa_family
) {
172 return sizeof(struct sockaddr_in
);
174 return sizeof(struct sockaddr_in6
);
179 static inline unsigned short svc_xprt_local_port(const struct svc_xprt
*xprt
)
181 return svc_addr_port((const struct sockaddr
*)&xprt
->xpt_local
);
184 static inline unsigned short svc_xprt_remote_port(const struct svc_xprt
*xprt
)
186 return svc_addr_port((const struct sockaddr
*)&xprt
->xpt_remote
);
189 static inline char *__svc_print_addr(const struct sockaddr
*addr
,
190 char *buf
, const size_t len
)
192 const struct sockaddr_in
*sin
= (const struct sockaddr_in
*)addr
;
193 const struct sockaddr_in6
*sin6
= (const struct sockaddr_in6
*)addr
;
195 switch (addr
->sa_family
) {
197 snprintf(buf
, len
, "%pI4, port=%u", &sin
->sin_addr
,
198 ntohs(sin
->sin_port
));
202 snprintf(buf
, len
, "%pI6, port=%u",
204 ntohs(sin6
->sin6_port
));
208 snprintf(buf
, len
, "unknown address type: %d", addr
->sa_family
);
214 #endif /* SUNRPC_SVC_XPRT_H */