Lines Matching refs:rep

187 	struct rpcrdma_rep *rep =  in rpcrdma_receive_worker()  local
190 rpcrdma_reply_handler(rep); in rpcrdma_receive_worker()
196 struct rpcrdma_rep *rep = in rpcrdma_recvcq_process_wc() local
208 __func__, rep, wc->byte_len); in rpcrdma_recvcq_process_wc()
210 rep->rr_len = wc->byte_len; in rpcrdma_recvcq_process_wc()
211 ib_dma_sync_single_for_cpu(rep->rr_device, in rpcrdma_recvcq_process_wc()
212 rdmab_addr(rep->rr_rdmabuf), in rpcrdma_recvcq_process_wc()
213 rep->rr_len, DMA_FROM_DEVICE); in rpcrdma_recvcq_process_wc()
214 prefetch(rdmab_to_msg(rep->rr_rdmabuf)); in rpcrdma_recvcq_process_wc()
217 queue_work(rpcrdma_receive_wq, &rep->rr_work); in rpcrdma_recvcq_process_wc()
223 __func__, rep, ib_wc_status_msg(wc->status)); in rpcrdma_recvcq_process_wc()
224 rep->rr_len = RPCRDMA_BAD_LEN; in rpcrdma_recvcq_process_wc()
919 struct rpcrdma_rep *rep; in rpcrdma_create_rep() local
923 rep = kzalloc(sizeof(*rep), GFP_KERNEL); in rpcrdma_create_rep()
924 if (rep == NULL) in rpcrdma_create_rep()
927 rep->rr_rdmabuf = rpcrdma_alloc_regbuf(ia, cdata->inline_rsize, in rpcrdma_create_rep()
929 if (IS_ERR(rep->rr_rdmabuf)) { in rpcrdma_create_rep()
930 rc = PTR_ERR(rep->rr_rdmabuf); in rpcrdma_create_rep()
934 rep->rr_device = ia->ri_device; in rpcrdma_create_rep()
935 rep->rr_rxprt = r_xprt; in rpcrdma_create_rep()
936 INIT_WORK(&rep->rr_work, rpcrdma_receive_worker); in rpcrdma_create_rep()
937 return rep; in rpcrdma_create_rep()
940 kfree(rep); in rpcrdma_create_rep()
979 struct rpcrdma_rep *rep; in rpcrdma_buffer_create() local
981 rep = rpcrdma_create_rep(r_xprt); in rpcrdma_buffer_create()
982 if (IS_ERR(rep)) { in rpcrdma_buffer_create()
985 rc = PTR_ERR(rep); in rpcrdma_buffer_create()
988 list_add(&rep->rr_list, &buf->rb_recv_bufs); in rpcrdma_buffer_create()
1011 struct rpcrdma_rep *rep; in rpcrdma_buffer_get_rep_locked() local
1013 rep = list_first_entry(&buf->rb_recv_bufs, in rpcrdma_buffer_get_rep_locked()
1015 list_del(&rep->rr_list); in rpcrdma_buffer_get_rep_locked()
1016 return rep; in rpcrdma_buffer_get_rep_locked()
1020 rpcrdma_destroy_rep(struct rpcrdma_ia *ia, struct rpcrdma_rep *rep) in rpcrdma_destroy_rep() argument
1022 rpcrdma_free_regbuf(ia, rep->rr_rdmabuf); in rpcrdma_destroy_rep()
1023 kfree(rep); in rpcrdma_destroy_rep()
1040 struct rpcrdma_rep *rep; in rpcrdma_buffer_destroy() local
1042 rep = rpcrdma_buffer_get_rep_locked(buf); in rpcrdma_buffer_destroy()
1043 rpcrdma_destroy_rep(ia, rep); in rpcrdma_buffer_destroy()
1131 struct rpcrdma_rep *rep = req->rl_reply; in rpcrdma_buffer_put() local
1138 if (rep) in rpcrdma_buffer_put()
1139 list_add_tail(&rep->rr_list, &buffers->rb_recv_bufs); in rpcrdma_buffer_put()
1163 rpcrdma_recv_buffer_put(struct rpcrdma_rep *rep) in rpcrdma_recv_buffer_put() argument
1165 struct rpcrdma_buffer *buffers = &rep->rr_rxprt->rx_buf; in rpcrdma_recv_buffer_put()
1168 list_add_tail(&rep->rr_list, &buffers->rb_recv_bufs); in rpcrdma_recv_buffer_put()
1259 struct rpcrdma_rep *rep = req->rl_reply; in rpcrdma_ep_post() local
1263 if (rep) { in rpcrdma_ep_post()
1264 rc = rpcrdma_ep_post_recv(ia, ep, rep); in rpcrdma_ep_post()
1303 struct rpcrdma_rep *rep) in rpcrdma_ep_post_recv() argument
1309 recv_wr.wr_id = (u64) (unsigned long) rep; in rpcrdma_ep_post_recv()
1310 recv_wr.sg_list = &rep->rr_rdmabuf->rg_iov; in rpcrdma_ep_post_recv()
1314 rdmab_addr(rep->rr_rdmabuf), in rpcrdma_ep_post_recv()
1315 rdmab_length(rep->rr_rdmabuf), in rpcrdma_ep_post_recv()
1339 struct rpcrdma_rep *rep; in rpcrdma_ep_post_extra_recv() local
1347 rep = rpcrdma_buffer_get_rep_locked(buffers); in rpcrdma_ep_post_extra_recv()
1350 rc = rpcrdma_ep_post_recv(ia, ep, rep); in rpcrdma_ep_post_extra_recv()
1363 rpcrdma_recv_buffer_put(rep); in rpcrdma_ep_post_extra_recv()