mwifiex: failure path handling in mwifiex_add_virtual_intf()
[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"
ca8acf8d 23#include "nfs4trace.h"
1da177e4 24
905f8d16
TM
25static void nfs_free_delegation(struct nfs_delegation *delegation)
26{
e00b8a24
TM
27 if (delegation->cred) {
28 put_rpccred(delegation->cred);
29 delegation->cred = NULL;
30 }
26f04dde 31 kfree_rcu(delegation, rcu);
8383e460
TM
32}
33
d3978bb3
CL
34/**
35 * nfs_mark_delegation_referenced - set delegation's REFERENCED flag
36 * @delegation: delegation to process
37 *
38 */
b7391f44
TM
39void nfs_mark_delegation_referenced(struct nfs_delegation *delegation)
40{
41 set_bit(NFS_DELEGATION_REFERENCED, &delegation->flags);
42}
43
d3978bb3
CL
44/**
45 * nfs_have_delegation - check if inode has a delegation
46 * @inode: inode to check
47 * @flags: delegation types to check for
48 *
49 * Returns one if inode has the indicated delegation, otherwise zero.
50 */
011e2a7f 51int nfs4_have_delegation(struct inode *inode, fmode_t flags)
b7391f44
TM
52{
53 struct nfs_delegation *delegation;
54 int ret = 0;
55
56 flags &= FMODE_READ|FMODE_WRITE;
57 rcu_read_lock();
58 delegation = rcu_dereference(NFS_I(inode)->delegation);
d25be546
TM
59 if (delegation != NULL && (delegation->type & flags) == flags &&
60 !test_bit(NFS_DELEGATION_RETURNING, &delegation->flags)) {
b7391f44
TM
61 nfs_mark_delegation_referenced(delegation);
62 ret = 1;
63 }
64 rcu_read_unlock();
65 return ret;
66}
67
db4f2e63 68static int nfs_delegation_claim_locks(struct nfs_open_context *ctx, struct nfs4_state *state, const nfs4_stateid *stateid)
888e694c
TM
69{
70 struct inode *inode = state->inode;
71 struct file_lock *fl;
d5122201 72 int status = 0;
888e694c 73
65b62a29
TM
74 if (inode->i_flock == NULL)
75 goto out;
314d7cc0 76
1c8c601a
JL
77 /* Protect inode->i_flock using the i_lock */
78 spin_lock(&inode->i_lock);
90dc7d27 79 for (fl = inode->i_flock; fl != NULL; fl = fl->fl_next) {
888e694c
TM
80 if (!(fl->fl_flags & (FL_POSIX|FL_FLOCK)))
81 continue;
cd3758e3 82 if (nfs_file_open_context(fl->fl_file) != ctx)
888e694c 83 continue;
1c8c601a 84 spin_unlock(&inode->i_lock);
db4f2e63 85 status = nfs4_lock_delegation_recall(fl, state, stateid);
d5122201 86 if (status < 0)
3f09df70 87 goto out;
1c8c601a 88 spin_lock(&inode->i_lock);
888e694c 89 }
1c8c601a 90 spin_unlock(&inode->i_lock);
3f09df70 91out:
888e694c
TM
92 return status;
93}
94
d18cc1fd 95static int nfs_delegation_claim_opens(struct inode *inode, const nfs4_stateid *stateid)
1da177e4
LT
96{
97 struct nfs_inode *nfsi = NFS_I(inode);
98 struct nfs_open_context *ctx;
d25be546 99 struct nfs4_state_owner *sp;
1da177e4 100 struct nfs4_state *state;
d25be546 101 unsigned int seq;
888e694c 102 int err;
1da177e4
LT
103
104again:
105 spin_lock(&inode->i_lock);
106 list_for_each_entry(ctx, &nfsi->open_files, list) {
107 state = ctx->state;
108 if (state == NULL)
109 continue;
110 if (!test_bit(NFS_DELEGATED_STATE, &state->flags))
111 continue;
f597c537 112 if (!nfs4_stateid_match(&state->stateid, stateid))
90163027 113 continue;
1da177e4
LT
114 get_nfs_open_context(ctx);
115 spin_unlock(&inode->i_lock);
d25be546 116 sp = state->owner;
65b62a29
TM
117 /* Block nfs4_proc_unlck */
118 mutex_lock(&sp->so_delegreturn_mutex);
d25be546 119 seq = raw_seqcount_begin(&sp->so_reclaim_seqcount);
13437e12 120 err = nfs4_open_delegation_recall(ctx, state, stateid);
d25be546 121 if (!err)
db4f2e63 122 err = nfs_delegation_claim_locks(ctx, state, stateid);
d25be546
TM
123 if (!err && read_seqcount_retry(&sp->so_reclaim_seqcount, seq))
124 err = -EAGAIN;
65b62a29 125 mutex_unlock(&sp->so_delegreturn_mutex);
1da177e4 126 put_nfs_open_context(ctx);
888e694c 127 if (err != 0)
d18cc1fd 128 return err;
1da177e4
LT
129 goto again;
130 }
131 spin_unlock(&inode->i_lock);
d18cc1fd 132 return 0;
1da177e4
LT
133}
134
d3978bb3
CL
135/**
136 * nfs_inode_reclaim_delegation - process a delegation reclaim request
137 * @inode: inode to process
138 * @cred: credential to use for request
139 * @res: new delegation state from server
140 *
1da177e4 141 */
d3978bb3
CL
142void nfs_inode_reclaim_delegation(struct inode *inode, struct rpc_cred *cred,
143 struct nfs_openres *res)
1da177e4 144{
8f649c37
TM
145 struct nfs_delegation *delegation;
146 struct rpc_cred *oldcred = NULL;
1da177e4 147
8f649c37
TM
148 rcu_read_lock();
149 delegation = rcu_dereference(NFS_I(inode)->delegation);
150 if (delegation != NULL) {
151 spin_lock(&delegation->lock);
152 if (delegation->inode != NULL) {
f597c537 153 nfs4_stateid_copy(&delegation->stateid, &res->delegation);
8f649c37
TM
154 delegation->type = res->delegation_type;
155 delegation->maxsize = res->maxsize;
156 oldcred = delegation->cred;
157 delegation->cred = get_rpccred(cred);
158 clear_bit(NFS_DELEGATION_NEED_RECLAIM,
159 &delegation->flags);
160 NFS_I(inode)->delegation_state = delegation->type;
161 spin_unlock(&delegation->lock);
162 put_rpccred(oldcred);
163 rcu_read_unlock();
ca8acf8d 164 trace_nfs4_reclaim_delegation(inode, res->delegation_type);
8f649c37
TM
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);
ca8acf8d 349 trace_nfs4_set_delegation(inode, res->delegation_type);
412c77ce 350
57bfa891 351out:
1da177e4 352 spin_unlock(&clp->cl_lock);
603c83da
TM
353 if (delegation != NULL)
354 nfs_free_delegation(delegation);
57bfa891
TM
355 if (freeme != NULL)
356 nfs_do_return_delegation(inode, freeme, 0);
1da177e4
LT
357 return status;
358}
359
1da177e4
LT
360/*
361 * Basic procedure for returning a delegation to the server
362 */
d25be546 363static int nfs_end_delegation_return(struct inode *inode, struct nfs_delegation *delegation, int issync)
1da177e4 364{
d25be546 365 struct nfs_client *clp = NFS_SERVER(inode)->nfs_client;
1da177e4 366 struct nfs_inode *nfsi = NFS_I(inode);
d18cc1fd 367 int err;
1da177e4 368
d25be546
TM
369 if (delegation == NULL)
370 return 0;
371 do {
372 err = nfs_delegation_claim_opens(inode, &delegation->stateid);
373 if (!issync || err != -EAGAIN)
374 break;
375 /*
376 * Guard against state recovery
377 */
378 err = nfs4_wait_clnt_recover(clp);
379 } while (err == 0);
380
381 if (err) {
382 nfs_abort_delegation_return(delegation, clp);
383 goto out;
384 }
385 if (!nfs_detach_delegation(nfsi, delegation, NFS_SERVER(inode)))
d18cc1fd 386 goto out;
1da177e4 387
d18cc1fd
TM
388 err = nfs_do_return_delegation(inode, delegation, issync);
389out:
390 return err;
90163027
TM
391}
392
b757144f
TM
393static bool nfs_delegation_need_return(struct nfs_delegation *delegation)
394{
395 bool ret = false;
396
397 if (test_and_clear_bit(NFS_DELEGATION_RETURN, &delegation->flags))
398 ret = true;
399 if (test_and_clear_bit(NFS_DELEGATION_RETURN_IF_CLOSED, &delegation->flags) && !ret) {
400 struct inode *inode;
401
402 spin_lock(&delegation->lock);
403 inode = delegation->inode;
404 if (inode && list_empty(&NFS_I(inode)->open_files))
405 ret = true;
406 spin_unlock(&delegation->lock);
407 }
408 return ret;
409}
410
d3978bb3
CL
411/**
412 * nfs_client_return_marked_delegations - return previously marked delegations
413 * @clp: nfs_client to process
414 *
dc327ed4
TM
415 * Note that this function is designed to be called by the state
416 * manager thread. For this reason, it cannot flush the dirty data,
417 * since that could deadlock in case of a state recovery error.
418 *
d3978bb3 419 * Returns zero on success, or a negative errno value.
515d8611 420 */
d18cc1fd 421int nfs_client_return_marked_delegations(struct nfs_client *clp)
515d8611
TM
422{
423 struct nfs_delegation *delegation;
d3978bb3 424 struct nfs_server *server;
515d8611 425 struct inode *inode;
d18cc1fd 426 int err = 0;
515d8611
TM
427
428restart:
429 rcu_read_lock();
d3978bb3
CL
430 list_for_each_entry_rcu(server, &clp->cl_superblocks, client_link) {
431 list_for_each_entry_rcu(delegation, &server->delegations,
432 super_list) {
b757144f 433 if (!nfs_delegation_need_return(delegation))
d3978bb3
CL
434 continue;
435 inode = nfs_delegation_grab_inode(delegation);
436 if (inode == NULL)
437 continue;
d25be546 438 delegation = nfs_start_delegation_return_locked(NFS_I(inode));
d3978bb3
CL
439 rcu_read_unlock();
440
d25be546 441 err = nfs_end_delegation_return(inode, delegation, 0);
d3978bb3
CL
442 iput(inode);
443 if (!err)
444 goto restart;
445 set_bit(NFS4CLNT_DELEGRETURN, &clp->cl_state);
446 return err;
d18cc1fd 447 }
515d8611
TM
448 }
449 rcu_read_unlock();
d18cc1fd 450 return 0;
515d8611
TM
451}
452
d3978bb3
CL
453/**
454 * nfs_inode_return_delegation_noreclaim - return delegation, don't reclaim opens
455 * @inode: inode to process
456 *
457 * Does not protect against delegation reclaims, therefore really only safe
458 * to be called from nfs4_clear_inode().
e6f81075
TM
459 */
460void nfs_inode_return_delegation_noreclaim(struct inode *inode)
461{
e6f81075
TM
462 struct nfs_delegation *delegation;
463
d25be546
TM
464 delegation = nfs_inode_detach_delegation(inode);
465 if (delegation != NULL)
466 nfs_do_return_delegation(inode, delegation, 0);
e6f81075
TM
467}
468
d3978bb3
CL
469/**
470 * nfs_inode_return_delegation - synchronously return a delegation
471 * @inode: inode to process
472 *
c57d1bc5
TM
473 * This routine will always flush any dirty data to disk on the
474 * assumption that if we need to return the delegation, then
475 * we should stop caching.
476 *
d3978bb3
CL
477 * Returns zero on success, or a negative errno value.
478 */
57ec14c5 479int nfs4_inode_return_delegation(struct inode *inode)
90163027 480{
90163027
TM
481 struct nfs_inode *nfsi = NFS_I(inode);
482 struct nfs_delegation *delegation;
483 int err = 0;
484
c57d1bc5 485 nfs_wb_all(inode);
d25be546
TM
486 delegation = nfs_start_delegation_return(nfsi);
487 if (delegation != NULL)
488 err = nfs_end_delegation_return(inode, delegation, 1);
90163027 489 return err;
1da177e4
LT
490}
491
b757144f
TM
492static void nfs_mark_return_if_closed_delegation(struct nfs_server *server,
493 struct nfs_delegation *delegation)
494{
495 set_bit(NFS_DELEGATION_RETURN_IF_CLOSED, &delegation->flags);
496 set_bit(NFS4CLNT_DELEGRETURN, &server->nfs_client->cl_state);
497}
498
ed1e6211
TM
499static void nfs_mark_return_delegation(struct nfs_server *server,
500 struct nfs_delegation *delegation)
6411bd4a
TM
501{
502 set_bit(NFS_DELEGATION_RETURN, &delegation->flags);
ed1e6211 503 set_bit(NFS4CLNT_DELEGRETURN, &server->nfs_client->cl_state);
6411bd4a
TM
504}
505
5c31e236
TM
506static bool nfs_server_mark_return_all_delegations(struct nfs_server *server)
507{
508 struct nfs_delegation *delegation;
509 bool ret = false;
510
511 list_for_each_entry_rcu(delegation, &server->delegations, super_list) {
512 nfs_mark_return_delegation(server, delegation);
513 ret = true;
514 }
515 return ret;
516}
517
b02ba0b6
TM
518static void nfs_client_mark_return_all_delegations(struct nfs_client *clp)
519{
520 struct nfs_server *server;
521
522 rcu_read_lock();
523 list_for_each_entry_rcu(server, &clp->cl_superblocks, client_link)
524 nfs_server_mark_return_all_delegations(server);
525 rcu_read_unlock();
526}
527
528static void nfs_delegation_run_state_manager(struct nfs_client *clp)
529{
530 if (test_bit(NFS4CLNT_DELEGRETURN, &clp->cl_state))
531 nfs4_schedule_state_manager(clp);
532}
533
534/**
535 * nfs_expire_all_delegations
536 * @clp: client to process
537 *
538 */
539void nfs_expire_all_delegations(struct nfs_client *clp)
540{
541 nfs_client_mark_return_all_delegations(clp);
542 nfs_delegation_run_state_manager(clp);
543}
544
d3978bb3
CL
545/**
546 * nfs_super_return_all_delegations - return delegations for one superblock
547 * @sb: sb to process
548 *
1da177e4 549 */
eeebf916 550void nfs_server_return_all_delegations(struct nfs_server *server)
1da177e4 551{
d3978bb3 552 struct nfs_client *clp = server->nfs_client;
5c31e236 553 bool need_wait;
1da177e4
LT
554
555 if (clp == NULL)
556 return;
d3978bb3 557
8383e460 558 rcu_read_lock();
5c31e236 559 need_wait = nfs_server_mark_return_all_delegations(server);
8383e460 560 rcu_read_unlock();
d3978bb3 561
5c31e236 562 if (need_wait) {
d18cc1fd 563 nfs4_schedule_state_manager(clp);
5c31e236
TM
564 nfs4_wait_clnt_recover(clp);
565 }
515d8611
TM
566}
567
826e0013 568static void nfs_mark_return_unused_delegation_types(struct nfs_server *server,
d3978bb3 569 fmode_t flags)
515d8611
TM
570{
571 struct nfs_delegation *delegation;
572
d3978bb3 573 list_for_each_entry_rcu(delegation, &server->delegations, super_list) {
c79571a5
AB
574 if ((delegation->type == (FMODE_READ|FMODE_WRITE)) && !(flags & FMODE_WRITE))
575 continue;
576 if (delegation->type & flags)
826e0013 577 nfs_mark_return_if_closed_delegation(server, delegation);
707fb4b3 578 }
d3978bb3
CL
579}
580
826e0013 581static void nfs_client_mark_return_unused_delegation_types(struct nfs_client *clp,
d3978bb3
CL
582 fmode_t flags)
583{
584 struct nfs_server *server;
585
586 rcu_read_lock();
587 list_for_each_entry_rcu(server, &clp->cl_superblocks, client_link)
826e0013 588 nfs_mark_return_unused_delegation_types(server, flags);
515d8611 589 rcu_read_unlock();
1da177e4
LT
590}
591
a1d0b5ee
TM
592void nfs_remove_bad_delegation(struct inode *inode)
593{
594 struct nfs_delegation *delegation;
595
d25be546 596 delegation = nfs_inode_detach_delegation(inode);
a1d0b5ee
TM
597 if (delegation) {
598 nfs_inode_find_state_and_recover(inode, &delegation->stateid);
599 nfs_free_delegation(delegation);
600 }
601}
9cb81968 602EXPORT_SYMBOL_GPL(nfs_remove_bad_delegation);
a1d0b5ee 603
d3978bb3 604/**
826e0013 605 * nfs_expire_unused_delegation_types
d3978bb3
CL
606 * @clp: client to process
607 * @flags: delegation types to expire
608 *
609 */
826e0013 610void nfs_expire_unused_delegation_types(struct nfs_client *clp, fmode_t flags)
58d9714a 611{
826e0013 612 nfs_client_mark_return_unused_delegation_types(clp, flags);
b0d3ded1 613 nfs_delegation_run_state_manager(clp);
58d9714a
TM
614}
615
d3978bb3 616static void nfs_mark_return_unreferenced_delegations(struct nfs_server *server)
b7391f44
TM
617{
618 struct nfs_delegation *delegation;
619
d3978bb3 620 list_for_each_entry_rcu(delegation, &server->delegations, super_list) {
b7391f44
TM
621 if (test_and_clear_bit(NFS_DELEGATION_REFERENCED, &delegation->flags))
622 continue;
b757144f 623 nfs_mark_return_if_closed_delegation(server, delegation);
b7391f44 624 }
b7391f44
TM
625}
626
d3978bb3
CL
627/**
628 * nfs_expire_unreferenced_delegations - Eliminate unused delegations
629 * @clp: nfs_client to process
630 *
631 */
b7391f44
TM
632void nfs_expire_unreferenced_delegations(struct nfs_client *clp)
633{
d3978bb3
CL
634 struct nfs_server *server;
635
636 rcu_read_lock();
637 list_for_each_entry_rcu(server, &clp->cl_superblocks, client_link)
638 nfs_mark_return_unreferenced_delegations(server);
639 rcu_read_unlock();
640
b7391f44
TM
641 nfs_delegation_run_state_manager(clp);
642}
643
d3978bb3
CL
644/**
645 * nfs_async_inode_return_delegation - asynchronously return a delegation
646 * @inode: inode to process
8e663f0e 647 * @stateid: state ID information
d3978bb3
CL
648 *
649 * Returns zero on success, or a negative errno value.
1da177e4 650 */
d3978bb3
CL
651int nfs_async_inode_return_delegation(struct inode *inode,
652 const nfs4_stateid *stateid)
1da177e4 653{
ed1e6211
TM
654 struct nfs_server *server = NFS_SERVER(inode);
655 struct nfs_client *clp = server->nfs_client;
6411bd4a 656 struct nfs_delegation *delegation;
1da177e4 657
dc327ed4
TM
658 filemap_flush(inode->i_mapping);
659
6411bd4a
TM
660 rcu_read_lock();
661 delegation = rcu_dereference(NFS_I(inode)->delegation);
2597641d 662
36281caa 663 if (!clp->cl_mvops->match_stateid(&delegation->stateid, stateid)) {
6411bd4a
TM
664 rcu_read_unlock();
665 return -ENOENT;
666 }
ed1e6211 667 nfs_mark_return_delegation(server, delegation);
6411bd4a 668 rcu_read_unlock();
d3978bb3 669
6411bd4a
TM
670 nfs_delegation_run_state_manager(clp);
671 return 0;
1da177e4
LT
672}
673
d3978bb3
CL
674static struct inode *
675nfs_delegation_find_inode_server(struct nfs_server *server,
676 const struct nfs_fh *fhandle)
1da177e4
LT
677{
678 struct nfs_delegation *delegation;
679 struct inode *res = NULL;
d3978bb3
CL
680
681 list_for_each_entry_rcu(delegation, &server->delegations, super_list) {
86e89489
TM
682 spin_lock(&delegation->lock);
683 if (delegation->inode != NULL &&
684 nfs_compare_fh(fhandle, &NFS_I(delegation->inode)->fh) == 0) {
1da177e4 685 res = igrab(delegation->inode);
1da177e4 686 }
86e89489
TM
687 spin_unlock(&delegation->lock);
688 if (res != NULL)
689 break;
1da177e4 690 }
d3978bb3
CL
691 return res;
692}
693
694/**
695 * nfs_delegation_find_inode - retrieve the inode associated with a delegation
696 * @clp: client state handle
697 * @fhandle: filehandle from a delegation recall
698 *
699 * Returns pointer to inode matching "fhandle," or NULL if a matching inode
700 * cannot be found.
701 */
702struct inode *nfs_delegation_find_inode(struct nfs_client *clp,
703 const struct nfs_fh *fhandle)
704{
705 struct nfs_server *server;
706 struct inode *res = NULL;
707
708 rcu_read_lock();
709 list_for_each_entry_rcu(server, &clp->cl_superblocks, client_link) {
710 res = nfs_delegation_find_inode_server(server, fhandle);
711 if (res != NULL)
712 break;
713 }
8383e460 714 rcu_read_unlock();
1da177e4
LT
715 return res;
716}
717
d3978bb3
CL
718static void nfs_delegation_mark_reclaim_server(struct nfs_server *server)
719{
720 struct nfs_delegation *delegation;
721
722 list_for_each_entry_rcu(delegation, &server->delegations, super_list)
723 set_bit(NFS_DELEGATION_NEED_RECLAIM, &delegation->flags);
724}
725
726/**
727 * nfs_delegation_mark_reclaim - mark all delegations as needing to be reclaimed
728 * @clp: nfs_client to process
729 *
1da177e4 730 */
adfa6f98 731void nfs_delegation_mark_reclaim(struct nfs_client *clp)
1da177e4 732{
d3978bb3
CL
733 struct nfs_server *server;
734
8383e460 735 rcu_read_lock();
d3978bb3
CL
736 list_for_each_entry_rcu(server, &clp->cl_superblocks, client_link)
737 nfs_delegation_mark_reclaim_server(server);
8383e460 738 rcu_read_unlock();
1da177e4
LT
739}
740
d3978bb3
CL
741/**
742 * nfs_delegation_reap_unclaimed - reap unclaimed delegations after reboot recovery is done
743 * @clp: nfs_client to process
744 *
1da177e4 745 */
adfa6f98 746void nfs_delegation_reap_unclaimed(struct nfs_client *clp)
1da177e4 747{
8383e460 748 struct nfs_delegation *delegation;
d3978bb3 749 struct nfs_server *server;
86e89489 750 struct inode *inode;
d3978bb3 751
8383e460
TM
752restart:
753 rcu_read_lock();
d3978bb3
CL
754 list_for_each_entry_rcu(server, &clp->cl_superblocks, client_link) {
755 list_for_each_entry_rcu(delegation, &server->delegations,
756 super_list) {
757 if (test_bit(NFS_DELEGATION_NEED_RECLAIM,
758 &delegation->flags) == 0)
759 continue;
760 inode = nfs_delegation_grab_inode(delegation);
761 if (inode == NULL)
762 continue;
763 delegation = nfs_detach_delegation(NFS_I(inode),
d25be546 764 delegation, server);
d3978bb3
CL
765 rcu_read_unlock();
766
767 if (delegation != NULL)
768 nfs_free_delegation(delegation);
769 iput(inode);
770 goto restart;
771 }
1da177e4 772 }
8383e460 773 rcu_read_unlock();
1da177e4 774}
3e4f6290 775
d3978bb3
CL
776/**
777 * nfs_delegations_present - check for existence of delegations
778 * @clp: client state handle
779 *
780 * Returns one if there are any nfs_delegation structures attached
781 * to this nfs_client.
782 */
783int nfs_delegations_present(struct nfs_client *clp)
784{
785 struct nfs_server *server;
786 int ret = 0;
787
788 rcu_read_lock();
789 list_for_each_entry_rcu(server, &clp->cl_superblocks, client_link)
790 if (!list_empty(&server->delegations)) {
791 ret = 1;
792 break;
793 }
794 rcu_read_unlock();
795 return ret;
796}
797
798/**
799 * nfs4_copy_delegation_stateid - Copy inode's state ID information
800 * @dst: stateid data structure to fill in
801 * @inode: inode to check
0032a7a7 802 * @flags: delegation type requirement
d3978bb3 803 *
0032a7a7
TM
804 * Returns "true" and fills in "dst->data" * if inode had a delegation,
805 * otherwise "false" is returned.
d3978bb3 806 */
0032a7a7
TM
807bool nfs4_copy_delegation_stateid(nfs4_stateid *dst, struct inode *inode,
808 fmode_t flags)
3e4f6290 809{
3e4f6290
TM
810 struct nfs_inode *nfsi = NFS_I(inode);
811 struct nfs_delegation *delegation;
0032a7a7 812 bool ret;
3e4f6290 813
0032a7a7 814 flags &= FMODE_READ|FMODE_WRITE;
8383e460
TM
815 rcu_read_lock();
816 delegation = rcu_dereference(nfsi->delegation);
0032a7a7
TM
817 ret = (delegation != NULL && (delegation->type & flags) == flags);
818 if (ret) {
f597c537 819 nfs4_stateid_copy(dst, &delegation->stateid);
0032a7a7 820 nfs_mark_delegation_referenced(delegation);
3e4f6290 821 }
8383e460
TM
822 rcu_read_unlock();
823 return ret;
3e4f6290 824}
This page took 1.109157 seconds and 5 git commands to generate.