Lines Matching refs:task
60 static void call_start(struct rpc_task *task);
61 static void call_reserve(struct rpc_task *task);
62 static void call_reserveresult(struct rpc_task *task);
63 static void call_allocate(struct rpc_task *task);
64 static void call_decode(struct rpc_task *task);
65 static void call_bind(struct rpc_task *task);
66 static void call_bind_status(struct rpc_task *task);
67 static void call_transmit(struct rpc_task *task);
69 static void call_bc_transmit(struct rpc_task *task);
71 static void call_status(struct rpc_task *task);
72 static void call_transmit_status(struct rpc_task *task);
73 static void call_refresh(struct rpc_task *task);
74 static void call_refreshresult(struct rpc_task *task);
75 static void call_timeout(struct rpc_task *task);
76 static void call_connect(struct rpc_task *task);
77 static void call_connect_status(struct rpc_task *task);
79 static __be32 *rpc_encode_header(struct rpc_task *task);
80 static __be32 *rpc_verify_header(struct rpc_task *task);
868 void rpc_task_release_client(struct rpc_task *task) in rpc_task_release_client() argument
870 struct rpc_clnt *clnt = task->tk_client; in rpc_task_release_client()
875 list_del(&task->tk_task); in rpc_task_release_client()
877 task->tk_client = NULL; in rpc_task_release_client()
884 void rpc_task_set_client(struct rpc_task *task, struct rpc_clnt *clnt) in rpc_task_set_client() argument
887 rpc_task_release_client(task); in rpc_task_set_client()
888 task->tk_client = clnt; in rpc_task_set_client()
891 task->tk_flags |= RPC_TASK_SOFT; in rpc_task_set_client()
893 task->tk_flags |= RPC_TASK_NO_RETRANS_TIMEOUT; in rpc_task_set_client()
895 task->tk_flags |= RPC_TASK_SWAPPER; in rpc_task_set_client()
898 list_add_tail(&task->tk_task, &clnt->cl_tasks); in rpc_task_set_client()
903 void rpc_task_reset_client(struct rpc_task *task, struct rpc_clnt *clnt) in rpc_task_reset_client() argument
905 rpc_task_release_client(task); in rpc_task_reset_client()
906 rpc_task_set_client(task, clnt); in rpc_task_reset_client()
912 rpc_task_set_rpc_message(struct rpc_task *task, const struct rpc_message *msg) in rpc_task_set_rpc_message() argument
915 task->tk_msg.rpc_proc = msg->rpc_proc; in rpc_task_set_rpc_message()
916 task->tk_msg.rpc_argp = msg->rpc_argp; in rpc_task_set_rpc_message()
917 task->tk_msg.rpc_resp = msg->rpc_resp; in rpc_task_set_rpc_message()
919 task->tk_msg.rpc_cred = get_rpccred(msg->rpc_cred); in rpc_task_set_rpc_message()
927 rpc_default_callback(struct rpc_task *task, void *data) in rpc_default_callback() argument
941 struct rpc_task *task; in rpc_run_task() local
943 task = rpc_new_task(task_setup_data); in rpc_run_task()
944 if (IS_ERR(task)) in rpc_run_task()
947 rpc_task_set_client(task, task_setup_data->rpc_client); in rpc_run_task()
948 rpc_task_set_rpc_message(task, task_setup_data->rpc_message); in rpc_run_task()
950 if (task->tk_action == NULL) in rpc_run_task()
951 rpc_call_start(task); in rpc_run_task()
953 atomic_inc(&task->tk_count); in rpc_run_task()
954 rpc_execute(task); in rpc_run_task()
956 return task; in rpc_run_task()
968 struct rpc_task *task; in rpc_call_sync() local
984 task = rpc_run_task(&task_setup_data); in rpc_call_sync()
985 if (IS_ERR(task)) in rpc_call_sync()
986 return PTR_ERR(task); in rpc_call_sync()
987 status = task->tk_status; in rpc_call_sync()
988 rpc_put_task(task); in rpc_call_sync()
1005 struct rpc_task *task; in rpc_call_async() local
1014 task = rpc_run_task(&task_setup_data); in rpc_call_async()
1015 if (IS_ERR(task)) in rpc_call_async()
1016 return PTR_ERR(task); in rpc_call_async()
1017 rpc_put_task(task); in rpc_call_async()
1030 struct rpc_task *task; in rpc_run_bc_task() local
1041 task = rpc_new_task(&task_setup_data); in rpc_run_bc_task()
1042 if (IS_ERR(task)) { in rpc_run_bc_task()
1046 task->tk_rqstp = req; in rpc_run_bc_task()
1055 task->tk_action = call_bc_transmit; in rpc_run_bc_task()
1056 atomic_inc(&task->tk_count); in rpc_run_bc_task()
1057 WARN_ON_ONCE(atomic_read(&task->tk_count) != 2); in rpc_run_bc_task()
1058 rpc_execute(task); in rpc_run_bc_task()
1061 dprintk("RPC: rpc_run_bc_task: task= %p\n", task); in rpc_run_bc_task()
1062 return task; in rpc_run_bc_task()
1067 rpc_call_start(struct rpc_task *task) in rpc_call_start() argument
1069 task->tk_action = call_start; in rpc_call_start()
1371 rpc_restart_call_prepare(struct rpc_task *task) in rpc_restart_call_prepare() argument
1373 if (RPC_ASSASSINATED(task)) in rpc_restart_call_prepare()
1375 task->tk_action = call_start; in rpc_restart_call_prepare()
1376 task->tk_status = 0; in rpc_restart_call_prepare()
1377 if (task->tk_ops->rpc_call_prepare != NULL) in rpc_restart_call_prepare()
1378 task->tk_action = rpc_prepare_task; in rpc_restart_call_prepare()
1388 rpc_restart_call(struct rpc_task *task) in rpc_restart_call() argument
1390 if (RPC_ASSASSINATED(task)) in rpc_restart_call()
1392 task->tk_action = call_start; in rpc_restart_call()
1393 task->tk_status = 0; in rpc_restart_call()
1400 *rpc_proc_name(const struct rpc_task *task) in rpc_proc_name() argument
1402 const struct rpc_procinfo *proc = task->tk_msg.rpc_proc; in rpc_proc_name()
1421 call_start(struct rpc_task *task) in call_start() argument
1423 struct rpc_clnt *clnt = task->tk_client; in call_start()
1425 dprintk("RPC: %5u call_start %s%d proc %s (%s)\n", task->tk_pid, in call_start()
1427 rpc_proc_name(task), in call_start()
1428 (RPC_IS_ASYNC(task) ? "async" : "sync")); in call_start()
1431 task->tk_msg.rpc_proc->p_count++; in call_start()
1433 task->tk_action = call_reserve; in call_start()
1440 call_reserve(struct rpc_task *task) in call_reserve() argument
1442 dprint_status(task); in call_reserve()
1444 task->tk_status = 0; in call_reserve()
1445 task->tk_action = call_reserveresult; in call_reserve()
1446 xprt_reserve(task); in call_reserve()
1449 static void call_retry_reserve(struct rpc_task *task);
1455 call_reserveresult(struct rpc_task *task) in call_reserveresult() argument
1457 int status = task->tk_status; in call_reserveresult()
1459 dprint_status(task); in call_reserveresult()
1465 task->tk_status = 0; in call_reserveresult()
1467 if (task->tk_rqstp) { in call_reserveresult()
1468 task->tk_action = call_refresh; in call_reserveresult()
1474 rpc_exit(task, -EIO); in call_reserveresult()
1482 if (task->tk_rqstp) { in call_reserveresult()
1485 xprt_release(task); in call_reserveresult()
1490 rpc_delay(task, HZ >> 2); in call_reserveresult()
1492 task->tk_action = call_retry_reserve; in call_reserveresult()
1501 rpc_exit(task, status); in call_reserveresult()
1508 call_retry_reserve(struct rpc_task *task) in call_retry_reserve() argument
1510 dprint_status(task); in call_retry_reserve()
1512 task->tk_status = 0; in call_retry_reserve()
1513 task->tk_action = call_reserveresult; in call_retry_reserve()
1514 xprt_retry_reserve(task); in call_retry_reserve()
1521 call_refresh(struct rpc_task *task) in call_refresh() argument
1523 dprint_status(task); in call_refresh()
1525 task->tk_action = call_refreshresult; in call_refresh()
1526 task->tk_status = 0; in call_refresh()
1527 task->tk_client->cl_stats->rpcauthrefresh++; in call_refresh()
1528 rpcauth_refreshcred(task); in call_refresh()
1535 call_refreshresult(struct rpc_task *task) in call_refreshresult() argument
1537 int status = task->tk_status; in call_refreshresult()
1539 dprint_status(task); in call_refreshresult()
1541 task->tk_status = 0; in call_refreshresult()
1542 task->tk_action = call_refresh; in call_refreshresult()
1545 if (rpcauth_uptodatecred(task)) { in call_refreshresult()
1546 task->tk_action = call_allocate; in call_refreshresult()
1553 rpc_delay(task, 3*HZ); in call_refreshresult()
1557 if (!task->tk_cred_retry) in call_refreshresult()
1559 task->tk_cred_retry--; in call_refreshresult()
1561 task->tk_pid, __func__); in call_refreshresult()
1565 task->tk_pid, __func__, status); in call_refreshresult()
1566 rpc_exit(task, status); in call_refreshresult()
1574 call_allocate(struct rpc_task *task) in call_allocate() argument
1576 unsigned int slack = task->tk_rqstp->rq_cred->cr_auth->au_cslack; in call_allocate()
1577 struct rpc_rqst *req = task->tk_rqstp; in call_allocate()
1579 struct rpc_procinfo *proc = task->tk_msg.rpc_proc; in call_allocate()
1581 dprint_status(task); in call_allocate()
1583 task->tk_status = 0; in call_allocate()
1584 task->tk_action = call_bind; in call_allocate()
1605 req->rq_buffer = xprt->ops->buf_alloc(task, in call_allocate()
1611 dprintk("RPC: %5u rpc_buffer allocation failed\n", task->tk_pid); in call_allocate()
1613 if (RPC_IS_ASYNC(task) || !fatal_signal_pending(current)) { in call_allocate()
1614 task->tk_action = call_allocate; in call_allocate()
1615 rpc_delay(task, HZ>>4); in call_allocate()
1619 rpc_exit(task, -ERESTARTSYS); in call_allocate()
1623 rpc_task_need_encode(struct rpc_task *task) in rpc_task_need_encode() argument
1625 return task->tk_rqstp->rq_snd_buf.len == 0; in rpc_task_need_encode()
1629 rpc_task_force_reencode(struct rpc_task *task) in rpc_task_force_reencode() argument
1631 task->tk_rqstp->rq_snd_buf.len = 0; in rpc_task_force_reencode()
1632 task->tk_rqstp->rq_bytes_sent = 0; in rpc_task_force_reencode()
1651 rpc_xdr_encode(struct rpc_task *task) in rpc_xdr_encode() argument
1653 struct rpc_rqst *req = task->tk_rqstp; in rpc_xdr_encode()
1657 dprint_status(task); in rpc_xdr_encode()
1666 p = rpc_encode_header(task); in rpc_xdr_encode()
1669 rpc_exit(task, -EIO); in rpc_xdr_encode()
1673 encode = task->tk_msg.rpc_proc->p_encode; in rpc_xdr_encode()
1677 task->tk_status = rpcauth_wrap_req(task, encode, req, p, in rpc_xdr_encode()
1678 task->tk_msg.rpc_argp); in rpc_xdr_encode()
1685 call_bind(struct rpc_task *task) in call_bind() argument
1687 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in call_bind()
1689 dprint_status(task); in call_bind()
1691 task->tk_action = call_connect; in call_bind()
1693 task->tk_action = call_bind_status; in call_bind()
1694 task->tk_timeout = xprt->bind_timeout; in call_bind()
1695 xprt->ops->rpcbind(task); in call_bind()
1703 call_bind_status(struct rpc_task *task) in call_bind_status() argument
1707 if (task->tk_status >= 0) { in call_bind_status()
1708 dprint_status(task); in call_bind_status()
1709 task->tk_status = 0; in call_bind_status()
1710 task->tk_action = call_connect; in call_bind_status()
1714 trace_rpc_bind_status(task); in call_bind_status()
1715 switch (task->tk_status) { in call_bind_status()
1717 dprintk("RPC: %5u rpcbind out of memory\n", task->tk_pid); in call_bind_status()
1718 rpc_delay(task, HZ >> 2); in call_bind_status()
1722 "unavailable\n", task->tk_pid); in call_bind_status()
1724 if (task->tk_msg.rpc_proc->p_proc == 0) { in call_bind_status()
1728 if (task->tk_rebind_retry == 0) in call_bind_status()
1730 task->tk_rebind_retry--; in call_bind_status()
1731 rpc_delay(task, 3*HZ); in call_bind_status()
1735 task->tk_pid); in call_bind_status()
1740 task->tk_pid); in call_bind_status()
1744 task->tk_pid); in call_bind_status()
1756 task->tk_pid, task->tk_status); in call_bind_status()
1757 if (!RPC_IS_SOFTCONN(task)) { in call_bind_status()
1758 rpc_delay(task, 5*HZ); in call_bind_status()
1761 status = task->tk_status; in call_bind_status()
1765 task->tk_pid, -task->tk_status); in call_bind_status()
1768 rpc_exit(task, status); in call_bind_status()
1772 task->tk_status = 0; in call_bind_status()
1773 task->tk_action = call_timeout; in call_bind_status()
1780 call_connect(struct rpc_task *task) in call_connect() argument
1782 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in call_connect()
1785 task->tk_pid, xprt, in call_connect()
1788 task->tk_action = call_transmit; in call_connect()
1790 task->tk_action = call_connect_status; in call_connect()
1791 if (task->tk_status < 0) in call_connect()
1793 if (task->tk_flags & RPC_TASK_NOCONNECT) { in call_connect()
1794 rpc_exit(task, -ENOTCONN); in call_connect()
1797 xprt_connect(task); in call_connect()
1805 call_connect_status(struct rpc_task *task) in call_connect_status() argument
1807 struct rpc_clnt *clnt = task->tk_client; in call_connect_status()
1808 int status = task->tk_status; in call_connect_status()
1810 dprint_status(task); in call_connect_status()
1812 trace_rpc_connect_status(task, status); in call_connect_status()
1813 task->tk_status = 0; in call_connect_status()
1823 if (RPC_IS_SOFTCONN(task)) in call_connect_status()
1826 rpc_delay(task, 3*HZ); in call_connect_status()
1830 task->tk_action = call_timeout; in call_connect_status()
1834 task->tk_action = call_transmit; in call_connect_status()
1837 rpc_exit(task, status); in call_connect_status()
1844 call_transmit(struct rpc_task *task) in call_transmit() argument
1846 int is_retrans = RPC_WAS_SENT(task); in call_transmit()
1848 dprint_status(task); in call_transmit()
1850 task->tk_action = call_status; in call_transmit()
1851 if (task->tk_status < 0) in call_transmit()
1853 if (!xprt_prepare_transmit(task)) in call_transmit()
1855 task->tk_action = call_transmit_status; in call_transmit()
1857 if (rpc_task_need_encode(task)) { in call_transmit()
1858 rpc_xdr_encode(task); in call_transmit()
1860 if (task->tk_status != 0) { in call_transmit()
1862 if (task->tk_status == -EAGAIN) in call_transmit()
1863 rpc_delay(task, HZ >> 4); in call_transmit()
1865 rpc_exit(task, task->tk_status); in call_transmit()
1869 xprt_transmit(task); in call_transmit()
1870 if (task->tk_status < 0) in call_transmit()
1873 task->tk_client->cl_stats->rpcretrans++; in call_transmit()
1878 call_transmit_status(task); in call_transmit()
1879 if (rpc_reply_expected(task)) in call_transmit()
1881 task->tk_action = rpc_exit_task; in call_transmit()
1882 rpc_wake_up_queued_task(&task->tk_rqstp->rq_xprt->pending, task); in call_transmit()
1889 call_transmit_status(struct rpc_task *task) in call_transmit_status() argument
1891 task->tk_action = call_status; in call_transmit_status()
1897 if (task->tk_status == 0) { in call_transmit_status()
1898 xprt_end_transmit(task); in call_transmit_status()
1899 rpc_task_force_reencode(task); in call_transmit_status()
1903 switch (task->tk_status) { in call_transmit_status()
1908 dprint_status(task); in call_transmit_status()
1909 xprt_end_transmit(task); in call_transmit_status()
1910 rpc_task_force_reencode(task); in call_transmit_status()
1923 if (RPC_IS_SOFTCONN(task)) { in call_transmit_status()
1924 xprt_end_transmit(task); in call_transmit_status()
1925 rpc_exit(task, task->tk_status); in call_transmit_status()
1933 rpc_task_force_reencode(task); in call_transmit_status()
1943 call_bc_transmit(struct rpc_task *task) in call_bc_transmit() argument
1945 struct rpc_rqst *req = task->tk_rqstp; in call_bc_transmit()
1947 if (!xprt_prepare_transmit(task)) in call_bc_transmit()
1950 if (task->tk_status < 0) { in call_bc_transmit()
1952 "error: %d\n", task->tk_status); in call_bc_transmit()
1958 xprt_transmit(task); in call_bc_transmit()
1960 if (task->tk_status == -EAGAIN) in call_bc_transmit()
1963 xprt_end_transmit(task); in call_bc_transmit()
1964 dprint_status(task); in call_bc_transmit()
1965 switch (task->tk_status) { in call_bc_transmit()
1986 "error: %d\n", task->tk_status); in call_bc_transmit()
1995 WARN_ON_ONCE(task->tk_status == -EAGAIN); in call_bc_transmit()
1997 "error: %d\n", task->tk_status); in call_bc_transmit()
2000 rpc_wake_up_queued_task(&req->rq_xprt->pending, task); in call_bc_transmit()
2002 task->tk_action = rpc_exit_task; in call_bc_transmit()
2007 task->tk_status = 0; in call_bc_transmit()
2015 call_status(struct rpc_task *task) in call_status() argument
2017 struct rpc_clnt *clnt = task->tk_client; in call_status()
2018 struct rpc_rqst *req = task->tk_rqstp; in call_status()
2022 task->tk_status = req->rq_reply_bytes_recvd; in call_status()
2024 dprint_status(task); in call_status()
2026 status = task->tk_status; in call_status()
2028 task->tk_action = call_decode; in call_status()
2032 trace_rpc_call_status(task); in call_status()
2033 task->tk_status = 0; in call_status()
2039 if (RPC_IS_SOFTCONN(task)) { in call_status()
2040 rpc_exit(task, status); in call_status()
2047 rpc_delay(task, 3*HZ); in call_status()
2049 task->tk_action = call_timeout; in call_status()
2050 if (!(task->tk_flags & RPC_TASK_NO_RETRANS_TIMEOUT) in call_status()
2051 && task->tk_client->cl_discrtry) in call_status()
2060 rpc_delay(task, 3*HZ); in call_status()
2063 task->tk_action = call_bind; in call_status()
2066 rpc_delay(task, HZ>>2); in call_status()
2068 task->tk_action = call_transmit; in call_status()
2072 rpc_exit(task, status); in call_status()
2078 rpc_exit(task, status); in call_status()
2088 call_timeout(struct rpc_task *task) in call_timeout() argument
2090 struct rpc_clnt *clnt = task->tk_client; in call_timeout()
2092 if (xprt_adjust_timeout(task->tk_rqstp) == 0) { in call_timeout()
2093 dprintk("RPC: %5u call_timeout (minor)\n", task->tk_pid); in call_timeout()
2097 dprintk("RPC: %5u call_timeout (major)\n", task->tk_pid); in call_timeout()
2098 task->tk_timeouts++; in call_timeout()
2100 if (RPC_IS_SOFTCONN(task)) { in call_timeout()
2101 rpc_exit(task, -ETIMEDOUT); in call_timeout()
2104 if (RPC_IS_SOFT(task)) { in call_timeout()
2112 if (task->tk_flags & RPC_TASK_TIMEOUT) in call_timeout()
2113 rpc_exit(task, -ETIMEDOUT); in call_timeout()
2115 rpc_exit(task, -EIO); in call_timeout()
2119 if (!(task->tk_flags & RPC_CALL_MAJORSEEN)) { in call_timeout()
2120 task->tk_flags |= RPC_CALL_MAJORSEEN; in call_timeout()
2134 rpcauth_invalcred(task); in call_timeout()
2137 task->tk_action = call_bind; in call_timeout()
2138 task->tk_status = 0; in call_timeout()
2145 call_decode(struct rpc_task *task) in call_decode() argument
2147 struct rpc_clnt *clnt = task->tk_client; in call_decode()
2148 struct rpc_rqst *req = task->tk_rqstp; in call_decode()
2149 kxdrdproc_t decode = task->tk_msg.rpc_proc->p_decode; in call_decode()
2152 dprint_status(task); in call_decode()
2154 if (task->tk_flags & RPC_CALL_MAJORSEEN) { in call_decode()
2162 task->tk_flags &= ~RPC_CALL_MAJORSEEN; in call_decode()
2177 if (!RPC_IS_SOFT(task)) { in call_decode()
2178 task->tk_action = call_bind; in call_decode()
2182 clnt->cl_program->name, task->tk_status); in call_decode()
2183 task->tk_action = call_timeout; in call_decode()
2187 p = rpc_verify_header(task); in call_decode()
2194 task->tk_action = rpc_exit_task; in call_decode()
2197 task->tk_status = rpcauth_unwrap_resp(task, decode, req, p, in call_decode()
2198 task->tk_msg.rpc_resp); in call_decode()
2200 dprintk("RPC: %5u call_decode result %d\n", task->tk_pid, in call_decode()
2201 task->tk_status); in call_decode()
2204 task->tk_status = 0; in call_decode()
2206 if (task->tk_rqstp == req) { in call_decode()
2208 if (task->tk_client->cl_discrtry) in call_decode()
2215 rpc_encode_header(struct rpc_task *task) in rpc_encode_header() argument
2217 struct rpc_clnt *clnt = task->tk_client; in rpc_encode_header()
2218 struct rpc_rqst *req = task->tk_rqstp; in rpc_encode_header()
2229 *p++ = htonl(task->tk_msg.rpc_proc->p_proc); /* procedure */ in rpc_encode_header()
2230 p = rpcauth_marshcred(task, p); in rpc_encode_header()
2236 rpc_verify_header(struct rpc_task *task) in rpc_verify_header() argument
2238 struct rpc_clnt *clnt = task->tk_client; in rpc_verify_header()
2239 struct kvec *iov = &task->tk_rqstp->rq_rcv_buf.head[0]; in rpc_verify_header()
2240 int len = task->tk_rqstp->rq_rcv_buf.len >> 2; in rpc_verify_header()
2245 if ((task->tk_rqstp->rq_rcv_buf.len & 3) != 0) { in rpc_verify_header()
2252 " 4 bytes: 0x%x\n", task->tk_pid, __func__, in rpc_verify_header()
2253 task->tk_rqstp->rq_rcv_buf.len); in rpc_verify_header()
2263 task->tk_pid, __func__, n); in rpc_verify_header()
2276 task->tk_pid, __func__); in rpc_verify_header()
2282 task->tk_pid, __func__, n); in rpc_verify_header()
2293 if (!task->tk_cred_retry) in rpc_verify_header()
2295 task->tk_cred_retry--; in rpc_verify_header()
2297 task->tk_pid, __func__); in rpc_verify_header()
2298 rpcauth_invalcred(task); in rpc_verify_header()
2300 xprt_release(task); in rpc_verify_header()
2301 task->tk_action = call_reserve; in rpc_verify_header()
2306 if (!task->tk_garb_retry) in rpc_verify_header()
2308 task->tk_garb_retry--; in rpc_verify_header()
2310 task->tk_pid, __func__); in rpc_verify_header()
2311 task->tk_action = call_bind; in rpc_verify_header()
2322 task->tk_pid, __func__, n); in rpc_verify_header()
2326 task->tk_pid, __func__, n); in rpc_verify_header()
2329 p = rpcauth_checkverf(task, p); in rpc_verify_header()
2333 task->tk_pid, __func__, error); in rpc_verify_header()
2344 "by server %s\n", task->tk_pid, __func__, in rpc_verify_header()
2351 "by server %s\n", task->tk_pid, __func__, in rpc_verify_header()
2360 task->tk_pid, __func__, in rpc_verify_header()
2361 rpc_proc_name(task), in rpc_verify_header()
2368 task->tk_pid, __func__); in rpc_verify_header()
2372 task->tk_pid, __func__, n); in rpc_verify_header()
2378 if (task->tk_garb_retry) { in rpc_verify_header()
2379 task->tk_garb_retry--; in rpc_verify_header()
2381 task->tk_pid, __func__); in rpc_verify_header()
2382 task->tk_action = call_bind; in rpc_verify_header()
2387 rpc_exit(task, error); in rpc_verify_header()
2388 dprintk("RPC: %5u %s: call failed with error %d\n", task->tk_pid, in rpc_verify_header()
2392 dprintk("RPC: %5u %s: server reply was truncated.\n", task->tk_pid, in rpc_verify_header()
2447 const struct rpc_task *task) in rpc_show_task() argument
2451 if (RPC_IS_QUEUED(task)) in rpc_show_task()
2452 rpc_waitq = rpc_qname(task->tk_waitqueue); in rpc_show_task()
2455 task->tk_pid, task->tk_flags, task->tk_status, in rpc_show_task()
2456 clnt, task->tk_rqstp, task->tk_timeout, task->tk_ops, in rpc_show_task()
2457 clnt->cl_program->name, clnt->cl_vers, rpc_proc_name(task), in rpc_show_task()
2458 task->tk_action, rpc_waitq); in rpc_show_task()
2464 struct rpc_task *task; in rpc_show_tasks() local
2471 list_for_each_entry(task, &clnt->cl_tasks, tk_task) { in rpc_show_tasks()
2476 rpc_show_task(clnt, task); in rpc_show_tasks()