X-Git-Url: https://git.whamcloud.com/?a=blobdiff_plain;f=lustre%2Fldlm%2Fldlm_plain.c;h=38a94b159000a8b94ada7e7f299c2def8ddd749a;hb=f9fe2977d184fbc8e345c4a77f4596d059b7d118;hp=6407fd20884f8d155a443b76f5071409e7a446b4;hpb=2c126c5a73edea434456c6c335772daaac717f2f;p=fs%2Flustre-release.git diff --git a/lustre/ldlm/ldlm_plain.c b/lustre/ldlm/ldlm_plain.c index 6407fd2..38a94b1 100644 --- a/lustre/ldlm/ldlm_plain.c +++ b/lustre/ldlm/ldlm_plain.c @@ -27,7 +27,6 @@ */ /* * This file is part of Lustre, http://www.lustre.org/ - * Lustre is a trademark of Sun Microsystems, Inc. * * lustre/ldlm/ldlm_plain.c * @@ -71,15 +70,17 @@ ldlm_plain_compat_queue(struct list_head *queue, struct ldlm_lock *req, enum ldlm_mode req_mode = req->l_req_mode; struct ldlm_lock *lock, *next_lock; int compat = 1; - ENTRY; + ENTRY; lockmode_verify(req_mode); list_for_each_entry_safe(lock, next_lock, queue, l_res_link) { - /* We stop walking the queue if we hit ourselves so we don't + /* + * We stop walking the queue if we hit ourselves so we don't * take conflicting locks enqueued after us into account, - * or we'd wait forever. */ + * or we'd wait forever. + */ if (req == lock) RETURN(compat); @@ -90,30 +91,32 @@ ldlm_plain_compat_queue(struct list_head *queue, struct ldlm_lock *req, struct ldlm_lock, l_res_link); if (lockmode_compat(lock->l_req_mode, req_mode)) - continue; + continue; - if (!work_list) - RETURN(0); + if (!work_list) + RETURN(0); - compat = 0; + compat = 0; - /* Add locks of the mode group to \a work_list as - * blocking locks for \a req. */ - if (lock->l_blocking_ast) - ldlm_add_ast_work_item(lock, req, work_list); + /* + * Add locks of the mode group to \a work_list as + * blocking locks for \a req. + */ + if (lock->l_blocking_ast) + ldlm_add_ast_work_item(lock, req, work_list); - { + { struct list_head *head; - head = &lock->l_sl_mode; + head = &lock->l_sl_mode; list_for_each_entry(lock, head, l_sl_mode) - if (lock->l_blocking_ast) - ldlm_add_ast_work_item(lock, req, - work_list); - } - } + if (lock->l_blocking_ast) + ldlm_add_ast_work_item(lock, req, + work_list); + } + } - RETURN(compat); + RETURN(compat); } /** @@ -132,25 +135,25 @@ int ldlm_process_plain_lock(struct ldlm_lock *lock, __u64 *flags, struct list_head *grant_work = intention == LDLM_PROCESS_ENQUEUE ? NULL : work_list; int rc; - ENTRY; + ENTRY; LASSERT(!ldlm_is_granted(lock)); check_res_locked(res); *err = ELDLM_OK; if (intention == LDLM_PROCESS_RESCAN) { - LASSERT(work_list != NULL); - rc = ldlm_plain_compat_queue(&res->lr_granted, lock, NULL); - if (!rc) - RETURN(LDLM_ITER_STOP); - rc = ldlm_plain_compat_queue(&res->lr_waiting, lock, NULL); - if (!rc) - RETURN(LDLM_ITER_STOP); - - ldlm_resource_unlink_lock(lock); + LASSERT(work_list != NULL); + rc = ldlm_plain_compat_queue(&res->lr_granted, lock, NULL); + if (!rc) + RETURN(LDLM_ITER_STOP); + rc = ldlm_plain_compat_queue(&res->lr_waiting, lock, NULL); + if (!rc) + RETURN(LDLM_ITER_STOP); + + ldlm_resource_unlink_lock(lock); ldlm_grant_lock(lock, grant_work); - RETURN(LDLM_ITER_CONTINUE); - } + RETURN(LDLM_ITER_CONTINUE); + } rc = ldlm_plain_compat_queue(&res->lr_granted, lock, work_list); rc += ldlm_plain_compat_queue(&res->lr_waiting, lock, work_list);