]> git.proxmox.com Git - mirror_ubuntu-focal-kernel.git/blame - fs/nfs/delegation.c
NFSv4: Fix nfs_server_return_all_delegations
[mirror_ubuntu-focal-kernel.git] / fs / nfs / delegation.c
CommitLineData
1da177e4
LT
1/*
2 * linux/fs/nfs/delegation.c
3 *
4 * Copyright (C) 2004 Trond Myklebust
5 *
6 * NFS file delegation management
7 *
8 */
1da177e4 9#include <linux/completion.h>
58d9714a 10#include <linux/kthread.h>
1da177e4
LT
11#include <linux/module.h>
12#include <linux/sched.h>
5a0e3ad6 13#include <linux/slab.h>
1da177e4
LT
14#include <linux/spinlock.h>
15
16#include <linux/nfs4.h>
17#include <linux/nfs_fs.h>
18#include <linux/nfs_xdr.h>
19
4ce79717 20#include "nfs4_fs.h"
1da177e4 21#include "delegation.h"
24c8dbbb 22#include "internal.h"
1da177e4 23
905f8d16
TM
24static void nfs_free_delegation(struct nfs_delegation *delegation)
25{
e00b8a24
TM
26 if (delegation->cred) {
27 put_rpccred(delegation->cred);
28 delegation->cred = NULL;
29 }
26f04dde 30 kfree_rcu(delegation, rcu);
8383e460
TM
31}
32
d3978bb3
CL
33/**
34 * nfs_mark_delegation_referenced - set delegation's REFERENCED flag
35 * @delegation: delegation to process
36 *
37 */
b7391f44
TM
38void nfs_mark_delegation_referenced(struct nfs_delegation *delegation)
39{
40 set_bit(NFS_DELEGATION_REFERENCED, &delegation->flags);
41}
42
d3978bb3
CL
43/**
44 * nfs_have_delegation - check if inode has a delegation
45 * @inode: inode to check
46 * @flags: delegation types to check for
47 *
48 * Returns one if inode has the indicated delegation, otherwise zero.
49 */
011e2a7f 50int nfs4_have_delegation(struct inode *inode, fmode_t flags)
b7391f44
TM
51{
52 struct nfs_delegation *delegation;
53 int ret = 0;
54
55 flags &= FMODE_READ|FMODE_WRITE;
56 rcu_read_lock();
57 delegation = rcu_dereference(NFS_I(inode)->delegation);
d25be546
TM
58 if (delegation != NULL && (delegation->type & flags) == flags &&
59 !test_bit(NFS_DELEGATION_RETURNING, &delegation->flags)) {
b7391f44
TM
60 nfs_mark_delegation_referenced(delegation);
61 ret = 1;
62 }
63 rcu_read_unlock();
64 return ret;
65}
66
db4f2e63 67static int nfs_delegation_claim_locks(struct nfs_open_context *ctx, struct nfs4_state *state, const nfs4_stateid *stateid)
888e694c
TM
68{
69 struct inode *inode = state->inode;
70 struct file_lock *fl;
d5122201 71 int status = 0;
888e694c 72
3f09df70 73 if (inode->i_flock == NULL)
65b62a29 74 return 0;
3f09df70 75
65b62a29
TM
76 if (inode->i_flock == NULL)
77 goto out;
b89f4321
AB
78 /* Protect inode->i_flock using the file locks lock */
79 lock_flocks();
90dc7d27 80 for (fl = inode->i_flock; fl != NULL; fl = fl->fl_next) {
888e694c
TM
81 if (!(fl->fl_flags & (FL_POSIX|FL_FLOCK)))
82 continue;
cd3758e3 83 if (nfs_file_open_context(fl->fl_file) != ctx)
888e694c 84 continue;
b89f4321 85 unlock_flocks();
db4f2e63 86 status = nfs4_lock_delegation_recall(fl, state, stateid);
d5122201 87 if (status < 0)
3f09df70 88 goto out;
b89f4321 89 lock_flocks();
888e694c 90 }
b89f4321 91 unlock_flocks();
3f09df70 92out:
888e694c
TM
93 return status;
94}
95
d18cc1fd 96static int nfs_delegation_claim_opens(struct inode *inode, const nfs4_stateid *stateid)
1da177e4
LT
97{
98 struct nfs_inode *nfsi = NFS_I(inode);
99 struct nfs_open_context *ctx;
d25be546 100 struct nfs4_state_owner *sp;
1da177e4 101 struct nfs4_state *state;
d25be546 102 unsigned int seq;
888e694c 103 int err;
1da177e4
LT
104
105again:
106 spin_lock(&inode->i_lock);
107 list_for_each_entry(ctx, &nfsi->open_files, list) {
108 state = ctx->state;
109 if (state == NULL)
110 continue;
111 if (!test_bit(NFS_DELEGATED_STATE, &state->flags))
112 continue;
f597c537 113 if (!nfs4_stateid_match(&state->stateid, stateid))
90163027 114 continue;
1da177e4
LT
115 get_nfs_open_context(ctx);
116 spin_unlock(&inode->i_lock);
d25be546 117 sp = state->owner;
65b62a29
TM
118 /* Block nfs4_proc_unlck */
119 mutex_lock(&sp->so_delegreturn_mutex);
d25be546 120 seq = raw_seqcount_begin(&sp->so_reclaim_seqcount);
13437e12 121 err = nfs4_open_delegation_recall(ctx, state, stateid);
d25be546 122 if (!err)
db4f2e63 123 err = nfs_delegation_claim_locks(ctx, state, stateid);
d25be546
TM
124 if (!err && read_seqcount_retry(&sp->so_reclaim_seqcount, seq))
125 err = -EAGAIN;
65b62a29 126 mutex_unlock(&sp->so_delegreturn_mutex);
1da177e4 127 put_nfs_open_context(ctx);
888e694c 128 if (err != 0)
d18cc1fd 129 return err;
1da177e4
LT
130 goto again;
131 }
132 spin_unlock(&inode->i_lock);
d18cc1fd 133 return 0;
1da177e4
LT
134}
135
d3978bb3
CL
136/**
137 * nfs_inode_reclaim_delegation - process a delegation reclaim request
138 * @inode: inode to process
139 * @cred: credential to use for request
140 * @res: new delegation state from server
141 *
1da177e4 142 */
d3978bb3
CL
143void nfs_inode_reclaim_delegation(struct inode *inode, struct rpc_cred *cred,
144 struct nfs_openres *res)
1da177e4 145{
8f649c37
TM
146 struct nfs_delegation *delegation;
147 struct rpc_cred *oldcred = NULL;
1da177e4 148
8f649c37
TM
149 rcu_read_lock();
150 delegation = rcu_dereference(NFS_I(inode)->delegation);
151 if (delegation != NULL) {
152 spin_lock(&delegation->lock);
153 if (delegation->inode != NULL) {
f597c537 154 nfs4_stateid_copy(&delegation->stateid, &res->delegation);
8f649c37
TM
155 delegation->type = res->delegation_type;
156 delegation->maxsize = res->maxsize;
157 oldcred = delegation->cred;
158 delegation->cred = get_rpccred(cred);
159 clear_bit(NFS_DELEGATION_NEED_RECLAIM,
160 &delegation->flags);
161 NFS_I(inode)->delegation_state = delegation->type;
162 spin_unlock(&delegation->lock);
163 put_rpccred(oldcred);
164 rcu_read_unlock();
165 } else {
166 /* We appear to have raced with a delegation return. */
167 spin_unlock(&delegation->lock);
168 rcu_read_unlock();
169 nfs_inode_set_delegation(inode, cred, res);
170 }
171 } else {
172 rcu_read_unlock();
173 }
1da177e4
LT
174}
175
57bfa891
TM
176static int nfs_do_return_delegation(struct inode *inode, struct nfs_delegation *delegation, int issync)
177{
178 int res = 0;
179
180 res = nfs4_proc_delegreturn(inode, delegation->cred, &delegation->stateid, issync);
181 nfs_free_delegation(delegation);
182 return res;
183}
184
86e89489
TM
185static struct inode *nfs_delegation_grab_inode(struct nfs_delegation *delegation)
186{
187 struct inode *inode = NULL;
188
189 spin_lock(&delegation->lock);
190 if (delegation->inode != NULL)
191 inode = igrab(delegation->inode);
192 spin_unlock(&delegation->lock);
193 return inode;
194}
195
d25be546
TM
196static struct nfs_delegation *
197nfs_start_delegation_return_locked(struct nfs_inode *nfsi)
198{
199 struct nfs_delegation *ret = NULL;
200 struct nfs_delegation *delegation = rcu_dereference(nfsi->delegation);
201
202 if (delegation == NULL)
203 goto out;
204 spin_lock(&delegation->lock);
205 if (!test_and_set_bit(NFS_DELEGATION_RETURNING, &delegation->flags))
206 ret = delegation;
207 spin_unlock(&delegation->lock);
208out:
209 return ret;
210}
211
212static struct nfs_delegation *
213nfs_start_delegation_return(struct nfs_inode *nfsi)
214{
215 struct nfs_delegation *delegation;
216
217 rcu_read_lock();
218 delegation = nfs_start_delegation_return_locked(nfsi);
219 rcu_read_unlock();
220 return delegation;
221}
222
223static void
224nfs_abort_delegation_return(struct nfs_delegation *delegation,
225 struct nfs_client *clp)
226{
227
228 spin_lock(&delegation->lock);
229 clear_bit(NFS_DELEGATION_RETURNING, &delegation->flags);
230 set_bit(NFS_DELEGATION_RETURN, &delegation->flags);
231 spin_unlock(&delegation->lock);
232 set_bit(NFS4CLNT_DELEGRETURN, &clp->cl_state);
233}
234
dda4b225
CL
235static struct nfs_delegation *
236nfs_detach_delegation_locked(struct nfs_inode *nfsi,
d25be546
TM
237 struct nfs_delegation *delegation,
238 struct nfs_client *clp)
57bfa891 239{
d25be546 240 struct nfs_delegation *deleg_cur =
17d2c0a0 241 rcu_dereference_protected(nfsi->delegation,
d25be546 242 lockdep_is_held(&clp->cl_lock));
57bfa891 243
d25be546
TM
244 if (deleg_cur == NULL || delegation != deleg_cur)
245 return NULL;
dda4b225 246
34310430 247 spin_lock(&delegation->lock);
d25be546 248 set_bit(NFS_DELEGATION_RETURNING, &delegation->flags);
57bfa891 249 list_del_rcu(&delegation->super_list);
86e89489 250 delegation->inode = NULL;
57bfa891
TM
251 nfsi->delegation_state = 0;
252 rcu_assign_pointer(nfsi->delegation, NULL);
34310430 253 spin_unlock(&delegation->lock);
57bfa891 254 return delegation;
57bfa891
TM
255}
256
dda4b225 257static struct nfs_delegation *nfs_detach_delegation(struct nfs_inode *nfsi,
d25be546
TM
258 struct nfs_delegation *delegation,
259 struct nfs_server *server)
dda4b225 260{
d3978bb3 261 struct nfs_client *clp = server->nfs_client;
dda4b225
CL
262
263 spin_lock(&clp->cl_lock);
d25be546 264 delegation = nfs_detach_delegation_locked(nfsi, delegation, clp);
dda4b225
CL
265 spin_unlock(&clp->cl_lock);
266 return delegation;
267}
268
d25be546
TM
269static struct nfs_delegation *
270nfs_inode_detach_delegation(struct inode *inode)
271{
272 struct nfs_inode *nfsi = NFS_I(inode);
273 struct nfs_server *server = NFS_SERVER(inode);
274 struct nfs_delegation *delegation;
275
276 delegation = nfs_start_delegation_return(nfsi);
277 if (delegation == NULL)
278 return NULL;
279 return nfs_detach_delegation(nfsi, delegation, server);
280}
281
d3978bb3
CL
282/**
283 * nfs_inode_set_delegation - set up a delegation on an inode
284 * @inode: inode to which delegation applies
285 * @cred: cred to use for subsequent delegation processing
286 * @res: new delegation state from server
287 *
288 * Returns zero on success, or a negative errno value.
1da177e4
LT
289 */
290int nfs_inode_set_delegation(struct inode *inode, struct rpc_cred *cred, struct nfs_openres *res)
291{
d3978bb3
CL
292 struct nfs_server *server = NFS_SERVER(inode);
293 struct nfs_client *clp = server->nfs_client;
1da177e4 294 struct nfs_inode *nfsi = NFS_I(inode);
17d2c0a0 295 struct nfs_delegation *delegation, *old_delegation;
57bfa891 296 struct nfs_delegation *freeme = NULL;
1da177e4
LT
297 int status = 0;
298
8535b2be 299 delegation = kmalloc(sizeof(*delegation), GFP_NOFS);
1da177e4
LT
300 if (delegation == NULL)
301 return -ENOMEM;
f597c537 302 nfs4_stateid_copy(&delegation->stateid, &res->delegation);
1da177e4
LT
303 delegation->type = res->delegation_type;
304 delegation->maxsize = res->maxsize;
a9a4a87a 305 delegation->change_attr = inode->i_version;
1da177e4
LT
306 delegation->cred = get_rpccred(cred);
307 delegation->inode = inode;
b7391f44 308 delegation->flags = 1<<NFS_DELEGATION_REFERENCED;
34310430 309 spin_lock_init(&delegation->lock);
1da177e4
LT
310
311 spin_lock(&clp->cl_lock);
17d2c0a0 312 old_delegation = rcu_dereference_protected(nfsi->delegation,
d3978bb3 313 lockdep_is_held(&clp->cl_lock));
17d2c0a0 314 if (old_delegation != NULL) {
f597c537
TM
315 if (nfs4_stateid_match(&delegation->stateid,
316 &old_delegation->stateid) &&
17d2c0a0 317 delegation->type == old_delegation->type) {
57bfa891 318 goto out;
1da177e4 319 }
57bfa891
TM
320 /*
321 * Deal with broken servers that hand out two
322 * delegations for the same file.
17280175
TM
323 * Allow for upgrades to a WRITE delegation, but
324 * nothing else.
57bfa891
TM
325 */
326 dfprintk(FILE, "%s: server %s handed out "
327 "a duplicate delegation!\n",
3110ff80 328 __func__, clp->cl_hostname);
17280175
TM
329 if (delegation->type == old_delegation->type ||
330 !(delegation->type & FMODE_WRITE)) {
57bfa891
TM
331 freeme = delegation;
332 delegation = NULL;
333 goto out;
334 }
d25be546
TM
335 freeme = nfs_detach_delegation_locked(nfsi,
336 old_delegation, clp);
337 if (freeme == NULL)
338 goto out;
1da177e4 339 }
d3978bb3 340 list_add_rcu(&delegation->super_list, &server->delegations);
57bfa891
TM
341 nfsi->delegation_state = delegation->type;
342 rcu_assign_pointer(nfsi->delegation, delegation);
343 delegation = NULL;
412c77ce
TM
344
345 /* Ensure we revalidate the attributes and page cache! */
346 spin_lock(&inode->i_lock);
347 nfsi->cache_validity |= NFS_INO_REVAL_FORCED;
348 spin_unlock(&inode->i_lock);
349
57bfa891 350out:
1da177e4 351 spin_unlock(&clp->cl_lock);
603c83da
TM
352 if (delegation != NULL)
353 nfs_free_delegation(delegation);
57bfa891
TM
354 if (freeme != NULL)
355 nfs_do_return_delegation(inode, freeme, 0);
1da177e4
LT
356 return status;
357}
358
1da177e4
LT
359/*
360 * Basic procedure for returning a delegation to the server
361 */
d25be546 362static int nfs_end_delegation_return(struct inode *inode, struct nfs_delegation *delegation, int issync)
1da177e4 363{
d25be546 364 struct nfs_client *clp = NFS_SERVER(inode)->nfs_client;
1da177e4 365 struct nfs_inode *nfsi = NFS_I(inode);
d18cc1fd 366 int err;
1da177e4 367
d25be546
TM
368 if (delegation == NULL)
369 return 0;
370 do {
371 err = nfs_delegation_claim_opens(inode, &delegation->stateid);
372 if (!issync || err != -EAGAIN)
373 break;
374 /*
375 * Guard against state recovery
376 */
377 err = nfs4_wait_clnt_recover(clp);
378 } while (err == 0);
379
380 if (err) {
381 nfs_abort_delegation_return(delegation, clp);
382 goto out;
383 }
384 if (!nfs_detach_delegation(nfsi, delegation, NFS_SERVER(inode)))
d18cc1fd 385 goto out;
1da177e4 386
d18cc1fd
TM
387 err = nfs_do_return_delegation(inode, delegation, issync);
388out:
389 return err;
90163027
TM
390}
391
b757144f
TM
392static bool nfs_delegation_need_return(struct nfs_delegation *delegation)
393{
394 bool ret = false;
395
396 if (test_and_clear_bit(NFS_DELEGATION_RETURN, &delegation->flags))
397 ret = true;
398 if (test_and_clear_bit(NFS_DELEGATION_RETURN_IF_CLOSED, &delegation->flags) && !ret) {
399 struct inode *inode;
400
401 spin_lock(&delegation->lock);
402 inode = delegation->inode;
403 if (inode && list_empty(&NFS_I(inode)->open_files))
404 ret = true;
405 spin_unlock(&delegation->lock);
406 }
407 return ret;
408}
409
d3978bb3
CL
410/**
411 * nfs_client_return_marked_delegations - return previously marked delegations
412 * @clp: nfs_client to process
413 *
dc327ed4
TM
414 * Note that this function is designed to be called by the state
415 * manager thread. For this reason, it cannot flush the dirty data,
416 * since that could deadlock in case of a state recovery error.
417 *
d3978bb3 418 * Returns zero on success, or a negative errno value.
515d8611 419 */
d18cc1fd 420int nfs_client_return_marked_delegations(struct nfs_client *clp)
515d8611
TM
421{
422 struct nfs_delegation *delegation;
d3978bb3 423 struct nfs_server *server;
515d8611 424 struct inode *inode;
d18cc1fd 425 int err = 0;
515d8611
TM
426
427restart:
428 rcu_read_lock();
d3978bb3
CL
429 list_for_each_entry_rcu(server, &clp->cl_superblocks, client_link) {
430 list_for_each_entry_rcu(delegation, &server->delegations,
431 super_list) {
b757144f 432 if (!nfs_delegation_need_return(delegation))
d3978bb3
CL
433 continue;
434 inode = nfs_delegation_grab_inode(delegation);
435 if (inode == NULL)
436 continue;
d25be546 437 delegation = nfs_start_delegation_return_locked(NFS_I(inode));
d3978bb3
CL
438 rcu_read_unlock();
439
d25be546 440 err = nfs_end_delegation_return(inode, delegation, 0);
d3978bb3
CL
441 iput(inode);
442 if (!err)
443 goto restart;
444 set_bit(NFS4CLNT_DELEGRETURN, &clp->cl_state);
445 return err;
d18cc1fd 446 }
515d8611
TM
447 }
448 rcu_read_unlock();
d18cc1fd 449 return 0;
515d8611
TM
450}
451
d3978bb3
CL
452/**
453 * nfs_inode_return_delegation_noreclaim - return delegation, don't reclaim opens
454 * @inode: inode to process
455 *
456 * Does not protect against delegation reclaims, therefore really only safe
457 * to be called from nfs4_clear_inode().
e6f81075
TM
458 */
459void nfs_inode_return_delegation_noreclaim(struct inode *inode)
460{
e6f81075
TM
461 struct nfs_delegation *delegation;
462
d25be546
TM
463 delegation = nfs_inode_detach_delegation(inode);
464 if (delegation != NULL)
465 nfs_do_return_delegation(inode, delegation, 0);
e6f81075
TM
466}
467
d3978bb3
CL
468/**
469 * nfs_inode_return_delegation - synchronously return a delegation
470 * @inode: inode to process
471 *
c57d1bc5
TM
472 * This routine will always flush any dirty data to disk on the
473 * assumption that if we need to return the delegation, then
474 * we should stop caching.
475 *
d3978bb3
CL
476 * Returns zero on success, or a negative errno value.
477 */
57ec14c5 478int nfs4_inode_return_delegation(struct inode *inode)
90163027 479{
90163027
TM
480 struct nfs_inode *nfsi = NFS_I(inode);
481 struct nfs_delegation *delegation;
482 int err = 0;
483
c57d1bc5 484 nfs_wb_all(inode);
d25be546
TM
485 delegation = nfs_start_delegation_return(nfsi);
486 if (delegation != NULL)
487 err = nfs_end_delegation_return(inode, delegation, 1);
90163027 488 return err;
1da177e4
LT
489}
490
b757144f
TM
491static void nfs_mark_return_if_closed_delegation(struct nfs_server *server,
492 struct nfs_delegation *delegation)
493{
494 set_bit(NFS_DELEGATION_RETURN_IF_CLOSED, &delegation->flags);
495 set_bit(NFS4CLNT_DELEGRETURN, &server->nfs_client->cl_state);
496}
497
ed1e6211
TM
498static void nfs_mark_return_delegation(struct nfs_server *server,
499 struct nfs_delegation *delegation)
6411bd4a
TM
500{
501 set_bit(NFS_DELEGATION_RETURN, &delegation->flags);
ed1e6211 502 set_bit(NFS4CLNT_DELEGRETURN, &server->nfs_client->cl_state);
6411bd4a
TM
503}
504
5c31e236
TM
505static bool nfs_server_mark_return_all_delegations(struct nfs_server *server)
506{
507 struct nfs_delegation *delegation;
508 bool ret = false;
509
510 list_for_each_entry_rcu(delegation, &server->delegations, super_list) {
511 nfs_mark_return_delegation(server, delegation);
512 ret = true;
513 }
514 return ret;
515}
516
d3978bb3
CL
517/**
518 * nfs_super_return_all_delegations - return delegations for one superblock
519 * @sb: sb to process
520 *
1da177e4 521 */
eeebf916 522void nfs_server_return_all_delegations(struct nfs_server *server)
1da177e4 523{
d3978bb3 524 struct nfs_client *clp = server->nfs_client;
5c31e236 525 bool need_wait;
1da177e4
LT
526
527 if (clp == NULL)
528 return;
d3978bb3 529
8383e460 530 rcu_read_lock();
5c31e236 531 need_wait = nfs_server_mark_return_all_delegations(server);
8383e460 532 rcu_read_unlock();
d3978bb3 533
5c31e236 534 if (need_wait) {
d18cc1fd 535 nfs4_schedule_state_manager(clp);
5c31e236
TM
536 nfs4_wait_clnt_recover(clp);
537 }
515d8611
TM
538}
539
d3978bb3
CL
540static void nfs_mark_return_all_delegation_types(struct nfs_server *server,
541 fmode_t flags)
515d8611
TM
542{
543 struct nfs_delegation *delegation;
544
d3978bb3 545 list_for_each_entry_rcu(delegation, &server->delegations, super_list) {
c79571a5
AB
546 if ((delegation->type == (FMODE_READ|FMODE_WRITE)) && !(flags & FMODE_WRITE))
547 continue;
548 if (delegation->type & flags)
ed1e6211 549 nfs_mark_return_delegation(server, delegation);
707fb4b3 550 }
d3978bb3
CL
551}
552
553static void nfs_client_mark_return_all_delegation_types(struct nfs_client *clp,
554 fmode_t flags)
555{
556 struct nfs_server *server;
557
558 rcu_read_lock();
559 list_for_each_entry_rcu(server, &clp->cl_superblocks, client_link)
560 nfs_mark_return_all_delegation_types(server, flags);
515d8611 561 rcu_read_unlock();
1da177e4
LT
562}
563
b0d3ded1 564static void nfs_delegation_run_state_manager(struct nfs_client *clp)
58d9714a 565{
b0d3ded1
TM
566 if (test_bit(NFS4CLNT_DELEGRETURN, &clp->cl_state))
567 nfs4_schedule_state_manager(clp);
58d9714a
TM
568}
569
a1d0b5ee
TM
570void nfs_remove_bad_delegation(struct inode *inode)
571{
572 struct nfs_delegation *delegation;
573
d25be546 574 delegation = nfs_inode_detach_delegation(inode);
a1d0b5ee
TM
575 if (delegation) {
576 nfs_inode_find_state_and_recover(inode, &delegation->stateid);
577 nfs_free_delegation(delegation);
578 }
579}
9cb81968 580EXPORT_SYMBOL_GPL(nfs_remove_bad_delegation);
a1d0b5ee 581
d3978bb3
CL
582/**
583 * nfs_expire_all_delegation_types
584 * @clp: client to process
585 * @flags: delegation types to expire
586 *
587 */
31f09607 588void nfs_expire_all_delegation_types(struct nfs_client *clp, fmode_t flags)
58d9714a 589{
c79571a5 590 nfs_client_mark_return_all_delegation_types(clp, flags);
b0d3ded1 591 nfs_delegation_run_state_manager(clp);
58d9714a
TM
592}
593
d3978bb3
CL
594/**
595 * nfs_expire_all_delegations
596 * @clp: client to process
597 *
598 */
c79571a5
AB
599void nfs_expire_all_delegations(struct nfs_client *clp)
600{
601 nfs_expire_all_delegation_types(clp, FMODE_READ|FMODE_WRITE);
602}
603
d3978bb3 604static void nfs_mark_return_unreferenced_delegations(struct nfs_server *server)
b7391f44
TM
605{
606 struct nfs_delegation *delegation;
607
d3978bb3 608 list_for_each_entry_rcu(delegation, &server->delegations, super_list) {
b7391f44
TM
609 if (test_and_clear_bit(NFS_DELEGATION_REFERENCED, &delegation->flags))
610 continue;
b757144f 611 nfs_mark_return_if_closed_delegation(server, delegation);
b7391f44 612 }
b7391f44
TM
613}
614
d3978bb3
CL
615/**
616 * nfs_expire_unreferenced_delegations - Eliminate unused delegations
617 * @clp: nfs_client to process
618 *
619 */
b7391f44
TM
620void nfs_expire_unreferenced_delegations(struct nfs_client *clp)
621{
d3978bb3
CL
622 struct nfs_server *server;
623
624 rcu_read_lock();
625 list_for_each_entry_rcu(server, &clp->cl_superblocks, client_link)
626 nfs_mark_return_unreferenced_delegations(server);
627 rcu_read_unlock();
628
b7391f44
TM
629 nfs_delegation_run_state_manager(clp);
630}
631
d3978bb3
CL
632/**
633 * nfs_async_inode_return_delegation - asynchronously return a delegation
634 * @inode: inode to process
8e663f0e 635 * @stateid: state ID information
d3978bb3
CL
636 *
637 * Returns zero on success, or a negative errno value.
1da177e4 638 */
d3978bb3
CL
639int nfs_async_inode_return_delegation(struct inode *inode,
640 const nfs4_stateid *stateid)
1da177e4 641{
ed1e6211
TM
642 struct nfs_server *server = NFS_SERVER(inode);
643 struct nfs_client *clp = server->nfs_client;
6411bd4a 644 struct nfs_delegation *delegation;
1da177e4 645
dc327ed4
TM
646 filemap_flush(inode->i_mapping);
647
6411bd4a
TM
648 rcu_read_lock();
649 delegation = rcu_dereference(NFS_I(inode)->delegation);
2597641d 650
36281caa 651 if (!clp->cl_mvops->match_stateid(&delegation->stateid, stateid)) {
6411bd4a
TM
652 rcu_read_unlock();
653 return -ENOENT;
654 }
ed1e6211 655 nfs_mark_return_delegation(server, delegation);
6411bd4a 656 rcu_read_unlock();
d3978bb3 657
6411bd4a
TM
658 nfs_delegation_run_state_manager(clp);
659 return 0;
1da177e4
LT
660}
661
d3978bb3
CL
662static struct inode *
663nfs_delegation_find_inode_server(struct nfs_server *server,
664 const struct nfs_fh *fhandle)
1da177e4
LT
665{
666 struct nfs_delegation *delegation;
667 struct inode *res = NULL;
d3978bb3
CL
668
669 list_for_each_entry_rcu(delegation, &server->delegations, super_list) {
86e89489
TM
670 spin_lock(&delegation->lock);
671 if (delegation->inode != NULL &&
672 nfs_compare_fh(fhandle, &NFS_I(delegation->inode)->fh) == 0) {
1da177e4 673 res = igrab(delegation->inode);
1da177e4 674 }
86e89489
TM
675 spin_unlock(&delegation->lock);
676 if (res != NULL)
677 break;
1da177e4 678 }
d3978bb3
CL
679 return res;
680}
681
682/**
683 * nfs_delegation_find_inode - retrieve the inode associated with a delegation
684 * @clp: client state handle
685 * @fhandle: filehandle from a delegation recall
686 *
687 * Returns pointer to inode matching "fhandle," or NULL if a matching inode
688 * cannot be found.
689 */
690struct inode *nfs_delegation_find_inode(struct nfs_client *clp,
691 const struct nfs_fh *fhandle)
692{
693 struct nfs_server *server;
694 struct inode *res = NULL;
695
696 rcu_read_lock();
697 list_for_each_entry_rcu(server, &clp->cl_superblocks, client_link) {
698 res = nfs_delegation_find_inode_server(server, fhandle);
699 if (res != NULL)
700 break;
701 }
8383e460 702 rcu_read_unlock();
1da177e4
LT
703 return res;
704}
705
d3978bb3
CL
706static void nfs_delegation_mark_reclaim_server(struct nfs_server *server)
707{
708 struct nfs_delegation *delegation;
709
710 list_for_each_entry_rcu(delegation, &server->delegations, super_list)
711 set_bit(NFS_DELEGATION_NEED_RECLAIM, &delegation->flags);
712}
713
714/**
715 * nfs_delegation_mark_reclaim - mark all delegations as needing to be reclaimed
716 * @clp: nfs_client to process
717 *
1da177e4 718 */
adfa6f98 719void nfs_delegation_mark_reclaim(struct nfs_client *clp)
1da177e4 720{
d3978bb3
CL
721 struct nfs_server *server;
722
8383e460 723 rcu_read_lock();
d3978bb3
CL
724 list_for_each_entry_rcu(server, &clp->cl_superblocks, client_link)
725 nfs_delegation_mark_reclaim_server(server);
8383e460 726 rcu_read_unlock();
1da177e4
LT
727}
728
d3978bb3
CL
729/**
730 * nfs_delegation_reap_unclaimed - reap unclaimed delegations after reboot recovery is done
731 * @clp: nfs_client to process
732 *
1da177e4 733 */
adfa6f98 734void nfs_delegation_reap_unclaimed(struct nfs_client *clp)
1da177e4 735{
8383e460 736 struct nfs_delegation *delegation;
d3978bb3 737 struct nfs_server *server;
86e89489 738 struct inode *inode;
d3978bb3 739
8383e460
TM
740restart:
741 rcu_read_lock();
d3978bb3
CL
742 list_for_each_entry_rcu(server, &clp->cl_superblocks, client_link) {
743 list_for_each_entry_rcu(delegation, &server->delegations,
744 super_list) {
745 if (test_bit(NFS_DELEGATION_NEED_RECLAIM,
746 &delegation->flags) == 0)
747 continue;
748 inode = nfs_delegation_grab_inode(delegation);
749 if (inode == NULL)
750 continue;
751 delegation = nfs_detach_delegation(NFS_I(inode),
d25be546 752 delegation, server);
d3978bb3
CL
753 rcu_read_unlock();
754
755 if (delegation != NULL)
756 nfs_free_delegation(delegation);
757 iput(inode);
758 goto restart;
759 }
1da177e4 760 }
8383e460 761 rcu_read_unlock();
1da177e4 762}
3e4f6290 763
d3978bb3
CL
764/**
765 * nfs_delegations_present - check for existence of delegations
766 * @clp: client state handle
767 *
768 * Returns one if there are any nfs_delegation structures attached
769 * to this nfs_client.
770 */
771int nfs_delegations_present(struct nfs_client *clp)
772{
773 struct nfs_server *server;
774 int ret = 0;
775
776 rcu_read_lock();
777 list_for_each_entry_rcu(server, &clp->cl_superblocks, client_link)
778 if (!list_empty(&server->delegations)) {
779 ret = 1;
780 break;
781 }
782 rcu_read_unlock();
783 return ret;
784}
785
786/**
787 * nfs4_copy_delegation_stateid - Copy inode's state ID information
788 * @dst: stateid data structure to fill in
789 * @inode: inode to check
0032a7a7 790 * @flags: delegation type requirement
d3978bb3 791 *
0032a7a7
TM
792 * Returns "true" and fills in "dst->data" * if inode had a delegation,
793 * otherwise "false" is returned.
d3978bb3 794 */
0032a7a7
TM
795bool nfs4_copy_delegation_stateid(nfs4_stateid *dst, struct inode *inode,
796 fmode_t flags)
3e4f6290 797{
3e4f6290
TM
798 struct nfs_inode *nfsi = NFS_I(inode);
799 struct nfs_delegation *delegation;
0032a7a7 800 bool ret;
3e4f6290 801
0032a7a7 802 flags &= FMODE_READ|FMODE_WRITE;
8383e460
TM
803 rcu_read_lock();
804 delegation = rcu_dereference(nfsi->delegation);
0032a7a7
TM
805 ret = (delegation != NULL && (delegation->type & flags) == flags);
806 if (ret) {
f597c537 807 nfs4_stateid_copy(dst, &delegation->stateid);
0032a7a7 808 nfs_mark_delegation_referenced(delegation);
3e4f6290 809 }
8383e460
TM
810 rcu_read_unlock();
811 return ret;
3e4f6290 812}