57 static void	call_start(struct rpc_task *task);
58 static void	call_reserve(struct rpc_task *task);
59 static void	call_reserveresult(struct rpc_task *task);
60 static void	call_allocate(struct rpc_task *task);
61 static void	call_encode(struct rpc_task *task);
62 static void	call_decode(struct rpc_task *task);
63 static void	call_bind(struct rpc_task *task);
64 static void	call_bind_status(struct rpc_task *task);
65 static void	call_transmit(struct rpc_task *task);
66 static void	call_status(struct rpc_task *task);
67 static void	call_transmit_status(struct rpc_task *task);
68 static void	call_refresh(struct rpc_task *task);
69 static void	call_refreshresult(struct rpc_task *task);
70 static void	call_connect(struct rpc_task *task);
71 static void	call_connect_status(struct rpc_task *task);
73 static int	rpc_encode_header(struct rpc_task *task,
75 static int	rpc_decode_header(struct rpc_task *task,
78 static void	rpc_check_timeout(struct rpc_task *task);
1014 void rpc_task_release_transport(struct rpc_task *task)  in rpc_task_release_transport()  argument
1016 	struct rpc_xprt *xprt = task->tk_xprt;  in rpc_task_release_transport()
1019 		task->tk_xprt = NULL;  in rpc_task_release_transport()
1020 		if (task->tk_client)  in rpc_task_release_transport()
1021 			rpc_task_release_xprt(task->tk_client, xprt);  in rpc_task_release_transport()
1028 void rpc_task_release_client(struct rpc_task *task)  in rpc_task_release_client()  argument
1030 	struct rpc_clnt *clnt = task->tk_client;  in rpc_task_release_client()
1032 	rpc_task_release_transport(task);  in rpc_task_release_client()
1034 		/* Remove from client task list */  in rpc_task_release_client()
1036 		list_del(&task->tk_task);  in rpc_task_release_client()
1038 		task->tk_client = NULL;  in rpc_task_release_client()
1062 void rpc_task_set_transport(struct rpc_task *task, struct rpc_clnt *clnt)  in rpc_task_set_transport()  argument
1064 	if (task->tk_xprt)  in rpc_task_set_transport()
1066 	if (task->tk_flags & RPC_TASK_NO_ROUND_ROBIN)  in rpc_task_set_transport()
1067 		task->tk_xprt = rpc_task_get_first_xprt(clnt);  in rpc_task_set_transport()
1069 		task->tk_xprt = rpc_task_get_next_xprt(clnt);  in rpc_task_set_transport()
1073 void rpc_task_set_client(struct rpc_task *task, struct rpc_clnt *clnt)  in rpc_task_set_client()  argument
1077 		rpc_task_set_transport(task, clnt);  in rpc_task_set_client()
1078 		task->tk_client = clnt;  in rpc_task_set_client()
1081 			task->tk_flags |= RPC_TASK_SOFT;  in rpc_task_set_client()
1083 			task->tk_flags |= RPC_TASK_TIMEOUT;  in rpc_task_set_client()
1085 			task->tk_flags |= RPC_TASK_NO_RETRANS_TIMEOUT;  in rpc_task_set_client()
1087 			task->tk_flags |= RPC_TASK_SWAPPER;  in rpc_task_set_client()
1090 		list_add_tail(&task->tk_task, &clnt->cl_tasks);  in rpc_task_set_client()
1096 rpc_task_set_rpc_message(struct rpc_task *task, const struct rpc_message *msg)  in rpc_task_set_rpc_message()  argument
1099 		task->tk_msg.rpc_proc = msg->rpc_proc;  in rpc_task_set_rpc_message()
1100 		task->tk_msg.rpc_argp = msg->rpc_argp;  in rpc_task_set_rpc_message()
1101 		task->tk_msg.rpc_resp = msg->rpc_resp;  in rpc_task_set_rpc_message()
1102 		task->tk_msg.rpc_cred = msg->rpc_cred;  in rpc_task_set_rpc_message()
1103 		if (!(task->tk_flags & RPC_TASK_CRED_NOREF))  in rpc_task_set_rpc_message()
1104 			get_cred(task->tk_msg.rpc_cred);  in rpc_task_set_rpc_message()
1112 rpc_default_callback(struct rpc_task *task, void *data)  in rpc_default_callback()  argument
1121  * rpc_run_task - Allocate a new RPC task, then run rpc_execute against it
1122  * @task_setup_data: pointer to task initialisation data
1126 	struct rpc_task *task;  in rpc_run_task()  local
1128 	task = rpc_new_task(task_setup_data);  in rpc_run_task()
1130 	if (!RPC_IS_ASYNC(task))  in rpc_run_task()
1131 		task->tk_flags |= RPC_TASK_CRED_NOREF;  in rpc_run_task()
1133 	rpc_task_set_client(task, task_setup_data->rpc_client);  in rpc_run_task()
1134 	rpc_task_set_rpc_message(task, task_setup_data->rpc_message);  in rpc_run_task()
1136 	if (task->tk_action == NULL)  in rpc_run_task()
1137 		rpc_call_start(task);  in rpc_run_task()
1139 	atomic_inc(&task->tk_count);  in rpc_run_task()
1140 	rpc_execute(task);  in rpc_run_task()
1141 	return task;  in rpc_run_task()
1153 	struct rpc_task	*task;  in rpc_call_sync()  local
1169 	task = rpc_run_task(&task_setup_data);  in rpc_call_sync()
1170 	if (IS_ERR(task))  in rpc_call_sync()
1171 		return PTR_ERR(task);  in rpc_call_sync()
1172 	status = task->tk_status;  in rpc_call_sync()
1173 	rpc_put_task(task);  in rpc_call_sync()
1190 	struct rpc_task	*task;  in rpc_call_async()  local
1199 	task = rpc_run_task(&task_setup_data);  in rpc_call_async()
1200 	if (IS_ERR(task))  in rpc_call_async()
1201 		return PTR_ERR(task);  in rpc_call_async()
1202 	rpc_put_task(task);  in rpc_call_async()
1208 static void call_bc_encode(struct rpc_task *task);
1211  * rpc_run_bc_task - Allocate a new RPC task for backchannel use, then run
1217 	struct rpc_task *task;  in rpc_run_bc_task()  local
1228 	task = rpc_new_task(&task_setup_data);  in rpc_run_bc_task()
1229 	xprt_init_bc_request(req, task);  in rpc_run_bc_task()
1231 	task->tk_action = call_bc_encode;  in rpc_run_bc_task()
1232 	atomic_inc(&task->tk_count);  in rpc_run_bc_task()
1233 	WARN_ON_ONCE(atomic_read(&task->tk_count) != 2);  in rpc_run_bc_task()
1234 	rpc_execute(task);  in rpc_run_bc_task()
1236 	dprintk("RPC: rpc_run_bc_task: task= %p\n", task);  in rpc_run_bc_task()
1237 	return task;  in rpc_run_bc_task()
1265 rpc_call_start(struct rpc_task *task)  in rpc_call_start()  argument
1267 	task->tk_action = call_start;  in rpc_call_start()
1565 __rpc_restart_call(struct rpc_task *task, void (*action)(struct rpc_task *))  in __rpc_restart_call()  argument
1567 	task->tk_status = 0;  in __rpc_restart_call()
1568 	task->tk_rpc_status = 0;  in __rpc_restart_call()
1569 	task->tk_action = action;  in __rpc_restart_call()
1578 rpc_restart_call(struct rpc_task *task)  in rpc_restart_call()  argument
1580 	return __rpc_restart_call(task, call_start);  in rpc_restart_call()
1589 rpc_restart_call_prepare(struct rpc_task *task)  in rpc_restart_call_prepare()  argument
1591 	if (task->tk_ops->rpc_call_prepare != NULL)  in rpc_restart_call_prepare()
1592 		return __rpc_restart_call(task, rpc_prepare_task);  in rpc_restart_call_prepare()
1593 	return rpc_restart_call(task);  in rpc_restart_call_prepare()
1598 *rpc_proc_name(const struct rpc_task *task)  in rpc_proc_name()  argument
1600 	const struct rpc_procinfo *proc = task->tk_msg.rpc_proc;  in rpc_proc_name()
1612 __rpc_call_rpcerror(struct rpc_task *task, int tk_status, int rpc_status)  in __rpc_call_rpcerror()  argument
1614 	trace_rpc_call_rpcerror(task, tk_status, rpc_status);  in __rpc_call_rpcerror()
1615 	task->tk_rpc_status = rpc_status;  in __rpc_call_rpcerror()
1616 	rpc_exit(task, tk_status);  in __rpc_call_rpcerror()
1620 rpc_call_rpcerror(struct rpc_task *task, int status)  in rpc_call_rpcerror()  argument
1622 	__rpc_call_rpcerror(task, status, status);  in rpc_call_rpcerror()
1632 call_start(struct rpc_task *task)  in call_start()  argument
1634 	struct rpc_clnt	*clnt = task->tk_client;  in call_start()
1635 	int idx = task->tk_msg.rpc_proc->p_statidx;  in call_start()
1637 	trace_rpc_request(task);  in call_start()
1643 	task->tk_action = call_reserve;  in call_start()
1644 	rpc_task_set_transport(task, clnt);  in call_start()
1651 call_reserve(struct rpc_task *task)  in call_reserve()  argument
1653 	task->tk_status  = 0;  in call_reserve()
1654 	task->tk_action  = call_reserveresult;  in call_reserve()
1655 	xprt_reserve(task);  in call_reserve()
1658 static void call_retry_reserve(struct rpc_task *task);
1664 call_reserveresult(struct rpc_task *task)  in call_reserveresult()  argument
1666 	int status = task->tk_status;  in call_reserveresult()
1672 	task->tk_status = 0;  in call_reserveresult()
1674 		if (task->tk_rqstp) {  in call_reserveresult()
1675 			task->tk_action = call_refresh;  in call_reserveresult()
1679 		rpc_call_rpcerror(task, -EIO);  in call_reserveresult()
1687 	if (task->tk_rqstp)  in call_reserveresult()
1688 		xprt_release(task);  in call_reserveresult()
1692 		rpc_delay(task, HZ >> 2);  in call_reserveresult()
1695 		task->tk_action = call_retry_reserve;  in call_reserveresult()
1698 		rpc_call_rpcerror(task, status);  in call_reserveresult()
1706 call_retry_reserve(struct rpc_task *task)  in call_retry_reserve()  argument
1708 	task->tk_status  = 0;  in call_retry_reserve()
1709 	task->tk_action  = call_reserveresult;  in call_retry_reserve()
1710 	xprt_retry_reserve(task);  in call_retry_reserve()
1717 call_refresh(struct rpc_task *task)  in call_refresh()  argument
1719 	task->tk_action = call_refreshresult;  in call_refresh()
1720 	task->tk_status = 0;  in call_refresh()
1721 	task->tk_client->cl_stats->rpcauthrefresh++;  in call_refresh()
1722 	rpcauth_refreshcred(task);  in call_refresh()
1729 call_refreshresult(struct rpc_task *task)  in call_refreshresult()  argument
1731 	int status = task->tk_status;  in call_refreshresult()
1733 	task->tk_status = 0;  in call_refreshresult()
1734 	task->tk_action = call_refresh;  in call_refreshresult()
1737 		if (rpcauth_uptodatecred(task)) {  in call_refreshresult()
1738 			task->tk_action = call_allocate;  in call_refreshresult()
1746 		rpc_delay(task, 3*HZ);  in call_refreshresult()
1752 		if (!task->tk_cred_retry)  in call_refreshresult()
1754 		task->tk_cred_retry--;  in call_refreshresult()
1755 		trace_rpc_retry_refresh_status(task);  in call_refreshresult()
1758 	trace_rpc_refresh_status(task);  in call_refreshresult()
1759 	rpc_call_rpcerror(task, status);  in call_refreshresult()
1767 call_allocate(struct rpc_task *task)  in call_allocate()  argument
1769 	const struct rpc_auth *auth = task->tk_rqstp->rq_cred->cr_auth;  in call_allocate()
1770 	struct rpc_rqst *req = task->tk_rqstp;  in call_allocate()
1772 	const struct rpc_procinfo *proc = task->tk_msg.rpc_proc;  in call_allocate()
1775 	task->tk_status = 0;  in call_allocate()
1776 	task->tk_action = call_encode;  in call_allocate()
1803 	status = xprt->ops->buf_alloc(task);  in call_allocate()
1804 	trace_rpc_buf_alloc(task, status);  in call_allocate()
1809 		rpc_call_rpcerror(task, status);  in call_allocate()
1813 	if (RPC_IS_ASYNC(task) || !fatal_signal_pending(current)) {  in call_allocate()
1814 		task->tk_action = call_allocate;  in call_allocate()
1815 		rpc_delay(task, HZ>>4);  in call_allocate()
1819 	rpc_call_rpcerror(task, -ERESTARTSYS);  in call_allocate()
1823 rpc_task_need_encode(struct rpc_task *task)  in rpc_task_need_encode()  argument
1825 	return test_bit(RPC_TASK_NEED_XMIT, &task->tk_runstate) == 0 &&  in rpc_task_need_encode()
1826 		(!(task->tk_flags & RPC_TASK_SENT) ||  in rpc_task_need_encode()
1827 		 !(task->tk_flags & RPC_TASK_NO_RETRANS_TIMEOUT) ||  in rpc_task_need_encode()
1828 		 xprt_request_need_retransmit(task));  in rpc_task_need_encode()
1832 rpc_xdr_encode(struct rpc_task *task)  in rpc_xdr_encode()  argument
1834 	struct rpc_rqst	*req = task->tk_rqstp;  in rpc_xdr_encode()
1849 	if (rpc_encode_header(task, &xdr))  in rpc_xdr_encode()
1852 	task->tk_status = rpcauth_wrap_req(task, &xdr);  in rpc_xdr_encode()
1859 call_encode(struct rpc_task *task)  in call_encode()  argument
1861 	if (!rpc_task_need_encode(task))  in call_encode()
1864 	/* Dequeue task from the receive queue while we're encoding */  in call_encode()
1865 	xprt_request_dequeue_xprt(task);  in call_encode()
1867 	rpc_xdr_encode(task);  in call_encode()
1869 	if (task->tk_status != 0) {  in call_encode()
1871 		switch (task->tk_status) {  in call_encode()
1874 			rpc_delay(task, HZ >> 4);  in call_encode()
1877 			if (!task->tk_cred_retry) {  in call_encode()
1878 				rpc_exit(task, task->tk_status);  in call_encode()
1880 				task->tk_action = call_refresh;  in call_encode()
1881 				task->tk_cred_retry--;  in call_encode()
1882 				trace_rpc_retry_refresh_status(task);  in call_encode()
1886 			rpc_call_rpcerror(task, task->tk_status);  in call_encode()
1891 	/* Add task to reply queue before transmission to avoid races */  in call_encode()
1892 	if (rpc_reply_expected(task))  in call_encode()
1893 		xprt_request_enqueue_receive(task);  in call_encode()
1894 	xprt_request_enqueue_transmit(task);  in call_encode()
1896 	task->tk_action = call_transmit;  in call_encode()
1898 	if (!xprt_bound(task->tk_xprt))  in call_encode()
1899 		task->tk_action = call_bind;  in call_encode()
1900 	else if (!xprt_connected(task->tk_xprt))  in call_encode()
1901 		task->tk_action = call_connect;  in call_encode()
1905  * Helpers to check if the task was already transmitted, and
1909 rpc_task_transmitted(struct rpc_task *task)  in rpc_task_transmitted()  argument
1911 	return !test_bit(RPC_TASK_NEED_XMIT, &task->tk_runstate);  in rpc_task_transmitted()
1915 rpc_task_handle_transmitted(struct rpc_task *task)  in rpc_task_handle_transmitted()  argument
1917 	xprt_end_transmit(task);  in rpc_task_handle_transmitted()
1918 	task->tk_action = call_transmit_status;  in rpc_task_handle_transmitted()
1925 call_bind(struct rpc_task *task)  in call_bind()  argument
1927 	struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt;  in call_bind()
1929 	if (rpc_task_transmitted(task)) {  in call_bind()
1930 		rpc_task_handle_transmitted(task);  in call_bind()
1935 		task->tk_action = call_connect;  in call_bind()
1939 	task->tk_action = call_bind_status;  in call_bind()
1940 	if (!xprt_prepare_transmit(task))  in call_bind()
1943 	xprt->ops->rpcbind(task);  in call_bind()
1950 call_bind_status(struct rpc_task *task)  in call_bind_status()  argument
1952 	struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt;  in call_bind_status()
1955 	if (rpc_task_transmitted(task)) {  in call_bind_status()
1956 		rpc_task_handle_transmitted(task);  in call_bind_status()
1960 	if (task->tk_status >= 0)  in call_bind_status()
1963 		task->tk_status = 0;  in call_bind_status()
1967 	switch (task->tk_status) {  in call_bind_status()
1969 		rpc_delay(task, HZ >> 2);  in call_bind_status()
1972 		trace_rpcb_prog_unavail_err(task);  in call_bind_status()
1974 		if (task->tk_msg.rpc_proc->p_proc == 0) {  in call_bind_status()
1978 		if (task->tk_rebind_retry == 0)  in call_bind_status()
1980 		task->tk_rebind_retry--;  in call_bind_status()
1981 		rpc_delay(task, 3*HZ);  in call_bind_status()
1984 		rpc_delay(task, HZ >> 2);  in call_bind_status()
1989 		trace_rpcb_timeout_err(task);  in call_bind_status()
1993 		trace_rpcb_bind_version_err(task);  in call_bind_status()
1996 		trace_rpcb_bind_version_err(task);  in call_bind_status()
2007 		trace_rpcb_unreachable_err(task);  in call_bind_status()
2008 		if (!RPC_IS_SOFTCONN(task)) {  in call_bind_status()
2009 			rpc_delay(task, 5*HZ);  in call_bind_status()
2012 		status = task->tk_status;  in call_bind_status()
2015 		trace_rpcb_unrecognized_err(task);  in call_bind_status()
2018 	rpc_call_rpcerror(task, status);  in call_bind_status()
2021 	task->tk_action = call_connect;  in call_bind_status()
2024 	task->tk_status = 0;  in call_bind_status()
2025 	task->tk_action = call_bind;  in call_bind_status()
2026 	rpc_check_timeout(task);  in call_bind_status()
2033 call_connect(struct rpc_task *task)  in call_connect()  argument
2035 	struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt;  in call_connect()
2037 	if (rpc_task_transmitted(task)) {  in call_connect()
2038 		rpc_task_handle_transmitted(task);  in call_connect()
2043 		task->tk_action = call_transmit;  in call_connect()
2047 	task->tk_action = call_connect_status;  in call_connect()
2048 	if (task->tk_status < 0)  in call_connect()
2050 	if (task->tk_flags & RPC_TASK_NOCONNECT) {  in call_connect()
2051 		rpc_call_rpcerror(task, -ENOTCONN);  in call_connect()
2054 	if (!xprt_prepare_transmit(task))  in call_connect()
2056 	xprt_connect(task);  in call_connect()
2063 call_connect_status(struct rpc_task *task)  in call_connect_status()  argument
2065 	struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt;  in call_connect_status()
2066 	struct rpc_clnt *clnt = task->tk_client;  in call_connect_status()
2067 	int status = task->tk_status;  in call_connect_status()
2069 	if (rpc_task_transmitted(task)) {  in call_connect_status()
2070 		rpc_task_handle_transmitted(task);  in call_connect_status()
2074 	trace_rpc_connect_status(task);  in call_connect_status()
2076 	if (task->tk_status == 0) {  in call_connect_status()
2081 		task->tk_status = 0;  in call_connect_status()
2085 	task->tk_status = 0;  in call_connect_status()
2089 		if (RPC_IS_SOFTCONN(task))  in call_connect_status()
2103 		xprt_conditional_disconnect(task->tk_rqstp->rq_xprt,  in call_connect_status()
2104 					    task->tk_rqstp->rq_connect_cookie);  in call_connect_status()
2105 		if (RPC_IS_SOFTCONN(task))  in call_connect_status()
2108 		rpc_delay(task, 3*HZ);  in call_connect_status()
2116 		rpc_delay(task, HZ >> 2);  in call_connect_status()
2119 	rpc_call_rpcerror(task, status);  in call_connect_status()
2122 	task->tk_action = call_transmit;  in call_connect_status()
2126 	task->tk_action = call_bind;  in call_connect_status()
2127 	rpc_check_timeout(task);  in call_connect_status()
2134 call_transmit(struct rpc_task *task)  in call_transmit()  argument
2136 	if (rpc_task_transmitted(task)) {  in call_transmit()
2137 		rpc_task_handle_transmitted(task);  in call_transmit()
2141 	task->tk_action = call_transmit_status;  in call_transmit()
2142 	if (!xprt_prepare_transmit(task))  in call_transmit()
2144 	task->tk_status = 0;  in call_transmit()
2145 	if (test_bit(RPC_TASK_NEED_XMIT, &task->tk_runstate)) {  in call_transmit()
2146 		if (!xprt_connected(task->tk_xprt)) {  in call_transmit()
2147 			task->tk_status = -ENOTCONN;  in call_transmit()
2150 		xprt_transmit(task);  in call_transmit()
2152 	xprt_end_transmit(task);  in call_transmit()
2159 call_transmit_status(struct rpc_task *task)  in call_transmit_status()  argument
2161 	task->tk_action = call_status;  in call_transmit_status()
2167 	if (rpc_task_transmitted(task)) {  in call_transmit_status()
2168 		task->tk_status = 0;  in call_transmit_status()
2169 		xprt_request_wait_receive(task);  in call_transmit_status()
2173 	switch (task->tk_status) {  in call_transmit_status()
2177 		task->tk_status = 0;  in call_transmit_status()
2178 		task->tk_action = call_encode;  in call_transmit_status()
2187 		rpc_delay(task, HZ>>2);  in call_transmit_status()
2191 		task->tk_action = call_transmit;  in call_transmit_status()
2192 		task->tk_status = 0;  in call_transmit_status()
2200 		if (RPC_IS_SOFTCONN(task)) {  in call_transmit_status()
2201 			if (!task->tk_msg.rpc_proc->p_proc)  in call_transmit_status()
2202 				trace_xprt_ping(task->tk_xprt,  in call_transmit_status()
2203 						task->tk_status);  in call_transmit_status()
2204 			rpc_call_rpcerror(task, task->tk_status);  in call_transmit_status()
2213 		task->tk_action = call_bind;  in call_transmit_status()
2214 		task->tk_status = 0;  in call_transmit_status()
2217 	rpc_check_timeout(task);  in call_transmit_status()
2221 static void call_bc_transmit(struct rpc_task *task);
2222 static void call_bc_transmit_status(struct rpc_task *task);
2225 call_bc_encode(struct rpc_task *task)  in call_bc_encode()  argument
2227 	xprt_request_enqueue_transmit(task);  in call_bc_encode()
2228 	task->tk_action = call_bc_transmit;  in call_bc_encode()
2236 call_bc_transmit(struct rpc_task *task)  in call_bc_transmit()  argument
2238 	task->tk_action = call_bc_transmit_status;  in call_bc_transmit()
2239 	if (test_bit(RPC_TASK_NEED_XMIT, &task->tk_runstate)) {  in call_bc_transmit()
2240 		if (!xprt_prepare_transmit(task))  in call_bc_transmit()
2242 		task->tk_status = 0;  in call_bc_transmit()
2243 		xprt_transmit(task);  in call_bc_transmit()
2245 	xprt_end_transmit(task);  in call_bc_transmit()
2249 call_bc_transmit_status(struct rpc_task *task)  in call_bc_transmit_status()  argument
2251 	struct rpc_rqst *req = task->tk_rqstp;  in call_bc_transmit_status()
2253 	if (rpc_task_transmitted(task))  in call_bc_transmit_status()
2254 		task->tk_status = 0;  in call_bc_transmit_status()
2256 	switch (task->tk_status) {  in call_bc_transmit_status()
2270 		rpc_delay(task, HZ>>2);  in call_bc_transmit_status()
2274 		task->tk_status = 0;  in call_bc_transmit_status()
2275 		task->tk_action = call_bc_transmit;  in call_bc_transmit_status()
2286 			"error: %d\n", task->tk_status);  in call_bc_transmit_status()
2296 			"error: %d\n", task->tk_status);  in call_bc_transmit_status()
2299 	task->tk_action = rpc_exit_task;  in call_bc_transmit_status()
2307 call_status(struct rpc_task *task)  in call_status()  argument
2309 	struct rpc_clnt	*clnt = task->tk_client;  in call_status()
2312 	if (!task->tk_msg.rpc_proc->p_proc)  in call_status()
2313 		trace_xprt_ping(task->tk_xprt, task->tk_status);  in call_status()
2315 	status = task->tk_status;  in call_status()
2317 		task->tk_action = call_decode;  in call_status()
2321 	trace_rpc_call_status(task);  in call_status()
2322 	task->tk_status = 0;  in call_status()
2329 		if (RPC_IS_SOFTCONN(task))  in call_status()
2335 		rpc_delay(task, 3*HZ);  in call_status()
2346 		rpc_delay(task, 3*HZ);  in call_status()
2360 	task->tk_action = call_encode;  in call_status()
2362 		rpc_check_timeout(task);  in call_status()
2365 	rpc_call_rpcerror(task, status);  in call_status()
2378 rpc_check_timeout(struct rpc_task *task)  in rpc_check_timeout()  argument
2380 	struct rpc_clnt	*clnt = task->tk_client;  in rpc_check_timeout()
2382 	if (RPC_SIGNALLED(task)) {  in rpc_check_timeout()
2383 		rpc_call_rpcerror(task, -ERESTARTSYS);  in rpc_check_timeout()
2387 	if (xprt_adjust_timeout(task->tk_rqstp) == 0)  in rpc_check_timeout()
2390 	trace_rpc_timeout_status(task);  in rpc_check_timeout()
2391 	task->tk_timeouts++;  in rpc_check_timeout()
2393 	if (RPC_IS_SOFTCONN(task) && !rpc_check_connected(task->tk_rqstp)) {  in rpc_check_timeout()
2394 		rpc_call_rpcerror(task, -ETIMEDOUT);  in rpc_check_timeout()
2398 	if (RPC_IS_SOFT(task)) {  in rpc_check_timeout()
2404 		if ((task->tk_flags & RPC_TASK_NO_RETRANS_TIMEOUT) &&  in rpc_check_timeout()
2405 		    rpc_check_connected(task->tk_rqstp))  in rpc_check_timeout()
2412 				task->tk_xprt->servername);  in rpc_check_timeout()
2414 		if (task->tk_flags & RPC_TASK_TIMEOUT)  in rpc_check_timeout()
2415 			rpc_call_rpcerror(task, -ETIMEDOUT);  in rpc_check_timeout()
2417 			__rpc_call_rpcerror(task, -EIO, -ETIMEDOUT);  in rpc_check_timeout()
2421 	if (!(task->tk_flags & RPC_CALL_MAJORSEEN)) {  in rpc_check_timeout()
2422 		task->tk_flags |= RPC_CALL_MAJORSEEN;  in rpc_check_timeout()
2427 				task->tk_xprt->servername);  in rpc_check_timeout()
2435 	rpcauth_invalcred(task);  in rpc_check_timeout()
2442 call_decode(struct rpc_task *task)  in call_decode()  argument
2444 	struct rpc_clnt	*clnt = task->tk_client;  in call_decode()
2445 	struct rpc_rqst	*req = task->tk_rqstp;  in call_decode()
2449 	if (!task->tk_msg.rpc_proc->p_decode) {  in call_decode()
2450 		task->tk_action = rpc_exit_task;  in call_decode()
2454 	if (task->tk_flags & RPC_CALL_MAJORSEEN) {  in call_decode()
2458 				task->tk_xprt->servername);  in call_decode()
2460 		task->tk_flags &= ~RPC_CALL_MAJORSEEN;  in call_decode()
2478 	trace_rpc_xdr_recvfrom(task, &req->rq_rcv_buf);  in call_decode()
2486 	err = rpc_decode_header(task, &xdr);  in call_decode()
2490 		task->tk_action = rpc_exit_task;  in call_decode()
2491 		task->tk_status = rpcauth_unwrap_resp(task, &xdr);  in call_decode()
2494 		task->tk_status = 0;  in call_decode()
2495 		if (task->tk_client->cl_discrtry)  in call_decode()
2498 		task->tk_action = call_encode;  in call_decode()
2499 		rpc_check_timeout(task);  in call_decode()
2502 		task->tk_action = call_reserve;  in call_decode()
2503 		rpc_check_timeout(task);  in call_decode()
2504 		rpcauth_invalcred(task);  in call_decode()
2506 		xprt_release(task);  in call_decode()
2511 rpc_encode_header(struct rpc_task *task, struct xdr_stream *xdr)  in rpc_encode_header()  argument
2513 	struct rpc_clnt *clnt = task->tk_client;  in rpc_encode_header()
2514 	struct rpc_rqst	*req = task->tk_rqstp;  in rpc_encode_header()
2527 	*p   = cpu_to_be32(task->tk_msg.rpc_proc->p_proc);  in rpc_encode_header()
2529 	error = rpcauth_marshcred(task, xdr);  in rpc_encode_header()
2534 	trace_rpc_bad_callhdr(task);  in rpc_encode_header()
2535 	rpc_call_rpcerror(task, error);  in rpc_encode_header()
2540 rpc_decode_header(struct rpc_task *task, struct xdr_stream *xdr)  in rpc_decode_header()  argument
2542 	struct rpc_clnt *clnt = task->tk_client;  in rpc_decode_header()
2551 	if (task->tk_rqstp->rq_rcv_buf.len & 3)  in rpc_decode_header()
2563 	error = rpcauth_checkverf(task, xdr);  in rpc_decode_header()
2574 		trace_rpc__prog_unavail(task);  in rpc_decode_header()
2578 		trace_rpc__prog_mismatch(task);  in rpc_decode_header()
2582 		trace_rpc__proc_unavail(task);  in rpc_decode_header()
2587 		trace_rpc__garbage_args(task);  in rpc_decode_header()
2596 	if (task->tk_garb_retry) {  in rpc_decode_header()
2597 		task->tk_garb_retry--;  in rpc_decode_header()
2598 		task->tk_action = call_encode;  in rpc_decode_header()
2602 	rpc_call_rpcerror(task, error);  in rpc_decode_header()
2606 	trace_rpc__unparsable(task);  in rpc_decode_header()
2611 	trace_rpc_bad_verifier(task);  in rpc_decode_header()
2623 		trace_rpc__mismatch(task);  in rpc_decode_header()
2638 		if (!task->tk_cred_retry)  in rpc_decode_header()
2640 		task->tk_cred_retry--;  in rpc_decode_header()
2641 		trace_rpc__stale_creds(task);  in rpc_decode_header()
2646 		if (!task->tk_garb_retry)  in rpc_decode_header()
2648 		task->tk_garb_retry--;  in rpc_decode_header()
2649 		trace_rpc__bad_creds(task);  in rpc_decode_header()
2650 		task->tk_action = call_encode;  in rpc_decode_header()
2653 		trace_rpc__auth_tooweak(task);  in rpc_decode_header()
2655 			task->tk_xprt->servername);  in rpc_decode_header()
2723 static void rpc_cb_add_xprt_done(struct rpc_task *task, void *calldata)  in rpc_cb_add_xprt_done()  argument
2727 	if (task->tk_status == 0)  in rpc_cb_add_xprt_done()
2757 	struct rpc_task *task;  in rpc_clnt_test_and_add_xprt()  local
2769 	task = rpc_call_null_helper(clnt, xprt, NULL, RPC_TASK_ASYNC,  in rpc_clnt_test_and_add_xprt()
2772 	rpc_put_task(task);  in rpc_clnt_test_and_add_xprt()
2801 	struct rpc_task *task;  in rpc_clnt_setup_test_and_add_xprt()  local
2812 	task = rpc_call_null_helper(clnt, xprt, NULL, 0, NULL, NULL);  in rpc_clnt_setup_test_and_add_xprt()
2813 	if (IS_ERR(task)) {  in rpc_clnt_setup_test_and_add_xprt()
2814 		status = PTR_ERR(task);  in rpc_clnt_setup_test_and_add_xprt()
2817 	status = task->tk_status;  in rpc_clnt_setup_test_and_add_xprt()
2818 	rpc_put_task(task);  in rpc_clnt_setup_test_and_add_xprt()
2982 			  const struct rpc_task *task)  in rpc_show_task()  argument
2986 	if (RPC_IS_QUEUED(task))  in rpc_show_task()
2987 		rpc_waitq = rpc_qname(task->tk_waitqueue);  in rpc_show_task()
2990 		task->tk_pid, task->tk_flags, task->tk_status,  in rpc_show_task()
2991 		clnt, task->tk_rqstp, rpc_task_timeout(task), task->tk_ops,  in rpc_show_task()
2992 		clnt->cl_program->name, clnt->cl_vers, rpc_proc_name(task),  in rpc_show_task()
2993 		task->tk_action, rpc_waitq);  in rpc_show_task()
2999 	struct rpc_task *task;  in rpc_show_tasks()  local
3006 		list_for_each_entry(task, &clnt->cl_tasks, tk_task) {  in rpc_show_tasks()
3011 			rpc_show_task(clnt, task);  in rpc_show_tasks()