Lines Matching refs:rep
82 struct rpcrdma_rep *rep; in rpcrdma_run_tasklet() local
89 rep = list_entry(rpcrdma_tasklets_g.next, in rpcrdma_run_tasklet()
91 list_del(&rep->rr_list); in rpcrdma_run_tasklet()
92 func = rep->rr_func; in rpcrdma_run_tasklet()
93 rep->rr_func = NULL; in rpcrdma_run_tasklet()
97 func(rep); in rpcrdma_run_tasklet()
99 rpcrdma_recv_buffer_put(rep); in rpcrdma_run_tasklet()
279 struct rpcrdma_rep *rep = in rpcrdma_recvcq_process_wc() local
291 __func__, rep, wc->byte_len); in rpcrdma_recvcq_process_wc()
293 rep->rr_len = wc->byte_len; in rpcrdma_recvcq_process_wc()
294 ib_dma_sync_single_for_cpu(rdmab_to_ia(rep->rr_buffer)->ri_id->device, in rpcrdma_recvcq_process_wc()
295 rdmab_addr(rep->rr_rdmabuf), in rpcrdma_recvcq_process_wc()
296 rep->rr_len, DMA_FROM_DEVICE); in rpcrdma_recvcq_process_wc()
297 prefetch(rdmab_to_msg(rep->rr_rdmabuf)); in rpcrdma_recvcq_process_wc()
300 list_add_tail(&rep->rr_list, sched_list); in rpcrdma_recvcq_process_wc()
305 __func__, rep, COMPLETION_MSG(wc->status)); in rpcrdma_recvcq_process_wc()
306 rep->rr_len = ~0U; in rpcrdma_recvcq_process_wc()
1041 struct rpcrdma_rep *rep; in rpcrdma_create_rep() local
1045 rep = kzalloc(sizeof(*rep), GFP_KERNEL); in rpcrdma_create_rep()
1046 if (rep == NULL) in rpcrdma_create_rep()
1049 rep->rr_rdmabuf = rpcrdma_alloc_regbuf(ia, cdata->inline_rsize, in rpcrdma_create_rep()
1051 if (IS_ERR(rep->rr_rdmabuf)) { in rpcrdma_create_rep()
1052 rc = PTR_ERR(rep->rr_rdmabuf); in rpcrdma_create_rep()
1056 rep->rr_buffer = &r_xprt->rx_buf; in rpcrdma_create_rep()
1057 return rep; in rpcrdma_create_rep()
1060 kfree(rep); in rpcrdma_create_rep()
1107 struct rpcrdma_rep *rep; in rpcrdma_buffer_create() local
1118 rep = rpcrdma_create_rep(r_xprt); in rpcrdma_buffer_create()
1119 if (IS_ERR(rep)) { in rpcrdma_buffer_create()
1122 rc = PTR_ERR(rep); in rpcrdma_buffer_create()
1125 buf->rb_recv_bufs[i] = rep; in rpcrdma_buffer_create()
1135 rpcrdma_destroy_rep(struct rpcrdma_ia *ia, struct rpcrdma_rep *rep) in rpcrdma_destroy_rep() argument
1137 if (!rep) in rpcrdma_destroy_rep()
1140 rpcrdma_free_regbuf(ia, rep->rr_rdmabuf); in rpcrdma_destroy_rep()
1141 kfree(rep); in rpcrdma_destroy_rep()
1424 rpcrdma_recv_buffer_put(struct rpcrdma_rep *rep) in rpcrdma_recv_buffer_put() argument
1426 struct rpcrdma_buffer *buffers = rep->rr_buffer; in rpcrdma_recv_buffer_put()
1429 rep->rr_func = NULL; in rpcrdma_recv_buffer_put()
1431 buffers->rb_recv_bufs[--buffers->rb_recv_index] = rep; in rpcrdma_recv_buffer_put()
1582 struct rpcrdma_rep *rep = req->rl_reply; in rpcrdma_ep_post() local
1585 if (rep) { in rpcrdma_ep_post()
1586 rc = rpcrdma_ep_post_recv(ia, ep, rep); in rpcrdma_ep_post()
1629 struct rpcrdma_rep *rep) in rpcrdma_ep_post_recv() argument
1635 recv_wr.wr_id = (u64) (unsigned long) rep; in rpcrdma_ep_post_recv()
1636 recv_wr.sg_list = &rep->rr_rdmabuf->rg_iov; in rpcrdma_ep_post_recv()
1640 rdmab_addr(rep->rr_rdmabuf), in rpcrdma_ep_post_recv()
1641 rdmab_length(rep->rr_rdmabuf), in rpcrdma_ep_post_recv()