Lines Matching refs:lockres
50 static inline int user_check_wait_flag(struct user_lock_res *lockres,
55 spin_lock(&lockres->l_lock);
56 ret = lockres->l_flags & flag;
57 spin_unlock(&lockres->l_lock);
62 static inline void user_wait_on_busy_lock(struct user_lock_res *lockres)
65 wait_event(lockres->l_event,
66 !user_check_wait_flag(lockres, USER_LOCK_BUSY));
69 static inline void user_wait_on_blocked_lock(struct user_lock_res *lockres)
72 wait_event(lockres->l_event,
73 !user_check_wait_flag(lockres, USER_LOCK_BLOCKED));
78 cluster_connection_from_user_lockres(struct user_lock_res *lockres)
82 ip = container_of(lockres,
89 user_dlm_inode_from_user_lockres(struct user_lock_res *lockres)
93 ip = container_of(lockres,
99 static inline void user_recover_from_dlm_error(struct user_lock_res *lockres)
101 spin_lock(&lockres->l_lock);
102 lockres->l_flags &= ~USER_LOCK_BUSY;
103 spin_unlock(&lockres->l_lock);
128 struct user_lock_res *lockres = user_lksb_to_lock_res(lksb);
131 mlog(ML_BASTS, "AST fired for lockres %.*s, level %d => %d\n",
132 lockres->l_namelen, lockres->l_name, lockres->l_level,
133 lockres->l_requested);
135 spin_lock(&lockres->l_lock);
137 status = ocfs2_dlm_lock_status(&lockres->l_lksb);
139 mlog(ML_ERROR, "lksb status value of %u on lockres %.*s\n",
140 status, lockres->l_namelen, lockres->l_name);
141 spin_unlock(&lockres->l_lock);
145 mlog_bug_on_msg(lockres->l_requested == DLM_LOCK_IV,
147 lockres->l_namelen, lockres->l_name, lockres->l_flags);
150 if (lockres->l_requested < lockres->l_level) {
151 if (lockres->l_requested <=
152 user_highest_compat_lock_level(lockres->l_blocking)) {
153 lockres->l_blocking = DLM_LOCK_NL;
154 lockres->l_flags &= ~USER_LOCK_BLOCKED;
158 lockres->l_level = lockres->l_requested;
159 lockres->l_requested = DLM_LOCK_IV;
160 lockres->l_flags |= USER_LOCK_ATTACHED;
161 lockres->l_flags &= ~USER_LOCK_BUSY;
163 spin_unlock(&lockres->l_lock);
165 wake_up(&lockres->l_event);
168 static inline void user_dlm_grab_inode_ref(struct user_lock_res *lockres)
171 inode = user_dlm_inode_from_user_lockres(lockres);
178 static void __user_dlm_queue_lockres(struct user_lock_res *lockres)
180 if (!(lockres->l_flags & USER_LOCK_QUEUED)) {
181 user_dlm_grab_inode_ref(lockres);
183 INIT_WORK(&lockres->l_work, user_dlm_unblock_lock);
185 queue_work(user_dlm_worker, &lockres->l_work);
186 lockres->l_flags |= USER_LOCK_QUEUED;
190 static void __user_dlm_cond_queue_lockres(struct user_lock_res *lockres)
194 if (!(lockres->l_flags & USER_LOCK_BLOCKED))
197 switch (lockres->l_blocking) {
199 if (!lockres->l_ex_holders && !lockres->l_ro_holders)
203 if (!lockres->l_ex_holders)
211 __user_dlm_queue_lockres(lockres);
216 struct user_lock_res *lockres = user_lksb_to_lock_res(lksb);
218 mlog(ML_BASTS, "BAST fired for lockres %.*s, blocking %d, level %d\n",
219 lockres->l_namelen, lockres->l_name, level, lockres->l_level);
221 spin_lock(&lockres->l_lock);
222 lockres->l_flags |= USER_LOCK_BLOCKED;
223 if (level > lockres->l_blocking)
224 lockres->l_blocking = level;
226 __user_dlm_queue_lockres(lockres);
227 spin_unlock(&lockres->l_lock);
229 wake_up(&lockres->l_event);
234 struct user_lock_res *lockres = user_lksb_to_lock_res(lksb);
236 mlog(ML_BASTS, "UNLOCK AST fired for lockres %.*s, flags 0x%x\n",
237 lockres->l_namelen, lockres->l_name, lockres->l_flags);
242 spin_lock(&lockres->l_lock);
246 if (lockres->l_flags & USER_LOCK_IN_TEARDOWN
247 && !(lockres->l_flags & USER_LOCK_IN_CANCEL)) {
248 lockres->l_level = DLM_LOCK_IV;
253 BUG_ON(!(lockres->l_flags & USER_LOCK_IN_CANCEL));
254 lockres->l_flags &= ~USER_LOCK_IN_CANCEL;
257 BUG_ON(!(lockres->l_flags & USER_LOCK_IN_CANCEL));
259 lockres->l_requested = DLM_LOCK_IV; /* cancel an
262 lockres->l_flags &= ~USER_LOCK_IN_CANCEL;
265 if (lockres->l_flags & USER_LOCK_BLOCKED)
266 __user_dlm_queue_lockres(lockres);
269 lockres->l_flags &= ~USER_LOCK_BUSY;
271 spin_unlock(&lockres->l_lock);
273 wake_up(&lockres->l_event);
291 static inline void user_dlm_drop_inode_ref(struct user_lock_res *lockres)
294 inode = user_dlm_inode_from_user_lockres(lockres);
301 struct user_lock_res *lockres =
304 cluster_connection_from_user_lockres(lockres);
306 mlog(0, "lockres %.*s\n", lockres->l_namelen, lockres->l_name);
308 spin_lock(&lockres->l_lock);
310 mlog_bug_on_msg(!(lockres->l_flags & USER_LOCK_QUEUED),
312 lockres->l_namelen, lockres->l_name, lockres->l_flags);
316 lockres->l_flags &= ~USER_LOCK_QUEUED;
323 if (!(lockres->l_flags & USER_LOCK_BLOCKED)) {
324 mlog(ML_BASTS, "lockres %.*s USER_LOCK_BLOCKED\n",
325 lockres->l_namelen, lockres->l_name);
326 spin_unlock(&lockres->l_lock);
330 if (lockres->l_flags & USER_LOCK_IN_TEARDOWN) {
331 mlog(ML_BASTS, "lockres %.*s USER_LOCK_IN_TEARDOWN\n",
332 lockres->l_namelen, lockres->l_name);
333 spin_unlock(&lockres->l_lock);
337 if (lockres->l_flags & USER_LOCK_BUSY) {
338 if (lockres->l_flags & USER_LOCK_IN_CANCEL) {
339 mlog(ML_BASTS, "lockres %.*s USER_LOCK_IN_CANCEL\n",
340 lockres->l_namelen, lockres->l_name);
341 spin_unlock(&lockres->l_lock);
345 lockres->l_flags |= USER_LOCK_IN_CANCEL;
346 spin_unlock(&lockres->l_lock);
348 status = ocfs2_dlm_unlock(conn, &lockres->l_lksb,
351 user_log_dlm_error("ocfs2_dlm_unlock", status, lockres);
358 if ((lockres->l_blocking == DLM_LOCK_EX)
359 && (lockres->l_ex_holders || lockres->l_ro_holders)) {
360 spin_unlock(&lockres->l_lock);
361 mlog(ML_BASTS, "lockres %.*s, EX/PR Holders %u,%u\n",
362 lockres->l_namelen, lockres->l_name,
363 lockres->l_ex_holders, lockres->l_ro_holders);
367 if ((lockres->l_blocking == DLM_LOCK_PR)
368 && lockres->l_ex_holders) {
369 spin_unlock(&lockres->l_lock);
370 mlog(ML_BASTS, "lockres %.*s, EX Holders %u\n",
371 lockres->l_namelen, lockres->l_name,
372 lockres->l_ex_holders);
377 new_level = user_highest_compat_lock_level(lockres->l_blocking);
378 lockres->l_requested = new_level;
379 lockres->l_flags |= USER_LOCK_BUSY;
380 mlog(ML_BASTS, "lockres %.*s, downconvert %d => %d\n",
381 lockres->l_namelen, lockres->l_name, lockres->l_level, new_level);
382 spin_unlock(&lockres->l_lock);
385 status = ocfs2_dlm_lock(conn, new_level, &lockres->l_lksb,
387 lockres->l_name,
388 lockres->l_namelen);
390 user_log_dlm_error("ocfs2_dlm_lock", status, lockres);
391 user_recover_from_dlm_error(lockres);
395 user_dlm_drop_inode_ref(lockres);
398 static inline void user_dlm_inc_holders(struct user_lock_res *lockres,
403 lockres->l_ex_holders++;
406 lockres->l_ro_holders++;
417 user_may_continue_on_blocked_lock(struct user_lock_res *lockres,
420 BUG_ON(!(lockres->l_flags & USER_LOCK_BLOCKED));
422 return wanted <= user_highest_compat_lock_level(lockres->l_blocking);
425 int user_dlm_cluster_lock(struct user_lock_res *lockres,
431 cluster_connection_from_user_lockres(lockres);
435 mlog(ML_ERROR, "lockres %.*s: invalid request!\n",
436 lockres->l_namelen, lockres->l_name);
441 mlog(ML_BASTS, "lockres %.*s, level %d, flags = 0x%x\n",
442 lockres->l_namelen, lockres->l_name, level, lkm_flags);
450 spin_lock(&lockres->l_lock);
455 if ((lockres->l_flags & USER_LOCK_BUSY) &&
456 (level > lockres->l_level)) {
459 spin_unlock(&lockres->l_lock);
461 user_wait_on_busy_lock(lockres);
465 if ((lockres->l_flags & USER_LOCK_BLOCKED) &&
466 (!user_may_continue_on_blocked_lock(lockres, level))) {
469 spin_unlock(&lockres->l_lock);
471 user_wait_on_blocked_lock(lockres);
475 if (level > lockres->l_level) {
477 if (lockres->l_level != DLM_LOCK_IV)
480 lockres->l_requested = level;
481 lockres->l_flags |= USER_LOCK_BUSY;
482 spin_unlock(&lockres->l_lock);
488 status = ocfs2_dlm_lock(conn, level, &lockres->l_lksb,
489 local_flags, lockres->l_name,
490 lockres->l_namelen);
495 status, lockres);
496 user_recover_from_dlm_error(lockres);
500 user_wait_on_busy_lock(lockres);
504 user_dlm_inc_holders(lockres, level);
505 spin_unlock(&lockres->l_lock);
512 static inline void user_dlm_dec_holders(struct user_lock_res *lockres,
517 BUG_ON(!lockres->l_ex_holders);
518 lockres->l_ex_holders--;
521 BUG_ON(!lockres->l_ro_holders);
522 lockres->l_ro_holders--;
529 void user_dlm_cluster_unlock(struct user_lock_res *lockres,
534 mlog(ML_ERROR, "lockres %.*s: invalid request!\n",
535 lockres->l_namelen, lockres->l_name);
539 spin_lock(&lockres->l_lock);
540 user_dlm_dec_holders(lockres, level);
541 __user_dlm_cond_queue_lockres(lockres);
542 spin_unlock(&lockres->l_lock);
549 struct user_lock_res *lockres = &DLMFS_I(inode)->ip_lockres;
554 spin_lock(&lockres->l_lock);
556 BUG_ON(lockres->l_level < DLM_LOCK_EX);
557 lvb = ocfs2_dlm_lvb(&lockres->l_lksb);
560 spin_unlock(&lockres->l_lock);
567 struct user_lock_res *lockres = &DLMFS_I(inode)->ip_lockres;
573 spin_lock(&lockres->l_lock);
575 BUG_ON(lockres->l_level < DLM_LOCK_PR);
576 if (ocfs2_dlm_lvb_valid(&lockres->l_lksb)) {
577 lvb = ocfs2_dlm_lvb(&lockres->l_lksb);
582 spin_unlock(&lockres->l_lock);
586 void user_dlm_lock_res_init(struct user_lock_res *lockres,
589 memset(lockres, 0, sizeof(*lockres));
591 spin_lock_init(&lockres->l_lock);
592 init_waitqueue_head(&lockres->l_event);
593 lockres->l_level = DLM_LOCK_IV;
594 lockres->l_requested = DLM_LOCK_IV;
595 lockres->l_blocking = DLM_LOCK_IV;
600 memcpy(lockres->l_name,
603 lockres->l_namelen = dentry->d_name.len;
606 int user_dlm_destroy_lock(struct user_lock_res *lockres)
610 cluster_connection_from_user_lockres(lockres);
612 mlog(ML_BASTS, "lockres %.*s\n", lockres->l_namelen, lockres->l_name);
614 spin_lock(&lockres->l_lock);
615 if (lockres->l_flags & USER_LOCK_IN_TEARDOWN) {
616 spin_unlock(&lockres->l_lock);
620 lockres->l_flags |= USER_LOCK_IN_TEARDOWN;
622 while (lockres->l_flags & USER_LOCK_BUSY) {
623 spin_unlock(&lockres->l_lock);
625 user_wait_on_busy_lock(lockres);
627 spin_lock(&lockres->l_lock);
630 if (lockres->l_ro_holders || lockres->l_ex_holders) {
631 spin_unlock(&lockres->l_lock);
636 if (!(lockres->l_flags & USER_LOCK_ATTACHED)) {
637 spin_unlock(&lockres->l_lock);
641 lockres->l_flags &= ~USER_LOCK_ATTACHED;
642 lockres->l_flags |= USER_LOCK_BUSY;
643 spin_unlock(&lockres->l_lock);
645 status = ocfs2_dlm_unlock(conn, &lockres->l_lksb, DLM_LKF_VALBLK);
647 user_log_dlm_error("ocfs2_dlm_unlock", status, lockres);
651 user_wait_on_busy_lock(lockres);