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,
79 static void	rpc_check_timeout(struct rpc_task *task);
1018 void rpc_task_release_transport(struct rpc_task *task)  in rpc_task_release_transport()  argument
1020 	struct rpc_xprt *xprt = task->tk_xprt;  in rpc_task_release_transport()
1023 		task->tk_xprt = NULL;  in rpc_task_release_transport()
1024 		if (task->tk_client)  in rpc_task_release_transport()
1025 			rpc_task_release_xprt(task->tk_client, xprt);  in rpc_task_release_transport()
1032 void rpc_task_release_client(struct rpc_task *task)  in rpc_task_release_client()  argument
1034 	struct rpc_clnt *clnt = task->tk_client;  in rpc_task_release_client()
1036 	rpc_task_release_transport(task);  in rpc_task_release_client()
1038 		/* Remove from client task list */  in rpc_task_release_client()
1040 		list_del(&task->tk_task);  in rpc_task_release_client()
1042 		task->tk_client = NULL;  in rpc_task_release_client()
1066 void rpc_task_set_transport(struct rpc_task *task, struct rpc_clnt *clnt)  in rpc_task_set_transport()  argument
1068 	if (task->tk_xprt)  in rpc_task_set_transport()
1070 	if (task->tk_flags & RPC_TASK_NO_ROUND_ROBIN)  in rpc_task_set_transport()
1071 		task->tk_xprt = rpc_task_get_first_xprt(clnt);  in rpc_task_set_transport()
1073 		task->tk_xprt = rpc_task_get_next_xprt(clnt);  in rpc_task_set_transport()
1077 void rpc_task_set_client(struct rpc_task *task, struct rpc_clnt *clnt)  in rpc_task_set_client()  argument
1081 		rpc_task_set_transport(task, clnt);  in rpc_task_set_client()
1082 		task->tk_client = clnt;  in rpc_task_set_client()
1085 			task->tk_flags |= RPC_TASK_SOFT;  in rpc_task_set_client()
1087 			task->tk_flags |= RPC_TASK_TIMEOUT;  in rpc_task_set_client()
1089 			task->tk_flags |= RPC_TASK_NO_RETRANS_TIMEOUT;  in rpc_task_set_client()
1091 			task->tk_flags |= RPC_TASK_SWAPPER;  in rpc_task_set_client()
1094 		list_add_tail(&task->tk_task, &clnt->cl_tasks);  in rpc_task_set_client()
1100 rpc_task_set_rpc_message(struct rpc_task *task, const struct rpc_message *msg)  in rpc_task_set_rpc_message()  argument
1103 		task->tk_msg.rpc_proc = msg->rpc_proc;  in rpc_task_set_rpc_message()
1104 		task->tk_msg.rpc_argp = msg->rpc_argp;  in rpc_task_set_rpc_message()
1105 		task->tk_msg.rpc_resp = msg->rpc_resp;  in rpc_task_set_rpc_message()
1106 		task->tk_msg.rpc_cred = msg->rpc_cred;  in rpc_task_set_rpc_message()
1107 		if (!(task->tk_flags & RPC_TASK_CRED_NOREF))  in rpc_task_set_rpc_message()
1108 			get_cred(task->tk_msg.rpc_cred);  in rpc_task_set_rpc_message()
1116 rpc_default_callback(struct rpc_task *task, void *data)  in rpc_default_callback()  argument
1125  * rpc_run_task - Allocate a new RPC task, then run rpc_execute against it
1126  * @task_setup_data: pointer to task initialisation data
1130 	struct rpc_task *task;  in rpc_run_task()  local
1132 	task = rpc_new_task(task_setup_data);  in rpc_run_task()
1134 	if (!RPC_IS_ASYNC(task))  in rpc_run_task()
1135 		task->tk_flags |= RPC_TASK_CRED_NOREF;  in rpc_run_task()
1137 	rpc_task_set_client(task, task_setup_data->rpc_client);  in rpc_run_task()
1138 	rpc_task_set_rpc_message(task, task_setup_data->rpc_message);  in rpc_run_task()
1140 	if (task->tk_action == NULL)  in rpc_run_task()
1141 		rpc_call_start(task);  in rpc_run_task()
1143 	atomic_inc(&task->tk_count);  in rpc_run_task()
1144 	rpc_execute(task);  in rpc_run_task()
1145 	return task;  in rpc_run_task()
1157 	struct rpc_task	*task;  in rpc_call_sync()  local
1173 	task = rpc_run_task(&task_setup_data);  in rpc_call_sync()
1174 	if (IS_ERR(task))  in rpc_call_sync()
1175 		return PTR_ERR(task);  in rpc_call_sync()
1176 	status = task->tk_status;  in rpc_call_sync()
1177 	rpc_put_task(task);  in rpc_call_sync()
1194 	struct rpc_task	*task;  in rpc_call_async()  local
1203 	task = rpc_run_task(&task_setup_data);  in rpc_call_async()
1204 	if (IS_ERR(task))  in rpc_call_async()
1205 		return PTR_ERR(task);  in rpc_call_async()
1206 	rpc_put_task(task);  in rpc_call_async()
1212 static void call_bc_encode(struct rpc_task *task);
1215  * rpc_run_bc_task - Allocate a new RPC task for backchannel use, then run
1221 	struct rpc_task *task;  in rpc_run_bc_task()  local
1232 	task = rpc_new_task(&task_setup_data);  in rpc_run_bc_task()
1233 	xprt_init_bc_request(req, task);  in rpc_run_bc_task()
1235 	task->tk_action = call_bc_encode;  in rpc_run_bc_task()
1236 	atomic_inc(&task->tk_count);  in rpc_run_bc_task()
1237 	WARN_ON_ONCE(atomic_read(&task->tk_count) != 2);  in rpc_run_bc_task()
1238 	rpc_execute(task);  in rpc_run_bc_task()
1240 	dprintk("RPC: rpc_run_bc_task: task= %p\n", task);  in rpc_run_bc_task()
1241 	return task;  in rpc_run_bc_task()
1266 rpc_call_start(struct rpc_task *task)  in rpc_call_start()  argument
1268 	task->tk_action = call_start;  in rpc_call_start()
1566 __rpc_restart_call(struct rpc_task *task, void (*action)(struct rpc_task *))  in __rpc_restart_call()  argument
1568 	task->tk_status = 0;  in __rpc_restart_call()
1569 	task->tk_rpc_status = 0;  in __rpc_restart_call()
1570 	task->tk_action = action;  in __rpc_restart_call()
1579 rpc_restart_call(struct rpc_task *task)  in rpc_restart_call()  argument
1581 	return __rpc_restart_call(task, call_start);  in rpc_restart_call()
1590 rpc_restart_call_prepare(struct rpc_task *task)  in rpc_restart_call_prepare()  argument
1592 	if (task->tk_ops->rpc_call_prepare != NULL)  in rpc_restart_call_prepare()
1593 		return __rpc_restart_call(task, rpc_prepare_task);  in rpc_restart_call_prepare()
1594 	return rpc_restart_call(task);  in rpc_restart_call_prepare()
1599 *rpc_proc_name(const struct rpc_task *task)  in rpc_proc_name()  argument
1601 	const struct rpc_procinfo *proc = task->tk_msg.rpc_proc;  in rpc_proc_name()
1613 __rpc_call_rpcerror(struct rpc_task *task, int tk_status, int rpc_status)  in __rpc_call_rpcerror()  argument
1615 	trace_rpc_call_rpcerror(task, tk_status, rpc_status);  in __rpc_call_rpcerror()
1616 	task->tk_rpc_status = rpc_status;  in __rpc_call_rpcerror()
1617 	rpc_exit(task, tk_status);  in __rpc_call_rpcerror()
1621 rpc_call_rpcerror(struct rpc_task *task, int status)  in rpc_call_rpcerror()  argument
1623 	__rpc_call_rpcerror(task, status, status);  in rpc_call_rpcerror()
1633 call_start(struct rpc_task *task)  in call_start()  argument
1635 	struct rpc_clnt	*clnt = task->tk_client;  in call_start()
1636 	int idx = task->tk_msg.rpc_proc->p_statidx;  in call_start()
1638 	trace_rpc_request(task);  in call_start()
1644 	task->tk_action = call_reserve;  in call_start()
1645 	rpc_task_set_transport(task, clnt);  in call_start()
1652 call_reserve(struct rpc_task *task)  in call_reserve()  argument
1654 	task->tk_status  = 0;  in call_reserve()
1655 	task->tk_action  = call_reserveresult;  in call_reserve()
1656 	xprt_reserve(task);  in call_reserve()
1659 static void call_retry_reserve(struct rpc_task *task);
1665 call_reserveresult(struct rpc_task *task)  in call_reserveresult()  argument
1667 	int status = task->tk_status;  in call_reserveresult()
1673 	task->tk_status = 0;  in call_reserveresult()
1675 		if (task->tk_rqstp) {  in call_reserveresult()
1676 			task->tk_action = call_refresh;  in call_reserveresult()
1680 		rpc_call_rpcerror(task, -EIO);  in call_reserveresult()
1686 		rpc_delay(task, HZ >> 2);  in call_reserveresult()
1689 		task->tk_action = call_retry_reserve;  in call_reserveresult()
1692 		rpc_call_rpcerror(task, status);  in call_reserveresult()
1700 call_retry_reserve(struct rpc_task *task)  in call_retry_reserve()  argument
1702 	task->tk_status  = 0;  in call_retry_reserve()
1703 	task->tk_action  = call_reserveresult;  in call_retry_reserve()
1704 	xprt_retry_reserve(task);  in call_retry_reserve()
1711 call_refresh(struct rpc_task *task)  in call_refresh()  argument
1713 	task->tk_action = call_refreshresult;  in call_refresh()
1714 	task->tk_status = 0;  in call_refresh()
1715 	task->tk_client->cl_stats->rpcauthrefresh++;  in call_refresh()
1716 	rpcauth_refreshcred(task);  in call_refresh()
1723 call_refreshresult(struct rpc_task *task)  in call_refreshresult()  argument
1725 	int status = task->tk_status;  in call_refreshresult()
1727 	task->tk_status = 0;  in call_refreshresult()
1728 	task->tk_action = call_refresh;  in call_refreshresult()
1731 		if (rpcauth_uptodatecred(task)) {  in call_refreshresult()
1732 			task->tk_action = call_allocate;  in call_refreshresult()
1740 		rpc_delay(task, 3*HZ);  in call_refreshresult()
1746 		if (!task->tk_cred_retry)  in call_refreshresult()
1748 		task->tk_cred_retry--;  in call_refreshresult()
1749 		trace_rpc_retry_refresh_status(task);  in call_refreshresult()
1752 	trace_rpc_refresh_status(task);  in call_refreshresult()
1753 	rpc_call_rpcerror(task, status);  in call_refreshresult()
1761 call_allocate(struct rpc_task *task)  in call_allocate()  argument
1763 	const struct rpc_auth *auth = task->tk_rqstp->rq_cred->cr_auth;  in call_allocate()
1764 	struct rpc_rqst *req = task->tk_rqstp;  in call_allocate()
1766 	const struct rpc_procinfo *proc = task->tk_msg.rpc_proc;  in call_allocate()
1769 	task->tk_status = 0;  in call_allocate()
1770 	task->tk_action = call_encode;  in call_allocate()
1797 	status = xprt->ops->buf_alloc(task);  in call_allocate()
1798 	trace_rpc_buf_alloc(task, status);  in call_allocate()
1802 		rpc_call_rpcerror(task, status);  in call_allocate()
1806 	if (RPC_IS_ASYNC(task) || !fatal_signal_pending(current)) {  in call_allocate()
1807 		task->tk_action = call_allocate;  in call_allocate()
1808 		rpc_delay(task, HZ>>4);  in call_allocate()
1812 	rpc_call_rpcerror(task, -ERESTARTSYS);  in call_allocate()
1816 rpc_task_need_encode(struct rpc_task *task)  in rpc_task_need_encode()  argument
1818 	return test_bit(RPC_TASK_NEED_XMIT, &task->tk_runstate) == 0 &&  in rpc_task_need_encode()
1819 		(!(task->tk_flags & RPC_TASK_SENT) ||  in rpc_task_need_encode()
1820 		 !(task->tk_flags & RPC_TASK_NO_RETRANS_TIMEOUT) ||  in rpc_task_need_encode()
1821 		 xprt_request_need_retransmit(task));  in rpc_task_need_encode()
1825 rpc_xdr_encode(struct rpc_task *task)  in rpc_xdr_encode()  argument
1827 	struct rpc_rqst	*req = task->tk_rqstp;  in rpc_xdr_encode()
1842 	if (rpc_encode_header(task, &xdr))  in rpc_xdr_encode()
1845 	task->tk_status = rpcauth_wrap_req(task, &xdr);  in rpc_xdr_encode()
1852 call_encode(struct rpc_task *task)  in call_encode()  argument
1854 	if (!rpc_task_need_encode(task))  in call_encode()
1857 	/* Dequeue task from the receive queue while we're encoding */  in call_encode()
1858 	xprt_request_dequeue_xprt(task);  in call_encode()
1860 	rpc_xdr_encode(task);  in call_encode()
1862 	if (task->tk_status != 0) {  in call_encode()
1864 		switch (task->tk_status) {  in call_encode()
1867 			rpc_delay(task, HZ >> 4);  in call_encode()
1870 			if (!task->tk_cred_retry) {  in call_encode()
1871 				rpc_exit(task, task->tk_status);  in call_encode()
1873 				task->tk_action = call_refresh;  in call_encode()
1874 				task->tk_cred_retry--;  in call_encode()
1875 				trace_rpc_retry_refresh_status(task);  in call_encode()
1879 			rpc_call_rpcerror(task, task->tk_status);  in call_encode()
1884 	/* Add task to reply queue before transmission to avoid races */  in call_encode()
1885 	if (rpc_reply_expected(task))  in call_encode()
1886 		xprt_request_enqueue_receive(task);  in call_encode()
1887 	xprt_request_enqueue_transmit(task);  in call_encode()
1889 	task->tk_action = call_transmit;  in call_encode()
1891 	if (!xprt_bound(task->tk_xprt))  in call_encode()
1892 		task->tk_action = call_bind;  in call_encode()
1893 	else if (!xprt_connected(task->tk_xprt))  in call_encode()
1894 		task->tk_action = call_connect;  in call_encode()
1898  * Helpers to check if the task was already transmitted, and
1902 rpc_task_transmitted(struct rpc_task *task)  in rpc_task_transmitted()  argument
1904 	return !test_bit(RPC_TASK_NEED_XMIT, &task->tk_runstate);  in rpc_task_transmitted()
1908 rpc_task_handle_transmitted(struct rpc_task *task)  in rpc_task_handle_transmitted()  argument
1910 	xprt_end_transmit(task);  in rpc_task_handle_transmitted()
1911 	task->tk_action = call_transmit_status;  in rpc_task_handle_transmitted()
1918 call_bind(struct rpc_task *task)  in call_bind()  argument
1920 	struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt;  in call_bind()
1922 	if (rpc_task_transmitted(task)) {  in call_bind()
1923 		rpc_task_handle_transmitted(task);  in call_bind()
1928 		task->tk_action = call_connect;  in call_bind()
1932 	task->tk_action = call_bind_status;  in call_bind()
1933 	if (!xprt_prepare_transmit(task))  in call_bind()
1936 	xprt->ops->rpcbind(task);  in call_bind()
1943 call_bind_status(struct rpc_task *task)  in call_bind_status()  argument
1945 	struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt;  in call_bind_status()
1948 	if (rpc_task_transmitted(task)) {  in call_bind_status()
1949 		rpc_task_handle_transmitted(task);  in call_bind_status()
1953 	if (task->tk_status >= 0)  in call_bind_status()
1956 		task->tk_status = 0;  in call_bind_status()
1960 	switch (task->tk_status) {  in call_bind_status()
1962 		rpc_delay(task, HZ >> 2);  in call_bind_status()
1965 		trace_rpcb_prog_unavail_err(task);  in call_bind_status()
1967 		if (task->tk_msg.rpc_proc->p_proc == 0) {  in call_bind_status()
1971 		if (task->tk_rebind_retry == 0)  in call_bind_status()
1973 		task->tk_rebind_retry--;  in call_bind_status()
1974 		rpc_delay(task, 3*HZ);  in call_bind_status()
1977 		rpc_delay(task, HZ >> 2);  in call_bind_status()
1982 		trace_rpcb_timeout_err(task);  in call_bind_status()
1986 		trace_rpcb_bind_version_err(task);  in call_bind_status()
1989 		trace_rpcb_bind_version_err(task);  in call_bind_status()
2000 		trace_rpcb_unreachable_err(task);  in call_bind_status()
2001 		if (!RPC_IS_SOFTCONN(task)) {  in call_bind_status()
2002 			rpc_delay(task, 5*HZ);  in call_bind_status()
2005 		status = task->tk_status;  in call_bind_status()
2008 		trace_rpcb_unrecognized_err(task);  in call_bind_status()
2011 	rpc_call_rpcerror(task, status);  in call_bind_status()
2014 	task->tk_action = call_connect;  in call_bind_status()
2017 	task->tk_status = 0;  in call_bind_status()
2018 	task->tk_action = call_bind;  in call_bind_status()
2019 	rpc_check_timeout(task);  in call_bind_status()
2026 call_connect(struct rpc_task *task)  in call_connect()  argument
2028 	struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt;  in call_connect()
2030 	if (rpc_task_transmitted(task)) {  in call_connect()
2031 		rpc_task_handle_transmitted(task);  in call_connect()
2036 		task->tk_action = call_transmit;  in call_connect()
2040 	task->tk_action = call_connect_status;  in call_connect()
2041 	if (task->tk_status < 0)  in call_connect()
2043 	if (task->tk_flags & RPC_TASK_NOCONNECT) {  in call_connect()
2044 		rpc_call_rpcerror(task, -ENOTCONN);  in call_connect()
2047 	if (!xprt_prepare_transmit(task))  in call_connect()
2049 	xprt_connect(task);  in call_connect()
2056 call_connect_status(struct rpc_task *task)  in call_connect_status()  argument
2058 	struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt;  in call_connect_status()
2059 	struct rpc_clnt *clnt = task->tk_client;  in call_connect_status()
2060 	int status = task->tk_status;  in call_connect_status()
2062 	if (rpc_task_transmitted(task)) {  in call_connect_status()
2063 		rpc_task_handle_transmitted(task);  in call_connect_status()
2067 	trace_rpc_connect_status(task);  in call_connect_status()
2069 	if (task->tk_status == 0) {  in call_connect_status()
2074 		task->tk_status = 0;  in call_connect_status()
2078 	task->tk_status = 0;  in call_connect_status()
2082 		if (RPC_IS_SOFTCONN(task))  in call_connect_status()
2096 		xprt_conditional_disconnect(task->tk_rqstp->rq_xprt,  in call_connect_status()
2097 					    task->tk_rqstp->rq_connect_cookie);  in call_connect_status()
2098 		if (RPC_IS_SOFTCONN(task))  in call_connect_status()
2101 		rpc_delay(task, 3*HZ);  in call_connect_status()
2107 		if (!(task->tk_flags & RPC_TASK_NO_ROUND_ROBIN) &&  in call_connect_status()
2108 		    (task->tk_flags & RPC_TASK_MOVEABLE) &&  in call_connect_status()
2110 			struct rpc_xprt *saved = task->tk_xprt;  in call_connect_status()
2119 				xprt_release(task);  in call_connect_status()
2124 				task->tk_xprt = NULL;  in call_connect_status()
2125 				task->tk_action = call_start;  in call_connect_status()
2128 			if (!task->tk_xprt)  in call_connect_status()
2133 		rpc_delay(task, HZ >> 2);  in call_connect_status()
2136 	rpc_call_rpcerror(task, status);  in call_connect_status()
2139 	task->tk_action = call_transmit;  in call_connect_status()
2143 	task->tk_action = call_bind;  in call_connect_status()
2144 	rpc_check_timeout(task);  in call_connect_status()
2151 call_transmit(struct rpc_task *task)  in call_transmit()  argument
2153 	if (rpc_task_transmitted(task)) {  in call_transmit()
2154 		rpc_task_handle_transmitted(task);  in call_transmit()
2158 	task->tk_action = call_transmit_status;  in call_transmit()
2159 	if (!xprt_prepare_transmit(task))  in call_transmit()
2161 	task->tk_status = 0;  in call_transmit()
2162 	if (test_bit(RPC_TASK_NEED_XMIT, &task->tk_runstate)) {  in call_transmit()
2163 		if (!xprt_connected(task->tk_xprt)) {  in call_transmit()
2164 			task->tk_status = -ENOTCONN;  in call_transmit()
2167 		xprt_transmit(task);  in call_transmit()
2169 	xprt_end_transmit(task);  in call_transmit()
2176 call_transmit_status(struct rpc_task *task)  in call_transmit_status()  argument
2178 	task->tk_action = call_status;  in call_transmit_status()
2184 	if (rpc_task_transmitted(task)) {  in call_transmit_status()
2185 		task->tk_status = 0;  in call_transmit_status()
2186 		xprt_request_wait_receive(task);  in call_transmit_status()
2190 	switch (task->tk_status) {  in call_transmit_status()
2194 		task->tk_status = 0;  in call_transmit_status()
2195 		task->tk_action = call_encode;  in call_transmit_status()
2204 		rpc_delay(task, HZ>>2);  in call_transmit_status()
2208 		task->tk_action = call_transmit;  in call_transmit_status()
2209 		task->tk_status = 0;  in call_transmit_status()
2217 		if (RPC_IS_SOFTCONN(task)) {  in call_transmit_status()
2218 			if (!task->tk_msg.rpc_proc->p_proc)  in call_transmit_status()
2219 				trace_xprt_ping(task->tk_xprt,  in call_transmit_status()
2220 						task->tk_status);  in call_transmit_status()
2221 			rpc_call_rpcerror(task, task->tk_status);  in call_transmit_status()
2230 		task->tk_action = call_bind;  in call_transmit_status()
2231 		task->tk_status = 0;  in call_transmit_status()
2234 	rpc_check_timeout(task);  in call_transmit_status()
2238 static void call_bc_transmit(struct rpc_task *task);
2239 static void call_bc_transmit_status(struct rpc_task *task);
2242 call_bc_encode(struct rpc_task *task)  in call_bc_encode()  argument
2244 	xprt_request_enqueue_transmit(task);  in call_bc_encode()
2245 	task->tk_action = call_bc_transmit;  in call_bc_encode()
2253 call_bc_transmit(struct rpc_task *task)  in call_bc_transmit()  argument
2255 	task->tk_action = call_bc_transmit_status;  in call_bc_transmit()
2256 	if (test_bit(RPC_TASK_NEED_XMIT, &task->tk_runstate)) {  in call_bc_transmit()
2257 		if (!xprt_prepare_transmit(task))  in call_bc_transmit()
2259 		task->tk_status = 0;  in call_bc_transmit()
2260 		xprt_transmit(task);  in call_bc_transmit()
2262 	xprt_end_transmit(task);  in call_bc_transmit()
2266 call_bc_transmit_status(struct rpc_task *task)  in call_bc_transmit_status()  argument
2268 	struct rpc_rqst *req = task->tk_rqstp;  in call_bc_transmit_status()
2270 	if (rpc_task_transmitted(task))  in call_bc_transmit_status()
2271 		task->tk_status = 0;  in call_bc_transmit_status()
2273 	switch (task->tk_status) {  in call_bc_transmit_status()
2287 		rpc_delay(task, HZ>>2);  in call_bc_transmit_status()
2291 		task->tk_status = 0;  in call_bc_transmit_status()
2292 		task->tk_action = call_bc_transmit;  in call_bc_transmit_status()
2303 			"error: %d\n", task->tk_status);  in call_bc_transmit_status()
2313 			"error: %d\n", task->tk_status);  in call_bc_transmit_status()
2316 	task->tk_action = rpc_exit_task;  in call_bc_transmit_status()
2324 call_status(struct rpc_task *task)  in call_status()  argument
2326 	struct rpc_clnt	*clnt = task->tk_client;  in call_status()
2329 	if (!task->tk_msg.rpc_proc->p_proc)  in call_status()
2330 		trace_xprt_ping(task->tk_xprt, task->tk_status);  in call_status()
2332 	status = task->tk_status;  in call_status()
2334 		task->tk_action = call_decode;  in call_status()
2338 	trace_rpc_call_status(task);  in call_status()
2339 	task->tk_status = 0;  in call_status()
2346 		if (RPC_IS_SOFTCONN(task))  in call_status()
2352 		rpc_delay(task, 3*HZ);  in call_status()
2363 		rpc_delay(task, 3*HZ);  in call_status()
2377 	task->tk_action = call_encode;  in call_status()
2379 		rpc_check_timeout(task);  in call_status()
2382 	rpc_call_rpcerror(task, status);  in call_status()
2395 rpc_check_timeout(struct rpc_task *task)  in rpc_check_timeout()  argument
2397 	struct rpc_clnt	*clnt = task->tk_client;  in rpc_check_timeout()
2399 	if (RPC_SIGNALLED(task)) {  in rpc_check_timeout()
2400 		rpc_call_rpcerror(task, -ERESTARTSYS);  in rpc_check_timeout()
2404 	if (xprt_adjust_timeout(task->tk_rqstp) == 0)  in rpc_check_timeout()
2407 	trace_rpc_timeout_status(task);  in rpc_check_timeout()
2408 	task->tk_timeouts++;  in rpc_check_timeout()
2410 	if (RPC_IS_SOFTCONN(task) && !rpc_check_connected(task->tk_rqstp)) {  in rpc_check_timeout()
2411 		rpc_call_rpcerror(task, -ETIMEDOUT);  in rpc_check_timeout()
2415 	if (RPC_IS_SOFT(task)) {  in rpc_check_timeout()
2421 		if ((task->tk_flags & RPC_TASK_NO_RETRANS_TIMEOUT) &&  in rpc_check_timeout()
2422 		    rpc_check_connected(task->tk_rqstp))  in rpc_check_timeout()
2429 				task->tk_xprt->servername);  in rpc_check_timeout()
2431 		if (task->tk_flags & RPC_TASK_TIMEOUT)  in rpc_check_timeout()
2432 			rpc_call_rpcerror(task, -ETIMEDOUT);  in rpc_check_timeout()
2434 			__rpc_call_rpcerror(task, -EIO, -ETIMEDOUT);  in rpc_check_timeout()
2438 	if (!(task->tk_flags & RPC_CALL_MAJORSEEN)) {  in rpc_check_timeout()
2439 		task->tk_flags |= RPC_CALL_MAJORSEEN;  in rpc_check_timeout()
2444 				task->tk_xprt->servername);  in rpc_check_timeout()
2452 	rpcauth_invalcred(task);  in rpc_check_timeout()
2459 call_decode(struct rpc_task *task)  in call_decode()  argument
2461 	struct rpc_clnt	*clnt = task->tk_client;  in call_decode()
2462 	struct rpc_rqst	*req = task->tk_rqstp;  in call_decode()
2466 	if (!task->tk_msg.rpc_proc->p_decode) {  in call_decode()
2467 		task->tk_action = rpc_exit_task;  in call_decode()
2471 	if (task->tk_flags & RPC_CALL_MAJORSEEN) {  in call_decode()
2475 				task->tk_xprt->servername);  in call_decode()
2477 		task->tk_flags &= ~RPC_CALL_MAJORSEEN;  in call_decode()
2494 	trace_rpc_xdr_recvfrom(task, &req->rq_rcv_buf);  in call_decode()
2502 	err = rpc_decode_header(task, &xdr);  in call_decode()
2506 		task->tk_action = rpc_exit_task;  in call_decode()
2507 		task->tk_status = rpcauth_unwrap_resp(task, &xdr);  in call_decode()
2510 		task->tk_status = 0;  in call_decode()
2511 		if (task->tk_client->cl_discrtry)  in call_decode()
2514 		task->tk_action = call_encode;  in call_decode()
2515 		rpc_check_timeout(task);  in call_decode()
2518 		task->tk_action = call_reserve;  in call_decode()
2519 		rpc_check_timeout(task);  in call_decode()
2520 		rpcauth_invalcred(task);  in call_decode()
2522 		xprt_release(task);  in call_decode()
2527 rpc_encode_header(struct rpc_task *task, struct xdr_stream *xdr)  in rpc_encode_header()  argument
2529 	struct rpc_clnt *clnt = task->tk_client;  in rpc_encode_header()
2530 	struct rpc_rqst	*req = task->tk_rqstp;  in rpc_encode_header()
2543 	*p   = cpu_to_be32(task->tk_msg.rpc_proc->p_proc);  in rpc_encode_header()
2545 	error = rpcauth_marshcred(task, xdr);  in rpc_encode_header()
2550 	trace_rpc_bad_callhdr(task);  in rpc_encode_header()
2551 	rpc_call_rpcerror(task, error);  in rpc_encode_header()
2556 rpc_decode_header(struct rpc_task *task, struct xdr_stream *xdr)  in rpc_decode_header()  argument
2558 	struct rpc_clnt *clnt = task->tk_client;  in rpc_decode_header()
2567 	if (task->tk_rqstp->rq_rcv_buf.len & 3)  in rpc_decode_header()
2579 	error = rpcauth_checkverf(task, xdr);  in rpc_decode_header()
2590 		trace_rpc__prog_unavail(task);  in rpc_decode_header()
2594 		trace_rpc__prog_mismatch(task);  in rpc_decode_header()
2598 		trace_rpc__proc_unavail(task);  in rpc_decode_header()
2603 		trace_rpc__garbage_args(task);  in rpc_decode_header()
2612 	if (task->tk_garb_retry) {  in rpc_decode_header()
2613 		task->tk_garb_retry--;  in rpc_decode_header()
2614 		task->tk_action = call_encode;  in rpc_decode_header()
2618 	rpc_call_rpcerror(task, error);  in rpc_decode_header()
2622 	trace_rpc__unparsable(task);  in rpc_decode_header()
2627 	trace_rpc_bad_verifier(task);  in rpc_decode_header()
2639 		trace_rpc__mismatch(task);  in rpc_decode_header()
2654 		if (!task->tk_cred_retry)  in rpc_decode_header()
2656 		task->tk_cred_retry--;  in rpc_decode_header()
2657 		trace_rpc__stale_creds(task);  in rpc_decode_header()
2662 		if (!task->tk_garb_retry)  in rpc_decode_header()
2664 		task->tk_garb_retry--;  in rpc_decode_header()
2665 		trace_rpc__bad_creds(task);  in rpc_decode_header()
2666 		task->tk_action = call_encode;  in rpc_decode_header()
2669 		trace_rpc__auth_tooweak(task);  in rpc_decode_header()
2671 			task->tk_xprt->servername);  in rpc_decode_header()
2696 rpc_null_call_prepare(struct rpc_task *task, void *data)  in rpc_null_call_prepare()  argument
2698 	task->tk_flags &= ~RPC_TASK_NO_RETRANS_TIMEOUT;  in rpc_null_call_prepare()
2699 	rpc_call_start(task);  in rpc_null_call_prepare()
2737 	struct rpc_task	*task;  in rpc_ping()  local
2740 	task = rpc_call_null_helper(clnt, NULL, NULL, 0, NULL, NULL);  in rpc_ping()
2741 	if (IS_ERR(task))  in rpc_ping()
2742 		return PTR_ERR(task);  in rpc_ping()
2743 	status = task->tk_status;  in rpc_ping()
2744 	rpc_put_task(task);  in rpc_ping()
2753 static void rpc_cb_add_xprt_done(struct rpc_task *task, void *calldata)  in rpc_cb_add_xprt_done()  argument
2757 	if (task->tk_status == 0)  in rpc_cb_add_xprt_done()
2788 	struct rpc_task *task;  in rpc_clnt_test_and_add_xprt()  local
2809 	task = rpc_call_null_helper(clnt, xprt, NULL, RPC_TASK_ASYNC,  in rpc_clnt_test_and_add_xprt()
2812 	rpc_put_task(task);  in rpc_clnt_test_and_add_xprt()
2841 	struct rpc_task *task;  in rpc_clnt_setup_test_and_add_xprt()  local
2852 	task = rpc_call_null_helper(clnt, xprt, NULL, 0, NULL, NULL);  in rpc_clnt_setup_test_and_add_xprt()
2853 	if (IS_ERR(task)) {  in rpc_clnt_setup_test_and_add_xprt()
2854 		status = PTR_ERR(task);  in rpc_clnt_setup_test_and_add_xprt()
2857 	status = task->tk_status;  in rpc_clnt_setup_test_and_add_xprt()
2858 	rpc_put_task(task);  in rpc_clnt_setup_test_and_add_xprt()
3022 			  const struct rpc_task *task)  in rpc_show_task()  argument
3026 	if (RPC_IS_QUEUED(task))  in rpc_show_task()
3027 		rpc_waitq = rpc_qname(task->tk_waitqueue);  in rpc_show_task()
3030 		task->tk_pid, task->tk_flags, task->tk_status,  in rpc_show_task()
3031 		clnt, task->tk_rqstp, rpc_task_timeout(task), task->tk_ops,  in rpc_show_task()
3032 		clnt->cl_program->name, clnt->cl_vers, rpc_proc_name(task),  in rpc_show_task()
3033 		task->tk_action, rpc_waitq);  in rpc_show_task()
3039 	struct rpc_task *task;  in rpc_show_tasks()  local
3046 		list_for_each_entry(task, &clnt->cl_tasks, tk_task) {  in rpc_show_tasks()
3051 			rpc_show_task(clnt, task);  in rpc_show_tasks()