NFSv4: Fix CB_RECALL_ANY to only return delegations that are not in use
[deliverable/linux.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
b02ba0b6
TM
517static void nfs_client_mark_return_all_delegations(struct nfs_client *clp)
518{
519 struct nfs_server *server;
520
521 rcu_read_lock();
522 list_for_each_entry_rcu(server, &clp->cl_superblocks, client_link)
523 nfs_server_mark_return_all_delegations(server);
524 rcu_read_unlock();
525}
526
527static void nfs_delegation_run_state_manager(struct nfs_client *clp)
528{
529 if (test_bit(NFS4CLNT_DELEGRETURN, &clp->cl_state))
530 nfs4_schedule_state_manager(clp);
531}
532
533/**
534 * nfs_expire_all_delegations
535 * @clp: client to process
536 *
537 */
538void nfs_expire_all_delegations(struct nfs_client *clp)
539{
540 nfs_client_mark_return_all_delegations(clp);
541 nfs_delegation_run_state_manager(clp);
542}
543
d3978bb3
CL
544/**
545 * nfs_super_return_all_delegations - return delegations for one superblock
546 * @sb: sb to process
547 *
1da177e4 548 */
eeebf916 549void nfs_server_return_all_delegations(struct nfs_server *server)
1da177e4 550{
d3978bb3 551 struct nfs_client *clp = server->nfs_client;
5c31e236 552 bool need_wait;
1da177e4
LT
553
554 if (clp == NULL)
555 return;
d3978bb3 556
8383e460 557 rcu_read_lock();
5c31e236 558 need_wait = nfs_server_mark_return_all_delegations(server);
8383e460 559 rcu_read_unlock();
d3978bb3 560
5c31e236 561 if (need_wait) {
d18cc1fd 562 nfs4_schedule_state_manager(clp);
5c31e236
TM
563 nfs4_wait_clnt_recover(clp);
564 }
515d8611
TM
565}
566
826e0013 567static void nfs_mark_return_unused_delegation_types(struct nfs_server *server,
d3978bb3 568 fmode_t flags)
515d8611
TM
569{
570 struct nfs_delegation *delegation;
571
d3978bb3 572 list_for_each_entry_rcu(delegation, &server->delegations, super_list) {
c79571a5
AB
573 if ((delegation->type == (FMODE_READ|FMODE_WRITE)) && !(flags & FMODE_WRITE))
574 continue;
575 if (delegation->type & flags)
826e0013 576 nfs_mark_return_if_closed_delegation(server, delegation);
707fb4b3 577 }
d3978bb3
CL
578}
579
826e0013 580static void nfs_client_mark_return_unused_delegation_types(struct nfs_client *clp,
d3978bb3
CL
581 fmode_t flags)
582{
583 struct nfs_server *server;
584
585 rcu_read_lock();
586 list_for_each_entry_rcu(server, &clp->cl_superblocks, client_link)
826e0013 587 nfs_mark_return_unused_delegation_types(server, flags);
515d8611 588 rcu_read_unlock();
1da177e4
LT
589}
590
a1d0b5ee
TM
591void nfs_remove_bad_delegation(struct inode *inode)
592{
593 struct nfs_delegation *delegation;
594
d25be546 595 delegation = nfs_inode_detach_delegation(inode);
a1d0b5ee
TM
596 if (delegation) {
597 nfs_inode_find_state_and_recover(inode, &delegation->stateid);
598 nfs_free_delegation(delegation);
599 }
600}
9cb81968 601EXPORT_SYMBOL_GPL(nfs_remove_bad_delegation);
a1d0b5ee 602
d3978bb3 603/**
826e0013 604 * nfs_expire_unused_delegation_types
d3978bb3
CL
605 * @clp: client to process
606 * @flags: delegation types to expire
607 *
608 */
826e0013 609void nfs_expire_unused_delegation_types(struct nfs_client *clp, fmode_t flags)
58d9714a 610{
826e0013 611 nfs_client_mark_return_unused_delegation_types(clp, flags);
b0d3ded1 612 nfs_delegation_run_state_manager(clp);
58d9714a
TM
613}
614
d3978bb3 615static void nfs_mark_return_unreferenced_delegations(struct nfs_server *server)
b7391f44
TM
616{
617 struct nfs_delegation *delegation;
618
d3978bb3 619 list_for_each_entry_rcu(delegation, &server->delegations, super_list) {
b7391f44
TM
620 if (test_and_clear_bit(NFS_DELEGATION_REFERENCED, &delegation->flags))
621 continue;
b757144f 622 nfs_mark_return_if_closed_delegation(server, delegation);
b7391f44 623 }
b7391f44
TM
624}
625
d3978bb3
CL
626/**
627 * nfs_expire_unreferenced_delegations - Eliminate unused delegations
628 * @clp: nfs_client to process
629 *
630 */
b7391f44
TM
631void nfs_expire_unreferenced_delegations(struct nfs_client *clp)
632{
d3978bb3
CL
633 struct nfs_server *server;
634
635 rcu_read_lock();
636 list_for_each_entry_rcu(server, &clp->cl_superblocks, client_link)
637 nfs_mark_return_unreferenced_delegations(server);
638 rcu_read_unlock();
639
b7391f44
TM
640 nfs_delegation_run_state_manager(clp);
641}
642
d3978bb3
CL
643/**
644 * nfs_async_inode_return_delegation - asynchronously return a delegation
645 * @inode: inode to process
8e663f0e 646 * @stateid: state ID information
d3978bb3
CL
647 *
648 * Returns zero on success, or a negative errno value.
1da177e4 649 */
d3978bb3
CL
650int nfs_async_inode_return_delegation(struct inode *inode,
651 const nfs4_stateid *stateid)
1da177e4 652{
ed1e6211
TM
653 struct nfs_server *server = NFS_SERVER(inode);
654 struct nfs_client *clp = server->nfs_client;
6411bd4a 655 struct nfs_delegation *delegation;
1da177e4 656
dc327ed4
TM
657 filemap_flush(inode->i_mapping);
658
6411bd4a
TM
659 rcu_read_lock();
660 delegation = rcu_dereference(NFS_I(inode)->delegation);
2597641d 661
36281caa 662 if (!clp->cl_mvops->match_stateid(&delegation->stateid, stateid)) {
6411bd4a
TM
663 rcu_read_unlock();
664 return -ENOENT;
665 }
ed1e6211 666 nfs_mark_return_delegation(server, delegation);
6411bd4a 667 rcu_read_unlock();
d3978bb3 668
6411bd4a
TM
669 nfs_delegation_run_state_manager(clp);
670 return 0;
1da177e4
LT
671}
672
d3978bb3
CL
673static struct inode *
674nfs_delegation_find_inode_server(struct nfs_server *server,
675 const struct nfs_fh *fhandle)
1da177e4
LT
676{
677 struct nfs_delegation *delegation;
678 struct inode *res = NULL;
d3978bb3
CL
679
680 list_for_each_entry_rcu(delegation, &server->delegations, super_list) {
86e89489
TM
681 spin_lock(&delegation->lock);
682 if (delegation->inode != NULL &&
683 nfs_compare_fh(fhandle, &NFS_I(delegation->inode)->fh) == 0) {
1da177e4 684 res = igrab(delegation->inode);
1da177e4 685 }
86e89489
TM
686 spin_unlock(&delegation->lock);
687 if (res != NULL)
688 break;
1da177e4 689 }
d3978bb3
CL
690 return res;
691}
692
693/**
694 * nfs_delegation_find_inode - retrieve the inode associated with a delegation
695 * @clp: client state handle
696 * @fhandle: filehandle from a delegation recall
697 *
698 * Returns pointer to inode matching "fhandle," or NULL if a matching inode
699 * cannot be found.
700 */
701struct inode *nfs_delegation_find_inode(struct nfs_client *clp,
702 const struct nfs_fh *fhandle)
703{
704 struct nfs_server *server;
705 struct inode *res = NULL;
706
707 rcu_read_lock();
708 list_for_each_entry_rcu(server, &clp->cl_superblocks, client_link) {
709 res = nfs_delegation_find_inode_server(server, fhandle);
710 if (res != NULL)
711 break;
712 }
8383e460 713 rcu_read_unlock();
1da177e4
LT
714 return res;
715}
716
d3978bb3
CL
717static void nfs_delegation_mark_reclaim_server(struct nfs_server *server)
718{
719 struct nfs_delegation *delegation;
720
721 list_for_each_entry_rcu(delegation, &server->delegations, super_list)
722 set_bit(NFS_DELEGATION_NEED_RECLAIM, &delegation->flags);
723}
724
725/**
726 * nfs_delegation_mark_reclaim - mark all delegations as needing to be reclaimed
727 * @clp: nfs_client to process
728 *
1da177e4 729 */
adfa6f98 730void nfs_delegation_mark_reclaim(struct nfs_client *clp)
1da177e4 731{
d3978bb3
CL
732 struct nfs_server *server;
733
8383e460 734 rcu_read_lock();
d3978bb3
CL
735 list_for_each_entry_rcu(server, &clp->cl_superblocks, client_link)
736 nfs_delegation_mark_reclaim_server(server);
8383e460 737 rcu_read_unlock();
1da177e4
LT
738}
739
d3978bb3
CL
740/**
741 * nfs_delegation_reap_unclaimed - reap unclaimed delegations after reboot recovery is done
742 * @clp: nfs_client to process
743 *
1da177e4 744 */
adfa6f98 745void nfs_delegation_reap_unclaimed(struct nfs_client *clp)
1da177e4 746{
8383e460 747 struct nfs_delegation *delegation;
d3978bb3 748 struct nfs_server *server;
86e89489 749 struct inode *inode;
d3978bb3 750
8383e460
TM
751restart:
752 rcu_read_lock();
d3978bb3
CL
753 list_for_each_entry_rcu(server, &clp->cl_superblocks, client_link) {
754 list_for_each_entry_rcu(delegation, &server->delegations,
755 super_list) {
756 if (test_bit(NFS_DELEGATION_NEED_RECLAIM,
757 &delegation->flags) == 0)
758 continue;
759 inode = nfs_delegation_grab_inode(delegation);
760 if (inode == NULL)
761 continue;
762 delegation = nfs_detach_delegation(NFS_I(inode),
d25be546 763 delegation, server);
d3978bb3
CL
764 rcu_read_unlock();
765
766 if (delegation != NULL)
767 nfs_free_delegation(delegation);
768 iput(inode);
769 goto restart;
770 }
1da177e4 771 }
8383e460 772 rcu_read_unlock();
1da177e4 773}
3e4f6290 774
d3978bb3
CL
775/**
776 * nfs_delegations_present - check for existence of delegations
777 * @clp: client state handle
778 *
779 * Returns one if there are any nfs_delegation structures attached
780 * to this nfs_client.
781 */
782int nfs_delegations_present(struct nfs_client *clp)
783{
784 struct nfs_server *server;
785 int ret = 0;
786
787 rcu_read_lock();
788 list_for_each_entry_rcu(server, &clp->cl_superblocks, client_link)
789 if (!list_empty(&server->delegations)) {
790 ret = 1;
791 break;
792 }
793 rcu_read_unlock();
794 return ret;
795}
796
797/**
798 * nfs4_copy_delegation_stateid - Copy inode's state ID information
799 * @dst: stateid data structure to fill in
800 * @inode: inode to check
0032a7a7 801 * @flags: delegation type requirement
d3978bb3 802 *
0032a7a7
TM
803 * Returns "true" and fills in "dst->data" * if inode had a delegation,
804 * otherwise "false" is returned.
d3978bb3 805 */
0032a7a7
TM
806bool nfs4_copy_delegation_stateid(nfs4_stateid *dst, struct inode *inode,
807 fmode_t flags)
3e4f6290 808{
3e4f6290
TM
809 struct nfs_inode *nfsi = NFS_I(inode);
810 struct nfs_delegation *delegation;
0032a7a7 811 bool ret;
3e4f6290 812
0032a7a7 813 flags &= FMODE_READ|FMODE_WRITE;
8383e460
TM
814 rcu_read_lock();
815 delegation = rcu_dereference(nfsi->delegation);
0032a7a7
TM
816 ret = (delegation != NULL && (delegation->type & flags) == flags);
817 if (ret) {
f597c537 818 nfs4_stateid_copy(dst, &delegation->stateid);
0032a7a7 819 nfs_mark_delegation_referenced(delegation);
3e4f6290 820 }
8383e460
TM
821 rcu_read_unlock();
822 return ret;
3e4f6290 823}
This page took 0.625413 seconds and 5 git commands to generate.