Lines Matching refs:block
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);
90 nlmsvc_insert_block_locked(struct nlm_block *block, unsigned long when) in nlmsvc_insert_block_locked() argument
95 dprintk("lockd: nlmsvc_insert_block(%p, %ld)\n", block, when); in nlmsvc_insert_block_locked()
96 if (list_empty(&block->b_list)) { in nlmsvc_insert_block_locked()
97 kref_get(&block->b_count); in nlmsvc_insert_block_locked()
99 list_del_init(&block->b_list); in nlmsvc_insert_block_locked()
116 list_add_tail(&block->b_list, pos); in nlmsvc_insert_block_locked()
117 block->b_when = when; in nlmsvc_insert_block_locked()
120 static void nlmsvc_insert_block(struct nlm_block *block, unsigned long when) in nlmsvc_insert_block() argument
123 nlmsvc_insert_block_locked(block, when); in nlmsvc_insert_block()
131 nlmsvc_remove_block(struct nlm_block *block) in nlmsvc_remove_block() argument
133 if (!list_empty(&block->b_list)) { in nlmsvc_remove_block()
135 list_del_init(&block->b_list); in nlmsvc_remove_block()
137 nlmsvc_release_block(block); in nlmsvc_remove_block()
147 struct nlm_block *block; in nlmsvc_lookup_block() local
154 list_for_each_entry(block, &nlm_blocked, b_list) { in nlmsvc_lookup_block()
155 fl = &block->b_call->a_args.lock.fl; in nlmsvc_lookup_block()
157 block->b_file, fl->fl_pid, in nlmsvc_lookup_block()
160 nlmdbg_cookie2a(&block->b_call->a_args.cookie)); in nlmsvc_lookup_block()
161 if (block->b_file == file && nlm_compare_locks(fl, &lock->fl)) { in nlmsvc_lookup_block()
162 kref_get(&block->b_count); in nlmsvc_lookup_block()
163 return block; in nlmsvc_lookup_block()
185 struct nlm_block *block; in nlmsvc_find_block() local
187 list_for_each_entry(block, &nlm_blocked, b_list) { in nlmsvc_find_block()
188 if (nlm_cookie_match(&block->b_call->a_args.cookie,cookie)) in nlmsvc_find_block()
195 dprintk("nlmsvc_find_block(%s): block=%p\n", nlmdbg_cookie2a(cookie), block); in nlmsvc_find_block()
196 kref_get(&block->b_count); in nlmsvc_find_block()
197 return block; in nlmsvc_find_block()
220 struct nlm_block *block; in nlmsvc_create_block() local
228 block = kzalloc(sizeof(*block), GFP_KERNEL); in nlmsvc_create_block()
229 if (block == NULL) in nlmsvc_create_block()
231 kref_init(&block->b_count); in nlmsvc_create_block()
232 INIT_LIST_HEAD(&block->b_list); in nlmsvc_create_block()
233 INIT_LIST_HEAD(&block->b_flist); in nlmsvc_create_block()
243 dprintk("lockd: created block %p...\n", block); in nlmsvc_create_block()
246 block->b_daemon = rqstp->rq_server; in nlmsvc_create_block()
247 block->b_host = host; in nlmsvc_create_block()
248 block->b_file = file; in nlmsvc_create_block()
252 list_add(&block->b_flist, &file->f_blocks); in nlmsvc_create_block()
255 block->b_call = call; in nlmsvc_create_block()
257 call->a_block = block; in nlmsvc_create_block()
259 return block; in nlmsvc_create_block()
262 kfree(block); in nlmsvc_create_block()
273 static int nlmsvc_unlink_block(struct nlm_block *block) in nlmsvc_unlink_block() argument
276 dprintk("lockd: unlinking block %p...\n", block); in nlmsvc_unlink_block()
279 status = locks_delete_block(&block->b_call->a_args.lock.fl); in nlmsvc_unlink_block()
280 nlmsvc_remove_block(block); in nlmsvc_unlink_block()
286 struct nlm_block *block = container_of(kref, struct nlm_block, b_count); in nlmsvc_free_block() local
287 struct nlm_file *file = block->b_file; in nlmsvc_free_block()
289 dprintk("lockd: freeing block %p...\n", block); in nlmsvc_free_block()
292 list_del_init(&block->b_flist); in nlmsvc_free_block()
295 nlmsvc_freegrantargs(block->b_call); in nlmsvc_free_block()
296 nlmsvc_release_call(block->b_call); in nlmsvc_free_block()
297 nlm_release_file(block->b_file); in nlmsvc_free_block()
298 kfree(block); in nlmsvc_free_block()
301 static void nlmsvc_release_block(struct nlm_block *block) in nlmsvc_release_block() argument
303 if (block != NULL) in nlmsvc_release_block()
304 kref_put_mutex(&block->b_count, nlmsvc_free_block, &block->b_file->f_mutex); in nlmsvc_release_block()
315 struct nlm_block *block, *next; in nlmsvc_traverse_blocks() local
319 list_for_each_entry_safe(block, next, &file->f_blocks, b_flist) { in nlmsvc_traverse_blocks()
320 if (!match(block->b_host, host)) in nlmsvc_traverse_blocks()
324 if (list_empty(&block->b_list)) in nlmsvc_traverse_blocks()
326 kref_get(&block->b_count); in nlmsvc_traverse_blocks()
328 nlmsvc_unlink_block(block); in nlmsvc_traverse_blocks()
329 nlmsvc_release_block(block); in nlmsvc_traverse_blocks()
442 nlmsvc_defer_lock_rqst(struct svc_rqst *rqstp, struct nlm_block *block) in nlmsvc_defer_lock_rqst() argument
446 block->b_flags |= B_QUEUED; in nlmsvc_defer_lock_rqst()
448 nlmsvc_insert_block(block, NLM_TIMEOUT); in nlmsvc_defer_lock_rqst()
450 block->b_cache_req = &rqstp->rq_chandle; in nlmsvc_defer_lock_rqst()
452 block->b_deferred_req = in nlmsvc_defer_lock_rqst()
453 rqstp->rq_chandle.defer(block->b_cache_req); in nlmsvc_defer_lock_rqst()
454 if (block->b_deferred_req != NULL) in nlmsvc_defer_lock_rqst()
458 block, block->b_flags, ntohl(status)); in nlmsvc_defer_lock_rqst()
472 struct nlm_block *block = NULL; in nlmsvc_lock() local
489 block = nlmsvc_lookup_block(file, lock); in nlmsvc_lock()
490 if (block == NULL) { in nlmsvc_lock()
491 block = nlmsvc_create_block(rqstp, host, file, lock, cookie); in nlmsvc_lock()
493 if (block == NULL) in nlmsvc_lock()
495 lock = &block->b_call->a_args.lock; in nlmsvc_lock()
499 if (block->b_flags & B_QUEUED) { in nlmsvc_lock()
501 block, block->b_flags); in nlmsvc_lock()
502 if (block->b_granted) { in nlmsvc_lock()
503 nlmsvc_unlink_block(block); in nlmsvc_lock()
507 if (block->b_flags & B_TIMED_OUT) { in nlmsvc_lock()
508 nlmsvc_unlink_block(block); in nlmsvc_lock()
550 ret = nlmsvc_defer_lock_rqst(rqstp, block); in nlmsvc_lock()
563 nlmsvc_insert_block(block, NLM_NEVER); in nlmsvc_lock()
566 nlmsvc_release_block(block); in nlmsvc_lock()
672 struct nlm_block *block; in nlmsvc_cancel_blocked() local
686 block = nlmsvc_lookup_block(file, lock); in nlmsvc_cancel_blocked()
688 if (block != NULL) { in nlmsvc_cancel_blocked()
689 vfs_cancel_lock(block->b_file->f_file, in nlmsvc_cancel_blocked()
690 &block->b_call->a_args.lock.fl); in nlmsvc_cancel_blocked()
691 status = nlmsvc_unlink_block(block); in nlmsvc_cancel_blocked()
692 nlmsvc_release_block(block); in nlmsvc_cancel_blocked()
707 nlmsvc_update_deferred_block(struct nlm_block *block, int result) in nlmsvc_update_deferred_block() argument
709 block->b_flags |= B_GOT_CALLBACK; in nlmsvc_update_deferred_block()
711 block->b_granted = 1; in nlmsvc_update_deferred_block()
713 block->b_flags |= B_TIMED_OUT; in nlmsvc_update_deferred_block()
718 struct nlm_block *block; in nlmsvc_grant_deferred() local
722 list_for_each_entry(block, &nlm_blocked, b_list) { in nlmsvc_grant_deferred()
723 if (nlm_compare_locks(&block->b_call->a_args.lock.fl, fl)) { in nlmsvc_grant_deferred()
725 block, block->b_flags); in nlmsvc_grant_deferred()
726 if (block->b_flags & B_QUEUED) { in nlmsvc_grant_deferred()
727 if (block->b_flags & B_TIMED_OUT) { in nlmsvc_grant_deferred()
731 nlmsvc_update_deferred_block(block, result); in nlmsvc_grant_deferred()
733 block->b_granted = 1; in nlmsvc_grant_deferred()
735 nlmsvc_insert_block_locked(block, 0); in nlmsvc_grant_deferred()
736 svc_wake_up(block->b_daemon); in nlmsvc_grant_deferred()
757 struct nlm_block *block; in nlmsvc_notify_blocked() local
761 list_for_each_entry(block, &nlm_blocked, b_list) { in nlmsvc_notify_blocked()
762 if (nlm_compare_locks(&block->b_call->a_args.lock.fl, fl)) { in nlmsvc_notify_blocked()
763 nlmsvc_insert_block_locked(block, 0); in nlmsvc_notify_blocked()
765 svc_wake_up(block->b_daemon); in nlmsvc_notify_blocked()
802 nlmsvc_grant_blocked(struct nlm_block *block) in nlmsvc_grant_blocked() argument
804 struct nlm_file *file = block->b_file; in nlmsvc_grant_blocked()
805 struct nlm_lock *lock = &block->b_call->a_args.lock; in nlmsvc_grant_blocked()
809 dprintk("lockd: grant blocked lock %p\n", block); in nlmsvc_grant_blocked()
811 kref_get(&block->b_count); in nlmsvc_grant_blocked()
814 nlmsvc_unlink_block(block); in nlmsvc_grant_blocked()
819 if (block->b_granted) { in nlmsvc_grant_blocked()
820 nlm_rebind_host(block->b_host); in nlmsvc_grant_blocked()
841 nlmsvc_insert_block(block, NLM_NEVER); in nlmsvc_grant_blocked()
842 nlmsvc_release_block(block); in nlmsvc_grant_blocked()
847 nlmsvc_insert_block(block, 10 * HZ); in nlmsvc_grant_blocked()
848 nlmsvc_release_block(block); in nlmsvc_grant_blocked()
855 block->b_granted = 1; in nlmsvc_grant_blocked()
860 nlmsvc_insert_block(block, NLM_NEVER); in nlmsvc_grant_blocked()
865 error = nlm_async_call(block->b_call, NLMPROC_GRANTED_MSG, in nlmsvc_grant_blocked()
870 nlmsvc_insert_block(block, 10 * HZ); in nlmsvc_grant_blocked()
884 struct nlm_block *block = call->a_block; in nlmsvc_grant_callback() local
898 if (list_empty(&block->b_list)) in nlmsvc_grant_callback()
911 nlmsvc_insert_block_locked(block, timeout); in nlmsvc_grant_callback()
912 svc_wake_up(block->b_daemon); in nlmsvc_grant_callback()
939 struct nlm_block *block; in nlmsvc_grant_reply() local
943 if (!(block = nlmsvc_find_block(cookie))) in nlmsvc_grant_reply()
948 nlmsvc_insert_block(block, 10 * HZ); in nlmsvc_grant_reply()
954 nlmsvc_unlink_block(block); in nlmsvc_grant_reply()
956 nlmsvc_release_block(block); in nlmsvc_grant_reply()
964 retry_deferred_block(struct nlm_block *block) in retry_deferred_block() argument
966 if (!(block->b_flags & B_GOT_CALLBACK)) in retry_deferred_block()
967 block->b_flags |= B_TIMED_OUT; in retry_deferred_block()
968 nlmsvc_insert_block(block, NLM_TIMEOUT); in retry_deferred_block()
969 dprintk("revisit block %p flags %d\n", block, block->b_flags); in retry_deferred_block()
970 if (block->b_deferred_req) { in retry_deferred_block()
971 block->b_deferred_req->revisit(block->b_deferred_req, 0); in retry_deferred_block()
972 block->b_deferred_req = NULL; in retry_deferred_block()
985 struct nlm_block *block; in nlmsvc_retry_blocked() local
989 block = list_entry(nlm_blocked.next, struct nlm_block, b_list); in nlmsvc_retry_blocked()
991 if (block->b_when == NLM_NEVER) in nlmsvc_retry_blocked()
993 if (time_after(block->b_when, jiffies)) { in nlmsvc_retry_blocked()
994 timeout = block->b_when - jiffies; in nlmsvc_retry_blocked()
1000 block, block->b_when); in nlmsvc_retry_blocked()
1001 if (block->b_flags & B_QUEUED) { in nlmsvc_retry_blocked()
1003 block, block->b_granted, block->b_flags); in nlmsvc_retry_blocked()
1004 retry_deferred_block(block); in nlmsvc_retry_blocked()
1006 nlmsvc_grant_blocked(block); in nlmsvc_retry_blocked()