42 static void nlmsvc_release_block(struct nlm_block *block);
43 static void	nlmsvc_insert_block(struct nlm_block *block, unsigned long);
44 static void	nlmsvc_remove_block(struct nlm_block *block);
89 nlmsvc_insert_block_locked(struct nlm_block *block, unsigned long when)  in nlmsvc_insert_block_locked()  argument
94 	dprintk("lockd: nlmsvc_insert_block(%p, %ld)\n", block, when);  in nlmsvc_insert_block_locked()
95 	if (list_empty(&block->b_list)) {  in nlmsvc_insert_block_locked()
96 		kref_get(&block->b_count);  in nlmsvc_insert_block_locked()
98 		list_del_init(&block->b_list);  in nlmsvc_insert_block_locked()
115 	list_add_tail(&block->b_list, pos);  in nlmsvc_insert_block_locked()
116 	block->b_when = when;  in nlmsvc_insert_block_locked()
119 static void nlmsvc_insert_block(struct nlm_block *block, unsigned long when)  in nlmsvc_insert_block()  argument
122 	nlmsvc_insert_block_locked(block, when);  in nlmsvc_insert_block()
130 nlmsvc_remove_block(struct nlm_block *block)  in nlmsvc_remove_block()  argument
132 	if (!list_empty(&block->b_list)) {  in nlmsvc_remove_block()
134 		list_del_init(&block->b_list);  in nlmsvc_remove_block()
136 		nlmsvc_release_block(block);  in nlmsvc_remove_block()
146 	struct nlm_block	*block;  in nlmsvc_lookup_block()  local
153 	list_for_each_entry(block, &nlm_blocked, b_list) {  in nlmsvc_lookup_block()
154 		fl = &block->b_call->a_args.lock.fl;  in nlmsvc_lookup_block()
156 				block->b_file, fl->fl_pid,  in nlmsvc_lookup_block()
159 				nlmdbg_cookie2a(&block->b_call->a_args.cookie));  in nlmsvc_lookup_block()
160 		if (block->b_file == file && nlm_compare_locks(fl, &lock->fl)) {  in nlmsvc_lookup_block()
161 			kref_get(&block->b_count);  in nlmsvc_lookup_block()
162 			return block;  in nlmsvc_lookup_block()
184 	struct nlm_block *block;  in nlmsvc_find_block()  local
186 	list_for_each_entry(block, &nlm_blocked, b_list) {  in nlmsvc_find_block()
187 		if (nlm_cookie_match(&block->b_call->a_args.cookie,cookie))  in nlmsvc_find_block()
194 	dprintk("nlmsvc_find_block(%s): block=%p\n", nlmdbg_cookie2a(cookie), block);  in nlmsvc_find_block()
195 	kref_get(&block->b_count);  in nlmsvc_find_block()
196 	return block;  in nlmsvc_find_block()
219 	struct nlm_block	*block;  in nlmsvc_create_block()  local
227 	block = kzalloc(sizeof(*block), GFP_KERNEL);  in nlmsvc_create_block()
228 	if (block == NULL)  in nlmsvc_create_block()
230 	kref_init(&block->b_count);  in nlmsvc_create_block()
231 	INIT_LIST_HEAD(&block->b_list);  in nlmsvc_create_block()
232 	INIT_LIST_HEAD(&block->b_flist);  in nlmsvc_create_block()
242 	dprintk("lockd: created block %p...\n", block);  in nlmsvc_create_block()
245 	block->b_daemon = rqstp->rq_server;  in nlmsvc_create_block()
246 	block->b_host   = host;  in nlmsvc_create_block()
247 	block->b_file   = file;  in nlmsvc_create_block()
251 	list_add(&block->b_flist, &file->f_blocks);  in nlmsvc_create_block()
254 	block->b_call = call;  in nlmsvc_create_block()
256 	call->a_block = block;  in nlmsvc_create_block()
258 	return block;  in nlmsvc_create_block()
261 	kfree(block);  in nlmsvc_create_block()
272 static int nlmsvc_unlink_block(struct nlm_block *block)  in nlmsvc_unlink_block()  argument
275 	dprintk("lockd: unlinking block %p...\n", block);  in nlmsvc_unlink_block()
278 	status = posix_unblock_lock(&block->b_call->a_args.lock.fl);  in nlmsvc_unlink_block()
279 	nlmsvc_remove_block(block);  in nlmsvc_unlink_block()
285 	struct nlm_block *block = container_of(kref, struct nlm_block, b_count);  in nlmsvc_free_block()  local
286 	struct nlm_file		*file = block->b_file;  in nlmsvc_free_block()
288 	dprintk("lockd: freeing block %p...\n", block);  in nlmsvc_free_block()
291 	list_del_init(&block->b_flist);  in nlmsvc_free_block()
294 	nlmsvc_freegrantargs(block->b_call);  in nlmsvc_free_block()
295 	nlmsvc_release_call(block->b_call);  in nlmsvc_free_block()
296 	nlm_release_file(block->b_file);  in nlmsvc_free_block()
297 	kfree(block);  in nlmsvc_free_block()
300 static void nlmsvc_release_block(struct nlm_block *block)  in nlmsvc_release_block()  argument
302 	if (block != NULL)  in nlmsvc_release_block()
303 		kref_put_mutex(&block->b_count, nlmsvc_free_block, &block->b_file->f_mutex);  in nlmsvc_release_block()
314 	struct nlm_block *block, *next;  in nlmsvc_traverse_blocks()  local
318 	list_for_each_entry_safe(block, next, &file->f_blocks, b_flist) {  in nlmsvc_traverse_blocks()
319 		if (!match(block->b_host, host))  in nlmsvc_traverse_blocks()
323 		if (list_empty(&block->b_list))  in nlmsvc_traverse_blocks()
325 		kref_get(&block->b_count);  in nlmsvc_traverse_blocks()
327 		nlmsvc_unlink_block(block);  in nlmsvc_traverse_blocks()
328 		nlmsvc_release_block(block);  in nlmsvc_traverse_blocks()
372 nlmsvc_defer_lock_rqst(struct svc_rqst *rqstp, struct nlm_block *block)  in nlmsvc_defer_lock_rqst()  argument
376 	block->b_flags |= B_QUEUED;  in nlmsvc_defer_lock_rqst()
378 	nlmsvc_insert_block(block, NLM_TIMEOUT);  in nlmsvc_defer_lock_rqst()
380 	block->b_cache_req = &rqstp->rq_chandle;  in nlmsvc_defer_lock_rqst()
382 		block->b_deferred_req =  in nlmsvc_defer_lock_rqst()
383 			rqstp->rq_chandle.defer(block->b_cache_req);  in nlmsvc_defer_lock_rqst()
384 		if (block->b_deferred_req != NULL)  in nlmsvc_defer_lock_rqst()
388 		block, block->b_flags, ntohl(status));  in nlmsvc_defer_lock_rqst()
402 	struct nlm_block	*block = NULL;  in nlmsvc_lock()  local
419 	block = nlmsvc_lookup_block(file, lock);  in nlmsvc_lock()
420 	if (block == NULL) {  in nlmsvc_lock()
421 		block = nlmsvc_create_block(rqstp, host, file, lock, cookie);  in nlmsvc_lock()
423 		if (block == NULL)  in nlmsvc_lock()
425 		lock = &block->b_call->a_args.lock;  in nlmsvc_lock()
429 	if (block->b_flags & B_QUEUED) {  in nlmsvc_lock()
431 							block, block->b_flags);  in nlmsvc_lock()
432 		if (block->b_granted) {  in nlmsvc_lock()
433 			nlmsvc_unlink_block(block);  in nlmsvc_lock()
437 		if (block->b_flags & B_TIMED_OUT) {  in nlmsvc_lock()
438 			nlmsvc_unlink_block(block);  in nlmsvc_lock()
480 			ret = nlmsvc_defer_lock_rqst(rqstp, block);  in nlmsvc_lock()
493 	nlmsvc_insert_block(block, NLM_NEVER);  in nlmsvc_lock()
496 	nlmsvc_release_block(block);  in nlmsvc_lock()
593 	struct nlm_block	*block;  in nlmsvc_cancel_blocked()  local
607 	block = nlmsvc_lookup_block(file, lock);  in nlmsvc_cancel_blocked()
609 	if (block != NULL) {  in nlmsvc_cancel_blocked()
610 		vfs_cancel_lock(block->b_file->f_file,  in nlmsvc_cancel_blocked()
611 				&block->b_call->a_args.lock.fl);  in nlmsvc_cancel_blocked()
612 		status = nlmsvc_unlink_block(block);  in nlmsvc_cancel_blocked()
613 		nlmsvc_release_block(block);  in nlmsvc_cancel_blocked()
628 nlmsvc_update_deferred_block(struct nlm_block *block, int result)  in nlmsvc_update_deferred_block()  argument
630 	block->b_flags |= B_GOT_CALLBACK;  in nlmsvc_update_deferred_block()
632 		block->b_granted = 1;  in nlmsvc_update_deferred_block()
634 		block->b_flags |= B_TIMED_OUT;  in nlmsvc_update_deferred_block()
639 	struct nlm_block *block;  in nlmsvc_grant_deferred()  local
643 	list_for_each_entry(block, &nlm_blocked, b_list) {  in nlmsvc_grant_deferred()
644 		if (nlm_compare_locks(&block->b_call->a_args.lock.fl, fl)) {  in nlmsvc_grant_deferred()
646 							block, block->b_flags);  in nlmsvc_grant_deferred()
647 			if (block->b_flags & B_QUEUED) {  in nlmsvc_grant_deferred()
648 				if (block->b_flags & B_TIMED_OUT) {  in nlmsvc_grant_deferred()
652 				nlmsvc_update_deferred_block(block, result);  in nlmsvc_grant_deferred()
654 				block->b_granted = 1;  in nlmsvc_grant_deferred()
656 			nlmsvc_insert_block_locked(block, 0);  in nlmsvc_grant_deferred()
657 			svc_wake_up(block->b_daemon);  in nlmsvc_grant_deferred()
678 	struct nlm_block	*block;  in nlmsvc_notify_blocked()  local
682 	list_for_each_entry(block, &nlm_blocked, b_list) {  in nlmsvc_notify_blocked()
683 		if (nlm_compare_locks(&block->b_call->a_args.lock.fl, fl)) {  in nlmsvc_notify_blocked()
684 			nlmsvc_insert_block_locked(block, 0);  in nlmsvc_notify_blocked()
686 			svc_wake_up(block->b_daemon);  in nlmsvc_notify_blocked()
729 nlmsvc_grant_blocked(struct nlm_block *block)  in nlmsvc_grant_blocked()  argument
731 	struct nlm_file		*file = block->b_file;  in nlmsvc_grant_blocked()
732 	struct nlm_lock		*lock = &block->b_call->a_args.lock;  in nlmsvc_grant_blocked()
736 	dprintk("lockd: grant blocked lock %p\n", block);  in nlmsvc_grant_blocked()
738 	kref_get(&block->b_count);  in nlmsvc_grant_blocked()
741 	nlmsvc_unlink_block(block);  in nlmsvc_grant_blocked()
746 	if (block->b_granted) {  in nlmsvc_grant_blocked()
747 		nlm_rebind_host(block->b_host);  in nlmsvc_grant_blocked()
768 		nlmsvc_insert_block(block, NLM_NEVER);  in nlmsvc_grant_blocked()
769 		nlmsvc_release_block(block);  in nlmsvc_grant_blocked()
774 		nlmsvc_insert_block(block, 10 * HZ);  in nlmsvc_grant_blocked()
775 		nlmsvc_release_block(block);  in nlmsvc_grant_blocked()
782 	block->b_granted = 1;  in nlmsvc_grant_blocked()
787 	nlmsvc_insert_block(block, NLM_NEVER);  in nlmsvc_grant_blocked()
792 	error = nlm_async_call(block->b_call, NLMPROC_GRANTED_MSG,  in nlmsvc_grant_blocked()
797 		nlmsvc_insert_block(block, 10 * HZ);  in nlmsvc_grant_blocked()
811 	struct nlm_block	*block = call->a_block;  in nlmsvc_grant_callback()  local
825 	if (list_empty(&block->b_list))  in nlmsvc_grant_callback()
838 	nlmsvc_insert_block_locked(block, timeout);  in nlmsvc_grant_callback()
839 	svc_wake_up(block->b_daemon);  in nlmsvc_grant_callback()
866 	struct nlm_block	*block;  in nlmsvc_grant_reply()  local
870 	if (!(block = nlmsvc_find_block(cookie)))  in nlmsvc_grant_reply()
873 	if (block) {  in nlmsvc_grant_reply()
876 			nlmsvc_insert_block(block, 10 * HZ);  in nlmsvc_grant_reply()
880 			nlmsvc_unlink_block(block);  in nlmsvc_grant_reply()
883 	nlmsvc_release_block(block);  in nlmsvc_grant_reply()
891 retry_deferred_block(struct nlm_block *block)  in retry_deferred_block()  argument
893 	if (!(block->b_flags & B_GOT_CALLBACK))  in retry_deferred_block()
894 		block->b_flags |= B_TIMED_OUT;  in retry_deferred_block()
895 	nlmsvc_insert_block(block, NLM_TIMEOUT);  in retry_deferred_block()
896 	dprintk("revisit block %p flags %d\n",	block, block->b_flags);  in retry_deferred_block()
897 	if (block->b_deferred_req) {  in retry_deferred_block()
898 		block->b_deferred_req->revisit(block->b_deferred_req, 0);  in retry_deferred_block()
899 		block->b_deferred_req = NULL;  in retry_deferred_block()
912 	struct nlm_block *block;  in nlmsvc_retry_blocked()  local
916 		block = list_entry(nlm_blocked.next, struct nlm_block, b_list);  in nlmsvc_retry_blocked()
918 		if (block->b_when == NLM_NEVER)  in nlmsvc_retry_blocked()
920 		if (time_after(block->b_when, jiffies)) {  in nlmsvc_retry_blocked()
921 			timeout = block->b_when - jiffies;  in nlmsvc_retry_blocked()
927 			block, block->b_when);  in nlmsvc_retry_blocked()
928 		if (block->b_flags & B_QUEUED) {  in nlmsvc_retry_blocked()
930 				block, block->b_granted, block->b_flags);  in nlmsvc_retry_blocked()
931 			retry_deferred_block(block);  in nlmsvc_retry_blocked()
933 			nlmsvc_grant_blocked(block);  in nlmsvc_retry_blocked()