58 static void	call_start(struct rpc_task *task);
59 static void	call_reserve(struct rpc_task *task);
60 static void	call_reserveresult(struct rpc_task *task);
61 static void	call_allocate(struct rpc_task *task);
62 static void	call_encode(struct rpc_task *task);
63 static void	call_decode(struct rpc_task *task);
64 static void	call_bind(struct rpc_task *task);
65 static void	call_bind_status(struct rpc_task *task);
66 static void	call_transmit(struct rpc_task *task);
67 static void	call_status(struct rpc_task *task);
68 static void	call_transmit_status(struct rpc_task *task);
69 static void	call_refresh(struct rpc_task *task);
70 static void	call_refreshresult(struct rpc_task *task);
71 static void	call_connect(struct rpc_task *task);
72 static void	call_connect_status(struct rpc_task *task);
74 static int	rpc_encode_header(struct rpc_task *task,
76 static int	rpc_decode_header(struct rpc_task *task,
80 static void	rpc_check_timeout(struct rpc_task *task);
890  * @error: RPC task error value to set
902 	struct rpc_task *task;  in rpc_cancel_tasks()  local
911 	list_for_each_entry(task, &clnt->cl_tasks, tk_task) {  in rpc_cancel_tasks()
912 		if (!RPC_IS_ACTIVATED(task))  in rpc_cancel_tasks()
914 		if (!fnmatch(task, data))  in rpc_cancel_tasks()
916 		rpc_task_try_cancel(task, error);  in rpc_cancel_tasks()
1104 void rpc_task_release_transport(struct rpc_task *task)  in rpc_task_release_transport()  argument
1106 	struct rpc_xprt *xprt = task->tk_xprt;  in rpc_task_release_transport()
1109 		task->tk_xprt = NULL;  in rpc_task_release_transport()
1110 		if (task->tk_client)  in rpc_task_release_transport()
1111 			rpc_task_release_xprt(task->tk_client, xprt);  in rpc_task_release_transport()
1118 void rpc_task_release_client(struct rpc_task *task)  in rpc_task_release_client()  argument
1120 	struct rpc_clnt *clnt = task->tk_client;  in rpc_task_release_client()
1122 	rpc_task_release_transport(task);  in rpc_task_release_client()
1124 		/* Remove from client task list */  in rpc_task_release_client()
1126 		list_del(&task->tk_task);  in rpc_task_release_client()
1128 		task->tk_client = NULL;  in rpc_task_release_client()
1152 void rpc_task_set_transport(struct rpc_task *task, struct rpc_clnt *clnt)  in rpc_task_set_transport()  argument
1154 	if (task->tk_xprt) {  in rpc_task_set_transport()
1155 		if (!(test_bit(XPRT_OFFLINE, &task->tk_xprt->state) &&  in rpc_task_set_transport()
1156 		      (task->tk_flags & RPC_TASK_MOVEABLE)))  in rpc_task_set_transport()
1158 		xprt_release(task);  in rpc_task_set_transport()
1159 		xprt_put(task->tk_xprt);  in rpc_task_set_transport()
1161 	if (task->tk_flags & RPC_TASK_NO_ROUND_ROBIN)  in rpc_task_set_transport()
1162 		task->tk_xprt = rpc_task_get_first_xprt(clnt);  in rpc_task_set_transport()
1164 		task->tk_xprt = rpc_task_get_next_xprt(clnt);  in rpc_task_set_transport()
1168 void rpc_task_set_client(struct rpc_task *task, struct rpc_clnt *clnt)  in rpc_task_set_client()  argument
1170 	rpc_task_set_transport(task, clnt);  in rpc_task_set_client()
1171 	task->tk_client = clnt;  in rpc_task_set_client()
1174 		task->tk_flags |= RPC_TASK_SOFT;  in rpc_task_set_client()
1176 		task->tk_flags |= RPC_TASK_TIMEOUT;  in rpc_task_set_client()
1178 		task->tk_flags |= RPC_TASK_NO_RETRANS_TIMEOUT;  in rpc_task_set_client()
1181 	list_add_tail(&task->tk_task, &clnt->cl_tasks);  in rpc_task_set_client()
1186 rpc_task_set_rpc_message(struct rpc_task *task, const struct rpc_message *msg)  in rpc_task_set_rpc_message()  argument
1189 		task->tk_msg.rpc_proc = msg->rpc_proc;  in rpc_task_set_rpc_message()
1190 		task->tk_msg.rpc_argp = msg->rpc_argp;  in rpc_task_set_rpc_message()
1191 		task->tk_msg.rpc_resp = msg->rpc_resp;  in rpc_task_set_rpc_message()
1192 		task->tk_msg.rpc_cred = msg->rpc_cred;  in rpc_task_set_rpc_message()
1193 		if (!(task->tk_flags & RPC_TASK_CRED_NOREF))  in rpc_task_set_rpc_message()
1194 			get_cred(task->tk_msg.rpc_cred);  in rpc_task_set_rpc_message()
1202 rpc_default_callback(struct rpc_task *task, void *data)  in rpc_default_callback()  argument
1211  * rpc_run_task - Allocate a new RPC task, then run rpc_execute against it
1212  * @task_setup_data: pointer to task initialisation data
1216 	struct rpc_task *task;  in rpc_run_task()  local
1218 	task = rpc_new_task(task_setup_data);  in rpc_run_task()
1219 	if (IS_ERR(task))  in rpc_run_task()
1220 		return task;  in rpc_run_task()
1222 	if (!RPC_IS_ASYNC(task))  in rpc_run_task()
1223 		task->tk_flags |= RPC_TASK_CRED_NOREF;  in rpc_run_task()
1225 	rpc_task_set_client(task, task_setup_data->rpc_client);  in rpc_run_task()
1226 	rpc_task_set_rpc_message(task, task_setup_data->rpc_message);  in rpc_run_task()
1228 	if (task->tk_action == NULL)  in rpc_run_task()
1229 		rpc_call_start(task);  in rpc_run_task()
1231 	atomic_inc(&task->tk_count);  in rpc_run_task()
1232 	rpc_execute(task);  in rpc_run_task()
1233 	return task;  in rpc_run_task()
1245 	struct rpc_task	*task;  in rpc_call_sync()  local
1261 	task = rpc_run_task(&task_setup_data);  in rpc_call_sync()
1262 	if (IS_ERR(task))  in rpc_call_sync()
1263 		return PTR_ERR(task);  in rpc_call_sync()
1264 	status = task->tk_status;  in rpc_call_sync()
1265 	rpc_put_task(task);  in rpc_call_sync()
1282 	struct rpc_task	*task;  in rpc_call_async()  local
1291 	task = rpc_run_task(&task_setup_data);  in rpc_call_async()
1292 	if (IS_ERR(task))  in rpc_call_async()
1293 		return PTR_ERR(task);  in rpc_call_async()
1294 	rpc_put_task(task);  in rpc_call_async()
1300 static void call_bc_encode(struct rpc_task *task);
1303  * rpc_run_bc_task - Allocate a new RPC task for backchannel use, then run
1309 	struct rpc_task *task;  in rpc_run_bc_task()  local
1320 	task = rpc_new_task(&task_setup_data);  in rpc_run_bc_task()
1321 	if (IS_ERR(task)) {  in rpc_run_bc_task()
1323 		return task;  in rpc_run_bc_task()
1326 	xprt_init_bc_request(req, task);  in rpc_run_bc_task()
1328 	task->tk_action = call_bc_encode;  in rpc_run_bc_task()
1329 	atomic_inc(&task->tk_count);  in rpc_run_bc_task()
1330 	WARN_ON_ONCE(atomic_read(&task->tk_count) != 2);  in rpc_run_bc_task()
1331 	rpc_execute(task);  in rpc_run_bc_task()
1333 	dprintk("RPC: rpc_run_bc_task: task= %p\n", task);  in rpc_run_bc_task()
1334 	return task;  in rpc_run_bc_task()
1359 rpc_call_start(struct rpc_task *task)  in rpc_call_start()  argument
1361 	task->tk_action = call_start;  in rpc_call_start()
1659 __rpc_restart_call(struct rpc_task *task, void (*action)(struct rpc_task *))  in __rpc_restart_call()  argument
1661 	task->tk_status = 0;  in __rpc_restart_call()
1662 	task->tk_rpc_status = 0;  in __rpc_restart_call()
1663 	task->tk_action = action;  in __rpc_restart_call()
1672 rpc_restart_call(struct rpc_task *task)  in rpc_restart_call()  argument
1674 	return __rpc_restart_call(task, call_start);  in rpc_restart_call()
1683 rpc_restart_call_prepare(struct rpc_task *task)  in rpc_restart_call_prepare()  argument
1685 	if (task->tk_ops->rpc_call_prepare != NULL)  in rpc_restart_call_prepare()
1686 		return __rpc_restart_call(task, rpc_prepare_task);  in rpc_restart_call_prepare()
1687 	return rpc_restart_call(task);  in rpc_restart_call_prepare()
1692 *rpc_proc_name(const struct rpc_task *task)  in rpc_proc_name()  argument
1694 	const struct rpc_procinfo *proc = task->tk_msg.rpc_proc;  in rpc_proc_name()
1706 __rpc_call_rpcerror(struct rpc_task *task, int tk_status, int rpc_status)  in __rpc_call_rpcerror()  argument
1708 	trace_rpc_call_rpcerror(task, tk_status, rpc_status);  in __rpc_call_rpcerror()
1709 	rpc_task_set_rpc_status(task, rpc_status);  in __rpc_call_rpcerror()
1710 	rpc_exit(task, tk_status);  in __rpc_call_rpcerror()
1714 rpc_call_rpcerror(struct rpc_task *task, int status)  in rpc_call_rpcerror()  argument
1716 	__rpc_call_rpcerror(task, status, status);  in rpc_call_rpcerror()
1726 call_start(struct rpc_task *task)  in call_start()  argument
1728 	struct rpc_clnt	*clnt = task->tk_client;  in call_start()
1729 	int idx = task->tk_msg.rpc_proc->p_statidx;  in call_start()
1731 	trace_rpc_request(task);  in call_start()
1733 	if (task->tk_client->cl_shutdown) {  in call_start()
1734 		rpc_call_rpcerror(task, -EIO);  in call_start()
1742 	task->tk_action = call_reserve;  in call_start()
1743 	rpc_task_set_transport(task, clnt);  in call_start()
1750 call_reserve(struct rpc_task *task)  in call_reserve()  argument
1752 	task->tk_status  = 0;  in call_reserve()
1753 	task->tk_action  = call_reserveresult;  in call_reserve()
1754 	xprt_reserve(task);  in call_reserve()
1757 static void call_retry_reserve(struct rpc_task *task);
1763 call_reserveresult(struct rpc_task *task)  in call_reserveresult()  argument
1765 	int status = task->tk_status;  in call_reserveresult()
1771 	task->tk_status = 0;  in call_reserveresult()
1773 		if (task->tk_rqstp) {  in call_reserveresult()
1774 			task->tk_action = call_refresh;  in call_reserveresult()
1778 		rpc_call_rpcerror(task, -EIO);  in call_reserveresult()
1784 		rpc_delay(task, HZ >> 2);  in call_reserveresult()
1787 		task->tk_action = call_retry_reserve;  in call_reserveresult()
1790 		rpc_call_rpcerror(task, status);  in call_reserveresult()
1798 call_retry_reserve(struct rpc_task *task)  in call_retry_reserve()  argument
1800 	task->tk_status  = 0;  in call_retry_reserve()
1801 	task->tk_action  = call_reserveresult;  in call_retry_reserve()
1802 	xprt_retry_reserve(task);  in call_retry_reserve()
1809 call_refresh(struct rpc_task *task)  in call_refresh()  argument
1811 	task->tk_action = call_refreshresult;  in call_refresh()
1812 	task->tk_status = 0;  in call_refresh()
1813 	task->tk_client->cl_stats->rpcauthrefresh++;  in call_refresh()
1814 	rpcauth_refreshcred(task);  in call_refresh()
1821 call_refreshresult(struct rpc_task *task)  in call_refreshresult()  argument
1823 	int status = task->tk_status;  in call_refreshresult()
1825 	task->tk_status = 0;  in call_refreshresult()
1826 	task->tk_action = call_refresh;  in call_refreshresult()
1829 		if (rpcauth_uptodatecred(task)) {  in call_refreshresult()
1830 			task->tk_action = call_allocate;  in call_refreshresult()
1838 		rpc_delay(task, 3*HZ);  in call_refreshresult()
1844 		if (!task->tk_cred_retry)  in call_refreshresult()
1846 		task->tk_cred_retry--;  in call_refreshresult()
1847 		trace_rpc_retry_refresh_status(task);  in call_refreshresult()
1850 		rpc_delay(task, HZ >> 4);  in call_refreshresult()
1853 	trace_rpc_refresh_status(task);  in call_refreshresult()
1854 	rpc_call_rpcerror(task, status);  in call_refreshresult()
1862 call_allocate(struct rpc_task *task)  in call_allocate()  argument
1864 	const struct rpc_auth *auth = task->tk_rqstp->rq_cred->cr_auth;  in call_allocate()
1865 	struct rpc_rqst *req = task->tk_rqstp;  in call_allocate()
1867 	const struct rpc_procinfo *proc = task->tk_msg.rpc_proc;  in call_allocate()
1870 	task->tk_status = 0;  in call_allocate()
1871 	task->tk_action = call_encode;  in call_allocate()
1898 	status = xprt->ops->buf_alloc(task);  in call_allocate()
1899 	trace_rpc_buf_alloc(task, status);  in call_allocate()
1903 		rpc_call_rpcerror(task, status);  in call_allocate()
1907 	if (RPC_IS_ASYNC(task) || !fatal_signal_pending(current)) {  in call_allocate()
1908 		task->tk_action = call_allocate;  in call_allocate()
1909 		rpc_delay(task, HZ>>4);  in call_allocate()
1913 	rpc_call_rpcerror(task, -ERESTARTSYS);  in call_allocate()
1917 rpc_task_need_encode(struct rpc_task *task)  in rpc_task_need_encode()  argument
1919 	return test_bit(RPC_TASK_NEED_XMIT, &task->tk_runstate) == 0 &&  in rpc_task_need_encode()
1920 		(!(task->tk_flags & RPC_TASK_SENT) ||  in rpc_task_need_encode()
1921 		 !(task->tk_flags & RPC_TASK_NO_RETRANS_TIMEOUT) ||  in rpc_task_need_encode()
1922 		 xprt_request_need_retransmit(task));  in rpc_task_need_encode()
1926 rpc_xdr_encode(struct rpc_task *task)  in rpc_xdr_encode()  argument
1928 	struct rpc_rqst	*req = task->tk_rqstp;  in rpc_xdr_encode()
1942 	if (rpc_encode_header(task, &xdr))  in rpc_xdr_encode()
1945 	task->tk_status = rpcauth_wrap_req(task, &xdr);  in rpc_xdr_encode()
1952 call_encode(struct rpc_task *task)  in call_encode()  argument
1954 	if (!rpc_task_need_encode(task))  in call_encode()
1957 	/* Dequeue task from the receive queue while we're encoding */  in call_encode()
1958 	xprt_request_dequeue_xprt(task);  in call_encode()
1960 	rpc_xdr_encode(task);  in call_encode()
1961 	/* Add task to reply queue before transmission to avoid races */  in call_encode()
1962 	if (task->tk_status == 0 && rpc_reply_expected(task))  in call_encode()
1963 		task->tk_status = xprt_request_enqueue_receive(task);  in call_encode()
1965 	if (task->tk_status != 0) {  in call_encode()
1967 		switch (task->tk_status) {  in call_encode()
1970 			rpc_delay(task, HZ >> 4);  in call_encode()
1973 			if (!task->tk_cred_retry) {  in call_encode()
1974 				rpc_call_rpcerror(task, task->tk_status);  in call_encode()
1976 				task->tk_action = call_refresh;  in call_encode()
1977 				task->tk_cred_retry--;  in call_encode()
1978 				trace_rpc_retry_refresh_status(task);  in call_encode()
1982 			rpc_call_rpcerror(task, task->tk_status);  in call_encode()
1987 	xprt_request_enqueue_transmit(task);  in call_encode()
1989 	task->tk_action = call_transmit;  in call_encode()
1991 	if (!xprt_bound(task->tk_xprt))  in call_encode()
1992 		task->tk_action = call_bind;  in call_encode()
1993 	else if (!xprt_connected(task->tk_xprt))  in call_encode()
1994 		task->tk_action = call_connect;  in call_encode()
1998  * Helpers to check if the task was already transmitted, and
2002 rpc_task_transmitted(struct rpc_task *task)  in rpc_task_transmitted()  argument
2004 	return !test_bit(RPC_TASK_NEED_XMIT, &task->tk_runstate);  in rpc_task_transmitted()
2008 rpc_task_handle_transmitted(struct rpc_task *task)  in rpc_task_handle_transmitted()  argument
2010 	xprt_end_transmit(task);  in rpc_task_handle_transmitted()
2011 	task->tk_action = call_transmit_status;  in rpc_task_handle_transmitted()
2018 call_bind(struct rpc_task *task)  in call_bind()  argument
2020 	struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt;  in call_bind()
2022 	if (rpc_task_transmitted(task)) {  in call_bind()
2023 		rpc_task_handle_transmitted(task);  in call_bind()
2028 		task->tk_action = call_connect;  in call_bind()
2032 	task->tk_action = call_bind_status;  in call_bind()
2033 	if (!xprt_prepare_transmit(task))  in call_bind()
2036 	xprt->ops->rpcbind(task);  in call_bind()
2043 call_bind_status(struct rpc_task *task)  in call_bind_status()  argument
2045 	struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt;  in call_bind_status()
2048 	if (rpc_task_transmitted(task)) {  in call_bind_status()
2049 		rpc_task_handle_transmitted(task);  in call_bind_status()
2053 	if (task->tk_status >= 0)  in call_bind_status()
2056 		task->tk_status = 0;  in call_bind_status()
2060 	switch (task->tk_status) {  in call_bind_status()
2062 		rpc_delay(task, HZ >> 2);  in call_bind_status()
2065 		trace_rpcb_prog_unavail_err(task);  in call_bind_status()
2067 		if (task->tk_msg.rpc_proc->p_proc == 0) {  in call_bind_status()
2071 		rpc_delay(task, 3*HZ);  in call_bind_status()
2074 		rpc_delay(task, HZ >> 2);  in call_bind_status()
2079 		trace_rpcb_timeout_err(task);  in call_bind_status()
2083 		trace_rpcb_bind_version_err(task);  in call_bind_status()
2086 		trace_rpcb_bind_version_err(task);  in call_bind_status()
2097 		trace_rpcb_unreachable_err(task);  in call_bind_status()
2098 		if (!RPC_IS_SOFTCONN(task)) {  in call_bind_status()
2099 			rpc_delay(task, 5*HZ);  in call_bind_status()
2102 		status = task->tk_status;  in call_bind_status()
2105 		trace_rpcb_unrecognized_err(task);  in call_bind_status()
2108 	rpc_call_rpcerror(task, status);  in call_bind_status()
2111 	task->tk_action = call_connect;  in call_bind_status()
2114 	task->tk_status = 0;  in call_bind_status()
2115 	task->tk_action = call_bind;  in call_bind_status()
2116 	rpc_check_timeout(task);  in call_bind_status()
2123 call_connect(struct rpc_task *task)  in call_connect()  argument
2125 	struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt;  in call_connect()
2127 	if (rpc_task_transmitted(task)) {  in call_connect()
2128 		rpc_task_handle_transmitted(task);  in call_connect()
2133 		task->tk_action = call_transmit;  in call_connect()
2137 	task->tk_action = call_connect_status;  in call_connect()
2138 	if (task->tk_status < 0)  in call_connect()
2140 	if (task->tk_flags & RPC_TASK_NOCONNECT) {  in call_connect()
2141 		rpc_call_rpcerror(task, -ENOTCONN);  in call_connect()
2144 	if (!xprt_prepare_transmit(task))  in call_connect()
2146 	xprt_connect(task);  in call_connect()
2153 call_connect_status(struct rpc_task *task)  in call_connect_status()  argument
2155 	struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt;  in call_connect_status()
2156 	struct rpc_clnt *clnt = task->tk_client;  in call_connect_status()
2157 	int status = task->tk_status;  in call_connect_status()
2159 	if (rpc_task_transmitted(task)) {  in call_connect_status()
2160 		rpc_task_handle_transmitted(task);  in call_connect_status()
2164 	trace_rpc_connect_status(task);  in call_connect_status()
2166 	if (task->tk_status == 0) {  in call_connect_status()
2171 		task->tk_status = 0;  in call_connect_status()
2175 	task->tk_status = 0;  in call_connect_status()
2180 		if (RPC_IS_SOFTCONN(task))  in call_connect_status()
2193 		xprt_conditional_disconnect(task->tk_rqstp->rq_xprt,  in call_connect_status()
2194 					    task->tk_rqstp->rq_connect_cookie);  in call_connect_status()
2195 		if (RPC_IS_SOFTCONN(task))  in call_connect_status()
2198 		rpc_delay(task, 3*HZ);  in call_connect_status()
2204 		if (!(task->tk_flags & RPC_TASK_NO_ROUND_ROBIN) &&  in call_connect_status()
2205 		    (task->tk_flags & RPC_TASK_MOVEABLE) &&  in call_connect_status()
2207 			struct rpc_xprt *saved = task->tk_xprt;  in call_connect_status()
2216 				xprt_release(task);  in call_connect_status()
2222 				task->tk_xprt = NULL;  in call_connect_status()
2223 				task->tk_action = call_start;  in call_connect_status()
2226 			if (!task->tk_xprt)  in call_connect_status()
2231 		rpc_delay(task, HZ >> 2);  in call_connect_status()
2234 	rpc_call_rpcerror(task, status);  in call_connect_status()
2237 	task->tk_action = call_transmit;  in call_connect_status()
2241 	task->tk_action = call_bind;  in call_connect_status()
2242 	rpc_check_timeout(task);  in call_connect_status()
2249 call_transmit(struct rpc_task *task)  in call_transmit()  argument
2251 	if (rpc_task_transmitted(task)) {  in call_transmit()
2252 		rpc_task_handle_transmitted(task);  in call_transmit()
2256 	task->tk_action = call_transmit_status;  in call_transmit()
2257 	if (!xprt_prepare_transmit(task))  in call_transmit()
2259 	task->tk_status = 0;  in call_transmit()
2260 	if (test_bit(RPC_TASK_NEED_XMIT, &task->tk_runstate)) {  in call_transmit()
2261 		if (!xprt_connected(task->tk_xprt)) {  in call_transmit()
2262 			task->tk_status = -ENOTCONN;  in call_transmit()
2265 		xprt_transmit(task);  in call_transmit()
2267 	xprt_end_transmit(task);  in call_transmit()
2274 call_transmit_status(struct rpc_task *task)  in call_transmit_status()  argument
2276 	task->tk_action = call_status;  in call_transmit_status()
2282 	if (rpc_task_transmitted(task)) {  in call_transmit_status()
2283 		task->tk_status = 0;  in call_transmit_status()
2284 		xprt_request_wait_receive(task);  in call_transmit_status()
2288 	switch (task->tk_status) {  in call_transmit_status()
2292 		task->tk_status = 0;  in call_transmit_status()
2293 		task->tk_action = call_encode;  in call_transmit_status()
2303 		rpc_delay(task, HZ>>2);  in call_transmit_status()
2307 		task->tk_action = call_transmit;  in call_transmit_status()
2308 		task->tk_status = 0;  in call_transmit_status()
2317 		if (RPC_IS_SOFTCONN(task)) {  in call_transmit_status()
2318 			if (!task->tk_msg.rpc_proc->p_proc)  in call_transmit_status()
2319 				trace_xprt_ping(task->tk_xprt,  in call_transmit_status()
2320 						task->tk_status);  in call_transmit_status()
2321 			rpc_call_rpcerror(task, task->tk_status);  in call_transmit_status()
2330 		task->tk_action = call_bind;  in call_transmit_status()
2331 		task->tk_status = 0;  in call_transmit_status()
2334 	rpc_check_timeout(task);  in call_transmit_status()
2338 static void call_bc_transmit(struct rpc_task *task);
2339 static void call_bc_transmit_status(struct rpc_task *task);
2342 call_bc_encode(struct rpc_task *task)  in call_bc_encode()  argument
2344 	xprt_request_enqueue_transmit(task);  in call_bc_encode()
2345 	task->tk_action = call_bc_transmit;  in call_bc_encode()
2353 call_bc_transmit(struct rpc_task *task)  in call_bc_transmit()  argument
2355 	task->tk_action = call_bc_transmit_status;  in call_bc_transmit()
2356 	if (test_bit(RPC_TASK_NEED_XMIT, &task->tk_runstate)) {  in call_bc_transmit()
2357 		if (!xprt_prepare_transmit(task))  in call_bc_transmit()
2359 		task->tk_status = 0;  in call_bc_transmit()
2360 		xprt_transmit(task);  in call_bc_transmit()
2362 	xprt_end_transmit(task);  in call_bc_transmit()
2366 call_bc_transmit_status(struct rpc_task *task)  in call_bc_transmit_status()  argument
2368 	struct rpc_rqst *req = task->tk_rqstp;  in call_bc_transmit_status()
2370 	if (rpc_task_transmitted(task))  in call_bc_transmit_status()
2371 		task->tk_status = 0;  in call_bc_transmit_status()
2373 	switch (task->tk_status) {  in call_bc_transmit_status()
2388 		rpc_delay(task, HZ>>2);  in call_bc_transmit_status()
2392 		task->tk_status = 0;  in call_bc_transmit_status()
2393 		task->tk_action = call_bc_transmit;  in call_bc_transmit_status()
2404 			"error: %d\n", task->tk_status);  in call_bc_transmit_status()
2414 			"error: %d\n", task->tk_status);  in call_bc_transmit_status()
2417 	task->tk_action = rpc_exit_task;  in call_bc_transmit_status()
2425 call_status(struct rpc_task *task)  in call_status()  argument
2427 	struct rpc_clnt	*clnt = task->tk_client;  in call_status()
2430 	if (!task->tk_msg.rpc_proc->p_proc)  in call_status()
2431 		trace_xprt_ping(task->tk_xprt, task->tk_status);  in call_status()
2433 	status = task->tk_status;  in call_status()
2435 		task->tk_action = call_decode;  in call_status()
2439 	trace_rpc_call_status(task);  in call_status()
2440 	task->tk_status = 0;  in call_status()
2447 		if (RPC_IS_SOFTCONN(task))  in call_status()
2453 		rpc_delay(task, 3*HZ);  in call_status()
2464 		rpc_delay(task, 3*HZ);  in call_status()
2472 		rpc_delay(task, HZ>>2);  in call_status()
2483 	task->tk_action = call_encode;  in call_status()
2484 	rpc_check_timeout(task);  in call_status()
2487 	rpc_call_rpcerror(task, status);  in call_status()
2500 rpc_check_timeout(struct rpc_task *task)  in rpc_check_timeout()  argument
2502 	struct rpc_clnt	*clnt = task->tk_client;  in rpc_check_timeout()
2504 	if (RPC_SIGNALLED(task))  in rpc_check_timeout()
2507 	if (xprt_adjust_timeout(task->tk_rqstp) == 0)  in rpc_check_timeout()
2510 	trace_rpc_timeout_status(task);  in rpc_check_timeout()
2511 	task->tk_timeouts++;  in rpc_check_timeout()
2513 	if (RPC_IS_SOFTCONN(task) && !rpc_check_connected(task->tk_rqstp)) {  in rpc_check_timeout()
2514 		rpc_call_rpcerror(task, -ETIMEDOUT);  in rpc_check_timeout()
2518 	if (RPC_IS_SOFT(task)) {  in rpc_check_timeout()
2524 		if ((task->tk_flags & RPC_TASK_NO_RETRANS_TIMEOUT) &&  in rpc_check_timeout()
2525 		    rpc_check_connected(task->tk_rqstp))  in rpc_check_timeout()
2532 				task->tk_xprt->servername);  in rpc_check_timeout()
2534 		if (task->tk_flags & RPC_TASK_TIMEOUT)  in rpc_check_timeout()
2535 			rpc_call_rpcerror(task, -ETIMEDOUT);  in rpc_check_timeout()
2537 			__rpc_call_rpcerror(task, -EIO, -ETIMEDOUT);  in rpc_check_timeout()
2541 	if (!(task->tk_flags & RPC_CALL_MAJORSEEN)) {  in rpc_check_timeout()
2542 		task->tk_flags |= RPC_CALL_MAJORSEEN;  in rpc_check_timeout()
2547 				task->tk_xprt->servername);  in rpc_check_timeout()
2555 	rpcauth_invalcred(task);  in rpc_check_timeout()
2562 call_decode(struct rpc_task *task)  in call_decode()  argument
2564 	struct rpc_clnt	*clnt = task->tk_client;  in call_decode()
2565 	struct rpc_rqst	*req = task->tk_rqstp;  in call_decode()
2569 	if (!task->tk_msg.rpc_proc->p_decode) {  in call_decode()
2570 		task->tk_action = rpc_exit_task;  in call_decode()
2574 	if (task->tk_flags & RPC_CALL_MAJORSEEN) {  in call_decode()
2578 				task->tk_xprt->servername);  in call_decode()
2580 		task->tk_flags &= ~RPC_CALL_MAJORSEEN;  in call_decode()
2597 	trace_rpc_xdr_recvfrom(task, &req->rq_rcv_buf);  in call_decode()
2605 	err = rpc_decode_header(task, &xdr);  in call_decode()
2609 		task->tk_action = rpc_exit_task;  in call_decode()
2610 		task->tk_status = rpcauth_unwrap_resp(task, &xdr);  in call_decode()
2614 		task->tk_status = 0;  in call_decode()
2615 		if (task->tk_client->cl_discrtry)  in call_decode()
2618 		task->tk_action = call_encode;  in call_decode()
2619 		rpc_check_timeout(task);  in call_decode()
2622 		task->tk_action = call_reserve;  in call_decode()
2623 		rpc_check_timeout(task);  in call_decode()
2624 		rpcauth_invalcred(task);  in call_decode()
2626 		xprt_release(task);  in call_decode()
2631 rpc_encode_header(struct rpc_task *task, struct xdr_stream *xdr)  in rpc_encode_header()  argument
2633 	struct rpc_clnt *clnt = task->tk_client;  in rpc_encode_header()
2634 	struct rpc_rqst	*req = task->tk_rqstp;  in rpc_encode_header()
2647 	*p   = cpu_to_be32(task->tk_msg.rpc_proc->p_proc);  in rpc_encode_header()
2649 	error = rpcauth_marshcred(task, xdr);  in rpc_encode_header()
2654 	trace_rpc_bad_callhdr(task);  in rpc_encode_header()
2655 	rpc_call_rpcerror(task, error);  in rpc_encode_header()
2660 rpc_decode_header(struct rpc_task *task, struct xdr_stream *xdr)  in rpc_decode_header()  argument
2662 	struct rpc_clnt *clnt = task->tk_client;  in rpc_decode_header()
2671 	if (task->tk_rqstp->rq_rcv_buf.len & 3)  in rpc_decode_header()
2683 	error = rpcauth_checkverf(task, xdr);  in rpc_decode_header()
2694 		trace_rpc__prog_unavail(task);  in rpc_decode_header()
2698 		trace_rpc__prog_mismatch(task);  in rpc_decode_header()
2702 		trace_rpc__proc_unavail(task);  in rpc_decode_header()
2707 		trace_rpc__garbage_args(task);  in rpc_decode_header()
2716 	if (task->tk_garb_retry) {  in rpc_decode_header()
2717 		task->tk_garb_retry--;  in rpc_decode_header()
2718 		task->tk_action = call_encode;  in rpc_decode_header()
2722 	rpc_call_rpcerror(task, error);  in rpc_decode_header()
2726 	trace_rpc__unparsable(task);  in rpc_decode_header()
2731 	trace_rpc_bad_verifier(task);  in rpc_decode_header()
2751 		trace_rpc__mismatch(task);  in rpc_decode_header()
2766 		rpcauth_invalcred(task);  in rpc_decode_header()
2767 		if (!task->tk_cred_retry)  in rpc_decode_header()
2769 		task->tk_cred_retry--;  in rpc_decode_header()
2770 		trace_rpc__stale_creds(task);  in rpc_decode_header()
2775 		if (!task->tk_garb_retry)  in rpc_decode_header()
2777 		task->tk_garb_retry--;  in rpc_decode_header()
2778 		trace_rpc__bad_creds(task);  in rpc_decode_header()
2779 		task->tk_action = call_encode;  in rpc_decode_header()
2782 		trace_rpc__auth_tooweak(task);  in rpc_decode_header()
2784 			task->tk_xprt->servername);  in rpc_decode_header()
2813 rpc_null_call_prepare(struct rpc_task *task, void *data)  in rpc_null_call_prepare()  argument
2815 	task->tk_flags &= ~RPC_TASK_NO_RETRANS_TIMEOUT;  in rpc_null_call_prepare()
2816 	rpc_call_start(task);  in rpc_null_call_prepare()
2854 	struct rpc_task	*task;  in rpc_ping()  local
2860 	task = rpc_call_null_helper(clnt, NULL, NULL, 0, NULL, NULL);  in rpc_ping()
2861 	if (IS_ERR(task))  in rpc_ping()
2862 		return PTR_ERR(task);  in rpc_ping()
2863 	status = task->tk_status;  in rpc_ping()
2864 	rpc_put_task(task);  in rpc_ping()
2879 	struct rpc_task	*task;  in rpc_ping_noreply()  local
2882 	task = rpc_run_task(&task_setup_data);  in rpc_ping_noreply()
2883 	if (IS_ERR(task))  in rpc_ping_noreply()
2884 		return PTR_ERR(task);  in rpc_ping_noreply()
2885 	status = task->tk_status;  in rpc_ping_noreply()
2886 	rpc_put_task(task);  in rpc_ping_noreply()
2895 static void rpc_cb_add_xprt_done(struct rpc_task *task, void *calldata)  in rpc_cb_add_xprt_done()  argument
2899 	if (task->tk_status == 0)  in rpc_cb_add_xprt_done()
2930 	struct rpc_task *task;  in rpc_clnt_test_and_add_xprt()  local
2954 	task = rpc_call_null_helper(clnt, xprt, NULL, RPC_TASK_ASYNC,  in rpc_clnt_test_and_add_xprt()
2956 	if (IS_ERR(task))  in rpc_clnt_test_and_add_xprt()
2957 		return PTR_ERR(task);  in rpc_clnt_test_and_add_xprt()
2960 	rpc_put_task(task);  in rpc_clnt_test_and_add_xprt()
2970 	struct rpc_task *task;  in rpc_clnt_add_xprt_helper()  local
2974 	task = rpc_call_null_helper(clnt, xprt, NULL, 0, NULL, NULL);  in rpc_clnt_add_xprt_helper()
2975 	if (IS_ERR(task))  in rpc_clnt_add_xprt_helper()
2976 		return PTR_ERR(task);  in rpc_clnt_add_xprt_helper()
2978 	status = task->tk_status;  in rpc_clnt_add_xprt_helper()
2979 	rpc_put_task(task);  in rpc_clnt_add_xprt_helper()
3320 			  const struct rpc_task *task)  in rpc_show_task()  argument
3324 	if (RPC_IS_QUEUED(task))  in rpc_show_task()
3325 		rpc_waitq = rpc_qname(task->tk_waitqueue);  in rpc_show_task()
3328 		task->tk_pid, task->tk_flags, task->tk_status,  in rpc_show_task()
3329 		clnt, task->tk_rqstp, rpc_task_timeout(task), task->tk_ops,  in rpc_show_task()
3330 		clnt->cl_program->name, clnt->cl_vers, rpc_proc_name(task),  in rpc_show_task()
3331 		task->tk_action, rpc_waitq);  in rpc_show_task()
3337 	struct rpc_task *task;  in rpc_show_tasks()  local
3344 		list_for_each_entry(task, &clnt->cl_tasks, tk_task) {  in rpc_show_tasks()
3349 			rpc_show_task(clnt, task);  in rpc_show_tasks()