Home
last modified time | relevance | path

Searched refs:rq_task (Results 1 – 13 of 13) sorted by relevance

/linux/include/trace/events/
H A Drpcrdma.h522 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 Drpc_rdma.c322 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()
1335 * rq_task pointers remain stable. in rpcrdma_complete_rqst()
1367 xprt_complete_rqst(rqst->rq_task, status); in rpcrdma_reply_done()
1375 rqst->rq_task->tk_status = status;
1511 trace_xprtrdma_reply(rqst->rq_task, rep, credits);
H A Dsvc_rdma_backchannel.c54 xprt_complete_rqst(req->rq_task, rcvbuf->len); in svc_rdma_handle_bc_reply()
H A Dtransport.c720 if (!rpc_reply_expected(rqst->rq_task)) in xprt_rdma_print_stats()
/linux/net/sunrpc/
H A Dxprt.c465 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 Dsvc.c695 if (!task_is_running(rqstp->rq_task)) { in svc_pool_wake_idle_thread()
696 wake_up_process(rqstp->rq_task); in svc_pool_wake_idle_thread()
697 trace_svc_pool_thread_wake(pool, rqstp->rq_task->pid); in svc_pool_wake_idle_thread()
700 trace_svc_pool_thread_running(pool, rqstp->rq_task->pid); in svc_pool_wake_idle_thread()
747 rqstp->rq_task = task; in svc_new_thread()
H A Dstats.c189 trace_rpc_stats_latency(req->rq_task, backlog, req->rq_rtt, execute); in rpc_count_iostats_metrics()
H A Dxprtsock.c689 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 Dsvcsock.c1121 xprt_complete_rqst(req->rq_task, rqstp->rq_arg.len); in svc_tcp_fragment_received()
H A Dclnt.c1381 trace_rpc_xdr_reply_pages(req->rq_task, &req->rq_rcv_buf); in rpc_prepare_reply_pages()
/linux/fs/nfs/
H A Dnfs2xdr.c85 if (rqstp->rq_task) in rpc_rqst_userns()
86 return rpc_userns(rqstp->rq_task->tk_client); in rpc_rqst_userns()
/linux/include/linux/sunrpc/
H A Dsvc.h256 struct task_struct *rq_task; /* service thread */ member
H A Dxprt.h67 struct rpc_task * rq_task; /* RPC task data */ member