1
2
3
4
5
6
7
8
9#ifndef _LINUX_SUNRPC_XPRT_H
10#define _LINUX_SUNRPC_XPRT_H
11
12#include <linux/uio.h>
13#include <linux/socket.h>
14#include <linux/in.h>
15#include <linux/kref.h>
16#include <linux/sunrpc/sched.h>
17#include <linux/sunrpc/xdr.h>
18#include <linux/sunrpc/msg_prot.h>
19
20#ifdef __KERNEL__
21
22#define RPC_MIN_SLOT_TABLE (2U)
23#define RPC_DEF_SLOT_TABLE (16U)
24#define RPC_MAX_SLOT_TABLE (128U)
25
26
27
28
29struct rpc_timeout {
30 unsigned long to_initval,
31 to_maxval,
32 to_increment;
33 unsigned int to_retries;
34 unsigned char to_exponential;
35};
36
37enum rpc_display_format_t {
38 RPC_DISPLAY_ADDR = 0,
39 RPC_DISPLAY_PORT,
40 RPC_DISPLAY_PROTO,
41 RPC_DISPLAY_HEX_ADDR,
42 RPC_DISPLAY_HEX_PORT,
43 RPC_DISPLAY_NETID,
44 RPC_DISPLAY_MAX,
45};
46
47struct rpc_task;
48struct rpc_xprt;
49struct seq_file;
50
51
52
53
54struct rpc_rqst {
55
56
57
58 struct rpc_xprt * rq_xprt;
59 struct xdr_buf rq_snd_buf;
60 struct xdr_buf rq_rcv_buf;
61
62
63
64
65 struct rpc_task * rq_task;
66 __be32 rq_xid;
67 int rq_cong;
68 int rq_reply_bytes_recvd;
69
70 u32 rq_seqno;
71 int rq_enc_pages_num;
72 struct page **rq_enc_pages;
73
74 void (*rq_release_snd_buf)(struct rpc_rqst *);
75 struct list_head rq_list;
76
77 __u32 * rq_buffer;
78 size_t rq_callsize,
79 rq_rcvsize;
80
81 struct xdr_buf rq_private_buf;
82
83
84 unsigned long rq_majortimeo;
85 unsigned long rq_timeout;
86 unsigned int rq_retries;
87 unsigned int rq_connect_cookie;
88
89
90
91
92
93
94
95 u32 rq_bytes_sent;
96
97 unsigned long rq_xtime;
98 int rq_ntrans;
99
100#if defined(CONFIG_NFS_V4_1)
101 struct list_head rq_bc_list;
102 unsigned long rq_bc_pa_state;
103 struct list_head rq_bc_pa_list;
104#endif
105};
106#define rq_svec rq_snd_buf.head
107#define rq_slen rq_snd_buf.len
108
109struct rpc_xprt_ops {
110 void (*set_buffer_size)(struct rpc_xprt *xprt, size_t sndsize, size_t rcvsize);
111 int (*reserve_xprt)(struct rpc_task *task);
112 void (*release_xprt)(struct rpc_xprt *xprt, struct rpc_task *task);
113 void (*rpcbind)(struct rpc_task *task);
114 void (*set_port)(struct rpc_xprt *xprt, unsigned short port);
115 void (*connect)(struct rpc_task *task);
116 void * (*buf_alloc)(struct rpc_task *task, size_t size);
117 void (*buf_free)(void *buffer);
118 int (*send_request)(struct rpc_task *task);
119 void (*set_retrans_timeout)(struct rpc_task *task);
120 void (*timer)(struct rpc_task *task);
121 void (*release_request)(struct rpc_task *task);
122 void (*close)(struct rpc_xprt *xprt);
123 void (*destroy)(struct rpc_xprt *xprt);
124 void (*print_stats)(struct rpc_xprt *xprt, struct seq_file *seq);
125};
126
127
128
129
130
131
132
133
134
135
136#define XPRT_TRANSPORT_BC (1 << 31)
137enum xprt_transports {
138 XPRT_TRANSPORT_UDP = IPPROTO_UDP,
139 XPRT_TRANSPORT_TCP = IPPROTO_TCP,
140 XPRT_TRANSPORT_BC_TCP = IPPROTO_TCP | XPRT_TRANSPORT_BC,
141 XPRT_TRANSPORT_RDMA = 256
142};
143
144struct rpc_xprt {
145 struct kref kref;
146 struct rpc_xprt_ops * ops;
147
148 const struct rpc_timeout *timeout;
149 struct sockaddr_storage addr;
150 size_t addrlen;
151 int prot;
152
153 unsigned long cong;
154 unsigned long cwnd;
155
156 size_t max_payload;
157
158 unsigned int tsh_size;
159
160
161 struct rpc_wait_queue binding;
162 struct rpc_wait_queue sending;
163 struct rpc_wait_queue resend;
164 struct rpc_wait_queue pending;
165 struct rpc_wait_queue backlog;
166 struct list_head free;
167 struct rpc_rqst * slot;
168 unsigned int max_reqs;
169 unsigned long state;
170 unsigned char shutdown : 1,
171 resvport : 1;
172 unsigned int bind_index;
173
174
175
176
177 unsigned long connect_timeout,
178 bind_timeout,
179 reestablish_timeout;
180 unsigned int connect_cookie;
181
182
183
184
185
186
187 struct work_struct task_cleanup;
188 struct timer_list timer;
189 unsigned long last_used,
190 idle_timeout;
191
192
193
194
195 spinlock_t transport_lock;
196 spinlock_t reserve_lock;
197 u32 xid;
198 struct rpc_task * snd_task;
199 struct svc_xprt *bc_xprt;
200#if defined(CONFIG_NFS_V4_1)
201 struct svc_serv *bc_serv;
202
203 unsigned int bc_alloc_count;
204 spinlock_t bc_pa_lock;
205
206 struct list_head bc_pa_list;
207
208#endif
209 struct list_head recv;
210
211 struct {
212 unsigned long bind_count,
213 connect_count,
214 connect_start,
215 connect_time,
216 sends,
217 recvs,
218 bad_xids;
219
220 unsigned long long req_u,
221 bklog_u;
222 } stat;
223
224 const char *address_strings[RPC_DISPLAY_MAX];
225};
226
227#if defined(CONFIG_NFS_V4_1)
228
229
230
231#define RPC_BC_PA_IN_USE 0x0001
232
233#endif
234
235#if defined(CONFIG_NFS_V4_1)
236static inline int bc_prealloc(struct rpc_rqst *req)
237{
238 return test_bit(RPC_BC_PA_IN_USE, &req->rq_bc_pa_state);
239}
240#else
241static inline int bc_prealloc(struct rpc_rqst *req)
242{
243 return 0;
244}
245#endif
246
247struct xprt_create {
248 int ident;
249 struct sockaddr * srcaddr;
250 struct sockaddr * dstaddr;
251 size_t addrlen;
252 struct svc_xprt *bc_xprt;
253};
254
255struct xprt_class {
256 struct list_head list;
257 int ident;
258 struct rpc_xprt * (*setup)(struct xprt_create *);
259 struct module *owner;
260 char name[32];
261};
262
263
264
265
266struct rpc_xprt *xprt_create_transport(struct xprt_create *args);
267void xprt_connect(struct rpc_task *task);
268void xprt_reserve(struct rpc_task *task);
269int xprt_reserve_xprt(struct rpc_task *task);
270int xprt_reserve_xprt_cong(struct rpc_task *task);
271int xprt_prepare_transmit(struct rpc_task *task);
272void xprt_transmit(struct rpc_task *task);
273void xprt_end_transmit(struct rpc_task *task);
274int xprt_adjust_timeout(struct rpc_rqst *req);
275void xprt_release_xprt(struct rpc_xprt *xprt, struct rpc_task *task);
276void xprt_release_xprt_cong(struct rpc_xprt *xprt, struct rpc_task *task);
277void xprt_release(struct rpc_task *task);
278struct rpc_xprt * xprt_get(struct rpc_xprt *xprt);
279void xprt_put(struct rpc_xprt *xprt);
280
281static inline __be32 *xprt_skip_transport_header(struct rpc_xprt *xprt, __be32 *p)
282{
283 return p + xprt->tsh_size;
284}
285
286
287
288
289int xprt_register_transport(struct xprt_class *type);
290int xprt_unregister_transport(struct xprt_class *type);
291int xprt_load_transport(const char *);
292void xprt_set_retrans_timeout_def(struct rpc_task *task);
293void xprt_set_retrans_timeout_rtt(struct rpc_task *task);
294void xprt_wake_pending_tasks(struct rpc_xprt *xprt, int status);
295void xprt_wait_for_buffer_space(struct rpc_task *task, rpc_action action);
296void xprt_write_space(struct rpc_xprt *xprt);
297void xprt_update_rtt(struct rpc_task *task);
298void xprt_adjust_cwnd(struct rpc_task *task, int result);
299struct rpc_rqst * xprt_lookup_rqst(struct rpc_xprt *xprt, __be32 xid);
300void xprt_complete_rqst(struct rpc_task *task, int copied);
301void xprt_release_rqst_cong(struct rpc_task *task);
302void xprt_disconnect_done(struct rpc_xprt *xprt);
303void xprt_force_disconnect(struct rpc_xprt *xprt);
304void xprt_conditional_disconnect(struct rpc_xprt *xprt, unsigned int cookie);
305
306
307
308
309#define XPRT_LOCKED (0)
310#define XPRT_CONNECTED (1)
311#define XPRT_CONNECTING (2)
312#define XPRT_CLOSE_WAIT (3)
313#define XPRT_BOUND (4)
314#define XPRT_BINDING (5)
315#define XPRT_CLOSING (6)
316#define XPRT_CONNECTION_ABORT (7)
317#define XPRT_CONNECTION_CLOSE (8)
318
319static inline void xprt_set_connected(struct rpc_xprt *xprt)
320{
321 set_bit(XPRT_CONNECTED, &xprt->state);
322}
323
324static inline void xprt_clear_connected(struct rpc_xprt *xprt)
325{
326 clear_bit(XPRT_CONNECTED, &xprt->state);
327}
328
329static inline int xprt_connected(struct rpc_xprt *xprt)
330{
331 return test_bit(XPRT_CONNECTED, &xprt->state);
332}
333
334static inline int xprt_test_and_set_connected(struct rpc_xprt *xprt)
335{
336 return test_and_set_bit(XPRT_CONNECTED, &xprt->state);
337}
338
339static inline int xprt_test_and_clear_connected(struct rpc_xprt *xprt)
340{
341 return test_and_clear_bit(XPRT_CONNECTED, &xprt->state);
342}
343
344static inline void xprt_clear_connecting(struct rpc_xprt *xprt)
345{
346 smp_mb__before_clear_bit();
347 clear_bit(XPRT_CONNECTING, &xprt->state);
348 smp_mb__after_clear_bit();
349}
350
351static inline int xprt_connecting(struct rpc_xprt *xprt)
352{
353 return test_bit(XPRT_CONNECTING, &xprt->state);
354}
355
356static inline int xprt_test_and_set_connecting(struct rpc_xprt *xprt)
357{
358 return test_and_set_bit(XPRT_CONNECTING, &xprt->state);
359}
360
361static inline void xprt_set_bound(struct rpc_xprt *xprt)
362{
363 test_and_set_bit(XPRT_BOUND, &xprt->state);
364}
365
366static inline int xprt_bound(struct rpc_xprt *xprt)
367{
368 return test_bit(XPRT_BOUND, &xprt->state);
369}
370
371static inline void xprt_clear_bound(struct rpc_xprt *xprt)
372{
373 clear_bit(XPRT_BOUND, &xprt->state);
374}
375
376static inline void xprt_clear_binding(struct rpc_xprt *xprt)
377{
378 smp_mb__before_clear_bit();
379 clear_bit(XPRT_BINDING, &xprt->state);
380 smp_mb__after_clear_bit();
381}
382
383static inline int xprt_test_and_set_binding(struct rpc_xprt *xprt)
384{
385 return test_and_set_bit(XPRT_BINDING, &xprt->state);
386}
387
388#endif
389
390#endif
391