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/idr.h>
39#include <linux/sunrpc/svc_xprt.h>
40#include "nfsfh.h"
41
42typedef struct {
43 u32 cl_boot;
44 u32 cl_id;
45} clientid_t;
46
47typedef struct {
48 clientid_t so_clid;
49 u32 so_id;
50} stateid_opaque_t;
51
52typedef struct {
53 u32 si_generation;
54 stateid_opaque_t si_opaque;
55} stateid_t;
56
57#define STATEID_FMT "(%08x/%08x/%08x/%08x)"
58#define STATEID_VAL(s) \
59 (s)->si_opaque.so_clid.cl_boot, \
60 (s)->si_opaque.so_clid.cl_id, \
61 (s)->si_opaque.so_id, \
62 (s)->si_generation
63
64struct nfsd4_callback {
65 struct nfs4_client *cb_clp;
66 struct rpc_message cb_msg;
67 const struct nfsd4_callback_ops *cb_ops;
68 struct work_struct cb_work;
69 int cb_seq_status;
70 int cb_status;
71 bool cb_need_restart;
72};
73
74struct nfsd4_callback_ops {
75 void (*prepare)(struct nfsd4_callback *);
76 int (*done)(struct nfsd4_callback *, struct rpc_task *);
77 void (*release)(struct nfsd4_callback *);
78};
79
80
81
82
83
84
85struct nfs4_stid {
86 atomic_t sc_count;
87#define NFS4_OPEN_STID 1
88#define NFS4_LOCK_STID 2
89#define NFS4_DELEG_STID 4
90
91#define NFS4_CLOSED_STID 8
92
93#define NFS4_REVOKED_DELEG_STID 16
94#define NFS4_CLOSED_DELEG_STID 32
95#define NFS4_LAYOUT_STID 64
96 unsigned char sc_type;
97 stateid_t sc_stateid;
98 spinlock_t sc_lock;
99 struct nfs4_client *sc_client;
100 struct nfs4_file *sc_file;
101 void (*sc_free)(struct nfs4_stid *);
102};
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125struct nfs4_delegation {
126 struct nfs4_stid dl_stid;
127 struct list_head dl_perfile;
128 struct list_head dl_perclnt;
129 struct list_head dl_recall_lru;
130 struct nfs4_clnt_odstate *dl_clnt_odstate;
131 u32 dl_type;
132 time_t dl_time;
133
134 int dl_retries;
135 struct nfsd4_callback dl_recall;
136};
137
138#define cb_to_delegation(cb) \
139 container_of(cb, struct nfs4_delegation, dl_recall)
140
141
142struct nfs4_cb_conn {
143
144 struct sockaddr_storage cb_addr;
145 struct sockaddr_storage cb_saddr;
146 size_t cb_addrlen;
147 u32 cb_prog;
148
149 u32 cb_ident;
150 struct svc_xprt *cb_xprt;
151};
152
153static inline struct nfs4_delegation *delegstateid(struct nfs4_stid *s)
154{
155 return container_of(s, struct nfs4_delegation, dl_stid);
156}
157
158
159#define NFSD_MAX_SLOTS_PER_SESSION 160
160
161#define NFSD_MAX_OPS_PER_COMPOUND 16
162
163#define NFSD_SLOT_CACHE_SIZE 2048
164
165#define NFSD_CACHE_SIZE_SLOTS_PER_SESSION 32
166#define NFSD_MAX_MEM_PER_SESSION \
167 (NFSD_CACHE_SIZE_SLOTS_PER_SESSION * NFSD_SLOT_CACHE_SIZE)
168
169struct nfsd4_slot {
170 u32 sl_seqid;
171 __be32 sl_status;
172 u32 sl_datalen;
173 u16 sl_opcnt;
174#define NFSD4_SLOT_INUSE (1 << 0)
175#define NFSD4_SLOT_CACHETHIS (1 << 1)
176#define NFSD4_SLOT_INITIALIZED (1 << 2)
177 u8 sl_flags;
178 char sl_data[];
179};
180
181struct nfsd4_channel_attrs {
182 u32 headerpadsz;
183 u32 maxreq_sz;
184 u32 maxresp_sz;
185 u32 maxresp_cached;
186 u32 maxops;
187 u32 maxreqs;
188 u32 nr_rdma_attrs;
189 u32 rdma_attrs;
190};
191
192struct nfsd4_cb_sec {
193 u32 flavor;
194 kuid_t uid;
195 kgid_t gid;
196};
197
198struct nfsd4_create_session {
199 clientid_t clientid;
200 struct nfs4_sessionid sessionid;
201 u32 seqid;
202 u32 flags;
203 struct nfsd4_channel_attrs fore_channel;
204 struct nfsd4_channel_attrs back_channel;
205 u32 callback_prog;
206 struct nfsd4_cb_sec cb_sec;
207};
208
209struct nfsd4_backchannel_ctl {
210 u32 bc_cb_program;
211 struct nfsd4_cb_sec bc_cb_sec;
212};
213
214struct nfsd4_bind_conn_to_session {
215 struct nfs4_sessionid sessionid;
216 u32 dir;
217};
218
219
220struct nfsd4_clid_slot {
221 u32 sl_seqid;
222 __be32 sl_status;
223 struct nfsd4_create_session sl_cr_ses;
224};
225
226struct nfsd4_conn {
227 struct list_head cn_persession;
228 struct svc_xprt *cn_xprt;
229 struct svc_xpt_user cn_xpt_user;
230 struct nfsd4_session *cn_session;
231
232 unsigned char cn_flags;
233};
234
235
236
237
238
239
240struct nfsd4_session {
241 atomic_t se_ref;
242 struct list_head se_hash;
243 struct list_head se_perclnt;
244
245#define NFS4_SESSION_DEAD 0x010
246 u32 se_flags;
247 struct nfs4_client *se_client;
248 struct nfs4_sessionid se_sessionid;
249 struct nfsd4_channel_attrs se_fchannel;
250 struct nfsd4_channel_attrs se_bchannel;
251 struct nfsd4_cb_sec se_cb_sec;
252 struct list_head se_conns;
253 u32 se_cb_prog;
254 u32 se_cb_seq_nr;
255 struct nfsd4_slot *se_slots[];
256};
257
258
259struct nfsd4_sessionid {
260 clientid_t clientid;
261 u32 sequence;
262 u32 reserved;
263};
264
265#define HEXDIR_LEN 33
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294struct nfs4_client {
295 struct list_head cl_idhash;
296 struct rb_node cl_namenode;
297 struct list_head *cl_ownerstr_hashtbl;
298 struct list_head cl_openowners;
299 struct idr cl_stateids;
300 struct list_head cl_delegations;
301 struct list_head cl_revoked;
302 struct list_head cl_lru;
303#ifdef CONFIG_NFSD_PNFS
304 struct list_head cl_lo_states;
305#endif
306 struct xdr_netobj cl_name;
307 nfs4_verifier cl_verifier;
308 time_t cl_time;
309 struct sockaddr_storage cl_addr;
310 bool cl_mach_cred;
311 struct svc_cred cl_cred;
312 clientid_t cl_clientid;
313 nfs4_verifier cl_confirm;
314 u32 cl_minorversion;
315
316
317 struct nfs4_cb_conn cl_cb_conn;
318#define NFSD4_CLIENT_CB_UPDATE (0)
319#define NFSD4_CLIENT_CB_KILL (1)
320#define NFSD4_CLIENT_STABLE (2)
321#define NFSD4_CLIENT_RECLAIM_COMPLETE (3)
322#define NFSD4_CLIENT_CONFIRMED (4)
323#define NFSD4_CLIENT_UPCALL_LOCK (5)
324#define NFSD4_CLIENT_CB_FLAG_MASK (1 << NFSD4_CLIENT_CB_UPDATE | \
325 1 << NFSD4_CLIENT_CB_KILL)
326 unsigned long cl_flags;
327 struct rpc_cred *cl_cb_cred;
328 struct rpc_clnt *cl_cb_client;
329 u32 cl_cb_ident;
330#define NFSD4_CB_UP 0
331#define NFSD4_CB_UNKNOWN 1
332#define NFSD4_CB_DOWN 2
333#define NFSD4_CB_FAULT 3
334 int cl_cb_state;
335 struct nfsd4_callback cl_cb_null;
336 struct nfsd4_session *cl_cb_session;
337
338
339 spinlock_t cl_lock;
340
341
342 struct list_head cl_sessions;
343 struct nfsd4_clid_slot cl_cs_slot;
344 u32 cl_exchange_flags;
345
346 atomic_t cl_refcount;
347 struct nfs4_op_map cl_spo_must_allow;
348
349
350
351 unsigned long cl_cb_slot_busy;
352 struct rpc_wait_queue cl_cb_waitq;
353
354 struct net *net;
355};
356
357
358
359
360
361
362struct nfs4_client_reclaim {
363 struct list_head cr_strhash;
364 struct nfs4_client *cr_clp;
365 char cr_recdir[HEXDIR_LEN];
366};
367
368
369
370
371
372
373
374
375#define NFSD4_REPLAY_ISIZE 112
376
377
378
379
380
381struct nfs4_replay {
382 __be32 rp_status;
383 unsigned int rp_buflen;
384 char *rp_buf;
385 struct knfsd_fh rp_openfh;
386 struct mutex rp_mutex;
387 char rp_ibuf[NFSD4_REPLAY_ISIZE];
388};
389
390struct nfs4_stateowner;
391
392struct nfs4_stateowner_operations {
393 void (*so_unhash)(struct nfs4_stateowner *);
394 void (*so_free)(struct nfs4_stateowner *);
395};
396
397
398
399
400
401
402
403struct nfs4_stateowner {
404 struct list_head so_strhash;
405 struct list_head so_stateids;
406 struct nfs4_client *so_client;
407 const struct nfs4_stateowner_operations *so_ops;
408
409
410 atomic_t so_count;
411 u32 so_seqid;
412 struct xdr_netobj so_owner;
413 struct nfs4_replay so_replay;
414 bool so_is_open_owner;
415};
416
417
418
419
420
421
422
423struct nfs4_openowner {
424 struct nfs4_stateowner oo_owner;
425 struct list_head oo_perclient;
426
427
428
429
430
431
432
433 struct list_head oo_close_lru;
434 struct nfs4_ol_stateid *oo_last_closed_stid;
435 time_t oo_time;
436#define NFS4_OO_CONFIRMED 1
437 unsigned char oo_flags;
438};
439
440
441
442
443
444
445struct nfs4_lockowner {
446 struct nfs4_stateowner lo_owner;
447 struct list_head lo_blocked;
448};
449
450static inline struct nfs4_openowner * openowner(struct nfs4_stateowner *so)
451{
452 return container_of(so, struct nfs4_openowner, oo_owner);
453}
454
455static inline struct nfs4_lockowner * lockowner(struct nfs4_stateowner *so)
456{
457 return container_of(so, struct nfs4_lockowner, lo_owner);
458}
459
460
461
462
463
464struct nfs4_clnt_odstate {
465 struct nfs4_client *co_client;
466 struct nfs4_file *co_file;
467 struct list_head co_perfile;
468 atomic_t co_odcount;
469};
470
471
472
473
474
475
476
477
478
479
480
481
482
483struct nfs4_file {
484 atomic_t fi_ref;
485 spinlock_t fi_lock;
486 struct hlist_node fi_hash;
487 struct list_head fi_stateids;
488 union {
489 struct list_head fi_delegations;
490 struct rcu_head fi_rcu;
491 };
492 struct list_head fi_clnt_odstate;
493
494 struct file * fi_fds[3];
495
496
497
498
499
500
501
502 atomic_t fi_access[2];
503 u32 fi_share_deny;
504 struct file *fi_deleg_file;
505 int fi_delegees;
506 struct knfsd_fh fi_fhandle;
507 bool fi_had_conflict;
508#ifdef CONFIG_NFSD_PNFS
509 struct list_head fi_lo_states;
510 atomic_t fi_lo_recalls;
511#endif
512};
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528struct nfs4_ol_stateid {
529 struct nfs4_stid st_stid;
530 struct list_head st_perfile;
531 struct list_head st_perstateowner;
532 struct list_head st_locks;
533 struct nfs4_stateowner *st_stateowner;
534 struct nfs4_clnt_odstate *st_clnt_odstate;
535 unsigned char st_access_bmap;
536 unsigned char st_deny_bmap;
537 struct nfs4_ol_stateid *st_openstp;
538 struct mutex st_mutex;
539};
540
541static inline struct nfs4_ol_stateid *openlockstateid(struct nfs4_stid *s)
542{
543 return container_of(s, struct nfs4_ol_stateid, st_stid);
544}
545
546struct nfs4_layout_stateid {
547 struct nfs4_stid ls_stid;
548 struct list_head ls_perclnt;
549 struct list_head ls_perfile;
550 spinlock_t ls_lock;
551 struct list_head ls_layouts;
552 u32 ls_layout_type;
553 struct file *ls_file;
554 struct nfsd4_callback ls_recall;
555 stateid_t ls_recall_sid;
556 bool ls_recalled;
557 struct mutex ls_mutex;
558};
559
560static inline struct nfs4_layout_stateid *layoutstateid(struct nfs4_stid *s)
561{
562 return container_of(s, struct nfs4_layout_stateid, ls_stid);
563}
564
565
566#define RD_STATE 0x00000010
567#define WR_STATE 0x00000020
568
569enum nfsd4_cb_op {
570 NFSPROC4_CLNT_CB_NULL = 0,
571 NFSPROC4_CLNT_CB_RECALL,
572 NFSPROC4_CLNT_CB_LAYOUT,
573 NFSPROC4_CLNT_CB_SEQUENCE,
574 NFSPROC4_CLNT_CB_NOTIFY_LOCK,
575};
576
577
578static inline bool nfsd4_stateid_generation_after(stateid_t *a, stateid_t *b)
579{
580 return (s32)(a->si_generation - b->si_generation) > 0;
581}
582
583
584
585
586
587
588struct nfsd4_blocked_lock {
589 struct list_head nbl_list;
590 struct list_head nbl_lru;
591 unsigned long nbl_time;
592 struct file_lock nbl_lock;
593 struct knfsd_fh nbl_fh;
594 struct nfsd4_callback nbl_cb;
595};
596
597struct nfsd4_compound_state;
598struct nfsd_net;
599
600extern __be32 nfs4_preprocess_stateid_op(struct svc_rqst *rqstp,
601 struct nfsd4_compound_state *cstate, struct svc_fh *fhp,
602 stateid_t *stateid, int flags, struct file **filp, bool *tmp_file);
603__be32 nfsd4_lookup_stateid(struct nfsd4_compound_state *cstate,
604 stateid_t *stateid, unsigned char typemask,
605 struct nfs4_stid **s, struct nfsd_net *nn);
606struct nfs4_stid *nfs4_alloc_stid(struct nfs4_client *cl, struct kmem_cache *slab,
607 void (*sc_free)(struct nfs4_stid *));
608void nfs4_unhash_stid(struct nfs4_stid *s);
609void nfs4_put_stid(struct nfs4_stid *s);
610void nfs4_inc_and_copy_stateid(stateid_t *dst, struct nfs4_stid *stid);
611void nfs4_remove_reclaim_record(struct nfs4_client_reclaim *, struct nfsd_net *);
612extern void nfs4_release_reclaim(struct nfsd_net *);
613extern struct nfs4_client_reclaim *nfsd4_find_reclaim_client(const char *recdir,
614 struct nfsd_net *nn);
615extern __be32 nfs4_check_open_reclaim(clientid_t *clid,
616 struct nfsd4_compound_state *cstate, struct nfsd_net *nn);
617extern int set_callback_cred(void);
618extern void cleanup_callback_cred(void);
619extern void nfsd4_probe_callback(struct nfs4_client *clp);
620extern void nfsd4_probe_callback_sync(struct nfs4_client *clp);
621extern void nfsd4_change_callback(struct nfs4_client *clp, struct nfs4_cb_conn *);
622extern void nfsd4_init_cb(struct nfsd4_callback *cb, struct nfs4_client *clp,
623 const struct nfsd4_callback_ops *ops, enum nfsd4_cb_op op);
624extern void nfsd4_run_cb(struct nfsd4_callback *cb);
625extern int nfsd4_create_callback_queue(void);
626extern void nfsd4_destroy_callback_queue(void);
627extern void nfsd4_shutdown_callback(struct nfs4_client *);
628extern void nfsd4_prepare_cb_recall(struct nfs4_delegation *dp);
629extern struct nfs4_client_reclaim *nfs4_client_to_reclaim(const char *name,
630 struct nfsd_net *nn);
631extern bool nfs4_has_reclaimed_state(const char *name, struct nfsd_net *nn);
632
633struct nfs4_file *find_file(struct knfsd_fh *fh);
634void put_nfs4_file(struct nfs4_file *fi);
635static inline void get_nfs4_file(struct nfs4_file *fi)
636{
637 atomic_inc(&fi->fi_ref);
638}
639struct file *find_any_file(struct nfs4_file *f);
640
641
642void nfsd4_end_grace(struct nfsd_net *nn);
643
644
645extern int nfsd4_client_tracking_init(struct net *net);
646extern void nfsd4_client_tracking_exit(struct net *net);
647extern void nfsd4_client_record_create(struct nfs4_client *clp);
648extern void nfsd4_client_record_remove(struct nfs4_client *clp);
649extern int nfsd4_client_record_check(struct nfs4_client *clp);
650extern void nfsd4_record_grace_done(struct nfsd_net *nn);
651
652
653#ifdef CONFIG_NFSD_FAULT_INJECTION
654int nfsd_fault_inject_init(void);
655void nfsd_fault_inject_cleanup(void);
656
657u64 nfsd_inject_print_clients(void);
658u64 nfsd_inject_forget_client(struct sockaddr_storage *, size_t);
659u64 nfsd_inject_forget_clients(u64);
660
661u64 nfsd_inject_print_locks(void);
662u64 nfsd_inject_forget_client_locks(struct sockaddr_storage *, size_t);
663u64 nfsd_inject_forget_locks(u64);
664
665u64 nfsd_inject_print_openowners(void);
666u64 nfsd_inject_forget_client_openowners(struct sockaddr_storage *, size_t);
667u64 nfsd_inject_forget_openowners(u64);
668
669u64 nfsd_inject_print_delegations(void);
670u64 nfsd_inject_forget_client_delegations(struct sockaddr_storage *, size_t);
671u64 nfsd_inject_forget_delegations(u64);
672u64 nfsd_inject_recall_client_delegations(struct sockaddr_storage *, size_t);
673u64 nfsd_inject_recall_delegations(u64);
674#else
675static inline int nfsd_fault_inject_init(void) { return 0; }
676static inline void nfsd_fault_inject_cleanup(void) {}
677#endif
678
679#endif
680