Searched refs:rqst (Results 1 – 8 of 8) sorted by relevance
/net/sunrpc/xprtrdma/ |
D | backchannel.c | 60 static int rpcrdma_bc_marshal_reply(struct rpc_rqst *rqst) in rpcrdma_bc_marshal_reply() argument 62 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(rqst->rq_xprt); in rpcrdma_bc_marshal_reply() 63 struct rpcrdma_req *req = rpcr_to_rdmar(rqst); in rpcrdma_bc_marshal_reply() 68 rdmab_data(req->rl_rdmabuf), rqst); in rpcrdma_bc_marshal_reply() 73 *p++ = rqst->rq_xid; in rpcrdma_bc_marshal_reply() 82 &rqst->rq_snd_buf, rpcrdma_noch)) in rpcrdma_bc_marshal_reply() 85 trace_xprtrdma_cb_reply(rqst); in rpcrdma_bc_marshal_reply() 101 int xprt_rdma_bc_send_reply(struct rpc_rqst *rqst) in xprt_rdma_bc_send_reply() argument 103 struct rpc_xprt *xprt = rqst->rq_xprt; in xprt_rdma_bc_send_reply() 105 struct rpcrdma_req *req = rpcr_to_rdmar(rqst); in xprt_rdma_bc_send_reply() [all …]
|
D | rpc_rdma.c | 136 struct rpc_rqst *rqst) in rpcrdma_args_inline() argument 138 struct xdr_buf *xdr = &rqst->rq_snd_buf; in rpcrdma_args_inline() 167 struct rpc_rqst *rqst) in rpcrdma_results_inline() argument 169 return rqst->rq_rcv_buf.buflen <= r_xprt->rx_ep.rep_max_inline_recv; in rpcrdma_results_inline() 178 const struct rpc_rqst *rqst) in rpcrdma_nonpayload_inline() argument 180 const struct xdr_buf *buf = &rqst->rq_rcv_buf; in rpcrdma_nonpayload_inline() 403 struct rpc_rqst *rqst, in rpcrdma_encode_read_list() argument 415 pos = rqst->rq_snd_buf.head[0].iov_len; in rpcrdma_encode_read_list() 419 nsegs = rpcrdma_convert_iovs(r_xprt, &rqst->rq_snd_buf, pos, in rpcrdma_encode_read_list() 432 trace_xprtrdma_chunk_read(rqst->rq_task, pos, mr, nsegs); in rpcrdma_encode_read_list() [all …]
|
D | svc_rdma_backchannel.c | 97 struct rpc_rqst *rqst, in svc_rdma_bc_sendto() argument 102 ret = svc_rdma_map_reply_msg(rdma, ctxt, &rqst->rq_snd_buf, NULL); in svc_rdma_bc_sendto() 109 get_page(virt_to_page(rqst->rq_buffer)); in svc_rdma_bc_sendto() 121 struct rpc_rqst *rqst = task->tk_rqstp; in xprt_rdma_bc_allocate() local 122 size_t size = rqst->rq_callsize; in xprt_rdma_bc_allocate() 134 rqst->rq_buffer = page_address(page); in xprt_rdma_bc_allocate() 136 rqst->rq_rbuffer = kmalloc(rqst->rq_rcvsize, RPCRDMA_DEF_GFP); in xprt_rdma_bc_allocate() 137 if (!rqst->rq_rbuffer) { in xprt_rdma_bc_allocate() 147 struct rpc_rqst *rqst = task->tk_rqstp; in xprt_rdma_bc_free() local 149 put_page(virt_to_page(rqst->rq_buffer)); in xprt_rdma_bc_free() [all …]
|
D | transport.c | 588 xprt_rdma_free_slot(struct rpc_xprt *xprt, struct rpc_rqst *rqst) in xprt_rdma_free_slot() argument 593 memset(rqst, 0, sizeof(*rqst)); in xprt_rdma_free_slot() 594 rpcrdma_buffer_put(&r_xprt->rx_buf, rpcr_to_rdmar(rqst)); in xprt_rdma_free_slot() 623 struct rpc_rqst *rqst = task->tk_rqstp; in xprt_rdma_allocate() local 624 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(rqst->rq_xprt); in xprt_rdma_allocate() 625 struct rpcrdma_req *req = rpcr_to_rdmar(rqst); in xprt_rdma_allocate() 634 if (!rpcrdma_check_regbuf(r_xprt, req->rl_sendbuf, rqst->rq_callsize, in xprt_rdma_allocate() 637 if (!rpcrdma_check_regbuf(r_xprt, req->rl_recvbuf, rqst->rq_rcvsize, in xprt_rdma_allocate() 641 rqst->rq_buffer = rdmab_data(req->rl_sendbuf); in xprt_rdma_allocate() 642 rqst->rq_rbuffer = rdmab_data(req->rl_recvbuf); in xprt_rdma_allocate() [all …]
|
D | xprt_rdma.h | 336 rpcr_to_rdmar(const struct rpc_rqst *rqst) in rpcr_to_rdmar() argument 338 return container_of(rqst, struct rpcrdma_req, rl_slot); in rpcr_to_rdmar() 580 int rpcrdma_marshal_req(struct rpcrdma_xprt *r_xprt, struct rpc_rqst *rqst); 611 int xprt_rdma_bc_send_reply(struct rpc_rqst *rqst);
|
/net/sunrpc/ |
D | sched.c | 1036 struct rpc_rqst *rqst = task->tk_rqstp; in rpc_malloc() local 1037 size_t size = rqst->rq_callsize + rqst->rq_rcvsize; in rpc_malloc() 1058 rqst->rq_buffer = buf->data; in rpc_malloc() 1059 rqst->rq_rbuffer = (char *)rqst->rq_buffer + rqst->rq_callsize; in rpc_malloc()
|
D | xdr.c | 523 struct rpc_rqst *rqst) in xdr_init_encode() argument 545 xdr->rqst = rqst; in xdr_init_encode() 862 struct rpc_rqst *rqst) in xdr_init_decode() argument 878 xdr->rqst = rqst; in xdr_init_decode()
|
D | xprtsock.c | 2641 struct rpc_rqst *rqst = task->tk_rqstp; in bc_malloc() local 2642 size_t size = rqst->rq_callsize; in bc_malloc() 2659 rqst->rq_buffer = buf->data; in bc_malloc() 2660 rqst->rq_rbuffer = (char *)rqst->rq_buffer + rqst->rq_callsize; in bc_malloc()
|