Lines Matching refs:req
126 static void nlmclnt_setlockargs(struct nlm_rqst *req, struct file_lock *fl) in nlmclnt_setlockargs() argument
128 struct nlm_args *argp = &req->a_args; in nlmclnt_setlockargs()
130 char *nodename = req->a_host->h_rpcclnt->cl_nodename; in nlmclnt_setlockargs()
135 lock->oh.data = req->a_owner; in nlmclnt_setlockargs()
136 lock->oh.len = snprintf(req->a_owner, sizeof(req->a_owner), "%u@%s", in nlmclnt_setlockargs()
145 static void nlmclnt_release_lockargs(struct nlm_rqst *req) in nlmclnt_release_lockargs() argument
147 WARN_ON_ONCE(req->a_args.lock.fl.fl_ops != NULL); in nlmclnt_release_lockargs()
261 nlmclnt_call(const struct cred *cred, struct nlm_rqst *req, u32 proc) in nlmclnt_call() argument
263 struct nlm_host *host = req->a_host; in nlmclnt_call()
265 struct nlm_args *argp = &req->a_args; in nlmclnt_call()
266 struct nlm_res *resp = &req->a_res; in nlmclnt_call()
339 static struct rpc_task *__nlm_async_call(struct nlm_rqst *req, u32 proc, struct rpc_message *msg, c… in __nlm_async_call() argument
341 struct nlm_host *host = req->a_host; in __nlm_async_call()
346 .callback_data = req, in __nlm_async_call()
363 tk_ops->rpc_release(req); in __nlm_async_call()
367 static int nlm_do_async_call(struct nlm_rqst *req, u32 proc, struct rpc_message *msg, const struct … in nlm_do_async_call() argument
371 task = __nlm_async_call(req, proc, msg, tk_ops); in nlm_do_async_call()
381 int nlm_async_call(struct nlm_rqst *req, u32 proc, const struct rpc_call_ops *tk_ops) in nlm_async_call() argument
384 .rpc_argp = &req->a_args, in nlm_async_call()
385 .rpc_resp = &req->a_res, in nlm_async_call()
387 return nlm_do_async_call(req, proc, &msg, tk_ops); in nlm_async_call()
390 int nlm_async_reply(struct nlm_rqst *req, u32 proc, const struct rpc_call_ops *tk_ops) in nlm_async_reply() argument
393 .rpc_argp = &req->a_res, in nlm_async_reply()
395 return nlm_do_async_call(req, proc, &msg, tk_ops); in nlm_async_reply()
406 static int nlmclnt_async_call(const struct cred *cred, struct nlm_rqst *req, u32 proc, const struct… in nlmclnt_async_call() argument
409 .rpc_argp = &req->a_args, in nlmclnt_async_call()
410 .rpc_resp = &req->a_res, in nlmclnt_async_call()
416 task = __nlm_async_call(req, proc, &msg, tk_ops); in nlmclnt_async_call()
428 nlmclnt_test(struct nlm_rqst *req, struct file_lock *fl) in nlmclnt_test() argument
432 status = nlmclnt_call(nfs_file_cred(fl->fl_file), req, NLMPROC_TEST); in nlmclnt_test()
436 switch (req->a_res.status) { in nlmclnt_test()
444 fl->fl_start = req->a_res.lock.fl.fl_start; in nlmclnt_test()
445 fl->fl_end = req->a_res.lock.fl.fl_end; in nlmclnt_test()
446 fl->fl_type = req->a_res.lock.fl.fl_type; in nlmclnt_test()
447 fl->fl_pid = -req->a_res.lock.fl.fl_pid; in nlmclnt_test()
450 status = nlm_stat_to_errno(req->a_res.status); in nlmclnt_test()
453 nlmclnt_release_call(req); in nlmclnt_test()
513 nlmclnt_lock(struct nlm_rqst *req, struct file_lock *fl) in nlmclnt_lock() argument
516 struct nlm_host *host = req->a_host; in nlmclnt_lock()
517 struct nlm_res *resp = &req->a_res; in nlmclnt_lock()
525 req->a_args.state = nsm_local_state; in nlmclnt_lock()
543 status = nlmclnt_call(cred, req, NLMPROC_LOCK); in nlmclnt_lock()
552 status = nlmclnt_block(block, req, NLMCLNT_POLL_TIMEOUT); in nlmclnt_lock()
563 if (!req->a_args.block) in nlmclnt_lock()
565 if (nlmclnt_cancel(host, req->a_args.block, fl) == 0) in nlmclnt_lock()
598 nlmclnt_release_call(req); in nlmclnt_lock()
612 nlmclnt_async_call(cred, req, NLMPROC_UNLOCK, &nlmclnt_unlock_ops); in nlmclnt_lock()
621 struct nlm_rqst *req) in nlmclnt_reclaim() argument
625 memset(req, 0, sizeof(*req)); in nlmclnt_reclaim()
626 locks_init_lock(&req->a_args.lock.fl); in nlmclnt_reclaim()
627 locks_init_lock(&req->a_res.lock.fl); in nlmclnt_reclaim()
628 req->a_host = host; in nlmclnt_reclaim()
631 nlmclnt_setlockargs(req, fl); in nlmclnt_reclaim()
632 req->a_args.reclaim = 1; in nlmclnt_reclaim()
634 status = nlmclnt_call(nfs_file_cred(fl->fl_file), req, NLMPROC_LOCK); in nlmclnt_reclaim()
635 if (status >= 0 && req->a_res.status == nlm_granted) in nlmclnt_reclaim()
640 status, ntohl(req->a_res.status)); in nlmclnt_reclaim()
661 nlmclnt_unlock(struct nlm_rqst *req, struct file_lock *fl) in nlmclnt_unlock() argument
663 struct nlm_host *host = req->a_host; in nlmclnt_unlock()
664 struct nlm_res *resp = &req->a_res; in nlmclnt_unlock()
683 refcount_inc(&req->a_count); in nlmclnt_unlock()
684 status = nlmclnt_async_call(nfs_file_cred(fl->fl_file), req, in nlmclnt_unlock()
698 nlmclnt_release_call(req); in nlmclnt_unlock()
704 struct nlm_rqst *req = data; in nlmclnt_unlock_prepare() local
705 const struct nlmclnt_operations *nlmclnt_ops = req->a_host->h_nlmclnt_ops; in nlmclnt_unlock_prepare()
709 defer_call = nlmclnt_ops->nlmclnt_unlock_prepare(task, req->a_callback_data); in nlmclnt_unlock_prepare()
717 struct nlm_rqst *req = data; in nlmclnt_unlock_callback() local
718 u32 status = ntohl(req->a_res.status); in nlmclnt_unlock_callback()
742 nlm_rebind_host(req->a_host); in nlmclnt_unlock_callback()
760 struct nlm_rqst *req; in nlmclnt_cancel() local
766 req = nlm_alloc_call(host); in nlmclnt_cancel()
767 if (!req) in nlmclnt_cancel()
769 req->a_flags = RPC_TASK_ASYNC; in nlmclnt_cancel()
771 nlmclnt_setlockargs(req, fl); in nlmclnt_cancel()
772 req->a_args.block = block; in nlmclnt_cancel()
774 refcount_inc(&req->a_count); in nlmclnt_cancel()
775 status = nlmclnt_async_call(nfs_file_cred(fl->fl_file), req, in nlmclnt_cancel()
777 if (status == 0 && req->a_res.status == nlm_lck_denied) in nlmclnt_cancel()
779 nlmclnt_release_call(req); in nlmclnt_cancel()
785 struct nlm_rqst *req = data; in nlmclnt_cancel_callback() local
786 u32 status = ntohl(req->a_res.status); in nlmclnt_cancel_callback()
819 if (req->a_retries++ >= NLMCLNT_MAX_RETRIES) in nlmclnt_cancel_callback()
821 nlm_rebind_host(req->a_host); in nlmclnt_cancel_callback()