Searched refs:rq_task (Results 1 – 14 of 14) sorted by relevance
| /linux/include/trace/events/ |
| H A D | rpcrdma.h | 522 const struct rpc_task *task = req->rl_slot.rq_task; 799 __entry->task_id = rqst->rq_task->tk_pid; 800 __entry->client_id = rqst->rq_task->tk_client->cl_clid; 858 __entry->task_id = rqst->rq_task->tk_pid; 859 __entry->client_id = rqst->rq_task->tk_client->cl_clid; 894 __entry->task_id = rqst->rq_task->tk_pid; 895 __entry->client_id = rqst->rq_task->tk_client->cl_clid; 921 __entry->task_id = rqst->rq_task->tk_pid; 922 __entry->client_id = rqst->rq_task->tk_client->cl_clid; 955 __entry->task_id = rqst->rq_task->tk_pid; [all …]
|
| /linux/net/sunrpc/xprtrdma/ |
| H A D | rpc_rdma.c | 322 trace_xprtrdma_chunk_read(rqst->rq_task, pos, mr, in rpcrdma_encode_read_list() 382 trace_xprtrdma_chunk_write(rqst->rq_task, mr, in rpcrdma_encode_write_list() 393 trace_xprtrdma_chunk_wp(rqst->rq_task, ep->re_write_pad_mr, in rpcrdma_encode_write_list() 457 trace_xprtrdma_chunk_reply(rqst->rq_task, mr, in rpcrdma_encode_reply_chunk() 1350 xprt_complete_rqst(rqst->rq_task, status); in rpcrdma_complete_rqst() 1358 rqst->rq_task->tk_status = status; in rpcrdma_complete_rqst() 1434 trace_xprtrdma_reply(rqst->rq_task, rep, credits); in rpcrdma_reply_handler()
|
| H A D | svc_rdma_backchannel.c | 54 xprt_complete_rqst(req->rq_task, rcvbuf->len); in svc_rdma_handle_bc_reply()
|
| H A D | transport.c | 669 if (!rpc_reply_expected(rqst->rq_task)) in xprt_rdma_send_request()
|
| /linux/net/sunrpc/ |
| H A D | xprt.c | 465 trace_xprt_get_cong(xprt, req->rq_task); in __xprt_get_cong() 487 trace_xprt_put_cong(xprt, req->rq_task); in __xprt_put_cong() 703 const struct rpc_timeout *to = req->rq_task->tk_client->cl_timeout; in xprt_adjust_timeout() 722 rpc_init_rtt(req->rq_task->tk_client->cl_rtt, to->to_initval); in xprt_adjust_timeout() 1112 if (!test_bit(RPC_TASK_MSG_PIN_WAIT, &req->rq_task->tk_runstate)) { in xprt_unpin_rqst() 1370 if (pos->rq_task->tk_owner != task->tk_owner) in xprt_request_enqueue_transmit() 1545 struct rpc_task *task = req->rq_task; in xprt_request_transmit() 1905 req->rq_task = task; in xprt_request_init() 2021 req->rq_task = task; in xprt_init_bc_request()
|
| H A D | svc.c | 771 if (!task_is_running(rqstp->rq_task)) { 772 wake_up_process(rqstp->rq_task); 773 trace_svc_pool_thread_wake(pool, rqstp->rq_task->pid); 776 trace_svc_pool_thread_running(pool, rqstp->rq_task->pid); in svc_new_thread() 815 rqstp->rq_task = task; in svc_start_kthreads()
|
| H A D | stats.c | 189 trace_rpc_stats_latency(req->rq_task, backlog, req->rq_rtt, execute); in rpc_count_iostats_metrics()
|
| H A D | xprtsock.c | 689 xprt_complete_rqst(req->rq_task, transport->recv.copied); in xs_read_stream_reply() 1406 xprt_update_rtt(rovr->rq_task); in xs_udp_data_read_skb() 1408 task = rovr->rq_task; in xs_udp_data_read_skb()
|
| H A D | svcsock.c | 1106 xprt_complete_rqst(req->rq_task, rqstp->rq_arg.len); in receive_cb_reply()
|
| H A D | clnt.c | 1366 trace_rpc_xdr_reply_pages(req->rq_task, &req->rq_rcv_buf); in rpc_prepare_reply_pages()
|
| /linux/fs/nfs/ |
| H A D | nfs2xdr.c | 85 if (rqstp->rq_task) in rpc_rqst_userns() 86 return rpc_userns(rqstp->rq_task->tk_client); in rpc_rqst_userns()
|
| H A D | nfstrace.h | 1944 xdr->rqst->rq_task->tk_client->cl_program->name) 1946 xdr->rqst->rq_task->tk_msg.rpc_proc->p_name) 1951 const struct rpc_task *task = rqstp->rq_task;
|
| H A D | nfs3xdr.c | 116 if (rqstp->rq_task) in rpc_rqst_userns() 117 return rpc_userns(rqstp->rq_task->tk_client); in rpc_rqst_userns()
|
| /linux/include/linux/sunrpc/ |
| H A D | xprt.h | 67 struct rpc_task * rq_task; /* RPC task data */ member
|