Pileus Git - ~andy/linux/blob - fs/nfs/delegation.c

   1 /*
   2  * linux/fs/nfs/delegation.c
   3  *
   4  * Copyright (C) 2004 Trond Myklebust
   5  *
   6  * NFS file delegation management
   7  *
   8  */
   9 #include <linux/completion.h>
  10 #include <linux/kthread.h>
  11 #include <linux/module.h>
  12 #include <linux/sched.h>
  13 #include <linux/slab.h>
  14 #include <linux/spinlock.h>
  15
  16 #include <linux/nfs4.h>
  17 #include <linux/nfs_fs.h>
  18 #include <linux/nfs_xdr.h>
  19
  20 #include "nfs4_fs.h"
  21 #include "delegation.h"
  22 #include "internal.h"
  23 #include "nfs4trace.h"
  24
  25 static void nfs_free_delegation(struct nfs_delegation *delegation)
  26 {
  27         if (delegation->cred) {
  28                 put_rpccred(delegation->cred);
  29                 delegation->cred = NULL;
  30         }
  31         kfree_rcu(delegation, rcu);
  32 }
  33
  34 /**
  35  * nfs_mark_delegation_referenced - set delegation's REFERENCED flag
  36  * @delegation: delegation to process
  37  *
  38  */
  39 void nfs_mark_delegation_referenced(struct nfs_delegation *delegation)
  40 {
  41         set_bit(NFS_DELEGATION_REFERENCED, &delegation->flags);
  42 }
  43
  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  */
  51 int nfs4_have_delegation(struct inode *inode, fmode_t flags)
  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);
  59         if (delegation != NULL && (delegation->type & flags) == flags &&
  60             !test_bit(NFS_DELEGATION_RETURNING, &delegation->flags)) {
  61                 nfs_mark_delegation_referenced(delegation);
  62                 ret = 1;
  63         }
  64         rcu_read_unlock();
  65         return ret;
  66 }
  67
  68 static int nfs_delegation_claim_locks(struct nfs_open_context *ctx, struct nfs4_state *state, const nfs4_stateid *stateid)
  69 {
  70         struct inode *inode = state->inode;
  71         struct file_lock *fl;
  72         int status = 0;
  73
  74         if (inode->i_flock == NULL)
  75                 goto out;
  76
  77         /* Protect inode->i_flock using the i_lock */
  78         spin_lock(&inode->i_lock);
  79         for (fl = inode->i_flock; fl != NULL; fl = fl->fl_next) {
  80                 if (!(fl->fl_flags & (FL_POSIX|FL_FLOCK)))
  81                         continue;
  82                 if (nfs_file_open_context(fl->fl_file) != ctx)
  83                         continue;
  84                 spin_unlock(&inode->i_lock);
  85                 status = nfs4_lock_delegation_recall(fl, state, stateid);
  86                 if (status < 0)
  87                         goto out;
  88                 spin_lock(&inode->i_lock);
  89         }
  90         spin_unlock(&inode->i_lock);
  91 out:
  92         return status;
  93 }
  94
  95 static int nfs_delegation_claim_opens(struct inode *inode, const nfs4_stateid *stateid)
  96 {
  97         struct nfs_inode *nfsi = NFS_I(inode);
  98         struct nfs_open_context *ctx;
  99         struct nfs4_state_owner *sp;
 100         struct nfs4_state *state;
 101         unsigned int seq;
 102         int err;
 103
 104 again:
 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;
 112                 if (!nfs4_stateid_match(&state->stateid, stateid))
 113                         continue;
 114                 get_nfs_open_context(ctx);
 115                 spin_unlock(&inode->i_lock);
 116                 sp = state->owner;
 117                 /* Block nfs4_proc_unlck */
 118                 mutex_lock(&sp->so_delegreturn_mutex);
 119                 seq = raw_seqcount_begin(&sp->so_reclaim_seqcount);
 120                 err = nfs4_open_delegation_recall(ctx, state, stateid);
 121                 if (!err)
 122                         err = nfs_delegation_claim_locks(ctx, state, stateid);
 123                 if (!err && read_seqcount_retry(&sp->so_reclaim_seqcount, seq))
 124                         err = -EAGAIN;
 125                 mutex_unlock(&sp->so_delegreturn_mutex);
 126                 put_nfs_open_context(ctx);
 127                 if (err != 0)
 128                         return err;
 129                 goto again;
 130         }
 131         spin_unlock(&inode->i_lock);
 132         return 0;
 133 }
 134
 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  *
 141  */
 142 void nfs_inode_reclaim_delegation(struct inode *inode, struct rpc_cred *cred,
 143                                   struct nfs_openres *res)
 144 {
 145         struct nfs_delegation *delegation;
 146         struct rpc_cred *oldcred = NULL;
 147
 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) {
 153                         nfs4_stateid_copy(&delegation->stateid, &res->delegation);
 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();
 164                         trace_nfs4_reclaim_delegation(inode, res->delegation_type);
 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         }
 174 }
 175
 176 static 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
 185 static 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
 196 static struct nfs_delegation *
 197 nfs_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);
 208 out:
 209         return ret;
 210 }
 211
 212 static struct nfs_delegation *
 213 nfs_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
 223 static void
 224 nfs_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
 235 static struct nfs_delegation *
 236 nfs_detach_delegation_locked(struct nfs_inode *nfsi,
 237                 struct nfs_delegation *delegation,
 238                 struct nfs_client *clp)
 239 {
 240         struct nfs_delegation *deleg_cur =
 241                 rcu_dereference_protected(nfsi->delegation,
 242                                 lockdep_is_held(&clp->cl_lock));
 243
 244         if (deleg_cur == NULL || delegation != deleg_cur)
 245                 return NULL;
 246
 247         spin_lock(&delegation->lock);
 248         set_bit(NFS_DELEGATION_RETURNING, &delegation->flags);
 249         list_del_rcu(&delegation->super_list);
 250         delegation->inode = NULL;
 251         nfsi->delegation_state = 0;
 252         rcu_assign_pointer(nfsi->delegation, NULL);
 253         spin_unlock(&delegation->lock);
 254         return delegation;
 255 }
 256
 257 static struct nfs_delegation *nfs_detach_delegation(struct nfs_inode *nfsi,
 258                 struct nfs_delegation *delegation,
 259                 struct nfs_server *server)
 260 {
 261         struct nfs_client *clp = server->nfs_client;
 262
 263         spin_lock(&clp->cl_lock);
 264         delegation = nfs_detach_delegation_locked(nfsi, delegation, clp);
 265         spin_unlock(&clp->cl_lock);
 266         return delegation;
 267 }
 268
 269 static struct nfs_delegation *
 270 nfs_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
 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.
 289  */
 290 int nfs_inode_set_delegation(struct inode *inode, struct rpc_cred *cred, struct nfs_openres *res)
 291 {
 292         struct nfs_server *server = NFS_SERVER(inode);
 293         struct nfs_client *clp = server->nfs_client;
 294         struct nfs_inode *nfsi = NFS_I(inode);
 295         struct nfs_delegation *delegation, *old_delegation;
 296         struct nfs_delegation *freeme = NULL;
 297         int status = 0;
 298
 299         delegation = kmalloc(sizeof(*delegation), GFP_NOFS);
 300         if (delegation == NULL)
 301                 return -ENOMEM;
 302         nfs4_stateid_copy(&delegation->stateid, &res->delegation);
 303         delegation->type = res->delegation_type;
 304         delegation->maxsize = res->maxsize;
 305         delegation->change_attr = inode->i_version;
 306         delegation->cred = get_rpccred(cred);
 307         delegation->inode = inode;
 308         delegation->flags = 1<<NFS_DELEGATION_REFERENCED;
 309         spin_lock_init(&delegation->lock);
 310
 311         spin_lock(&clp->cl_lock);
 312         old_delegation = rcu_dereference_protected(nfsi->delegation,
 313                                         lockdep_is_held(&clp->cl_lock));
 314         if (old_delegation != NULL) {
 315                 if (nfs4_stateid_match(&delegation->stateid,
 316                                         &old_delegation->stateid) &&
 317                                 delegation->type == old_delegation->type) {
 318                         goto out;
 319                 }
 320                 /*
 321                  * Deal with broken servers that hand out two
 322                  * delegations for the same file.
 323                  * Allow for upgrades to a WRITE delegation, but
 324                  * nothing else.
 325                  */
 326                 dfprintk(FILE, "%s: server %s handed out "
 327                                 "a duplicate delegation!\n",
 328                                 __func__, clp->cl_hostname);
 329                 if (delegation->type == old_delegation->type ||
 330                     !(delegation->type & FMODE_WRITE)) {
 331                         freeme = delegation;
 332                         delegation = NULL;
 333                         goto out;
 334                 }
 335                 freeme = nfs_detach_delegation_locked(nfsi,
 336                                 old_delegation, clp);
 337                 if (freeme == NULL)
 338                         goto out;
 339         }
 340         list_add_rcu(&delegation->super_list, &server->delegations);
 341         nfsi->delegation_state = delegation->type;
 342         rcu_assign_pointer(nfsi->delegation, delegation);
 343         delegation = NULL;
 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         trace_nfs4_set_delegation(inode, res->delegation_type);
 350
 351 out:
 352         spin_unlock(&clp->cl_lock);
 353         if (delegation != NULL)
 354                 nfs_free_delegation(delegation);
 355         if (freeme != NULL)
 356                 nfs_do_return_delegation(inode, freeme, 0);
 357         return status;
 358 }
 359
 360 /*
 361  * Basic procedure for returning a delegation to the server
 362  */
 363 static int nfs_end_delegation_return(struct inode *inode, struct nfs_delegation *delegation, int issync)
 364 {
 365         struct nfs_client *clp = NFS_SERVER(inode)->nfs_client;
 366         struct nfs_inode *nfsi = NFS_I(inode);
 367         int err;
 368
 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)))
 386                 goto out;
 387
 388         err = nfs_do_return_delegation(inode, delegation, issync);
 389 out:
 390         return err;
 391 }
 392
 393 static 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
 411 /**
 412  * nfs_client_return_marked_delegations - return previously marked delegations
 413  * @clp: nfs_client to process
 414  *
 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  *
 419  * Returns zero on success, or a negative errno value.
 420  */
 421 int nfs_client_return_marked_delegations(struct nfs_client *clp)
 422 {
 423         struct nfs_delegation *delegation;
 424         struct nfs_server *server;
 425         struct inode *inode;
 426         int err = 0;
 427
 428 restart:
 429         rcu_read_lock();
 430         list_for_each_entry_rcu(server, &clp->cl_superblocks, client_link) {
 431                 list_for_each_entry_rcu(delegation, &server->delegations,
 432                                                                 super_list) {
 433                         if (!nfs_delegation_need_return(delegation))
 434                                 continue;
 435                         inode = nfs_delegation_grab_inode(delegation);
 436                         if (inode == NULL)
 437                                 continue;
 438                         delegation = nfs_start_delegation_return_locked(NFS_I(inode));
 439                         rcu_read_unlock();
 440
 441                         err = nfs_end_delegation_return(inode, delegation, 0);
 442                         iput(inode);
 443                         if (!err)
 444                                 goto restart;
 445                         set_bit(NFS4CLNT_DELEGRETURN, &clp->cl_state);
 446                         return err;
 447                 }
 448         }
 449         rcu_read_unlock();
 450         return 0;
 451 }
 452
 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().
 459  */
 460 void nfs_inode_return_delegation_noreclaim(struct inode *inode)
 461 {
 462         struct nfs_delegation *delegation;
 463
 464         delegation = nfs_inode_detach_delegation(inode);
 465         if (delegation != NULL)
 466                 nfs_do_return_delegation(inode, delegation, 0);
 467 }
 468
 469 /**
 470  * nfs_inode_return_delegation - synchronously return a delegation
 471  * @inode: inode to process
 472  *
 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  *
 477  * Returns zero on success, or a negative errno value.
 478  */
 479 int nfs4_inode_return_delegation(struct inode *inode)
 480 {
 481         struct nfs_inode *nfsi = NFS_I(inode);
 482         struct nfs_delegation *delegation;
 483         int err = 0;
 484
 485         nfs_wb_all(inode);
 486         delegation = nfs_start_delegation_return(nfsi);
 487         if (delegation != NULL)
 488                 err = nfs_end_delegation_return(inode, delegation, 1);
 489         return err;
 490 }
 491
 492 static 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
 499 static void nfs_mark_return_delegation(struct nfs_server *server,
 500                 struct nfs_delegation *delegation)
 501 {
 502         set_bit(NFS_DELEGATION_RETURN, &delegation->flags);
 503         set_bit(NFS4CLNT_DELEGRETURN, &server->nfs_client->cl_state);
 504 }
 505
 506 static 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
 518 static 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
 528 static 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  */
 539 void 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
 545 /**
 546  * nfs_super_return_all_delegations - return delegations for one superblock
 547  * @sb: sb to process
 548  *
 549  */
 550 void nfs_server_return_all_delegations(struct nfs_server *server)
 551 {
 552         struct nfs_client *clp = server->nfs_client;
 553         bool need_wait;
 554
 555         if (clp == NULL)
 556                 return;
 557
 558         rcu_read_lock();
 559         need_wait = nfs_server_mark_return_all_delegations(server);
 560         rcu_read_unlock();
 561
 562         if (need_wait) {
 563                 nfs4_schedule_state_manager(clp);
 564                 nfs4_wait_clnt_recover(clp);
 565         }
 566 }
 567
 568 static void nfs_mark_return_unused_delegation_types(struct nfs_server *server,
 569                                                  fmode_t flags)
 570 {
 571         struct nfs_delegation *delegation;
 572
 573         list_for_each_entry_rcu(delegation, &server->delegations, super_list) {
 574                 if ((delegation->type == (FMODE_READ|FMODE_WRITE)) && !(flags & FMODE_WRITE))
 575                         continue;
 576                 if (delegation->type & flags)
 577                         nfs_mark_return_if_closed_delegation(server, delegation);
 578         }
 579 }
 580
 581 static void nfs_client_mark_return_unused_delegation_types(struct nfs_client *clp,
 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)
 588                 nfs_mark_return_unused_delegation_types(server, flags);
 589         rcu_read_unlock();
 590 }
 591
 592 void nfs_remove_bad_delegation(struct inode *inode)
 593 {
 594         struct nfs_delegation *delegation;
 595
 596         delegation = nfs_inode_detach_delegation(inode);
 597         if (delegation) {
 598                 nfs_inode_find_state_and_recover(inode, &delegation->stateid);
 599                 nfs_free_delegation(delegation);
 600         }
 601 }
 602 EXPORT_SYMBOL_GPL(nfs_remove_bad_delegation);
 603
 604 /**
 605  * nfs_expire_unused_delegation_types
 606  * @clp: client to process
 607  * @flags: delegation types to expire
 608  *
 609  */
 610 void nfs_expire_unused_delegation_types(struct nfs_client *clp, fmode_t flags)
 611 {
 612         nfs_client_mark_return_unused_delegation_types(clp, flags);
 613         nfs_delegation_run_state_manager(clp);
 614 }
 615
 616 static void nfs_mark_return_unreferenced_delegations(struct nfs_server *server)
 617 {
 618         struct nfs_delegation *delegation;
 619
 620         list_for_each_entry_rcu(delegation, &server->delegations, super_list) {
 621                 if (test_and_clear_bit(NFS_DELEGATION_REFERENCED, &delegation->flags))
 622                         continue;
 623                 nfs_mark_return_if_closed_delegation(server, delegation);
 624         }
 625 }
 626
 627 /**
 628  * nfs_expire_unreferenced_delegations - Eliminate unused delegations
 629  * @clp: nfs_client to process
 630  *
 631  */
 632 void nfs_expire_unreferenced_delegations(struct nfs_client *clp)
 633 {
 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
 641         nfs_delegation_run_state_manager(clp);
 642 }
 643
 644 /**
 645  * nfs_async_inode_return_delegation - asynchronously return a delegation
 646  * @inode: inode to process
 647  * @stateid: state ID information
 648  *
 649  * Returns zero on success, or a negative errno value.
 650  */
 651 int nfs_async_inode_return_delegation(struct inode *inode,
 652                                       const nfs4_stateid *stateid)
 653 {
 654         struct nfs_server *server = NFS_SERVER(inode);
 655         struct nfs_client *clp = server->nfs_client;
 656         struct nfs_delegation *delegation;
 657
 658         filemap_flush(inode->i_mapping);
 659
 660         rcu_read_lock();
 661         delegation = rcu_dereference(NFS_I(inode)->delegation);
 662
 663         if (!clp->cl_mvops->match_stateid(&delegation->stateid, stateid)) {
 664                 rcu_read_unlock();
 665                 return -ENOENT;
 666         }
 667         nfs_mark_return_delegation(server, delegation);
 668         rcu_read_unlock();
 669
 670         nfs_delegation_run_state_manager(clp);
 671         return 0;
 672 }
 673
 674 static struct inode *
 675 nfs_delegation_find_inode_server(struct nfs_server *server,
 676                                  const struct nfs_fh *fhandle)
 677 {
 678         struct nfs_delegation *delegation;
 679         struct inode *res = NULL;
 680
 681         list_for_each_entry_rcu(delegation, &server->delegations, super_list) {
 682                 spin_lock(&delegation->lock);
 683                 if (delegation->inode != NULL &&
 684                     nfs_compare_fh(fhandle, &NFS_I(delegation->inode)->fh) == 0) {
 685                         res = igrab(delegation->inode);
 686                 }
 687                 spin_unlock(&delegation->lock);
 688                 if (res != NULL)
 689                         break;
 690         }
 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  */
 702 struct 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         }
 714         rcu_read_unlock();
 715         return res;
 716 }
 717
 718 static 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  *
 730  */
 731 void nfs_delegation_mark_reclaim(struct nfs_client *clp)
 732 {
 733         struct nfs_server *server;
 734
 735         rcu_read_lock();
 736         list_for_each_entry_rcu(server, &clp->cl_superblocks, client_link)
 737                 nfs_delegation_mark_reclaim_server(server);
 738         rcu_read_unlock();
 739 }
 740
 741 /**
 742  * nfs_delegation_reap_unclaimed - reap unclaimed delegations after reboot recovery is done
 743  * @clp: nfs_client to process
 744  *
 745  */
 746 void nfs_delegation_reap_unclaimed(struct nfs_client *clp)
 747 {
 748         struct nfs_delegation *delegation;
 749         struct nfs_server *server;
 750         struct inode *inode;
 751
 752 restart:
 753         rcu_read_lock();
 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),
 764                                         delegation, server);
 765                         rcu_read_unlock();
 766
 767                         if (delegation != NULL)
 768                                 nfs_free_delegation(delegation);
 769                         iput(inode);
 770                         goto restart;
 771                 }
 772         }
 773         rcu_read_unlock();
 774 }
 775
 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  */
 783 int 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
 802  * @flags: delegation type requirement
 803  *
 804  * Returns "true" and fills in "dst->data" * if inode had a delegation,
 805  * otherwise "false" is returned.
 806  */
 807 bool nfs4_copy_delegation_stateid(nfs4_stateid *dst, struct inode *inode,
 808                 fmode_t flags)
 809 {
 810         struct nfs_inode *nfsi = NFS_I(inode);
 811         struct nfs_delegation *delegation;
 812         bool ret;
 813
 814         flags &= FMODE_READ|FMODE_WRITE;
 815         rcu_read_lock();
 816         delegation = rcu_dereference(nfsi->delegation);
 817         ret = (delegation != NULL && (delegation->type & flags) == flags);
 818         if (ret) {
 819                 nfs4_stateid_copy(dst, &delegation->stateid);
 820                 nfs_mark_delegation_referenced(delegation);
 821         }
 822         rcu_read_unlock();
 823         return ret;
 824 }