LCOV - code coverage report
Current view: top level - fs/lockd - svclock.c (source / functions) Hit Total Coverage
Test: combined.info Lines: 0 410 0.0 %
Date: 2022-04-01 14:58:12 Functions: 0 29 0.0 %
Branches: 0 162 0.0 %

           Branch data     Line data    Source code
       1                 :            : // SPDX-License-Identifier: GPL-2.0
       2                 :            : /*
       3                 :            :  * linux/fs/lockd/svclock.c
       4                 :            :  *
       5                 :            :  * Handling of server-side locks, mostly of the blocked variety.
       6                 :            :  * This is the ugliest part of lockd because we tread on very thin ice.
       7                 :            :  * GRANT and CANCEL calls may get stuck, meet in mid-flight, etc.
       8                 :            :  * IMNSHO introducing the grant callback into the NLM protocol was one
       9                 :            :  * of the worst ideas Sun ever had. Except maybe for the idea of doing
      10                 :            :  * NFS file locking at all.
      11                 :            :  *
      12                 :            :  * I'm trying hard to avoid race conditions by protecting most accesses
      13                 :            :  * to a file's list of blocked locks through a semaphore. The global
      14                 :            :  * list of blocked locks is not protected in this fashion however.
      15                 :            :  * Therefore, some functions (such as the RPC callback for the async grant
      16                 :            :  * call) move blocked locks towards the head of the list *while some other
      17                 :            :  * process might be traversing it*. This should not be a problem in
      18                 :            :  * practice, because this will only cause functions traversing the list
      19                 :            :  * to visit some blocks twice.
      20                 :            :  *
      21                 :            :  * Copyright (C) 1996, Olaf Kirch <okir@monad.swb.de>
      22                 :            :  */
      23                 :            : 
      24                 :            : #include <linux/types.h>
      25                 :            : #include <linux/slab.h>
      26                 :            : #include <linux/errno.h>
      27                 :            : #include <linux/kernel.h>
      28                 :            : #include <linux/sched.h>
      29                 :            : #include <linux/sunrpc/clnt.h>
      30                 :            : #include <linux/sunrpc/svc_xprt.h>
      31                 :            : #include <linux/lockd/nlm.h>
      32                 :            : #include <linux/lockd/lockd.h>
      33                 :            : #include <linux/kthread.h>
      34                 :            : 
      35                 :            : #define NLMDBG_FACILITY         NLMDBG_SVCLOCK
      36                 :            : 
      37                 :            : #ifdef CONFIG_LOCKD_V4
      38                 :            : #define nlm_deadlock    nlm4_deadlock
      39                 :            : #else
      40                 :            : #define nlm_deadlock    nlm_lck_denied
      41                 :            : #endif
      42                 :            : 
      43                 :            : static void nlmsvc_release_block(struct nlm_block *block);
      44                 :            : static void     nlmsvc_insert_block(struct nlm_block *block, unsigned long);
      45                 :            : static void     nlmsvc_remove_block(struct nlm_block *block);
      46                 :            : 
      47                 :            : static int nlmsvc_setgrantargs(struct nlm_rqst *call, struct nlm_lock *lock);
      48                 :            : static void nlmsvc_freegrantargs(struct nlm_rqst *call);
      49                 :            : static const struct rpc_call_ops nlmsvc_grant_ops;
      50                 :            : 
      51                 :            : /*
      52                 :            :  * The list of blocked locks to retry
      53                 :            :  */
      54                 :            : static LIST_HEAD(nlm_blocked);
      55                 :            : static DEFINE_SPINLOCK(nlm_blocked_lock);
      56                 :            : 
      57                 :            : #if IS_ENABLED(CONFIG_SUNRPC_DEBUG)
      58                 :            : static const char *nlmdbg_cookie2a(const struct nlm_cookie *cookie)
      59                 :            : {
      60                 :            :         /*
      61                 :            :          * We can get away with a static buffer because this is only called
      62                 :            :          * from lockd, which is single-threaded.
      63                 :            :          */
      64                 :            :         static char buf[2*NLM_MAXCOOKIELEN+1];
      65                 :            :         unsigned int i, len = sizeof(buf);
      66                 :            :         char *p = buf;
      67                 :            : 
      68                 :            :         len--;  /* allow for trailing \0 */
      69                 :            :         if (len < 3)
      70                 :            :                 return "???";
      71                 :            :         for (i = 0 ; i < cookie->len ; i++) {
      72                 :            :                 if (len < 2) {
      73                 :            :                         strcpy(p-3, "...");
      74                 :            :                         break;
      75                 :            :                 }
      76                 :            :                 sprintf(p, "%02x", cookie->data[i]);
      77                 :            :                 p += 2;
      78                 :            :                 len -= 2;
      79                 :            :         }
      80                 :            :         *p = '\0';
      81                 :            : 
      82                 :            :         return buf;
      83                 :            : }
      84                 :            : #endif
      85                 :            : 
      86                 :            : /*
      87                 :            :  * Insert a blocked lock into the global list
      88                 :            :  */
      89                 :            : static void
      90                 :          0 : nlmsvc_insert_block_locked(struct nlm_block *block, unsigned long when)
      91                 :            : {
      92                 :          0 :         struct nlm_block *b;
      93                 :          0 :         struct list_head *pos;
      94                 :            : 
      95                 :          0 :         dprintk("lockd: nlmsvc_insert_block(%p, %ld)\n", block, when);
      96         [ #  # ]:          0 :         if (list_empty(&block->b_list)) {
      97                 :          0 :                 kref_get(&block->b_count);
      98                 :            :         } else {
      99                 :          0 :                 list_del_init(&block->b_list);
     100                 :            :         }
     101                 :            : 
     102                 :          0 :         pos = &nlm_blocked;
     103         [ #  # ]:          0 :         if (when != NLM_NEVER) {
     104         [ #  # ]:          0 :                 if ((when += jiffies) == NLM_NEVER)
     105                 :          0 :                         when ++;
     106         [ #  # ]:          0 :                 list_for_each(pos, &nlm_blocked) {
     107                 :          0 :                         b = list_entry(pos, struct nlm_block, b_list);
     108   [ #  #  #  # ]:          0 :                         if (time_after(b->b_when,when) || b->b_when == NLM_NEVER)
     109                 :            :                                 break;
     110                 :            :                 }
     111                 :            :                 /* On normal exit from the loop, pos == &nlm_blocked,
     112                 :            :                  * so we will be adding to the end of the list - good
     113                 :            :                  */
     114                 :            :         }
     115                 :            : 
     116                 :          0 :         list_add_tail(&block->b_list, pos);
     117                 :          0 :         block->b_when = when;
     118                 :          0 : }
     119                 :            : 
     120                 :          0 : static void nlmsvc_insert_block(struct nlm_block *block, unsigned long when)
     121                 :            : {
     122                 :          0 :         spin_lock(&nlm_blocked_lock);
     123                 :          0 :         nlmsvc_insert_block_locked(block, when);
     124                 :          0 :         spin_unlock(&nlm_blocked_lock);
     125                 :          0 : }
     126                 :            : 
     127                 :            : /*
     128                 :            :  * Remove a block from the global list
     129                 :            :  */
     130                 :            : static inline void
     131                 :          0 : nlmsvc_remove_block(struct nlm_block *block)
     132                 :            : {
     133         [ #  # ]:          0 :         if (!list_empty(&block->b_list)) {
     134                 :          0 :                 spin_lock(&nlm_blocked_lock);
     135                 :          0 :                 list_del_init(&block->b_list);
     136                 :          0 :                 spin_unlock(&nlm_blocked_lock);
     137                 :          0 :                 nlmsvc_release_block(block);
     138                 :            :         }
     139                 :          0 : }
     140                 :            : 
     141                 :            : /*
     142                 :            :  * Find a block for a given lock
     143                 :            :  */
     144                 :            : static struct nlm_block *
     145                 :          0 : nlmsvc_lookup_block(struct nlm_file *file, struct nlm_lock *lock)
     146                 :            : {
     147                 :          0 :         struct nlm_block        *block;
     148                 :          0 :         struct file_lock        *fl;
     149                 :            : 
     150                 :          0 :         dprintk("lockd: nlmsvc_lookup_block f=%p pd=%d %Ld-%Ld ty=%d\n",
     151                 :            :                                 file, lock->fl.fl_pid,
     152                 :            :                                 (long long)lock->fl.fl_start,
     153                 :            :                                 (long long)lock->fl.fl_end, lock->fl.fl_type);
     154         [ #  # ]:          0 :         list_for_each_entry(block, &nlm_blocked, b_list) {
     155                 :          0 :                 fl = &block->b_call->a_args.lock.fl;
     156                 :          0 :                 dprintk("lockd: check f=%p pd=%d %Ld-%Ld ty=%d cookie=%s\n",
     157                 :            :                                 block->b_file, fl->fl_pid,
     158                 :            :                                 (long long)fl->fl_start,
     159                 :            :                                 (long long)fl->fl_end, fl->fl_type,
     160                 :            :                                 nlmdbg_cookie2a(&block->b_call->a_args.cookie));
     161   [ #  #  #  # ]:          0 :                 if (block->b_file == file && nlm_compare_locks(fl, &lock->fl)) {
     162                 :          0 :                         kref_get(&block->b_count);
     163                 :          0 :                         return block;
     164                 :            :                 }
     165                 :            :         }
     166                 :            : 
     167                 :            :         return NULL;
     168                 :            : }
     169                 :            : 
     170                 :          0 : static inline int nlm_cookie_match(struct nlm_cookie *a, struct nlm_cookie *b)
     171                 :            : {
     172                 :          0 :         if (a->len != b->len)
     173                 :            :                 return 0;
     174         [ #  # ]:          0 :         if (memcmp(a->data, b->data, a->len))
     175                 :            :                 return 0;
     176                 :            :         return 1;
     177                 :            : }
     178                 :            : 
     179                 :            : /*
     180                 :            :  * Find a block with a given NLM cookie.
     181                 :            :  */
     182                 :            : static inline struct nlm_block *
     183                 :          0 : nlmsvc_find_block(struct nlm_cookie *cookie)
     184                 :            : {
     185                 :          0 :         struct nlm_block *block;
     186                 :            : 
     187         [ #  # ]:          0 :         list_for_each_entry(block, &nlm_blocked, b_list) {
     188         [ #  # ]:          0 :                 if (nlm_cookie_match(&block->b_call->a_args.cookie,cookie))
     189                 :          0 :                         goto found;
     190                 :            :         }
     191                 :            : 
     192                 :            :         return NULL;
     193                 :            : 
     194                 :            : found:
     195                 :          0 :         dprintk("nlmsvc_find_block(%s): block=%p\n", nlmdbg_cookie2a(cookie), block);
     196                 :          0 :         kref_get(&block->b_count);
     197                 :          0 :         return block;
     198                 :            : }
     199                 :            : 
     200                 :            : /*
     201                 :            :  * Create a block and initialize it.
     202                 :            :  *
     203                 :            :  * Note: we explicitly set the cookie of the grant reply to that of
     204                 :            :  * the blocked lock request. The spec explicitly mentions that the client
     205                 :            :  * should _not_ rely on the callback containing the same cookie as the
     206                 :            :  * request, but (as I found out later) that's because some implementations
     207                 :            :  * do just this. Never mind the standards comittees, they support our
     208                 :            :  * logging industries.
     209                 :            :  *
     210                 :            :  * 10 years later: I hope we can safely ignore these old and broken
     211                 :            :  * clients by now. Let's fix this so we can uniquely identify an incoming
     212                 :            :  * GRANTED_RES message by cookie, without having to rely on the client's IP
     213                 :            :  * address. --okir
     214                 :            :  */
     215                 :            : static struct nlm_block *
     216                 :            : nlmsvc_create_block(struct svc_rqst *rqstp, struct nlm_host *host,
     217                 :            :                     struct nlm_file *file, struct nlm_lock *lock,
     218                 :            :                     struct nlm_cookie *cookie)
     219                 :            : {
     220                 :            :         struct nlm_block        *block;
     221                 :            :         struct nlm_rqst         *call = NULL;
     222                 :            : 
     223                 :            :         call = nlm_alloc_call(host);
     224                 :            :         if (call == NULL)
     225                 :            :                 return NULL;
     226                 :            : 
     227                 :            :         /* Allocate memory for block, and initialize arguments */
     228                 :            :         block = kzalloc(sizeof(*block), GFP_KERNEL);
     229                 :            :         if (block == NULL)
     230                 :            :                 goto failed;
     231                 :            :         kref_init(&block->b_count);
     232                 :            :         INIT_LIST_HEAD(&block->b_list);
     233                 :            :         INIT_LIST_HEAD(&block->b_flist);
     234                 :            : 
     235                 :            :         if (!nlmsvc_setgrantargs(call, lock))
     236                 :            :                 goto failed_free;
     237                 :            : 
     238                 :            :         /* Set notifier function for VFS, and init args */
     239                 :            :         call->a_args.lock.fl.fl_flags |= FL_SLEEP;
     240                 :            :         call->a_args.lock.fl.fl_lmops = &nlmsvc_lock_operations;
     241                 :            :         nlmclnt_next_cookie(&call->a_args.cookie);
     242                 :            : 
     243                 :            :         dprintk("lockd: created block %p...\n", block);
     244                 :            : 
     245                 :            :         /* Create and initialize the block */
     246                 :            :         block->b_daemon = rqstp->rq_server;
     247                 :            :         block->b_host   = host;
     248                 :            :         block->b_file   = file;
     249                 :            :         file->f_count++;
     250                 :            : 
     251                 :            :         /* Add to file's list of blocks */
     252                 :            :         list_add(&block->b_flist, &file->f_blocks);
     253                 :            : 
     254                 :            :         /* Set up RPC arguments for callback */
     255                 :            :         block->b_call = call;
     256                 :            :         call->a_flags   = RPC_TASK_ASYNC;
     257                 :            :         call->a_block = block;
     258                 :            : 
     259                 :            :         return block;
     260                 :            : 
     261                 :            : failed_free:
     262                 :            :         kfree(block);
     263                 :            : failed:
     264                 :            :         nlmsvc_release_call(call);
     265                 :            :         return NULL;
     266                 :            : }
     267                 :            : 
     268                 :            : /*
     269                 :            :  * Delete a block.
     270                 :            :  * It is the caller's responsibility to check whether the file
     271                 :            :  * can be closed hereafter.
     272                 :            :  */
     273                 :          0 : static int nlmsvc_unlink_block(struct nlm_block *block)
     274                 :            : {
     275                 :          0 :         int status;
     276                 :          0 :         dprintk("lockd: unlinking block %p...\n", block);
     277                 :            : 
     278                 :            :         /* Remove block from list */
     279                 :          0 :         status = locks_delete_block(&block->b_call->a_args.lock.fl);
     280                 :          0 :         nlmsvc_remove_block(block);
     281                 :          0 :         return status;
     282                 :            : }
     283                 :            : 
     284                 :          0 : static void nlmsvc_free_block(struct kref *kref)
     285                 :            : {
     286                 :          0 :         struct nlm_block *block = container_of(kref, struct nlm_block, b_count);
     287                 :          0 :         struct nlm_file         *file = block->b_file;
     288                 :            : 
     289                 :          0 :         dprintk("lockd: freeing block %p...\n", block);
     290                 :            : 
     291                 :            :         /* Remove block from file's list of blocks */
     292                 :          0 :         list_del_init(&block->b_flist);
     293                 :          0 :         mutex_unlock(&file->f_mutex);
     294                 :            : 
     295                 :          0 :         nlmsvc_freegrantargs(block->b_call);
     296                 :          0 :         nlmsvc_release_call(block->b_call);
     297                 :          0 :         nlm_release_file(block->b_file);
     298                 :          0 :         kfree(block);
     299                 :          0 : }
     300                 :            : 
     301                 :          0 : static void nlmsvc_release_block(struct nlm_block *block)
     302                 :            : {
     303         [ #  # ]:          0 :         if (block != NULL)
     304                 :          0 :                 kref_put_mutex(&block->b_count, nlmsvc_free_block, &block->b_file->f_mutex);
     305                 :          0 : }
     306                 :            : 
     307                 :            : /*
     308                 :            :  * Loop over all blocks and delete blocks held by
     309                 :            :  * a matching host.
     310                 :            :  */
     311                 :          0 : void nlmsvc_traverse_blocks(struct nlm_host *host,
     312                 :            :                         struct nlm_file *file,
     313                 :            :                         nlm_host_match_fn_t match)
     314                 :            : {
     315                 :          0 :         struct nlm_block *block, *next;
     316                 :            : 
     317                 :          0 : restart:
     318                 :          0 :         mutex_lock(&file->f_mutex);
     319         [ #  # ]:          0 :         list_for_each_entry_safe(block, next, &file->f_blocks, b_flist) {
     320         [ #  # ]:          0 :                 if (!match(block->b_host, host))
     321                 :          0 :                         continue;
     322                 :            :                 /* Do not destroy blocks that are not on
     323                 :            :                  * the global retry list - why? */
     324         [ #  # ]:          0 :                 if (list_empty(&block->b_list))
     325                 :          0 :                         continue;
     326                 :          0 :                 kref_get(&block->b_count);
     327                 :          0 :                 mutex_unlock(&file->f_mutex);
     328                 :          0 :                 nlmsvc_unlink_block(block);
     329                 :          0 :                 nlmsvc_release_block(block);
     330                 :          0 :                 goto restart;
     331                 :            :         }
     332                 :          0 :         mutex_unlock(&file->f_mutex);
     333                 :          0 : }
     334                 :            : 
     335                 :            : static struct nlm_lockowner *
     336                 :          0 : nlmsvc_get_lockowner(struct nlm_lockowner *lockowner)
     337                 :            : {
     338                 :          0 :         refcount_inc(&lockowner->count);
     339                 :          0 :         return lockowner;
     340                 :            : }
     341                 :            : 
     342                 :          0 : static void nlmsvc_put_lockowner(struct nlm_lockowner *lockowner)
     343                 :            : {
     344         [ #  # ]:          0 :         if (!refcount_dec_and_lock(&lockowner->count, &lockowner->host->h_lock))
     345                 :            :                 return;
     346                 :          0 :         list_del(&lockowner->list);
     347                 :          0 :         spin_unlock(&lockowner->host->h_lock);
     348                 :          0 :         nlmsvc_release_host(lockowner->host);
     349                 :          0 :         kfree(lockowner);
     350                 :            : }
     351                 :            : 
     352                 :          0 : static struct nlm_lockowner *__nlmsvc_find_lockowner(struct nlm_host *host, pid_t pid)
     353                 :            : {
     354                 :          0 :         struct nlm_lockowner *lockowner;
     355   [ #  #  #  # ]:          0 :         list_for_each_entry(lockowner, &host->h_lockowners, list) {
     356   [ #  #  #  # ]:          0 :                 if (lockowner->pid != pid)
     357                 :          0 :                         continue;
     358                 :          0 :                 return nlmsvc_get_lockowner(lockowner);
     359                 :            :         }
     360                 :            :         return NULL;
     361                 :            : }
     362                 :            : 
     363                 :          0 : static struct nlm_lockowner *nlmsvc_find_lockowner(struct nlm_host *host, pid_t pid)
     364                 :            : {
     365                 :          0 :         struct nlm_lockowner *res, *new = NULL;
     366                 :            : 
     367                 :          0 :         spin_lock(&host->h_lock);
     368                 :          0 :         res = __nlmsvc_find_lockowner(host, pid);
     369                 :            : 
     370         [ #  # ]:          0 :         if (res == NULL) {
     371                 :          0 :                 spin_unlock(&host->h_lock);
     372                 :          0 :                 new = kmalloc(sizeof(*res), GFP_KERNEL);
     373                 :          0 :                 spin_lock(&host->h_lock);
     374                 :          0 :                 res = __nlmsvc_find_lockowner(host, pid);
     375         [ #  # ]:          0 :                 if (res == NULL && new != NULL) {
     376                 :          0 :                         res = new;
     377                 :            :                         /* fs/locks.c will manage the refcount through lock_ops */
     378                 :          0 :                         refcount_set(&new->count, 1);
     379                 :          0 :                         new->pid = pid;
     380                 :          0 :                         new->host = nlm_get_host(host);
     381                 :          0 :                         list_add(&new->list, &host->h_lockowners);
     382                 :          0 :                         new = NULL;
     383                 :            :                 }
     384                 :            :         }
     385                 :            : 
     386                 :          0 :         spin_unlock(&host->h_lock);
     387                 :          0 :         kfree(new);
     388                 :          0 :         return res;
     389                 :            : }
     390                 :            : 
     391                 :            : void
     392                 :          0 : nlmsvc_release_lockowner(struct nlm_lock *lock)
     393                 :            : {
     394         [ #  # ]:          0 :         if (lock->fl.fl_owner)
     395                 :          0 :                 nlmsvc_put_lockowner(lock->fl.fl_owner);
     396                 :          0 : }
     397                 :            : 
     398                 :          0 : static void nlmsvc_locks_copy_lock(struct file_lock *new, struct file_lock *fl)
     399                 :            : {
     400                 :          0 :         struct nlm_lockowner *nlm_lo = (struct nlm_lockowner *)fl->fl_owner;
     401                 :          0 :         new->fl_owner = nlmsvc_get_lockowner(nlm_lo);
     402                 :          0 : }
     403                 :            : 
     404                 :          0 : static void nlmsvc_locks_release_private(struct file_lock *fl)
     405                 :            : {
     406                 :          0 :         nlmsvc_put_lockowner((struct nlm_lockowner *)fl->fl_owner);
     407                 :          0 : }
     408                 :            : 
     409                 :            : static const struct file_lock_operations nlmsvc_lock_ops = {
     410                 :            :         .fl_copy_lock = nlmsvc_locks_copy_lock,
     411                 :            :         .fl_release_private = nlmsvc_locks_release_private,
     412                 :            : };
     413                 :            : 
     414                 :          0 : void nlmsvc_locks_init_private(struct file_lock *fl, struct nlm_host *host,
     415                 :            :                                                 pid_t pid)
     416                 :            : {
     417                 :          0 :         fl->fl_owner = nlmsvc_find_lockowner(host, pid);
     418         [ #  # ]:          0 :         if (fl->fl_owner != NULL)
     419                 :          0 :                 fl->fl_ops = &nlmsvc_lock_ops;
     420                 :          0 : }
     421                 :            : 
     422                 :            : /*
     423                 :            :  * Initialize arguments for GRANTED call. The nlm_rqst structure
     424                 :            :  * has been cleared already.
     425                 :            :  */
     426                 :          0 : static int nlmsvc_setgrantargs(struct nlm_rqst *call, struct nlm_lock *lock)
     427                 :            : {
     428                 :          0 :         locks_copy_lock(&call->a_args.lock.fl, &lock->fl);
     429                 :          0 :         memcpy(&call->a_args.lock.fh, &lock->fh, sizeof(call->a_args.lock.fh));
     430         [ #  # ]:          0 :         call->a_args.lock.caller = utsname()->nodename;
     431                 :          0 :         call->a_args.lock.oh.len = lock->oh.len;
     432                 :            : 
     433                 :            :         /* set default data area */
     434                 :          0 :         call->a_args.lock.oh.data = call->a_owner;
     435                 :          0 :         call->a_args.lock.svid = ((struct nlm_lockowner *)lock->fl.fl_owner)->pid;
     436                 :            : 
     437         [ #  # ]:          0 :         if (lock->oh.len > NLMCLNT_OHSIZE) {
     438         [ #  # ]:          0 :                 void *data = kmalloc(lock->oh.len, GFP_KERNEL);
     439         [ #  # ]:          0 :                 if (!data)
     440                 :            :                         return 0;
     441                 :          0 :                 call->a_args.lock.oh.data = (u8 *) data;
     442                 :            :         }
     443                 :            : 
     444                 :          0 :         memcpy(call->a_args.lock.oh.data, lock->oh.data, lock->oh.len);
     445                 :          0 :         return 1;
     446                 :            : }
     447                 :            : 
     448                 :          0 : static void nlmsvc_freegrantargs(struct nlm_rqst *call)
     449                 :            : {
     450         [ #  # ]:          0 :         if (call->a_args.lock.oh.data != call->a_owner)
     451                 :          0 :                 kfree(call->a_args.lock.oh.data);
     452                 :            : 
     453                 :          0 :         locks_release_private(&call->a_args.lock.fl);
     454                 :          0 : }
     455                 :            : 
     456                 :            : /*
     457                 :            :  * Deferred lock request handling for non-blocking lock
     458                 :            :  */
     459                 :            : static __be32
     460                 :          0 : nlmsvc_defer_lock_rqst(struct svc_rqst *rqstp, struct nlm_block *block)
     461                 :            : {
     462                 :          0 :         __be32 status = nlm_lck_denied_nolocks;
     463                 :            : 
     464                 :          0 :         block->b_flags |= B_QUEUED;
     465                 :            : 
     466                 :          0 :         nlmsvc_insert_block(block, NLM_TIMEOUT);
     467                 :            : 
     468                 :          0 :         block->b_cache_req = &rqstp->rq_chandle;
     469         [ #  # ]:          0 :         if (rqstp->rq_chandle.defer) {
     470                 :          0 :                 block->b_deferred_req =
     471                 :          0 :                         rqstp->rq_chandle.defer(block->b_cache_req);
     472         [ #  # ]:          0 :                 if (block->b_deferred_req != NULL)
     473                 :          0 :                         status = nlm_drop_reply;
     474                 :            :         }
     475                 :          0 :         dprintk("lockd: nlmsvc_defer_lock_rqst block %p flags %d status %d\n",
     476                 :            :                 block, block->b_flags, ntohl(status));
     477                 :            : 
     478                 :          0 :         return status;
     479                 :            : }
     480                 :            : 
     481                 :            : /*
     482                 :            :  * Attempt to establish a lock, and if it can't be granted, block it
     483                 :            :  * if required.
     484                 :            :  */
     485                 :            : __be32
     486                 :          0 : nlmsvc_lock(struct svc_rqst *rqstp, struct nlm_file *file,
     487                 :            :             struct nlm_host *host, struct nlm_lock *lock, int wait,
     488                 :            :             struct nlm_cookie *cookie, int reclaim)
     489                 :            : {
     490                 :          0 :         struct nlm_block        *block = NULL;
     491                 :          0 :         int                     error;
     492                 :          0 :         __be32                  ret;
     493                 :            : 
     494                 :          0 :         dprintk("lockd: nlmsvc_lock(%s/%ld, ty=%d, pi=%d, %Ld-%Ld, bl=%d)\n",
     495                 :            :                                 locks_inode(file->f_file)->i_sb->s_id,
     496                 :            :                                 locks_inode(file->f_file)->i_ino,
     497                 :            :                                 lock->fl.fl_type, lock->fl.fl_pid,
     498                 :            :                                 (long long)lock->fl.fl_start,
     499                 :            :                                 (long long)lock->fl.fl_end,
     500                 :            :                                 wait);
     501                 :            : 
     502                 :            :         /* Lock file against concurrent access */
     503                 :          0 :         mutex_lock(&file->f_mutex);
     504                 :            :         /* Get existing block (in case client is busy-waiting)
     505                 :            :          * or create new block
     506                 :            :          */
     507                 :          0 :         block = nlmsvc_lookup_block(file, lock);
     508         [ #  # ]:          0 :         if (block == NULL) {
     509                 :          0 :                 block = nlmsvc_create_block(rqstp, host, file, lock, cookie);
     510                 :          0 :                 ret = nlm_lck_denied_nolocks;
     511         [ #  # ]:          0 :                 if (block == NULL)
     512                 :          0 :                         goto out;
     513                 :          0 :                 lock = &block->b_call->a_args.lock;
     514                 :            :         } else
     515                 :          0 :                 lock->fl.fl_flags &= ~FL_SLEEP;
     516                 :            : 
     517         [ #  # ]:          0 :         if (block->b_flags & B_QUEUED) {
     518                 :          0 :                 dprintk("lockd: nlmsvc_lock deferred block %p flags %d\n",
     519                 :            :                                                         block, block->b_flags);
     520         [ #  # ]:          0 :                 if (block->b_granted) {
     521                 :          0 :                         nlmsvc_unlink_block(block);
     522                 :          0 :                         ret = nlm_granted;
     523                 :          0 :                         goto out;
     524                 :            :                 }
     525         [ #  # ]:          0 :                 if (block->b_flags & B_TIMED_OUT) {
     526                 :          0 :                         nlmsvc_unlink_block(block);
     527                 :          0 :                         ret = nlm_lck_denied;
     528                 :          0 :                         goto out;
     529                 :            :                 }
     530                 :          0 :                 ret = nlm_drop_reply;
     531                 :          0 :                 goto out;
     532                 :            :         }
     533                 :            : 
     534   [ #  #  #  #  :          0 :         if (locks_in_grace(SVC_NET(rqstp)) && !reclaim) {
                   #  # ]
     535                 :          0 :                 ret = nlm_lck_denied_grace_period;
     536                 :          0 :                 goto out;
     537                 :            :         }
     538   [ #  #  #  #  :          0 :         if (reclaim && !locks_in_grace(SVC_NET(rqstp))) {
                   #  # ]
     539                 :          0 :                 ret = nlm_lck_denied_grace_period;
     540                 :          0 :                 goto out;
     541                 :            :         }
     542                 :            : 
     543         [ #  # ]:          0 :         if (!wait)
     544                 :          0 :                 lock->fl.fl_flags &= ~FL_SLEEP;
     545                 :          0 :         error = vfs_lock_file(file->f_file, F_SETLK, &lock->fl, NULL);
     546                 :          0 :         lock->fl.fl_flags &= ~FL_SLEEP;
     547                 :            : 
     548                 :          0 :         dprintk("lockd: vfs_lock_file returned %d\n", error);
     549   [ #  #  #  #  :          0 :         switch (error) {
                      # ]
     550                 :          0 :                 case 0:
     551                 :          0 :                         ret = nlm_granted;
     552                 :          0 :                         goto out;
     553                 :          0 :                 case -EAGAIN:
     554                 :            :                         /*
     555                 :            :                          * If this is a blocking request for an
     556                 :            :                          * already pending lock request then we need
     557                 :            :                          * to put it back on lockd's block list
     558                 :            :                          */
     559         [ #  # ]:          0 :                         if (wait)
     560                 :            :                                 break;
     561                 :          0 :                         ret = nlm_lck_denied;
     562                 :          0 :                         goto out;
     563                 :          0 :                 case FILE_LOCK_DEFERRED:
     564         [ #  # ]:          0 :                         if (wait)
     565                 :            :                                 break;
     566                 :            :                         /* Filesystem lock operation is in progress
     567                 :            :                            Add it to the queue waiting for callback */
     568                 :          0 :                         ret = nlmsvc_defer_lock_rqst(rqstp, block);
     569                 :          0 :                         goto out;
     570                 :          0 :                 case -EDEADLK:
     571                 :          0 :                         ret = nlm_deadlock;
     572                 :          0 :                         goto out;
     573                 :          0 :                 default:                        /* includes ENOLCK */
     574                 :          0 :                         ret = nlm_lck_denied_nolocks;
     575                 :          0 :                         goto out;
     576                 :            :         }
     577                 :            : 
     578                 :          0 :         ret = nlm_lck_blocked;
     579                 :            : 
     580                 :            :         /* Append to list of blocked */
     581                 :          0 :         nlmsvc_insert_block(block, NLM_NEVER);
     582                 :          0 : out:
     583                 :          0 :         mutex_unlock(&file->f_mutex);
     584                 :          0 :         nlmsvc_release_block(block);
     585                 :          0 :         dprintk("lockd: nlmsvc_lock returned %u\n", ret);
     586                 :          0 :         return ret;
     587                 :            : }
     588                 :            : 
     589                 :            : /*
     590                 :            :  * Test for presence of a conflicting lock.
     591                 :            :  */
     592                 :            : __be32
     593                 :          0 : nlmsvc_testlock(struct svc_rqst *rqstp, struct nlm_file *file,
     594                 :            :                 struct nlm_host *host, struct nlm_lock *lock,
     595                 :            :                 struct nlm_lock *conflock, struct nlm_cookie *cookie)
     596                 :            : {
     597                 :          0 :         int                     error;
     598                 :          0 :         __be32                  ret;
     599                 :          0 :         struct nlm_lockowner    *test_owner;
     600                 :            : 
     601                 :          0 :         dprintk("lockd: nlmsvc_testlock(%s/%ld, ty=%d, %Ld-%Ld)\n",
     602                 :            :                                 locks_inode(file->f_file)->i_sb->s_id,
     603                 :            :                                 locks_inode(file->f_file)->i_ino,
     604                 :            :                                 lock->fl.fl_type,
     605                 :            :                                 (long long)lock->fl.fl_start,
     606                 :            :                                 (long long)lock->fl.fl_end);
     607                 :            : 
     608   [ #  #  #  # ]:          0 :         if (locks_in_grace(SVC_NET(rqstp))) {
     609                 :          0 :                 ret = nlm_lck_denied_grace_period;
     610                 :          0 :                 goto out;
     611                 :            :         }
     612                 :            : 
     613                 :            :         /* If there's a conflicting lock, remember to clean up the test lock */
     614                 :          0 :         test_owner = (struct nlm_lockowner *)lock->fl.fl_owner;
     615                 :            : 
     616                 :          0 :         error = vfs_test_lock(file->f_file, &lock->fl);
     617         [ #  # ]:          0 :         if (error) {
     618                 :            :                 /* We can't currently deal with deferred test requests */
     619         [ #  # ]:          0 :                 if (error == FILE_LOCK_DEFERRED)
     620                 :          0 :                         WARN_ON_ONCE(1);
     621                 :            : 
     622                 :          0 :                 ret = nlm_lck_denied_nolocks;
     623                 :          0 :                 goto out;
     624                 :            :         }
     625                 :            : 
     626         [ #  # ]:          0 :         if (lock->fl.fl_type == F_UNLCK) {
     627                 :          0 :                 ret = nlm_granted;
     628                 :          0 :                 goto out;
     629                 :            :         }
     630                 :            : 
     631                 :          0 :         dprintk("lockd: conflicting lock(ty=%d, %Ld-%Ld)\n",
     632                 :            :                 lock->fl.fl_type, (long long)lock->fl.fl_start,
     633                 :            :                 (long long)lock->fl.fl_end);
     634                 :          0 :         conflock->caller = "somehost";     /* FIXME */
     635                 :          0 :         conflock->len = strlen(conflock->caller);
     636                 :          0 :         conflock->oh.len = 0;                /* don't return OH info */
     637                 :          0 :         conflock->svid = ((struct nlm_lockowner *)lock->fl.fl_owner)->pid;
     638                 :          0 :         conflock->fl.fl_type = lock->fl.fl_type;
     639                 :          0 :         conflock->fl.fl_start = lock->fl.fl_start;
     640                 :          0 :         conflock->fl.fl_end = lock->fl.fl_end;
     641                 :          0 :         locks_release_private(&lock->fl);
     642                 :            : 
     643                 :            :         /* Clean up the test lock */
     644                 :          0 :         lock->fl.fl_owner = NULL;
     645                 :          0 :         nlmsvc_put_lockowner(test_owner);
     646                 :            : 
     647                 :          0 :         ret = nlm_lck_denied;
     648                 :          0 : out:
     649                 :          0 :         return ret;
     650                 :            : }
     651                 :            : 
     652                 :            : /*
     653                 :            :  * Remove a lock.
     654                 :            :  * This implies a CANCEL call: We send a GRANT_MSG, the client replies
     655                 :            :  * with a GRANT_RES call which gets lost, and calls UNLOCK immediately
     656                 :            :  * afterwards. In this case the block will still be there, and hence
     657                 :            :  * must be removed.
     658                 :            :  */
     659                 :            : __be32
     660                 :          0 : nlmsvc_unlock(struct net *net, struct nlm_file *file, struct nlm_lock *lock)
     661                 :            : {
     662                 :          0 :         int     error;
     663                 :            : 
     664                 :          0 :         dprintk("lockd: nlmsvc_unlock(%s/%ld, pi=%d, %Ld-%Ld)\n",
     665                 :            :                                 locks_inode(file->f_file)->i_sb->s_id,
     666                 :            :                                 locks_inode(file->f_file)->i_ino,
     667                 :            :                                 lock->fl.fl_pid,
     668                 :            :                                 (long long)lock->fl.fl_start,
     669                 :            :                                 (long long)lock->fl.fl_end);
     670                 :            : 
     671                 :            :         /* First, cancel any lock that might be there */
     672                 :          0 :         nlmsvc_cancel_blocked(net, file, lock);
     673                 :            : 
     674                 :          0 :         lock->fl.fl_type = F_UNLCK;
     675                 :          0 :         error = vfs_lock_file(file->f_file, F_SETLK, &lock->fl, NULL);
     676                 :            : 
     677                 :          0 :         return (error < 0)? nlm_lck_denied_nolocks : nlm_granted;
     678                 :            : }
     679                 :            : 
     680                 :            : /*
     681                 :            :  * Cancel a previously blocked request.
     682                 :            :  *
     683                 :            :  * A cancel request always overrides any grant that may currently
     684                 :            :  * be in progress.
     685                 :            :  * The calling procedure must check whether the file can be closed.
     686                 :            :  */
     687                 :            : __be32
     688                 :          0 : nlmsvc_cancel_blocked(struct net *net, struct nlm_file *file, struct nlm_lock *lock)
     689                 :            : {
     690                 :          0 :         struct nlm_block        *block;
     691                 :          0 :         int status = 0;
     692                 :            : 
     693                 :          0 :         dprintk("lockd: nlmsvc_cancel(%s/%ld, pi=%d, %Ld-%Ld)\n",
     694                 :            :                                 locks_inode(file->f_file)->i_sb->s_id,
     695                 :            :                                 locks_inode(file->f_file)->i_ino,
     696                 :            :                                 lock->fl.fl_pid,
     697                 :            :                                 (long long)lock->fl.fl_start,
     698                 :            :                                 (long long)lock->fl.fl_end);
     699                 :            : 
     700         [ #  # ]:          0 :         if (locks_in_grace(net))
     701                 :            :                 return nlm_lck_denied_grace_period;
     702                 :            : 
     703                 :          0 :         mutex_lock(&file->f_mutex);
     704                 :          0 :         block = nlmsvc_lookup_block(file, lock);
     705                 :          0 :         mutex_unlock(&file->f_mutex);
     706         [ #  # ]:          0 :         if (block != NULL) {
     707                 :          0 :                 vfs_cancel_lock(block->b_file->f_file,
     708                 :          0 :                                 &block->b_call->a_args.lock.fl);
     709                 :          0 :                 status = nlmsvc_unlink_block(block);
     710                 :          0 :                 nlmsvc_release_block(block);
     711                 :            :         }
     712         [ #  # ]:          0 :         return status ? nlm_lck_denied : nlm_granted;
     713                 :            : }
     714                 :            : 
     715                 :            : /*
     716                 :            :  * This is a callback from the filesystem for VFS file lock requests.
     717                 :            :  * It will be used if lm_grant is defined and the filesystem can not
     718                 :            :  * respond to the request immediately.
     719                 :            :  * For SETLK or SETLKW request it will get the local posix lock.
     720                 :            :  * In all cases it will move the block to the head of nlm_blocked q where
     721                 :            :  * nlmsvc_retry_blocked() can send back a reply for SETLKW or revisit the
     722                 :            :  * deferred rpc for GETLK and SETLK.
     723                 :            :  */
     724                 :            : static void
     725                 :          0 : nlmsvc_update_deferred_block(struct nlm_block *block, int result)
     726                 :            : {
     727                 :          0 :         block->b_flags |= B_GOT_CALLBACK;
     728                 :          0 :         if (result == 0)
     729                 :          0 :                 block->b_granted = 1;
     730                 :            :         else
     731                 :          0 :                 block->b_flags |= B_TIMED_OUT;
     732                 :            : }
     733                 :            : 
     734                 :          0 : static int nlmsvc_grant_deferred(struct file_lock *fl, int result)
     735                 :            : {
     736                 :          0 :         struct nlm_block *block;
     737                 :          0 :         int rc = -ENOENT;
     738                 :            : 
     739                 :          0 :         spin_lock(&nlm_blocked_lock);
     740         [ #  # ]:          0 :         list_for_each_entry(block, &nlm_blocked, b_list) {
     741         [ #  # ]:          0 :                 if (nlm_compare_locks(&block->b_call->a_args.lock.fl, fl)) {
     742                 :          0 :                         dprintk("lockd: nlmsvc_notify_blocked block %p flags %d\n",
     743                 :            :                                                         block, block->b_flags);
     744         [ #  # ]:          0 :                         if (block->b_flags & B_QUEUED) {
     745         [ #  # ]:          0 :                                 if (block->b_flags & B_TIMED_OUT) {
     746                 :            :                                         rc = -ENOLCK;
     747                 :            :                                         break;
     748                 :            :                                 }
     749         [ #  # ]:          0 :                                 nlmsvc_update_deferred_block(block, result);
     750         [ #  # ]:          0 :                         } else if (result == 0)
     751                 :          0 :                                 block->b_granted = 1;
     752                 :            : 
     753                 :          0 :                         nlmsvc_insert_block_locked(block, 0);
     754                 :          0 :                         svc_wake_up(block->b_daemon);
     755                 :          0 :                         rc = 0;
     756                 :          0 :                         break;
     757                 :            :                 }
     758                 :            :         }
     759                 :          0 :         spin_unlock(&nlm_blocked_lock);
     760         [ #  # ]:          0 :         if (rc == -ENOENT)
     761                 :          0 :                 printk(KERN_WARNING "lockd: grant for unknown block\n");
     762                 :          0 :         return rc;
     763                 :            : }
     764                 :            : 
     765                 :            : /*
     766                 :            :  * Unblock a blocked lock request. This is a callback invoked from the
     767                 :            :  * VFS layer when a lock on which we blocked is removed.
     768                 :            :  *
     769                 :            :  * This function doesn't grant the blocked lock instantly, but rather moves
     770                 :            :  * the block to the head of nlm_blocked where it can be picked up by lockd.
     771                 :            :  */
     772                 :            : static void
     773                 :          0 : nlmsvc_notify_blocked(struct file_lock *fl)
     774                 :            : {
     775                 :          0 :         struct nlm_block        *block;
     776                 :            : 
     777                 :          0 :         dprintk("lockd: VFS unblock notification for block %p\n", fl);
     778                 :          0 :         spin_lock(&nlm_blocked_lock);
     779         [ #  # ]:          0 :         list_for_each_entry(block, &nlm_blocked, b_list) {
     780         [ #  # ]:          0 :                 if (nlm_compare_locks(&block->b_call->a_args.lock.fl, fl)) {
     781                 :          0 :                         nlmsvc_insert_block_locked(block, 0);
     782                 :          0 :                         spin_unlock(&nlm_blocked_lock);
     783                 :          0 :                         svc_wake_up(block->b_daemon);
     784                 :          0 :                         return;
     785                 :            :                 }
     786                 :            :         }
     787                 :          0 :         spin_unlock(&nlm_blocked_lock);
     788                 :          0 :         printk(KERN_WARNING "lockd: notification for unknown block!\n");
     789                 :            : }
     790                 :            : 
     791                 :            : const struct lock_manager_operations nlmsvc_lock_operations = {
     792                 :            :         .lm_notify = nlmsvc_notify_blocked,
     793                 :            :         .lm_grant = nlmsvc_grant_deferred,
     794                 :            : };
     795                 :            : 
     796                 :            : /*
     797                 :            :  * Try to claim a lock that was previously blocked.
     798                 :            :  *
     799                 :            :  * Note that we use both the RPC_GRANTED_MSG call _and_ an async
     800                 :            :  * RPC thread when notifying the client. This seems like overkill...
     801                 :            :  * Here's why:
     802                 :            :  *  -   we don't want to use a synchronous RPC thread, otherwise
     803                 :            :  *      we might find ourselves hanging on a dead portmapper.
     804                 :            :  *  -   Some lockd implementations (e.g. HP) don't react to
     805                 :            :  *      RPC_GRANTED calls; they seem to insist on RPC_GRANTED_MSG calls.
     806                 :            :  */
     807                 :            : static void
     808                 :          0 : nlmsvc_grant_blocked(struct nlm_block *block)
     809                 :            : {
     810                 :          0 :         struct nlm_file         *file = block->b_file;
     811                 :          0 :         struct nlm_lock         *lock = &block->b_call->a_args.lock;
     812                 :          0 :         int                     error;
     813                 :          0 :         loff_t                  fl_start, fl_end;
     814                 :            : 
     815                 :          0 :         dprintk("lockd: grant blocked lock %p\n", block);
     816                 :            : 
     817                 :          0 :         kref_get(&block->b_count);
     818                 :            : 
     819                 :            :         /* Unlink block request from list */
     820                 :          0 :         nlmsvc_unlink_block(block);
     821                 :            : 
     822                 :            :         /* If b_granted is true this means we've been here before.
     823                 :            :          * Just retry the grant callback, possibly refreshing the RPC
     824                 :            :          * binding */
     825         [ #  # ]:          0 :         if (block->b_granted) {
     826                 :          0 :                 nlm_rebind_host(block->b_host);
     827                 :          0 :                 goto callback;
     828                 :            :         }
     829                 :            : 
     830                 :            :         /* Try the lock operation again */
     831                 :            :         /* vfs_lock_file() can mangle fl_start and fl_end, but we need
     832                 :            :          * them unchanged for the GRANT_MSG
     833                 :            :          */
     834                 :          0 :         lock->fl.fl_flags |= FL_SLEEP;
     835                 :          0 :         fl_start = lock->fl.fl_start;
     836                 :          0 :         fl_end = lock->fl.fl_end;
     837                 :          0 :         error = vfs_lock_file(file->f_file, F_SETLK, &lock->fl, NULL);
     838                 :          0 :         lock->fl.fl_flags &= ~FL_SLEEP;
     839                 :          0 :         lock->fl.fl_start = fl_start;
     840                 :          0 :         lock->fl.fl_end = fl_end;
     841                 :            : 
     842      [ #  #  # ]:          0 :         switch (error) {
     843                 :            :         case 0:
     844                 :            :                 break;
     845                 :          0 :         case FILE_LOCK_DEFERRED:
     846                 :          0 :                 dprintk("lockd: lock still blocked error %d\n", error);
     847                 :          0 :                 nlmsvc_insert_block(block, NLM_NEVER);
     848                 :          0 :                 nlmsvc_release_block(block);
     849                 :          0 :                 return;
     850                 :          0 :         default:
     851                 :          0 :                 printk(KERN_WARNING "lockd: unexpected error %d in %s!\n",
     852                 :            :                                 -error, __func__);
     853                 :          0 :                 nlmsvc_insert_block(block, 10 * HZ);
     854                 :          0 :                 nlmsvc_release_block(block);
     855                 :          0 :                 return;
     856                 :            :         }
     857                 :            : 
     858                 :          0 : callback:
     859                 :            :         /* Lock was granted by VFS. */
     860                 :          0 :         dprintk("lockd: GRANTing blocked lock.\n");
     861                 :          0 :         block->b_granted = 1;
     862                 :            : 
     863                 :            :         /* keep block on the list, but don't reattempt until the RPC
     864                 :            :          * completes or the submission fails
     865                 :            :          */
     866                 :          0 :         nlmsvc_insert_block(block, NLM_NEVER);
     867                 :            : 
     868                 :            :         /* Call the client -- use a soft RPC task since nlmsvc_retry_blocked
     869                 :            :          * will queue up a new one if this one times out
     870                 :            :          */
     871                 :          0 :         error = nlm_async_call(block->b_call, NLMPROC_GRANTED_MSG,
     872                 :            :                                 &nlmsvc_grant_ops);
     873                 :            : 
     874                 :            :         /* RPC submission failed, wait a bit and retry */
     875         [ #  # ]:          0 :         if (error < 0)
     876                 :          0 :                 nlmsvc_insert_block(block, 10 * HZ);
     877                 :            : }
     878                 :            : 
     879                 :            : /*
     880                 :            :  * This is the callback from the RPC layer when the NLM_GRANTED_MSG
     881                 :            :  * RPC call has succeeded or timed out.
     882                 :            :  * Like all RPC callbacks, it is invoked by the rpciod process, so it
     883                 :            :  * better not sleep. Therefore, we put the blocked lock on the nlm_blocked
     884                 :            :  * chain once more in order to have it removed by lockd itself (which can
     885                 :            :  * then sleep on the file semaphore without disrupting e.g. the nfs client).
     886                 :            :  */
     887                 :          0 : static void nlmsvc_grant_callback(struct rpc_task *task, void *data)
     888                 :            : {
     889                 :          0 :         struct nlm_rqst         *call = data;
     890                 :          0 :         struct nlm_block        *block = call->a_block;
     891                 :          0 :         unsigned long           timeout;
     892                 :            : 
     893                 :          0 :         dprintk("lockd: GRANT_MSG RPC callback\n");
     894                 :            : 
     895                 :          0 :         spin_lock(&nlm_blocked_lock);
     896                 :            :         /* if the block is not on a list at this point then it has
     897                 :            :          * been invalidated. Don't try to requeue it.
     898                 :            :          *
     899                 :            :          * FIXME: it's possible that the block is removed from the list
     900                 :            :          * after this check but before the nlmsvc_insert_block. In that
     901                 :            :          * case it will be added back. Perhaps we need better locking
     902                 :            :          * for nlm_blocked?
     903                 :            :          */
     904         [ #  # ]:          0 :         if (list_empty(&block->b_list))
     905                 :          0 :                 goto out;
     906                 :            : 
     907                 :            :         /* Technically, we should down the file semaphore here. Since we
     908                 :            :          * move the block towards the head of the queue only, no harm
     909                 :            :          * can be done, though. */
     910         [ #  # ]:          0 :         if (task->tk_status < 0) {
     911                 :            :                 /* RPC error: Re-insert for retransmission */
     912                 :            :                 timeout = 10 * HZ;
     913                 :            :         } else {
     914                 :            :                 /* Call was successful, now wait for client callback */
     915                 :          0 :                 timeout = 60 * HZ;
     916                 :            :         }
     917                 :          0 :         nlmsvc_insert_block_locked(block, timeout);
     918                 :          0 :         svc_wake_up(block->b_daemon);
     919                 :          0 : out:
     920                 :          0 :         spin_unlock(&nlm_blocked_lock);
     921                 :          0 : }
     922                 :            : 
     923                 :            : /*
     924                 :            :  * FIXME: nlmsvc_release_block() grabs a mutex.  This is not allowed for an
     925                 :            :  * .rpc_release rpc_call_op
     926                 :            :  */
     927                 :          0 : static void nlmsvc_grant_release(void *data)
     928                 :            : {
     929                 :          0 :         struct nlm_rqst         *call = data;
     930                 :          0 :         nlmsvc_release_block(call->a_block);
     931                 :          0 : }
     932                 :            : 
     933                 :            : static const struct rpc_call_ops nlmsvc_grant_ops = {
     934                 :            :         .rpc_call_done = nlmsvc_grant_callback,
     935                 :            :         .rpc_release = nlmsvc_grant_release,
     936                 :            : };
     937                 :            : 
     938                 :            : /*
     939                 :            :  * We received a GRANT_RES callback. Try to find the corresponding
     940                 :            :  * block.
     941                 :            :  */
     942                 :            : void
     943                 :          0 : nlmsvc_grant_reply(struct nlm_cookie *cookie, __be32 status)
     944                 :            : {
     945                 :          0 :         struct nlm_block        *block;
     946                 :            : 
     947                 :          0 :         dprintk("grant_reply: looking for cookie %x, s=%d \n",
     948                 :            :                 *(unsigned int *)(cookie->data), status);
     949         [ #  # ]:          0 :         if (!(block = nlmsvc_find_block(cookie)))
     950                 :            :                 return;
     951                 :            : 
     952         [ #  # ]:          0 :         if (status == nlm_lck_denied_grace_period) {
     953                 :            :                 /* Try again in a couple of seconds */
     954                 :          0 :                 nlmsvc_insert_block(block, 10 * HZ);
     955                 :            :         } else {
     956                 :            :                 /*
     957                 :            :                  * Lock is now held by client, or has been rejected.
     958                 :            :                  * In both cases, the block should be removed.
     959                 :            :                  */
     960                 :          0 :                 nlmsvc_unlink_block(block);
     961                 :            :         }
     962                 :          0 :         nlmsvc_release_block(block);
     963                 :            : }
     964                 :            : 
     965                 :            : /* Helper function to handle retry of a deferred block.
     966                 :            :  * If it is a blocking lock, call grant_blocked.
     967                 :            :  * For a non-blocking lock or test lock, revisit the request.
     968                 :            :  */
     969                 :            : static void
     970                 :          0 : retry_deferred_block(struct nlm_block *block)
     971                 :            : {
     972         [ #  # ]:          0 :         if (!(block->b_flags & B_GOT_CALLBACK))
     973                 :          0 :                 block->b_flags |= B_TIMED_OUT;
     974                 :          0 :         nlmsvc_insert_block(block, NLM_TIMEOUT);
     975                 :          0 :         dprintk("revisit block %p flags %d\n",        block, block->b_flags);
     976         [ #  # ]:          0 :         if (block->b_deferred_req) {
     977                 :          0 :                 block->b_deferred_req->revisit(block->b_deferred_req, 0);
     978                 :          0 :                 block->b_deferred_req = NULL;
     979                 :            :         }
     980                 :          0 : }
     981                 :            : 
     982                 :            : /*
     983                 :            :  * Retry all blocked locks that have been notified. This is where lockd
     984                 :            :  * picks up locks that can be granted, or grant notifications that must
     985                 :            :  * be retransmitted.
     986                 :            :  */
     987                 :            : unsigned long
     988                 :          0 : nlmsvc_retry_blocked(void)
     989                 :            : {
     990                 :          0 :         unsigned long   timeout = MAX_SCHEDULE_TIMEOUT;
     991                 :          0 :         struct nlm_block *block;
     992                 :            : 
     993                 :          0 :         spin_lock(&nlm_blocked_lock);
     994   [ #  #  #  # ]:          0 :         while (!list_empty(&nlm_blocked) && !kthread_should_stop()) {
     995                 :          0 :                 block = list_entry(nlm_blocked.next, struct nlm_block, b_list);
     996                 :            : 
     997         [ #  # ]:          0 :                 if (block->b_when == NLM_NEVER)
     998                 :            :                         break;
     999         [ #  # ]:          0 :                 if (time_after(block->b_when, jiffies)) {
    1000                 :          0 :                         timeout = block->b_when - jiffies;
    1001                 :          0 :                         break;
    1002                 :            :                 }
    1003                 :          0 :                 spin_unlock(&nlm_blocked_lock);
    1004                 :            : 
    1005                 :          0 :                 dprintk("nlmsvc_retry_blocked(%p, when=%ld)\n",
    1006                 :            :                         block, block->b_when);
    1007         [ #  # ]:          0 :                 if (block->b_flags & B_QUEUED) {
    1008                 :          0 :                         dprintk("nlmsvc_retry_blocked delete block (%p, granted=%d, flags=%d)\n",
    1009                 :            :                                 block, block->b_granted, block->b_flags);
    1010                 :          0 :                         retry_deferred_block(block);
    1011                 :            :                 } else
    1012                 :          0 :                         nlmsvc_grant_blocked(block);
    1013                 :          0 :                 spin_lock(&nlm_blocked_lock);
    1014                 :            :         }
    1015                 :          0 :         spin_unlock(&nlm_blocked_lock);
    1016                 :            : 
    1017                 :          0 :         return timeout;
    1018                 :            : }

Generated by: LCOV version 1.14