Lines Matching refs:waiter
597 static void locks_insert_global_blocked(struct file_lock *waiter) in locks_insert_global_blocked() argument
601 hash_add(blocked_hash, &waiter->fl_link, posix_owner_key(waiter)); in locks_insert_global_blocked()
604 static void locks_delete_global_blocked(struct file_lock *waiter) in locks_delete_global_blocked() argument
608 hash_del(&waiter->fl_link); in locks_delete_global_blocked()
616 static void __locks_delete_block(struct file_lock *waiter) in __locks_delete_block() argument
618 locks_delete_global_blocked(waiter); in __locks_delete_block()
619 list_del_init(&waiter->fl_blocked_member); in __locks_delete_block()
625 struct file_lock *waiter; in __locks_wake_up_blocks() local
627 waiter = list_first_entry(&blocker->fl_blocked_requests, in __locks_wake_up_blocks()
629 __locks_delete_block(waiter); in __locks_wake_up_blocks()
630 if (waiter->fl_lmops && waiter->fl_lmops->lm_notify) in __locks_wake_up_blocks()
631 waiter->fl_lmops->lm_notify(waiter); in __locks_wake_up_blocks()
633 wake_up(&waiter->fl_wait); in __locks_wake_up_blocks()
640 smp_store_release(&waiter->fl_blocker, NULL); in __locks_wake_up_blocks()
650 int locks_delete_block(struct file_lock *waiter) in locks_delete_block() argument
675 if (!smp_load_acquire(&waiter->fl_blocker) && in locks_delete_block()
676 list_empty(&waiter->fl_blocked_requests)) in locks_delete_block()
680 if (waiter->fl_blocker) in locks_delete_block()
682 __locks_wake_up_blocks(waiter); in locks_delete_block()
683 __locks_delete_block(waiter); in locks_delete_block()
689 smp_store_release(&waiter->fl_blocker, NULL); in locks_delete_block()
711 struct file_lock *waiter, in __locks_insert_block() argument
716 BUG_ON(!list_empty(&waiter->fl_blocked_member)); in __locks_insert_block()
720 if (conflict(fl, waiter)) { in __locks_insert_block()
724 waiter->fl_blocker = blocker; in __locks_insert_block()
725 list_add_tail(&waiter->fl_blocked_member, &blocker->fl_blocked_requests); in __locks_insert_block()
727 locks_insert_global_blocked(waiter); in __locks_insert_block()
733 __locks_wake_up_blocks(waiter); in __locks_insert_block()
738 struct file_lock *waiter, in locks_insert_block() argument
743 __locks_insert_block(blocker, waiter, conflict); in locks_insert_block()