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()
900 task->tk_flags |= RPC_TASK_SWAPPER; in rpc_task_set_client()
905 list_add_tail(&task->tk_task, &clnt->cl_tasks); in rpc_task_set_client()
910 void rpc_task_reset_client(struct rpc_task *task, struct rpc_clnt *clnt) in rpc_task_reset_client() argument
912 rpc_task_release_client(task); in rpc_task_reset_client()
913 rpc_task_set_client(task, clnt); in rpc_task_reset_client()
919 rpc_task_set_rpc_message(struct rpc_task *task, const struct rpc_message *msg) in rpc_task_set_rpc_message() argument
922 task->tk_msg.rpc_proc = msg->rpc_proc; in rpc_task_set_rpc_message()
923 task->tk_msg.rpc_argp = msg->rpc_argp; in rpc_task_set_rpc_message()
924 task->tk_msg.rpc_resp = msg->rpc_resp; in rpc_task_set_rpc_message()
926 task->tk_msg.rpc_cred = get_rpccred(msg->rpc_cred); in rpc_task_set_rpc_message()
934 rpc_default_callback(struct rpc_task *task, void *data) in rpc_default_callback() argument
948 struct rpc_task *task; in rpc_run_task() local
950 task = rpc_new_task(task_setup_data); in rpc_run_task()
951 if (IS_ERR(task)) in rpc_run_task()
954 rpc_task_set_client(task, task_setup_data->rpc_client); in rpc_run_task()
955 rpc_task_set_rpc_message(task, task_setup_data->rpc_message); in rpc_run_task()
957 if (task->tk_action == NULL) in rpc_run_task()
958 rpc_call_start(task); in rpc_run_task()
960 atomic_inc(&task->tk_count); in rpc_run_task()
961 rpc_execute(task); in rpc_run_task()
963 return task; in rpc_run_task()
975 struct rpc_task *task; in rpc_call_sync() local
991 task = rpc_run_task(&task_setup_data); in rpc_call_sync()
992 if (IS_ERR(task)) in rpc_call_sync()
993 return PTR_ERR(task); in rpc_call_sync()
994 status = task->tk_status; in rpc_call_sync()
995 rpc_put_task(task); in rpc_call_sync()
1012 struct rpc_task *task; in rpc_call_async() local
1021 task = rpc_run_task(&task_setup_data); in rpc_call_async()
1022 if (IS_ERR(task)) in rpc_call_async()
1023 return PTR_ERR(task); in rpc_call_async()
1024 rpc_put_task(task); in rpc_call_async()
1039 struct rpc_task *task; in rpc_run_bc_task() local
1049 task = rpc_new_task(&task_setup_data); in rpc_run_bc_task()
1050 if (IS_ERR(task)) { in rpc_run_bc_task()
1054 task->tk_rqstp = req; in rpc_run_bc_task()
1063 task->tk_action = call_bc_transmit; in rpc_run_bc_task()
1064 atomic_inc(&task->tk_count); in rpc_run_bc_task()
1065 WARN_ON_ONCE(atomic_read(&task->tk_count) != 2); in rpc_run_bc_task()
1066 rpc_execute(task); in rpc_run_bc_task()
1069 dprintk("RPC: rpc_run_bc_task: task= %p\n", task); in rpc_run_bc_task()
1070 return task; in rpc_run_bc_task()
1075 rpc_call_start(struct rpc_task *task) in rpc_call_start() argument
1077 task->tk_action = call_start; in rpc_call_start()
1379 rpc_restart_call_prepare(struct rpc_task *task) in rpc_restart_call_prepare() argument
1381 if (RPC_ASSASSINATED(task)) in rpc_restart_call_prepare()
1383 task->tk_action = call_start; in rpc_restart_call_prepare()
1384 task->tk_status = 0; in rpc_restart_call_prepare()
1385 if (task->tk_ops->rpc_call_prepare != NULL) in rpc_restart_call_prepare()
1386 task->tk_action = rpc_prepare_task; in rpc_restart_call_prepare()
1396 rpc_restart_call(struct rpc_task *task) in rpc_restart_call() argument
1398 if (RPC_ASSASSINATED(task)) in rpc_restart_call()
1400 task->tk_action = call_start; in rpc_restart_call()
1401 task->tk_status = 0; in rpc_restart_call()
1408 *rpc_proc_name(const struct rpc_task *task) in rpc_proc_name() argument
1410 const struct rpc_procinfo *proc = task->tk_msg.rpc_proc; in rpc_proc_name()
1429 call_start(struct rpc_task *task) in call_start() argument
1431 struct rpc_clnt *clnt = task->tk_client; in call_start()
1433 dprintk("RPC: %5u call_start %s%d proc %s (%s)\n", task->tk_pid, in call_start()
1435 rpc_proc_name(task), in call_start()
1436 (RPC_IS_ASYNC(task) ? "async" : "sync")); in call_start()
1439 task->tk_msg.rpc_proc->p_count++; in call_start()
1441 task->tk_action = call_reserve; in call_start()
1448 call_reserve(struct rpc_task *task) in call_reserve() argument
1450 dprint_status(task); in call_reserve()
1452 task->tk_status = 0; in call_reserve()
1453 task->tk_action = call_reserveresult; in call_reserve()
1454 xprt_reserve(task); in call_reserve()
1457 static void call_retry_reserve(struct rpc_task *task);
1463 call_reserveresult(struct rpc_task *task) in call_reserveresult() argument
1465 int status = task->tk_status; in call_reserveresult()
1467 dprint_status(task); in call_reserveresult()
1473 task->tk_status = 0; in call_reserveresult()
1475 if (task->tk_rqstp) { in call_reserveresult()
1476 task->tk_action = call_refresh; in call_reserveresult()
1482 rpc_exit(task, -EIO); in call_reserveresult()
1490 if (task->tk_rqstp) { in call_reserveresult()
1493 xprt_release(task); in call_reserveresult()
1498 rpc_delay(task, HZ >> 2); in call_reserveresult()
1500 task->tk_action = call_retry_reserve; in call_reserveresult()
1509 rpc_exit(task, status); in call_reserveresult()
1516 call_retry_reserve(struct rpc_task *task) in call_retry_reserve() argument
1518 dprint_status(task); in call_retry_reserve()
1520 task->tk_status = 0; in call_retry_reserve()
1521 task->tk_action = call_reserveresult; in call_retry_reserve()
1522 xprt_retry_reserve(task); in call_retry_reserve()
1529 call_refresh(struct rpc_task *task) in call_refresh() argument
1531 dprint_status(task); in call_refresh()
1533 task->tk_action = call_refreshresult; in call_refresh()
1534 task->tk_status = 0; in call_refresh()
1535 task->tk_client->cl_stats->rpcauthrefresh++; in call_refresh()
1536 rpcauth_refreshcred(task); in call_refresh()
1543 call_refreshresult(struct rpc_task *task) in call_refreshresult() argument
1545 int status = task->tk_status; in call_refreshresult()
1547 dprint_status(task); in call_refreshresult()
1549 task->tk_status = 0; in call_refreshresult()
1550 task->tk_action = call_refresh; in call_refreshresult()
1553 if (rpcauth_uptodatecred(task)) { in call_refreshresult()
1554 task->tk_action = call_allocate; in call_refreshresult()
1561 rpc_delay(task, 3*HZ); in call_refreshresult()
1565 if (!task->tk_cred_retry) in call_refreshresult()
1567 task->tk_cred_retry--; in call_refreshresult()
1569 task->tk_pid, __func__); in call_refreshresult()
1573 task->tk_pid, __func__, status); in call_refreshresult()
1574 rpc_exit(task, status); in call_refreshresult()
1582 call_allocate(struct rpc_task *task) in call_allocate() argument
1584 unsigned int slack = task->tk_rqstp->rq_cred->cr_auth->au_cslack; in call_allocate()
1585 struct rpc_rqst *req = task->tk_rqstp; in call_allocate()
1587 struct rpc_procinfo *proc = task->tk_msg.rpc_proc; in call_allocate()
1589 dprint_status(task); in call_allocate()
1591 task->tk_status = 0; in call_allocate()
1592 task->tk_action = call_bind; in call_allocate()
1613 req->rq_buffer = xprt->ops->buf_alloc(task, in call_allocate()
1618 dprintk("RPC: %5u rpc_buffer allocation failed\n", task->tk_pid); in call_allocate()
1620 if (RPC_IS_ASYNC(task) || !fatal_signal_pending(current)) { in call_allocate()
1621 task->tk_action = call_allocate; in call_allocate()
1622 rpc_delay(task, HZ>>4); in call_allocate()
1626 rpc_exit(task, -ERESTARTSYS); in call_allocate()
1630 rpc_task_need_encode(struct rpc_task *task) in rpc_task_need_encode() argument
1632 return task->tk_rqstp->rq_snd_buf.len == 0; in rpc_task_need_encode()
1636 rpc_task_force_reencode(struct rpc_task *task) in rpc_task_force_reencode() argument
1638 task->tk_rqstp->rq_snd_buf.len = 0; in rpc_task_force_reencode()
1639 task->tk_rqstp->rq_bytes_sent = 0; in rpc_task_force_reencode()
1658 rpc_xdr_encode(struct rpc_task *task) in rpc_xdr_encode() argument
1660 struct rpc_rqst *req = task->tk_rqstp; in rpc_xdr_encode()
1664 dprint_status(task); in rpc_xdr_encode()
1673 p = rpc_encode_header(task); in rpc_xdr_encode()
1676 rpc_exit(task, -EIO); in rpc_xdr_encode()
1680 encode = task->tk_msg.rpc_proc->p_encode; in rpc_xdr_encode()
1684 task->tk_status = rpcauth_wrap_req(task, encode, req, p, in rpc_xdr_encode()
1685 task->tk_msg.rpc_argp); in rpc_xdr_encode()
1692 call_bind(struct rpc_task *task) in call_bind() argument
1694 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in call_bind()
1696 dprint_status(task); in call_bind()
1698 task->tk_action = call_connect; in call_bind()
1700 task->tk_action = call_bind_status; in call_bind()
1701 task->tk_timeout = xprt->bind_timeout; in call_bind()
1702 xprt->ops->rpcbind(task); in call_bind()
1710 call_bind_status(struct rpc_task *task) in call_bind_status() argument
1714 if (task->tk_status >= 0) { in call_bind_status()
1715 dprint_status(task); in call_bind_status()
1716 task->tk_status = 0; in call_bind_status()
1717 task->tk_action = call_connect; in call_bind_status()
1721 trace_rpc_bind_status(task); in call_bind_status()
1722 switch (task->tk_status) { in call_bind_status()
1724 dprintk("RPC: %5u rpcbind out of memory\n", task->tk_pid); in call_bind_status()
1725 rpc_delay(task, HZ >> 2); in call_bind_status()
1729 "unavailable\n", task->tk_pid); in call_bind_status()
1731 if (task->tk_msg.rpc_proc->p_proc == 0) { in call_bind_status()
1735 if (task->tk_rebind_retry == 0) in call_bind_status()
1737 task->tk_rebind_retry--; in call_bind_status()
1738 rpc_delay(task, 3*HZ); in call_bind_status()
1742 task->tk_pid); in call_bind_status()
1747 task->tk_pid); in call_bind_status()
1751 task->tk_pid); in call_bind_status()
1763 task->tk_pid, task->tk_status); in call_bind_status()
1764 if (!RPC_IS_SOFTCONN(task)) { in call_bind_status()
1765 rpc_delay(task, 5*HZ); in call_bind_status()
1768 status = task->tk_status; in call_bind_status()
1772 task->tk_pid, -task->tk_status); in call_bind_status()
1775 rpc_exit(task, status); in call_bind_status()
1779 task->tk_status = 0; in call_bind_status()
1780 task->tk_action = call_timeout; in call_bind_status()
1787 call_connect(struct rpc_task *task) in call_connect() argument
1789 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in call_connect()
1792 task->tk_pid, xprt, in call_connect()
1795 task->tk_action = call_transmit; in call_connect()
1797 task->tk_action = call_connect_status; in call_connect()
1798 if (task->tk_status < 0) in call_connect()
1800 if (task->tk_flags & RPC_TASK_NOCONNECT) { in call_connect()
1801 rpc_exit(task, -ENOTCONN); in call_connect()
1804 xprt_connect(task); in call_connect()
1812 call_connect_status(struct rpc_task *task) in call_connect_status() argument
1814 struct rpc_clnt *clnt = task->tk_client; in call_connect_status()
1815 int status = task->tk_status; in call_connect_status()
1817 dprint_status(task); in call_connect_status()
1819 trace_rpc_connect_status(task, status); in call_connect_status()
1820 task->tk_status = 0; in call_connect_status()
1830 if (RPC_IS_SOFTCONN(task)) in call_connect_status()
1833 rpc_delay(task, 3*HZ); in call_connect_status()
1837 task->tk_action = call_timeout; in call_connect_status()
1841 task->tk_action = call_transmit; in call_connect_status()
1844 rpc_exit(task, status); in call_connect_status()
1851 call_transmit(struct rpc_task *task) in call_transmit() argument
1853 int is_retrans = RPC_WAS_SENT(task); in call_transmit()
1855 dprint_status(task); in call_transmit()
1857 task->tk_action = call_status; in call_transmit()
1858 if (task->tk_status < 0) in call_transmit()
1860 if (!xprt_prepare_transmit(task)) in call_transmit()
1862 task->tk_action = call_transmit_status; in call_transmit()
1864 if (rpc_task_need_encode(task)) { in call_transmit()
1865 rpc_xdr_encode(task); in call_transmit()
1867 if (task->tk_status != 0) { in call_transmit()
1869 if (task->tk_status == -EAGAIN) in call_transmit()
1870 rpc_delay(task, HZ >> 4); in call_transmit()
1872 rpc_exit(task, task->tk_status); in call_transmit()
1876 xprt_transmit(task); in call_transmit()
1877 if (task->tk_status < 0) in call_transmit()
1880 task->tk_client->cl_stats->rpcretrans++; in call_transmit()
1885 call_transmit_status(task); in call_transmit()
1886 if (rpc_reply_expected(task)) in call_transmit()
1888 task->tk_action = rpc_exit_task; in call_transmit()
1889 rpc_wake_up_queued_task(&task->tk_rqstp->rq_xprt->pending, task); in call_transmit()
1896 call_transmit_status(struct rpc_task *task) in call_transmit_status() argument
1898 task->tk_action = call_status; in call_transmit_status()
1904 if (task->tk_status == 0) { in call_transmit_status()
1905 xprt_end_transmit(task); in call_transmit_status()
1906 rpc_task_force_reencode(task); in call_transmit_status()
1910 switch (task->tk_status) { in call_transmit_status()
1914 dprint_status(task); in call_transmit_status()
1915 xprt_end_transmit(task); in call_transmit_status()
1916 rpc_task_force_reencode(task); in call_transmit_status()
1929 if (RPC_IS_SOFTCONN(task)) { in call_transmit_status()
1930 xprt_end_transmit(task); in call_transmit_status()
1931 rpc_exit(task, task->tk_status); in call_transmit_status()
1940 rpc_task_force_reencode(task); in call_transmit_status()
1950 call_bc_transmit(struct rpc_task *task) in call_bc_transmit() argument
1952 struct rpc_rqst *req = task->tk_rqstp; in call_bc_transmit()
1954 if (!xprt_prepare_transmit(task)) { in call_bc_transmit()
1959 task->tk_status = 0; in call_bc_transmit()
1960 task->tk_action = call_bc_transmit; in call_bc_transmit()
1964 task->tk_action = rpc_exit_task; in call_bc_transmit()
1965 if (task->tk_status < 0) { in call_bc_transmit()
1967 "error: %d\n", task->tk_status); in call_bc_transmit()
1971 xprt_transmit(task); in call_bc_transmit()
1972 xprt_end_transmit(task); in call_bc_transmit()
1973 dprint_status(task); in call_bc_transmit()
1974 switch (task->tk_status) { in call_bc_transmit()
1990 "error: %d\n", task->tk_status); in call_bc_transmit()
1999 WARN_ON_ONCE(task->tk_status == -EAGAIN); in call_bc_transmit()
2001 "error: %d\n", task->tk_status); in call_bc_transmit()
2004 rpc_wake_up_queued_task(&req->rq_xprt->pending, task); in call_bc_transmit()
2012 call_status(struct rpc_task *task) in call_status() argument
2014 struct rpc_clnt *clnt = task->tk_client; in call_status()
2015 struct rpc_rqst *req = task->tk_rqstp; in call_status()
2019 task->tk_status = req->rq_reply_bytes_recvd; in call_status()
2021 dprint_status(task); in call_status()
2023 status = task->tk_status; in call_status()
2025 task->tk_action = call_decode; in call_status()
2029 trace_rpc_call_status(task); in call_status()
2030 task->tk_status = 0; in call_status()
2036 if (RPC_IS_SOFTCONN(task)) { in call_status()
2037 rpc_exit(task, status); in call_status()
2044 rpc_delay(task, 3*HZ); in call_status()
2046 task->tk_action = call_timeout; in call_status()
2047 if (!(task->tk_flags & RPC_TASK_NO_RETRANS_TIMEOUT) in call_status()
2048 && task->tk_client->cl_discrtry) in call_status()
2058 rpc_delay(task, 3*HZ); in call_status()
2061 task->tk_action = call_bind; in call_status()
2064 task->tk_action = call_transmit; in call_status()
2068 rpc_exit(task, status); in call_status()
2074 rpc_exit(task, status); in call_status()
2084 call_timeout(struct rpc_task *task) in call_timeout() argument
2086 struct rpc_clnt *clnt = task->tk_client; in call_timeout()
2088 if (xprt_adjust_timeout(task->tk_rqstp) == 0) { in call_timeout()
2089 dprintk("RPC: %5u call_timeout (minor)\n", task->tk_pid); in call_timeout()
2093 dprintk("RPC: %5u call_timeout (major)\n", task->tk_pid); in call_timeout()
2094 task->tk_timeouts++; in call_timeout()
2096 if (RPC_IS_SOFTCONN(task)) { in call_timeout()
2097 rpc_exit(task, -ETIMEDOUT); in call_timeout()
2100 if (RPC_IS_SOFT(task)) { in call_timeout()
2108 if (task->tk_flags & RPC_TASK_TIMEOUT) in call_timeout()
2109 rpc_exit(task, -ETIMEDOUT); in call_timeout()
2111 rpc_exit(task, -EIO); in call_timeout()
2115 if (!(task->tk_flags & RPC_CALL_MAJORSEEN)) { in call_timeout()
2116 task->tk_flags |= RPC_CALL_MAJORSEEN; in call_timeout()
2130 rpcauth_invalcred(task); in call_timeout()
2133 task->tk_action = call_bind; in call_timeout()
2134 task->tk_status = 0; in call_timeout()
2141 call_decode(struct rpc_task *task) in call_decode() argument
2143 struct rpc_clnt *clnt = task->tk_client; in call_decode()
2144 struct rpc_rqst *req = task->tk_rqstp; in call_decode()
2145 kxdrdproc_t decode = task->tk_msg.rpc_proc->p_decode; in call_decode()
2148 dprint_status(task); in call_decode()
2150 if (task->tk_flags & RPC_CALL_MAJORSEEN) { in call_decode()
2158 task->tk_flags &= ~RPC_CALL_MAJORSEEN; in call_decode()
2173 if (!RPC_IS_SOFT(task)) { in call_decode()
2174 task->tk_action = call_bind; in call_decode()
2178 clnt->cl_program->name, task->tk_status); in call_decode()
2179 task->tk_action = call_timeout; in call_decode()
2183 p = rpc_verify_header(task); in call_decode()
2190 task->tk_action = rpc_exit_task; in call_decode()
2193 task->tk_status = rpcauth_unwrap_resp(task, decode, req, p, in call_decode()
2194 task->tk_msg.rpc_resp); in call_decode()
2196 dprintk("RPC: %5u call_decode result %d\n", task->tk_pid, in call_decode()
2197 task->tk_status); in call_decode()
2200 task->tk_status = 0; in call_decode()
2202 if (task->tk_rqstp == req) { in call_decode()
2204 if (task->tk_client->cl_discrtry) in call_decode()
2211 rpc_encode_header(struct rpc_task *task) in rpc_encode_header() argument
2213 struct rpc_clnt *clnt = task->tk_client; in rpc_encode_header()
2214 struct rpc_rqst *req = task->tk_rqstp; in rpc_encode_header()
2225 *p++ = htonl(task->tk_msg.rpc_proc->p_proc); /* procedure */ in rpc_encode_header()
2226 p = rpcauth_marshcred(task, p); in rpc_encode_header()
2232 rpc_verify_header(struct rpc_task *task) in rpc_verify_header() argument
2234 struct rpc_clnt *clnt = task->tk_client; in rpc_verify_header()
2235 struct kvec *iov = &task->tk_rqstp->rq_rcv_buf.head[0]; in rpc_verify_header()
2236 int len = task->tk_rqstp->rq_rcv_buf.len >> 2; in rpc_verify_header()
2241 if ((task->tk_rqstp->rq_rcv_buf.len & 3) != 0) { in rpc_verify_header()
2248 " 4 bytes: 0x%x\n", task->tk_pid, __func__, in rpc_verify_header()
2249 task->tk_rqstp->rq_rcv_buf.len); in rpc_verify_header()
2259 task->tk_pid, __func__, n); in rpc_verify_header()
2272 task->tk_pid, __func__); in rpc_verify_header()
2278 task->tk_pid, __func__, n); in rpc_verify_header()
2289 if (!task->tk_cred_retry) in rpc_verify_header()
2291 task->tk_cred_retry--; in rpc_verify_header()
2293 task->tk_pid, __func__); in rpc_verify_header()
2294 rpcauth_invalcred(task); in rpc_verify_header()
2296 xprt_release(task); in rpc_verify_header()
2297 task->tk_action = call_reserve; in rpc_verify_header()
2302 if (!task->tk_garb_retry) in rpc_verify_header()
2304 task->tk_garb_retry--; in rpc_verify_header()
2306 task->tk_pid, __func__); in rpc_verify_header()
2307 task->tk_action = call_bind; in rpc_verify_header()
2318 task->tk_pid, __func__, n); in rpc_verify_header()
2322 task->tk_pid, __func__, n); in rpc_verify_header()
2325 p = rpcauth_checkverf(task, p); in rpc_verify_header()
2329 task->tk_pid, __func__, error); in rpc_verify_header()
2340 "by server %s\n", task->tk_pid, __func__, in rpc_verify_header()
2347 "by server %s\n", task->tk_pid, __func__, in rpc_verify_header()
2356 task->tk_pid, __func__, in rpc_verify_header()
2357 rpc_proc_name(task), in rpc_verify_header()
2364 task->tk_pid, __func__); in rpc_verify_header()
2368 task->tk_pid, __func__, n); in rpc_verify_header()
2374 if (task->tk_garb_retry) { in rpc_verify_header()
2375 task->tk_garb_retry--; in rpc_verify_header()
2377 task->tk_pid, __func__); in rpc_verify_header()
2378 task->tk_action = call_bind; in rpc_verify_header()
2383 rpc_exit(task, error); in rpc_verify_header()
2384 dprintk("RPC: %5u %s: call failed with error %d\n", task->tk_pid, in rpc_verify_header()
2388 dprintk("RPC: %5u %s: server reply was truncated.\n", task->tk_pid, in rpc_verify_header()
2443 const struct rpc_task *task) in rpc_show_task() argument
2447 if (RPC_IS_QUEUED(task)) in rpc_show_task()
2448 rpc_waitq = rpc_qname(task->tk_waitqueue); in rpc_show_task()
2451 task->tk_pid, task->tk_flags, task->tk_status, in rpc_show_task()
2452 clnt, task->tk_rqstp, task->tk_timeout, task->tk_ops, in rpc_show_task()
2453 clnt->cl_program->name, clnt->cl_vers, rpc_proc_name(task), in rpc_show_task()
2454 task->tk_action, rpc_waitq); in rpc_show_task()
2460 struct rpc_task *task; in rpc_show_tasks() local
2467 list_for_each_entry(task, &clnt->cl_tasks, tk_task) { in rpc_show_tasks()
2472 rpc_show_task(clnt, task); in rpc_show_tasks()