1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35#ifndef _NFSD4_STATE_H
36#define _NFSD4_STATE_H
37
38#include <linux/sunrpc/svc_xprt.h>
39#include <linux/nfsd/nfsfh.h>
40#include "nfsfh.h"
41
42typedef struct {
43 u32 cl_boot;
44 u32 cl_id;
45} clientid_t;
46
47typedef struct {
48 u32 so_boot;
49 u32 so_stateownerid;
50 u32 so_fileid;
51} stateid_opaque_t;
52
53typedef struct {
54 u32 si_generation;
55 stateid_opaque_t si_opaque;
56} stateid_t;
57#define si_boot si_opaque.so_boot
58#define si_stateownerid si_opaque.so_stateownerid
59#define si_fileid si_opaque.so_fileid
60
61#define STATEID_FMT "(%08x/%08x/%08x/%08x)"
62#define STATEID_VAL(s) \
63 (s)->si_boot, \
64 (s)->si_stateownerid, \
65 (s)->si_fileid, \
66 (s)->si_generation
67
68struct nfsd4_callback {
69 void *cb_op;
70 struct nfs4_client *cb_clp;
71 struct list_head cb_per_client;
72 u32 cb_minorversion;
73 struct rpc_message cb_msg;
74 const struct rpc_call_ops *cb_ops;
75 struct work_struct cb_work;
76 bool cb_done;
77};
78
79struct nfs4_delegation {
80 struct list_head dl_perfile;
81 struct list_head dl_perclnt;
82 struct list_head dl_recall_lru;
83 atomic_t dl_count;
84 struct nfs4_client *dl_client;
85 struct nfs4_file *dl_file;
86 u32 dl_type;
87 time_t dl_time;
88
89 stateid_t dl_stateid;
90 struct knfsd_fh dl_fh;
91 int dl_retries;
92 struct nfsd4_callback dl_recall;
93};
94
95
96struct nfs4_cb_conn {
97
98 struct sockaddr_storage cb_addr;
99 struct sockaddr_storage cb_saddr;
100 size_t cb_addrlen;
101 u32 cb_prog;
102
103 u32 cb_ident;
104 struct svc_xprt *cb_xprt;
105};
106
107
108#define NFSD_MAX_SLOTS_PER_SESSION 160
109
110#define NFSD_MAX_OPS_PER_COMPOUND 16
111
112#define NFSD_SLOT_CACHE_SIZE 1024
113
114#define NFSD_CACHE_SIZE_SLOTS_PER_SESSION 32
115#define NFSD_MAX_MEM_PER_SESSION \
116 (NFSD_CACHE_SIZE_SLOTS_PER_SESSION * NFSD_SLOT_CACHE_SIZE)
117
118struct nfsd4_slot {
119 bool sl_inuse;
120 bool sl_cachethis;
121 u16 sl_opcnt;
122 u32 sl_seqid;
123 __be32 sl_status;
124 u32 sl_datalen;
125 char sl_data[];
126};
127
128struct nfsd4_channel_attrs {
129 u32 headerpadsz;
130 u32 maxreq_sz;
131 u32 maxresp_sz;
132 u32 maxresp_cached;
133 u32 maxops;
134 u32 maxreqs;
135 u32 nr_rdma_attrs;
136 u32 rdma_attrs;
137};
138
139struct nfsd4_create_session {
140 clientid_t clientid;
141 struct nfs4_sessionid sessionid;
142 u32 seqid;
143 u32 flags;
144 struct nfsd4_channel_attrs fore_channel;
145 struct nfsd4_channel_attrs back_channel;
146 u32 callback_prog;
147 u32 uid;
148 u32 gid;
149};
150
151struct nfsd4_bind_conn_to_session {
152 struct nfs4_sessionid sessionid;
153 u32 dir;
154};
155
156
157struct nfsd4_clid_slot {
158 u32 sl_seqid;
159 __be32 sl_status;
160 struct nfsd4_create_session sl_cr_ses;
161};
162
163struct nfsd4_conn {
164 struct list_head cn_persession;
165 struct svc_xprt *cn_xprt;
166 struct svc_xpt_user cn_xpt_user;
167 struct nfsd4_session *cn_session;
168
169 unsigned char cn_flags;
170};
171
172struct nfsd4_session {
173 struct kref se_ref;
174 struct list_head se_hash;
175 struct list_head se_perclnt;
176 u32 se_flags;
177 struct nfs4_client *se_client;
178 struct nfs4_sessionid se_sessionid;
179 struct nfsd4_channel_attrs se_fchannel;
180 struct nfsd4_channel_attrs se_bchannel;
181 struct list_head se_conns;
182 u32 se_cb_prog;
183 u32 se_cb_seq_nr;
184 struct nfsd4_slot *se_slots[];
185};
186
187static inline void
188nfsd4_put_session(struct nfsd4_session *ses)
189{
190 extern void free_session(struct kref *kref);
191 kref_put(&ses->se_ref, free_session);
192}
193
194static inline void
195nfsd4_get_session(struct nfsd4_session *ses)
196{
197 kref_get(&ses->se_ref);
198}
199
200
201struct nfsd4_sessionid {
202 clientid_t clientid;
203 u32 sequence;
204 u32 reserved;
205};
206
207#define HEXDIR_LEN 33
208
209
210
211
212
213
214
215
216
217
218
219struct nfs4_client {
220 struct list_head cl_idhash;
221 struct list_head cl_strhash;
222 struct list_head cl_openowners;
223 struct list_head cl_delegations;
224 struct list_head cl_lru;
225 struct xdr_netobj cl_name;
226 char cl_recdir[HEXDIR_LEN];
227 nfs4_verifier cl_verifier;
228 time_t cl_time;
229 struct sockaddr_storage cl_addr;
230 u32 cl_flavor;
231 char *cl_principal;
232 struct svc_cred cl_cred;
233 clientid_t cl_clientid;
234 nfs4_verifier cl_confirm;
235 u32 cl_firststate;
236 u32 cl_minorversion;
237
238
239 struct nfs4_cb_conn cl_cb_conn;
240#define NFSD4_CLIENT_CB_UPDATE 1
241#define NFSD4_CLIENT_KILL 2
242 unsigned long cl_cb_flags;
243 struct rpc_clnt *cl_cb_client;
244 u32 cl_cb_ident;
245#define NFSD4_CB_UP 0
246#define NFSD4_CB_UNKNOWN 1
247#define NFSD4_CB_DOWN 2
248 int cl_cb_state;
249 struct nfsd4_callback cl_cb_null;
250 struct nfsd4_session *cl_cb_session;
251 struct list_head cl_callbacks;
252
253
254 spinlock_t cl_lock;
255
256
257 struct list_head cl_sessions;
258 struct nfsd4_clid_slot cl_cs_slot;
259 u32 cl_exchange_flags;
260
261 atomic_t cl_refcount;
262
263
264
265 unsigned long cl_cb_slot_busy;
266 struct rpc_wait_queue cl_cb_waitq;
267
268};
269
270static inline void
271mark_client_expired(struct nfs4_client *clp)
272{
273 clp->cl_time = 0;
274}
275
276static inline bool
277is_client_expired(struct nfs4_client *clp)
278{
279 return clp->cl_time == 0;
280}
281
282
283
284
285
286
287struct nfs4_client_reclaim {
288 struct list_head cr_strhash;
289 char cr_recdir[HEXDIR_LEN];
290};
291
292static inline void
293update_stateid(stateid_t *stateid)
294{
295 stateid->si_generation++;
296}
297
298
299
300
301
302
303
304
305#define NFSD4_REPLAY_ISIZE 112
306
307
308
309
310
311struct nfs4_replay {
312 __be32 rp_status;
313 unsigned int rp_buflen;
314 char *rp_buf;
315 unsigned intrp_allocated;
316 struct knfsd_fh rp_openfh;
317 char rp_ibuf[NFSD4_REPLAY_ISIZE];
318};
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338struct nfs4_stateowner {
339 struct kref so_ref;
340 struct list_head so_idhash;
341 struct list_head so_strhash;
342 struct list_head so_perclient;
343 struct list_head so_stateids;
344 struct list_head so_perstateid;
345 struct list_head so_close_lru;
346 time_t so_time;
347 int so_is_open_owner;
348 u32 so_id;
349 struct nfs4_client * so_client;
350
351
352 u32 so_seqid;
353 struct xdr_netobj so_owner;
354 int so_confirmed;
355 struct nfs4_replay so_replay;
356};
357
358
359
360
361
362
363struct nfs4_file {
364 atomic_t fi_ref;
365 struct list_head fi_hash;
366 struct list_head fi_stateids;
367 struct list_head fi_delegations;
368
369 struct file * fi_fds[3];
370
371 atomic_t fi_access[2];
372
373
374
375
376
377
378 atomic_t fi_readers;
379 atomic_t fi_writers;
380 struct file *fi_deleg_file;
381 struct file_lock *fi_lease;
382 atomic_t fi_delegees;
383 struct inode *fi_inode;
384 u32 fi_id;
385
386 bool fi_had_conflict;
387};
388
389
390
391static inline struct file *find_writeable_file(struct nfs4_file *f)
392{
393 if (f->fi_fds[O_WRONLY])
394 return f->fi_fds[O_WRONLY];
395 return f->fi_fds[O_RDWR];
396}
397
398static inline struct file *find_readable_file(struct nfs4_file *f)
399{
400 if (f->fi_fds[O_RDONLY])
401 return f->fi_fds[O_RDONLY];
402 return f->fi_fds[O_RDWR];
403}
404
405static inline struct file *find_any_file(struct nfs4_file *f)
406{
407 if (f->fi_fds[O_RDWR])
408 return f->fi_fds[O_RDWR];
409 else if (f->fi_fds[O_WRONLY])
410 return f->fi_fds[O_WRONLY];
411 else
412 return f->fi_fds[O_RDONLY];
413}
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432struct nfs4_stateid {
433 struct list_head st_hash;
434 struct list_head st_perfile;
435 struct list_head st_perstateowner;
436 struct list_head st_lockowners;
437 struct nfs4_stateowner * st_stateowner;
438 struct nfs4_file * st_file;
439 stateid_t st_stateid;
440 unsigned long st_access_bmap;
441 unsigned long st_deny_bmap;
442 struct nfs4_stateid * st_openstp;
443};
444
445
446#define HAS_SESSION 0x00000001
447#define CONFIRM 0x00000002
448#define OPEN_STATE 0x00000004
449#define LOCK_STATE 0x00000008
450#define RD_STATE 0x00000010
451#define WR_STATE 0x00000020
452#define CLOSE_STATE 0x00000040
453
454#define seqid_mutating_err(err) \
455 (((err) != nfserr_stale_clientid) && \
456 ((err) != nfserr_bad_seqid) && \
457 ((err) != nfserr_stale_stateid) && \
458 ((err) != nfserr_bad_stateid))
459
460struct nfsd4_compound_state;
461
462extern __be32 nfs4_preprocess_stateid_op(struct nfsd4_compound_state *cstate,
463 stateid_t *stateid, int flags, struct file **filp);
464extern void nfs4_lock_state(void);
465extern void nfs4_unlock_state(void);
466extern int nfs4_in_grace(void);
467extern __be32 nfs4_check_open_reclaim(clientid_t *clid);
468extern void nfs4_free_stateowner(struct kref *kref);
469extern int set_callback_cred(void);
470extern void nfsd4_probe_callback(struct nfs4_client *clp);
471extern void nfsd4_probe_callback_sync(struct nfs4_client *clp);
472extern void nfsd4_change_callback(struct nfs4_client *clp, struct nfs4_cb_conn *);
473extern void nfsd4_do_callback_rpc(struct work_struct *);
474extern void nfsd4_cb_recall(struct nfs4_delegation *dp);
475extern int nfsd4_create_callback_queue(void);
476extern void nfsd4_destroy_callback_queue(void);
477extern void nfsd4_shutdown_callback(struct nfs4_client *);
478extern void nfs4_put_delegation(struct nfs4_delegation *dp);
479extern __be32 nfs4_make_rec_clidname(char *clidname, struct xdr_netobj *clname);
480extern void nfsd4_init_recdir(char *recdir_name);
481extern int nfsd4_recdir_load(void);
482extern void nfsd4_shutdown_recdir(void);
483extern int nfs4_client_to_reclaim(const char *name);
484extern int nfs4_has_reclaimed_state(const char *name, bool use_exchange_id);
485extern void nfsd4_recdir_purge_old(void);
486extern int nfsd4_create_clid_dir(struct nfs4_client *clp);
487extern void nfsd4_remove_clid_dir(struct nfs4_client *clp);
488extern void release_session_client(struct nfsd4_session *);
489
490static inline void
491nfs4_put_stateowner(struct nfs4_stateowner *so)
492{
493 kref_put(&so->so_ref, nfs4_free_stateowner);
494}
495
496static inline void
497nfs4_get_stateowner(struct nfs4_stateowner *so)
498{
499 kref_get(&so->so_ref);
500}
501
502#endif
503