Lines Matching refs:lock
62 struct dlm_lock *lock, int flags);
66 static void dlm_lock_detach_lockres(struct dlm_lock *lock);
92 struct dlm_lock *lock) in dlm_can_grant_new_lock() argument
97 if (!dlm_lock_compatible(tmplock->ml.type, lock->ml.type)) in dlm_can_grant_new_lock()
102 if (!dlm_lock_compatible(tmplock->ml.type, lock->ml.type)) in dlm_can_grant_new_lock()
105 lock->ml.type)) in dlm_can_grant_new_lock()
121 struct dlm_lock *lock, int flags) in dlmlock_master() argument
126 mlog(0, "type=%d\n", lock->ml.type); in dlmlock_master()
133 lock->ml.node != dlm->node_num) { in dlmlock_master()
142 if (dlm_can_grant_new_lock(res, lock)) { in dlmlock_master()
145 lock->lksb->status = DLM_NORMAL; in dlmlock_master()
147 dlm_lock_get(lock); in dlmlock_master()
148 list_add_tail(&lock->list, &res->granted); in dlmlock_master()
162 lock->ml.node); in dlmlock_master()
173 lock->ml.node); in dlmlock_master()
177 dlm_lock_get(lock); in dlmlock_master()
178 list_add_tail(&lock->list, &res->blocked); in dlmlock_master()
188 dlm_queue_ast(dlm, lock); in dlmlock_master()
200 struct dlm_lock *lock) in dlm_revert_pending_lock() argument
203 list_del_init(&lock->list); in dlm_revert_pending_lock()
204 lock->lksb->flags &= ~DLM_LKSB_GET_LVB; in dlm_revert_pending_lock()
217 struct dlm_lock *lock, int flags) in dlmlock_remote() argument
223 lock->ml.type, res->lockname.len, in dlmlock_remote()
239 dlm_lock_get(lock); in dlmlock_remote()
240 list_add_tail(&lock->list, &res->blocked); in dlmlock_remote()
241 lock->lock_pending = 1; in dlmlock_remote()
246 status = dlm_send_remote_lock_request(dlm, res, lock, flags); in dlmlock_remote()
250 lock->lock_pending = 0; in dlmlock_remote()
271 dlm_revert_pending_lock(res, lock); in dlmlock_remote()
272 dlm_lock_put(lock); in dlmlock_remote()
282 list_move_tail(&lock->list, &res->granted); in dlmlock_remote()
303 struct dlm_lock *lock, int flags) in dlm_send_remote_lock_request() argument
311 create.requested_type = lock->ml.type; in dlm_send_remote_lock_request()
312 create.cookie = lock->ml.cookie; in dlm_send_remote_lock_request()
342 void dlm_lock_get(struct dlm_lock *lock) in dlm_lock_get() argument
344 kref_get(&lock->lock_refs); in dlm_lock_get()
347 void dlm_lock_put(struct dlm_lock *lock) in dlm_lock_put() argument
349 kref_put(&lock->lock_refs, dlm_lock_release); in dlm_lock_put()
354 struct dlm_lock *lock; in dlm_lock_release() local
356 lock = container_of(kref, struct dlm_lock, lock_refs); in dlm_lock_release()
358 BUG_ON(!list_empty(&lock->list)); in dlm_lock_release()
359 BUG_ON(!list_empty(&lock->ast_list)); in dlm_lock_release()
360 BUG_ON(!list_empty(&lock->bast_list)); in dlm_lock_release()
361 BUG_ON(lock->ast_pending); in dlm_lock_release()
362 BUG_ON(lock->bast_pending); in dlm_lock_release()
364 dlm_lock_detach_lockres(lock); in dlm_lock_release()
366 if (lock->lksb_kernel_allocated) { in dlm_lock_release()
368 kfree(lock->lksb); in dlm_lock_release()
370 kmem_cache_free(dlm_lock_cache, lock); in dlm_lock_release()
374 void dlm_lock_attach_lockres(struct dlm_lock *lock, in dlm_lock_attach_lockres() argument
378 lock->lockres = res; in dlm_lock_attach_lockres()
382 static void dlm_lock_detach_lockres(struct dlm_lock *lock) in dlm_lock_detach_lockres() argument
386 res = lock->lockres; in dlm_lock_detach_lockres()
388 lock->lockres = NULL; in dlm_lock_detach_lockres()
426 struct dlm_lock *lock; in dlm_new_lock() local
429 lock = kmem_cache_zalloc(dlm_lock_cache, GFP_NOFS); in dlm_new_lock()
430 if (!lock) in dlm_new_lock()
437 kmem_cache_free(dlm_lock_cache, lock); in dlm_new_lock()
443 dlm_init_lock(lock, type, node, cookie); in dlm_new_lock()
445 lock->lksb_kernel_allocated = 1; in dlm_new_lock()
446 lock->lksb = lksb; in dlm_new_lock()
447 lksb->lockid = lock; in dlm_new_lock()
448 return lock; in dlm_new_lock()
565 struct dlm_lock *lock = NULL; in dlmlock() local
604 lock = lksb->lockid; in dlmlock()
605 if (!lock) { in dlmlock()
611 res = lock->lockres; in dlmlock()
624 if (lock->lksb != lksb || lock->ast != ast || in dlmlock()
625 lock->bast != bast || lock->astdata != data) { in dlmlock()
630 "astdata=%p\n", lock->lksb, lock->ast, in dlmlock()
631 lock->bast, lock->astdata); in dlmlock()
638 status = dlmconvert_master(dlm, res, lock, flags, mode); in dlmlock()
640 status = dlmconvert_remote(dlm, res, lock, flags, mode); in dlmlock()
669 lock = dlm_new_lock(mode, dlm->node_num, tmpcookie, lksb); in dlmlock()
670 if (!lock) { in dlmlock()
687 mlog(0, "creating lock: lock=%p res=%p\n", lock, res); in dlmlock()
689 dlm_lock_attach_lockres(lock, res); in dlmlock()
690 lock->ast = ast; in dlmlock()
691 lock->bast = bast; in dlmlock()
692 lock->astdata = data; in dlmlock()
704 lock->lksb->flags |= DLM_LKSB_GET_LVB; in dlmlock()
709 status = dlmlock_master(dlm, res, lock, flags); in dlmlock()
711 status = dlmlock_remote(dlm, res, lock, flags); in dlmlock()
739 lock->lksb->flags &= ~DLM_LKSB_GET_LVB; in dlmlock()
748 if (lock && !convert) in dlmlock()
749 dlm_lock_put(lock); in dlmlock()