Home
last modified time | relevance | path

Searched refs:rqst (Results 1 – 8 of 8) sorted by relevance

/net/sunrpc/xprtrdma/
Dbackchannel.c60 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 …]
Drpc_rdma.c136 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 …]
Dsvc_rdma_backchannel.c97 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 …]
Dtransport.c588 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 …]
Dxprt_rdma.h336 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/
Dsched.c1036 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()
Dxdr.c523 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()
Dxprtsock.c2641 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()