Lines Matching refs:task
395 static int nfs4_wait_for_completion_rpc_task(struct rpc_task *task) in nfs4_wait_for_completion_rpc_task() argument
399 ret = rpc_wait_for_completion_task(task); in nfs4_wait_for_completion_rpc_task()
828 static void nfs4_open_confirm_done(struct rpc_task *task, void *calldata) in nfs4_open_confirm_done() argument
832 data->rpc_status = task->tk_status; in nfs4_open_confirm_done()
833 if (RPC_ASSASSINATED(task)) in nfs4_open_confirm_done()
873 struct rpc_task *task; in _nfs4_proc_open_confirm() local
894 task = rpc_run_task(&task_setup_data); in _nfs4_proc_open_confirm()
895 if (IS_ERR(task)) in _nfs4_proc_open_confirm()
896 return PTR_ERR(task); in _nfs4_proc_open_confirm()
897 status = nfs4_wait_for_completion_rpc_task(task); in _nfs4_proc_open_confirm()
903 rpc_put_task(task); in _nfs4_proc_open_confirm()
907 static void nfs4_open_prepare(struct rpc_task *task, void *calldata) in nfs4_open_prepare() argument
912 if (nfs_wait_on_sequence(data->o_arg.seqid, task) != 0) in nfs4_open_prepare()
936 task->tk_msg.rpc_proc = &nfs4_procedures[NFSPROC4_CLNT_OPEN_NOATTR]; in nfs4_open_prepare()
940 rpc_call_start(task); in nfs4_open_prepare()
943 task->tk_action = NULL; in nfs4_open_prepare()
947 static void nfs4_open_done(struct rpc_task *task, void *calldata) in nfs4_open_done() argument
951 data->rpc_status = task->tk_status; in nfs4_open_done()
952 if (RPC_ASSASSINATED(task)) in nfs4_open_done()
954 if (task->tk_status == 0) { in nfs4_open_done()
1010 struct rpc_task *task; in _nfs4_proc_open() local
1031 task = rpc_run_task(&task_setup_data); in _nfs4_proc_open()
1032 if (IS_ERR(task)) in _nfs4_proc_open()
1033 return PTR_ERR(task); in _nfs4_proc_open()
1034 status = nfs4_wait_for_completion_rpc_task(task); in _nfs4_proc_open()
1040 rpc_put_task(task); in _nfs4_proc_open()
1323 static void nfs4_close_done(struct rpc_task *task, void *data) in nfs4_close_done() argument
1329 if (RPC_ASSASSINATED(task)) in nfs4_close_done()
1334 switch (task->tk_status) { in nfs4_close_done()
1346 if (nfs4_async_handle_error(task, server, state) == -EAGAIN) { in nfs4_close_done()
1347 rpc_restart_call(task); in nfs4_close_done()
1354 static void nfs4_close_prepare(struct rpc_task *task, void *data) in nfs4_close_prepare() argument
1360 if (nfs_wait_on_sequence(calldata->arg.seqid, task) != 0) in nfs4_close_prepare()
1379 task->tk_action = NULL; in nfs4_close_prepare()
1384 task->tk_msg.rpc_proc = &nfs4_procedures[NFSPROC4_CLNT_OPEN_DOWNGRADE]; in nfs4_close_prepare()
1387 task->tk_msg.rpc_proc = &nfs4_procedures[NFSPROC4_CLNT_OPEN_DOWNGRADE]; in nfs4_close_prepare()
1391 rpc_call_start(task); in nfs4_close_prepare()
1416 struct rpc_task *task; in nfs4_do_close() local
1452 task = rpc_run_task(&task_setup_data); in nfs4_do_close()
1453 if (IS_ERR(task)) in nfs4_do_close()
1454 return PTR_ERR(task); in nfs4_do_close()
1457 status = rpc_wait_for_completion_task(task); in nfs4_do_close()
1458 rpc_put_task(task); in nfs4_do_close()
2087 static int nfs4_proc_unlink_done(struct rpc_task *task, struct inode *dir) in nfs4_proc_unlink_done() argument
2089 struct nfs_removeres *res = task->tk_msg.rpc_resp; in nfs4_proc_unlink_done()
2091 if (nfs4_async_handle_error(task, res->server, NULL) == -EAGAIN) in nfs4_proc_unlink_done()
2515 static int nfs4_read_done(struct rpc_task *task, struct nfs_read_data *data) in nfs4_read_done() argument
2519 if (nfs4_async_handle_error(task, server, data->args.context->state) == -EAGAIN) { in nfs4_read_done()
2520 rpc_restart_call(task); in nfs4_read_done()
2525 if (task->tk_status > 0) in nfs4_read_done()
2536 static int nfs4_write_done(struct rpc_task *task, struct nfs_write_data *data) in nfs4_write_done() argument
2540 if (nfs4_async_handle_error(task, NFS_SERVER(inode), data->args.context->state) == -EAGAIN) { in nfs4_write_done()
2541 rpc_restart_call(task); in nfs4_write_done()
2544 if (task->tk_status >= 0) { in nfs4_write_done()
2562 static int nfs4_commit_done(struct rpc_task *task, struct nfs_write_data *data) in nfs4_commit_done() argument
2566 if (nfs4_async_handle_error(task, NFS_SERVER(inode), NULL) == -EAGAIN) { in nfs4_commit_done()
2567 rpc_restart_call(task); in nfs4_commit_done()
2587 static void nfs4_renew_done(struct rpc_task *task, void *data) in nfs4_renew_done() argument
2589 struct nfs_client *clp = (struct nfs_client *)task->tk_msg.rpc_argp; in nfs4_renew_done()
2592 if (task->tk_status < 0) { in nfs4_renew_done()
2593 switch (task->tk_status) { in nfs4_renew_done()
2859 nfs4_async_handle_error(struct rpc_task *task, const struct nfs_server *server, struct nfs4_state *… in nfs4_async_handle_error() argument
2863 if (!clp || task->tk_status >= 0) in nfs4_async_handle_error()
2865 switch(task->tk_status) { in nfs4_async_handle_error()
2875 rpc_sleep_on(&clp->cl_rpcwaitq, task, NULL); in nfs4_async_handle_error()
2878 rpc_wake_up_queued_task(&clp->cl_rpcwaitq, task); in nfs4_async_handle_error()
2879 task->tk_status = 0; in nfs4_async_handle_error()
2884 rpc_delay(task, NFS4_POLL_RETRY_MAX); in nfs4_async_handle_error()
2885 task->tk_status = 0; in nfs4_async_handle_error()
2888 task->tk_status = 0; in nfs4_async_handle_error()
2891 task->tk_status = nfs4_map_errors(task->tk_status); in nfs4_async_handle_error()
2999 static void nfs4_delegreturn_done(struct rpc_task *task, void *calldata) in nfs4_delegreturn_done() argument
3002 data->rpc_status = task->tk_status; in nfs4_delegreturn_done()
3021 struct rpc_task *task; in _nfs4_proc_delegreturn() local
3051 task = rpc_run_task(&task_setup_data); in _nfs4_proc_delegreturn()
3052 if (IS_ERR(task)) in _nfs4_proc_delegreturn()
3053 return PTR_ERR(task); in _nfs4_proc_delegreturn()
3056 status = nfs4_wait_for_completion_rpc_task(task); in _nfs4_proc_delegreturn()
3064 rpc_put_task(task); in _nfs4_proc_delegreturn()
3215 static void nfs4_locku_done(struct rpc_task *task, void *data) in nfs4_locku_done() argument
3219 if (RPC_ASSASSINATED(task)) in nfs4_locku_done()
3221 switch (task->tk_status) { in nfs4_locku_done()
3234 if (nfs4_async_handle_error(task, calldata->server, NULL) == -EAGAIN) in nfs4_locku_done()
3235 rpc_restart_call(task); in nfs4_locku_done()
3239 static void nfs4_locku_prepare(struct rpc_task *task, void *data) in nfs4_locku_prepare() argument
3243 if (nfs_wait_on_sequence(calldata->arg.seqid, task) != 0) in nfs4_locku_prepare()
3247 task->tk_action = NULL; in nfs4_locku_prepare()
3251 rpc_call_start(task); in nfs4_locku_prepare()
3300 struct rpc_task *task; in nfs4_proc_unlck() local
3323 task = nfs4_do_unlck(request, nfs_file_open_context(request->fl_file), lsp, seqid); in nfs4_proc_unlck()
3324 status = PTR_ERR(task); in nfs4_proc_unlck()
3325 if (IS_ERR(task)) in nfs4_proc_unlck()
3327 status = nfs4_wait_for_completion_rpc_task(task); in nfs4_proc_unlck()
3328 rpc_put_task(task); in nfs4_proc_unlck()
3380 static void nfs4_lock_prepare(struct rpc_task *task, void *calldata) in nfs4_lock_prepare() argument
3386 if (nfs_wait_on_sequence(data->arg.lock_seqid, task) != 0) in nfs4_lock_prepare()
3390 if (nfs_wait_on_sequence(data->arg.open_seqid, task) != 0) in nfs4_lock_prepare()
3398 rpc_call_start(task); in nfs4_lock_prepare()
3402 static void nfs4_lock_done(struct rpc_task *task, void *calldata) in nfs4_lock_done() argument
3408 data->rpc_status = task->tk_status; in nfs4_lock_done()
3409 if (RPC_ASSASSINATED(task)) in nfs4_lock_done()
3434 struct rpc_task *task; in nfs4_lock_release() local
3435 task = nfs4_do_unlck(&data->fl, data->ctx, data->lsp, in nfs4_lock_release()
3437 if (!IS_ERR(task)) in nfs4_lock_release()
3438 rpc_put_task(task); in nfs4_lock_release()
3457 struct rpc_task *task; in _nfs4_do_setlk() local
3483 task = rpc_run_task(&task_setup_data); in _nfs4_do_setlk()
3484 if (IS_ERR(task)) in _nfs4_do_setlk()
3485 return PTR_ERR(task); in _nfs4_do_setlk()
3486 ret = nfs4_wait_for_completion_rpc_task(task); in _nfs4_do_setlk()
3493 rpc_put_task(task); in _nfs4_do_setlk()