Lines Matching full:task
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);
906 * @error: RPC task error value to set
918 struct rpc_task *task; in rpc_cancel_tasks() local
927 list_for_each_entry(task, &clnt->cl_tasks, tk_task) { in rpc_cancel_tasks()
928 if (!RPC_IS_ACTIVATED(task)) in rpc_cancel_tasks()
930 if (!fnmatch(task, data)) in rpc_cancel_tasks()
932 rpc_task_try_cancel(task, error); in rpc_cancel_tasks()
1118 void rpc_task_release_transport(struct rpc_task *task) in rpc_task_release_transport() argument
1120 struct rpc_xprt *xprt = task->tk_xprt; in rpc_task_release_transport()
1123 task->tk_xprt = NULL; in rpc_task_release_transport()
1124 if (task->tk_client) in rpc_task_release_transport()
1125 rpc_task_release_xprt(task->tk_client, xprt); in rpc_task_release_transport()
1132 void rpc_task_release_client(struct rpc_task *task) in rpc_task_release_client() argument
1134 struct rpc_clnt *clnt = task->tk_client; in rpc_task_release_client()
1136 rpc_task_release_transport(task); in rpc_task_release_client()
1138 /* Remove from client task list */ in rpc_task_release_client()
1140 list_del(&task->tk_task); in rpc_task_release_client()
1142 task->tk_client = NULL; in rpc_task_release_client()
1166 void rpc_task_set_transport(struct rpc_task *task, struct rpc_clnt *clnt) in rpc_task_set_transport() argument
1168 if (task->tk_xprt) { in rpc_task_set_transport()
1169 if (!(test_bit(XPRT_OFFLINE, &task->tk_xprt->state) && in rpc_task_set_transport()
1170 (task->tk_flags & RPC_TASK_MOVEABLE))) in rpc_task_set_transport()
1172 xprt_release(task); in rpc_task_set_transport()
1173 xprt_put(task->tk_xprt); in rpc_task_set_transport()
1175 if (task->tk_flags & RPC_TASK_NO_ROUND_ROBIN) in rpc_task_set_transport()
1176 task->tk_xprt = rpc_task_get_first_xprt(clnt); in rpc_task_set_transport()
1178 task->tk_xprt = rpc_task_get_next_xprt(clnt); in rpc_task_set_transport()
1182 void rpc_task_set_client(struct rpc_task *task, struct rpc_clnt *clnt) in rpc_task_set_client() argument
1184 rpc_task_set_transport(task, clnt); in rpc_task_set_client()
1185 task->tk_client = clnt; in rpc_task_set_client()
1188 task->tk_flags |= RPC_TASK_SOFT; in rpc_task_set_client()
1190 task->tk_flags |= RPC_TASK_TIMEOUT; in rpc_task_set_client()
1192 task->tk_flags |= RPC_TASK_NO_RETRANS_TIMEOUT; in rpc_task_set_client()
1195 list_add_tail(&task->tk_task, &clnt->cl_tasks); in rpc_task_set_client()
1200 rpc_task_set_rpc_message(struct rpc_task *task, const struct rpc_message *msg) in rpc_task_set_rpc_message() argument
1203 task->tk_msg.rpc_proc = msg->rpc_proc; in rpc_task_set_rpc_message()
1204 task->tk_msg.rpc_argp = msg->rpc_argp; in rpc_task_set_rpc_message()
1205 task->tk_msg.rpc_resp = msg->rpc_resp; in rpc_task_set_rpc_message()
1206 task->tk_msg.rpc_cred = msg->rpc_cred; in rpc_task_set_rpc_message()
1207 if (!(task->tk_flags & RPC_TASK_CRED_NOREF)) in rpc_task_set_rpc_message()
1208 get_cred(task->tk_msg.rpc_cred); in rpc_task_set_rpc_message()
1216 rpc_default_callback(struct rpc_task *task, void *data) in rpc_default_callback() argument
1225 * rpc_run_task - Allocate a new RPC task, then run rpc_execute against it
1226 * @task_setup_data: pointer to task initialisation data
1230 struct rpc_task *task; in rpc_run_task() local
1232 task = rpc_new_task(task_setup_data); in rpc_run_task()
1233 if (IS_ERR(task)) in rpc_run_task()
1234 return task; in rpc_run_task()
1236 if (!RPC_IS_ASYNC(task)) in rpc_run_task()
1237 task->tk_flags |= RPC_TASK_CRED_NOREF; in rpc_run_task()
1239 rpc_task_set_client(task, task_setup_data->rpc_client); in rpc_run_task()
1240 rpc_task_set_rpc_message(task, task_setup_data->rpc_message); in rpc_run_task()
1242 if (task->tk_action == NULL) in rpc_run_task()
1243 rpc_call_start(task); in rpc_run_task()
1245 atomic_inc(&task->tk_count); in rpc_run_task()
1246 rpc_execute(task); in rpc_run_task()
1247 return task; in rpc_run_task()
1259 struct rpc_task *task; in rpc_call_sync() local
1275 task = rpc_run_task(&task_setup_data); in rpc_call_sync()
1276 if (IS_ERR(task)) in rpc_call_sync()
1277 return PTR_ERR(task); in rpc_call_sync()
1278 status = task->tk_status; in rpc_call_sync()
1279 rpc_put_task(task); in rpc_call_sync()
1296 struct rpc_task *task; in rpc_call_async() local
1305 task = rpc_run_task(&task_setup_data); in rpc_call_async()
1306 if (IS_ERR(task)) in rpc_call_async()
1307 return PTR_ERR(task); in rpc_call_async()
1308 rpc_put_task(task); in rpc_call_async()
1314 static void call_bc_encode(struct rpc_task *task);
1317 * rpc_run_bc_task - Allocate a new RPC task for backchannel use, then run
1320 * @timeout: timeout values to use for this task
1325 struct rpc_task *task; in rpc_run_bc_task() local
1336 task = rpc_new_task(&task_setup_data); in rpc_run_bc_task()
1337 if (IS_ERR(task)) { in rpc_run_bc_task()
1339 return task; in rpc_run_bc_task()
1342 xprt_init_bc_request(req, task, timeout); in rpc_run_bc_task()
1344 task->tk_action = call_bc_encode; in rpc_run_bc_task()
1345 atomic_inc(&task->tk_count); in rpc_run_bc_task()
1346 WARN_ON_ONCE(atomic_read(&task->tk_count) != 2); in rpc_run_bc_task()
1347 rpc_execute(task); in rpc_run_bc_task()
1349 dprintk("RPC: rpc_run_bc_task: task= %p\n", task); in rpc_run_bc_task()
1350 return task; in rpc_run_bc_task()
1375 rpc_call_start(struct rpc_task *task) in rpc_call_start() argument
1377 task->tk_action = call_start; in rpc_call_start()
1675 __rpc_restart_call(struct rpc_task *task, void (*action)(struct rpc_task *)) in __rpc_restart_call() argument
1677 task->tk_status = 0; in __rpc_restart_call()
1678 task->tk_rpc_status = 0; in __rpc_restart_call()
1679 task->tk_action = action; in __rpc_restart_call()
1688 rpc_restart_call(struct rpc_task *task) in rpc_restart_call() argument
1690 return __rpc_restart_call(task, call_start); in rpc_restart_call()
1699 rpc_restart_call_prepare(struct rpc_task *task) in rpc_restart_call_prepare() argument
1701 if (task->tk_ops->rpc_call_prepare != NULL) in rpc_restart_call_prepare()
1702 return __rpc_restart_call(task, rpc_prepare_task); in rpc_restart_call_prepare()
1703 return rpc_restart_call(task); in rpc_restart_call_prepare()
1708 *rpc_proc_name(const struct rpc_task *task) in rpc_proc_name() argument
1710 const struct rpc_procinfo *proc = task->tk_msg.rpc_proc; in rpc_proc_name()
1722 __rpc_call_rpcerror(struct rpc_task *task, int tk_status, int rpc_status) in __rpc_call_rpcerror() argument
1724 trace_rpc_call_rpcerror(task, tk_status, rpc_status); in __rpc_call_rpcerror()
1725 rpc_task_set_rpc_status(task, rpc_status); in __rpc_call_rpcerror()
1726 rpc_exit(task, tk_status); in __rpc_call_rpcerror()
1730 rpc_call_rpcerror(struct rpc_task *task, int status) in rpc_call_rpcerror() argument
1732 __rpc_call_rpcerror(task, status, status); in rpc_call_rpcerror()
1742 call_start(struct rpc_task *task) in call_start() argument
1744 struct rpc_clnt *clnt = task->tk_client; in call_start()
1745 int idx = task->tk_msg.rpc_proc->p_statidx; in call_start()
1747 trace_rpc_request(task); in call_start()
1749 if (task->tk_client->cl_shutdown) { in call_start()
1750 rpc_call_rpcerror(task, -EIO); in call_start()
1758 task->tk_action = call_reserve; in call_start()
1759 rpc_task_set_transport(task, clnt); in call_start()
1766 call_reserve(struct rpc_task *task) in call_reserve() argument
1768 task->tk_status = 0; in call_reserve()
1769 task->tk_action = call_reserveresult; in call_reserve()
1770 xprt_reserve(task); in call_reserve()
1773 static void call_retry_reserve(struct rpc_task *task);
1779 call_reserveresult(struct rpc_task *task) in call_reserveresult() argument
1781 int status = task->tk_status; in call_reserveresult()
1787 task->tk_status = 0; in call_reserveresult()
1789 if (task->tk_rqstp) { in call_reserveresult()
1790 task->tk_action = call_refresh; in call_reserveresult()
1794 rpc_call_rpcerror(task, -EIO); in call_reserveresult()
1800 rpc_delay(task, HZ >> 2); in call_reserveresult()
1803 task->tk_action = call_retry_reserve; in call_reserveresult()
1806 rpc_call_rpcerror(task, status); in call_reserveresult()
1814 call_retry_reserve(struct rpc_task *task) in call_retry_reserve() argument
1816 task->tk_status = 0; in call_retry_reserve()
1817 task->tk_action = call_reserveresult; in call_retry_reserve()
1818 xprt_retry_reserve(task); in call_retry_reserve()
1825 call_refresh(struct rpc_task *task) in call_refresh() argument
1827 task->tk_action = call_refreshresult; in call_refresh()
1828 task->tk_status = 0; in call_refresh()
1829 task->tk_client->cl_stats->rpcauthrefresh++; in call_refresh()
1830 rpcauth_refreshcred(task); in call_refresh()
1837 call_refreshresult(struct rpc_task *task) in call_refreshresult() argument
1839 int status = task->tk_status; in call_refreshresult()
1841 task->tk_status = 0; in call_refreshresult()
1842 task->tk_action = call_refresh; in call_refreshresult()
1845 if (rpcauth_uptodatecred(task)) { in call_refreshresult()
1846 task->tk_action = call_allocate; in call_refreshresult()
1854 rpc_delay(task, 3*HZ); in call_refreshresult()
1860 if (!task->tk_cred_retry) in call_refreshresult()
1862 task->tk_cred_retry--; in call_refreshresult()
1863 trace_rpc_retry_refresh_status(task); in call_refreshresult()
1866 rpc_delay(task, HZ >> 4); in call_refreshresult()
1869 trace_rpc_refresh_status(task); in call_refreshresult()
1870 rpc_call_rpcerror(task, status); in call_refreshresult()
1878 call_allocate(struct rpc_task *task) in call_allocate() argument
1880 const struct rpc_auth *auth = task->tk_rqstp->rq_cred->cr_auth; in call_allocate()
1881 struct rpc_rqst *req = task->tk_rqstp; in call_allocate()
1883 const struct rpc_procinfo *proc = task->tk_msg.rpc_proc; in call_allocate()
1886 task->tk_status = 0; in call_allocate()
1887 task->tk_action = call_encode; in call_allocate()
1914 status = xprt->ops->buf_alloc(task); in call_allocate()
1915 trace_rpc_buf_alloc(task, status); in call_allocate()
1919 rpc_call_rpcerror(task, status); in call_allocate()
1923 if (RPC_IS_ASYNC(task) || !fatal_signal_pending(current)) { in call_allocate()
1924 task->tk_action = call_allocate; in call_allocate()
1925 rpc_delay(task, HZ>>4); in call_allocate()
1929 rpc_call_rpcerror(task, -ERESTARTSYS); in call_allocate()
1933 rpc_task_need_encode(struct rpc_task *task) in rpc_task_need_encode() argument
1935 return test_bit(RPC_TASK_NEED_XMIT, &task->tk_runstate) == 0 && in rpc_task_need_encode()
1936 (!(task->tk_flags & RPC_TASK_SENT) || in rpc_task_need_encode()
1937 !(task->tk_flags & RPC_TASK_NO_RETRANS_TIMEOUT) || in rpc_task_need_encode()
1938 xprt_request_need_retransmit(task)); in rpc_task_need_encode()
1942 rpc_xdr_encode(struct rpc_task *task) in rpc_xdr_encode() argument
1944 struct rpc_rqst *req = task->tk_rqstp; in rpc_xdr_encode()
1958 if (rpc_encode_header(task, &xdr)) in rpc_xdr_encode()
1961 task->tk_status = rpcauth_wrap_req(task, &xdr); in rpc_xdr_encode()
1968 call_encode(struct rpc_task *task) in call_encode() argument
1970 if (!rpc_task_need_encode(task)) in call_encode()
1973 /* Dequeue task from the receive queue while we're encoding */ in call_encode()
1974 xprt_request_dequeue_xprt(task); in call_encode()
1976 rpc_xdr_encode(task); in call_encode()
1977 /* Add task to reply queue before transmission to avoid races */ in call_encode()
1978 if (task->tk_status == 0 && rpc_reply_expected(task)) in call_encode()
1979 task->tk_status = xprt_request_enqueue_receive(task); in call_encode()
1981 if (task->tk_status != 0) { in call_encode()
1983 switch (task->tk_status) { in call_encode()
1986 rpc_delay(task, HZ >> 4); in call_encode()
1989 if (!task->tk_cred_retry) { in call_encode()
1990 rpc_call_rpcerror(task, task->tk_status); in call_encode()
1992 task->tk_action = call_refresh; in call_encode()
1993 task->tk_cred_retry--; in call_encode()
1994 trace_rpc_retry_refresh_status(task); in call_encode()
1998 rpc_call_rpcerror(task, task->tk_status); in call_encode()
2003 xprt_request_enqueue_transmit(task); in call_encode()
2005 task->tk_action = call_transmit; in call_encode()
2007 if (!xprt_bound(task->tk_xprt)) in call_encode()
2008 task->tk_action = call_bind; in call_encode()
2009 else if (!xprt_connected(task->tk_xprt)) in call_encode()
2010 task->tk_action = call_connect; in call_encode()
2014 * Helpers to check if the task was already transmitted, and
2018 rpc_task_transmitted(struct rpc_task *task) in rpc_task_transmitted() argument
2020 return !test_bit(RPC_TASK_NEED_XMIT, &task->tk_runstate); in rpc_task_transmitted()
2024 rpc_task_handle_transmitted(struct rpc_task *task) in rpc_task_handle_transmitted() argument
2026 xprt_end_transmit(task); in rpc_task_handle_transmitted()
2027 task->tk_action = call_transmit_status; in rpc_task_handle_transmitted()
2034 call_bind(struct rpc_task *task) in call_bind() argument
2036 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in call_bind()
2038 if (rpc_task_transmitted(task)) { in call_bind()
2039 rpc_task_handle_transmitted(task); in call_bind()
2044 task->tk_action = call_connect; in call_bind()
2048 task->tk_action = call_bind_status; in call_bind()
2049 if (!xprt_prepare_transmit(task)) in call_bind()
2052 xprt->ops->rpcbind(task); in call_bind()
2059 call_bind_status(struct rpc_task *task) in call_bind_status() argument
2061 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in call_bind_status()
2064 if (rpc_task_transmitted(task)) { in call_bind_status()
2065 rpc_task_handle_transmitted(task); in call_bind_status()
2069 if (task->tk_status >= 0) in call_bind_status()
2072 task->tk_status = 0; in call_bind_status()
2076 switch (task->tk_status) { in call_bind_status()
2078 rpc_delay(task, HZ >> 2); in call_bind_status()
2081 trace_rpcb_prog_unavail_err(task); in call_bind_status()
2083 if (task->tk_msg.rpc_proc->p_proc == 0) { in call_bind_status()
2087 rpc_delay(task, 3*HZ); in call_bind_status()
2090 rpc_delay(task, HZ >> 2); in call_bind_status()
2095 trace_rpcb_timeout_err(task); in call_bind_status()
2099 trace_rpcb_bind_version_err(task); in call_bind_status()
2102 trace_rpcb_bind_version_err(task); in call_bind_status()
2113 trace_rpcb_unreachable_err(task); in call_bind_status()
2114 if (!RPC_IS_SOFTCONN(task)) { in call_bind_status()
2115 rpc_delay(task, 5*HZ); in call_bind_status()
2118 status = task->tk_status; in call_bind_status()
2121 trace_rpcb_unrecognized_err(task); in call_bind_status()
2124 rpc_call_rpcerror(task, status); in call_bind_status()
2127 task->tk_action = call_connect; in call_bind_status()
2130 task->tk_status = 0; in call_bind_status()
2131 task->tk_action = call_bind; in call_bind_status()
2132 rpc_check_timeout(task); in call_bind_status()
2139 call_connect(struct rpc_task *task) in call_connect() argument
2141 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in call_connect()
2143 if (rpc_task_transmitted(task)) { in call_connect()
2144 rpc_task_handle_transmitted(task); in call_connect()
2149 task->tk_action = call_transmit; in call_connect()
2153 task->tk_action = call_connect_status; in call_connect()
2154 if (task->tk_status < 0) in call_connect()
2156 if (task->tk_flags & RPC_TASK_NOCONNECT) { in call_connect()
2157 rpc_call_rpcerror(task, -ENOTCONN); in call_connect()
2160 if (!xprt_prepare_transmit(task)) in call_connect()
2162 xprt_connect(task); in call_connect()
2169 call_connect_status(struct rpc_task *task) in call_connect_status() argument
2171 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in call_connect_status()
2172 struct rpc_clnt *clnt = task->tk_client; in call_connect_status()
2173 int status = task->tk_status; in call_connect_status()
2175 if (rpc_task_transmitted(task)) { in call_connect_status()
2176 rpc_task_handle_transmitted(task); in call_connect_status()
2180 trace_rpc_connect_status(task); in call_connect_status()
2182 if (task->tk_status == 0) { in call_connect_status()
2187 task->tk_status = 0; in call_connect_status()
2191 task->tk_status = 0; in call_connect_status()
2196 if (RPC_IS_SOFTCONN(task)) in call_connect_status()
2209 xprt_conditional_disconnect(task->tk_rqstp->rq_xprt, in call_connect_status()
2210 task->tk_rqstp->rq_connect_cookie); in call_connect_status()
2211 if (RPC_IS_SOFTCONN(task)) in call_connect_status()
2214 rpc_delay(task, 3*HZ); in call_connect_status()
2220 if (!(task->tk_flags & RPC_TASK_NO_ROUND_ROBIN) && in call_connect_status()
2221 (task->tk_flags & RPC_TASK_MOVEABLE) && in call_connect_status()
2223 struct rpc_xprt *saved = task->tk_xprt; in call_connect_status()
2230 xprt_release(task); in call_connect_status()
2236 task->tk_xprt = NULL; in call_connect_status()
2237 task->tk_action = call_start; in call_connect_status()
2240 if (!task->tk_xprt) in call_connect_status()
2245 rpc_delay(task, HZ >> 2); in call_connect_status()
2248 rpc_call_rpcerror(task, status); in call_connect_status()
2251 task->tk_action = call_transmit; in call_connect_status()
2255 task->tk_action = call_bind; in call_connect_status()
2257 rpc_check_timeout(task); in call_connect_status()
2264 call_transmit(struct rpc_task *task) in call_transmit() argument
2266 if (rpc_task_transmitted(task)) { in call_transmit()
2267 rpc_task_handle_transmitted(task); in call_transmit()
2271 task->tk_action = call_transmit_status; in call_transmit()
2272 if (!xprt_prepare_transmit(task)) in call_transmit()
2274 task->tk_status = 0; in call_transmit()
2275 if (test_bit(RPC_TASK_NEED_XMIT, &task->tk_runstate)) { in call_transmit()
2276 if (!xprt_connected(task->tk_xprt)) { in call_transmit()
2277 task->tk_status = -ENOTCONN; in call_transmit()
2280 xprt_transmit(task); in call_transmit()
2282 xprt_end_transmit(task); in call_transmit()
2289 call_transmit_status(struct rpc_task *task) in call_transmit_status() argument
2291 task->tk_action = call_status; in call_transmit_status()
2297 if (rpc_task_transmitted(task)) { in call_transmit_status()
2298 task->tk_status = 0; in call_transmit_status()
2299 xprt_request_wait_receive(task); in call_transmit_status()
2303 switch (task->tk_status) { in call_transmit_status()
2307 task->tk_status = 0; in call_transmit_status()
2308 task->tk_action = call_encode; in call_transmit_status()
2318 rpc_delay(task, HZ>>2); in call_transmit_status()
2322 task->tk_action = call_transmit; in call_transmit_status()
2323 task->tk_status = 0; in call_transmit_status()
2331 if (RPC_IS_SOFTCONN(task)) { in call_transmit_status()
2332 if (!task->tk_msg.rpc_proc->p_proc) in call_transmit_status()
2333 trace_xprt_ping(task->tk_xprt, in call_transmit_status()
2334 task->tk_status); in call_transmit_status()
2335 rpc_call_rpcerror(task, task->tk_status); in call_transmit_status()
2344 task->tk_action = call_bind; in call_transmit_status()
2345 task->tk_status = 0; in call_transmit_status()
2348 rpc_check_timeout(task); in call_transmit_status()
2352 static void call_bc_transmit(struct rpc_task *task);
2353 static void call_bc_transmit_status(struct rpc_task *task);
2356 call_bc_encode(struct rpc_task *task) in call_bc_encode() argument
2358 xprt_request_enqueue_transmit(task); in call_bc_encode()
2359 task->tk_action = call_bc_transmit; in call_bc_encode()
2367 call_bc_transmit(struct rpc_task *task) in call_bc_transmit() argument
2369 task->tk_action = call_bc_transmit_status; in call_bc_transmit()
2370 if (test_bit(RPC_TASK_NEED_XMIT, &task->tk_runstate)) { in call_bc_transmit()
2371 if (!xprt_prepare_transmit(task)) in call_bc_transmit()
2373 task->tk_status = 0; in call_bc_transmit()
2374 xprt_transmit(task); in call_bc_transmit()
2376 xprt_end_transmit(task); in call_bc_transmit()
2380 call_bc_transmit_status(struct rpc_task *task) in call_bc_transmit_status() argument
2382 struct rpc_rqst *req = task->tk_rqstp; in call_bc_transmit_status()
2384 if (rpc_task_transmitted(task)) in call_bc_transmit_status()
2385 task->tk_status = 0; in call_bc_transmit_status()
2387 switch (task->tk_status) { in call_bc_transmit_status()
2402 rpc_delay(task, HZ>>2); in call_bc_transmit_status()
2406 task->tk_status = 0; in call_bc_transmit_status()
2407 task->tk_action = call_bc_transmit; in call_bc_transmit_status()
2418 "error: %d\n", task->tk_status); in call_bc_transmit_status()
2428 "error: %d\n", task->tk_status); in call_bc_transmit_status()
2431 task->tk_action = rpc_exit_task; in call_bc_transmit_status()
2439 call_status(struct rpc_task *task) in call_status() argument
2441 struct rpc_clnt *clnt = task->tk_client; in call_status()
2444 if (!task->tk_msg.rpc_proc->p_proc) in call_status()
2445 trace_xprt_ping(task->tk_xprt, task->tk_status); in call_status()
2447 status = task->tk_status; in call_status()
2449 task->tk_action = call_decode; in call_status()
2453 trace_rpc_call_status(task); in call_status()
2454 task->tk_status = 0; in call_status()
2461 if (RPC_IS_SOFTCONN(task)) in call_status()
2467 rpc_delay(task, 3*HZ); in call_status()
2478 rpc_delay(task, 3*HZ); in call_status()
2486 rpc_delay(task, HZ>>2); in call_status()
2497 task->tk_action = call_encode; in call_status()
2498 rpc_check_timeout(task); in call_status()
2501 rpc_call_rpcerror(task, status); in call_status()
2514 rpc_check_timeout(struct rpc_task *task) in rpc_check_timeout() argument
2516 struct rpc_clnt *clnt = task->tk_client; in rpc_check_timeout()
2518 if (RPC_SIGNALLED(task)) in rpc_check_timeout()
2521 if (xprt_adjust_timeout(task->tk_rqstp) == 0) in rpc_check_timeout()
2524 trace_rpc_timeout_status(task); in rpc_check_timeout()
2525 task->tk_timeouts++; in rpc_check_timeout()
2527 if (RPC_IS_SOFTCONN(task) && !rpc_check_connected(task->tk_rqstp)) { in rpc_check_timeout()
2528 rpc_call_rpcerror(task, -ETIMEDOUT); in rpc_check_timeout()
2532 if (RPC_IS_SOFT(task)) { in rpc_check_timeout()
2538 if ((task->tk_flags & RPC_TASK_NO_RETRANS_TIMEOUT) && in rpc_check_timeout()
2539 rpc_check_connected(task->tk_rqstp)) in rpc_check_timeout()
2546 task->tk_xprt->servername); in rpc_check_timeout()
2548 if (task->tk_flags & RPC_TASK_TIMEOUT) in rpc_check_timeout()
2549 rpc_call_rpcerror(task, -ETIMEDOUT); in rpc_check_timeout()
2551 __rpc_call_rpcerror(task, -EIO, -ETIMEDOUT); in rpc_check_timeout()
2555 if (!(task->tk_flags & RPC_CALL_MAJORSEEN)) { in rpc_check_timeout()
2556 task->tk_flags |= RPC_CALL_MAJORSEEN; in rpc_check_timeout()
2561 task->tk_xprt->servername); in rpc_check_timeout()
2569 rpcauth_invalcred(task); in rpc_check_timeout()
2576 call_decode(struct rpc_task *task) in call_decode() argument
2578 struct rpc_clnt *clnt = task->tk_client; in call_decode()
2579 struct rpc_rqst *req = task->tk_rqstp; in call_decode()
2583 if (!task->tk_msg.rpc_proc->p_decode) { in call_decode()
2584 task->tk_action = rpc_exit_task; in call_decode()
2588 if (task->tk_flags & RPC_CALL_MAJORSEEN) { in call_decode()
2592 task->tk_xprt->servername); in call_decode()
2594 task->tk_flags &= ~RPC_CALL_MAJORSEEN; in call_decode()
2611 trace_rpc_xdr_recvfrom(task, &req->rq_rcv_buf); in call_decode()
2619 err = rpc_decode_header(task, &xdr); in call_decode()
2623 task->tk_action = rpc_exit_task; in call_decode()
2624 task->tk_status = rpcauth_unwrap_resp(task, &xdr); in call_decode()
2628 task->tk_status = 0; in call_decode()
2629 if (task->tk_client->cl_discrtry) in call_decode()
2632 task->tk_action = call_encode; in call_decode()
2633 rpc_check_timeout(task); in call_decode()
2636 task->tk_action = call_reserve; in call_decode()
2637 rpc_check_timeout(task); in call_decode()
2638 rpcauth_invalcred(task); in call_decode()
2640 xprt_release(task); in call_decode()
2645 rpc_encode_header(struct rpc_task *task, struct xdr_stream *xdr) in rpc_encode_header() argument
2647 struct rpc_clnt *clnt = task->tk_client; in rpc_encode_header()
2648 struct rpc_rqst *req = task->tk_rqstp; in rpc_encode_header()
2661 *p = cpu_to_be32(task->tk_msg.rpc_proc->p_proc); in rpc_encode_header()
2663 error = rpcauth_marshcred(task, xdr); in rpc_encode_header()
2668 trace_rpc_bad_callhdr(task); in rpc_encode_header()
2669 rpc_call_rpcerror(task, error); in rpc_encode_header()
2674 rpc_decode_header(struct rpc_task *task, struct xdr_stream *xdr) in rpc_decode_header() argument
2676 struct rpc_clnt *clnt = task->tk_client; in rpc_decode_header()
2685 if (task->tk_rqstp->rq_rcv_buf.len & 3) in rpc_decode_header()
2697 error = rpcauth_checkverf(task, xdr); in rpc_decode_header()
2708 trace_rpc__prog_unavail(task); in rpc_decode_header()
2712 trace_rpc__prog_mismatch(task); in rpc_decode_header()
2716 trace_rpc__proc_unavail(task); in rpc_decode_header()
2721 trace_rpc__garbage_args(task); in rpc_decode_header()
2730 if (task->tk_garb_retry) { in rpc_decode_header()
2731 task->tk_garb_retry--; in rpc_decode_header()
2732 task->tk_action = call_encode; in rpc_decode_header()
2736 rpc_call_rpcerror(task, error); in rpc_decode_header()
2740 trace_rpc__unparsable(task); in rpc_decode_header()
2745 trace_rpc_bad_verifier(task); in rpc_decode_header()
2765 trace_rpc__mismatch(task); in rpc_decode_header()
2780 rpcauth_invalcred(task); in rpc_decode_header()
2781 if (!task->tk_cred_retry) in rpc_decode_header()
2783 task->tk_cred_retry--; in rpc_decode_header()
2784 trace_rpc__stale_creds(task); in rpc_decode_header()
2789 if (!task->tk_garb_retry) in rpc_decode_header()
2791 task->tk_garb_retry--; in rpc_decode_header()
2792 trace_rpc__bad_creds(task); in rpc_decode_header()
2793 task->tk_action = call_encode; in rpc_decode_header()
2796 trace_rpc__auth_tooweak(task); in rpc_decode_header()
2798 task->tk_xprt->servername); in rpc_decode_header()
2827 rpc_null_call_prepare(struct rpc_task *task, void *data) in rpc_null_call_prepare() argument
2829 task->tk_flags &= ~RPC_TASK_NO_RETRANS_TIMEOUT; in rpc_null_call_prepare()
2830 rpc_call_start(task); in rpc_null_call_prepare()
2868 struct rpc_task *task; in rpc_ping() local
2874 task = rpc_call_null_helper(clnt, NULL, NULL, 0, NULL, NULL); in rpc_ping()
2875 if (IS_ERR(task)) in rpc_ping()
2876 return PTR_ERR(task); in rpc_ping()
2877 status = task->tk_status; in rpc_ping()
2878 rpc_put_task(task); in rpc_ping()
2893 struct rpc_task *task; in rpc_ping_noreply() local
2896 task = rpc_run_task(&task_setup_data); in rpc_ping_noreply()
2897 if (IS_ERR(task)) in rpc_ping_noreply()
2898 return PTR_ERR(task); in rpc_ping_noreply()
2899 status = task->tk_status; in rpc_ping_noreply()
2900 rpc_put_task(task); in rpc_ping_noreply()
2909 static void rpc_cb_add_xprt_done(struct rpc_task *task, void *calldata) in rpc_cb_add_xprt_done() argument
2913 if (task->tk_status == 0) in rpc_cb_add_xprt_done()
2944 struct rpc_task *task; in rpc_clnt_test_and_add_xprt() local
2968 task = rpc_call_null_helper(clnt, xprt, NULL, RPC_TASK_ASYNC, in rpc_clnt_test_and_add_xprt()
2970 if (IS_ERR(task)) in rpc_clnt_test_and_add_xprt()
2971 return PTR_ERR(task); in rpc_clnt_test_and_add_xprt()
2974 rpc_put_task(task); in rpc_clnt_test_and_add_xprt()
2984 struct rpc_task *task; in rpc_clnt_add_xprt_helper() local
2988 task = rpc_call_null_helper(clnt, xprt, NULL, 0, NULL, NULL); in rpc_clnt_add_xprt_helper()
2989 if (IS_ERR(task)) in rpc_clnt_add_xprt_helper()
2990 return PTR_ERR(task); in rpc_clnt_add_xprt_helper()
2992 status = task->tk_status; in rpc_clnt_add_xprt_helper()
2993 rpc_put_task(task); in rpc_clnt_add_xprt_helper()
3324 const struct rpc_task *task) in rpc_show_task() argument
3328 if (RPC_IS_QUEUED(task)) in rpc_show_task()
3329 rpc_waitq = rpc_qname(task->tk_waitqueue); in rpc_show_task()
3332 task->tk_pid, task->tk_flags, task->tk_status, in rpc_show_task()
3333 clnt, task->tk_rqstp, rpc_task_timeout(task), task->tk_ops, in rpc_show_task()
3334 clnt->cl_program->name, clnt->cl_vers, rpc_proc_name(task), in rpc_show_task()
3335 task->tk_action, rpc_waitq); in rpc_show_task()
3341 struct rpc_task *task; in rpc_show_tasks() local
3348 list_for_each_entry(task, &clnt->cl_tasks, tk_task) { in rpc_show_tasks()
3353 rpc_show_task(clnt, task); in rpc_show_tasks()