Lines Matching refs:rep
79 struct rpcrdma_rep *rep;
86 rep = list_entry(rpcrdma_tasklets_g.next,
88 list_del(&rep->rr_list);
89 func = rep->rr_func;
90 rep->rr_func = NULL;
94 func(rep);
96 rpcrdma_recv_buffer_put(rep);
106 rpcrdma_schedule_tasklet(struct rpcrdma_rep *rep)
111 list_add_tail(&rep->rr_list, &rpcrdma_tasklets_g);
147 struct rpcrdma_rep *rep =
150 dprintk("RPC: %s: event rep %p status %X opcode %X length %u\n",
151 __func__, rep, wc->status, wc->opcode, wc->byte_len);
153 if (!rep) /* send or bind completion that we don't care about */
160 rep->rr_len = ~0U;
161 rpcrdma_schedule_tasklet(rep);
167 rep->rr_len = wc->byte_len;
169 rdmab_to_ia(rep->rr_buffer)->ri_id->device,
170 rep->rr_iov.addr, rep->rr_len, DMA_FROM_DEVICE);
172 if (rep->rr_len >= 16) {
174 (struct rpcrdma_msg *) rep->rr_base;
181 } else if (credits > rep->rr_buffer->rb_max_requests) {
185 rep->rr_buffer->rb_max_requests);
186 credits = rep->rr_buffer->rb_max_requests;
188 atomic_set(&rep->rr_buffer->rb_credits, credits);
192 rpcrdma_schedule_tasklet(rep);
973 * Send/recv buffers in req/rep need to be registered
1099 struct rpcrdma_rep *rep;
1127 rep = kmalloc(len, GFP_KERNEL);
1128 if (rep == NULL) {
1134 memset(rep, 0, sizeof(struct rpcrdma_rep));
1135 buf->rb_recv_bufs[i] = rep;
1137 init_waitqueue_head(&rep->rr_unbind);
1139 rc = rpcrdma_register_internal(ia, rep->rr_base,
1354 rpcrdma_recv_buffer_put(struct rpcrdma_rep *rep)
1356 struct rpcrdma_buffer *buffers = rep->rr_buffer;
1359 rep->rr_func = NULL;
1361 buffers->rb_recv_bufs[--buffers->rb_recv_index] = rep;
1828 struct rpcrdma_rep *rep = r;
1829 void (*func)(struct rpcrdma_rep *) = rep->rr_func;
1830 rep->rr_func = NULL;
1831 func(rep); /* dereg done, callback now */
1847 struct rpcrdma_rep *rep = req->rl_reply;
1850 if (rep) {
1851 rc = rpcrdma_ep_post_recv(ia, ep, rep);
1894 struct rpcrdma_rep *rep)
1900 recv_wr.wr_id = (u64) (unsigned long) rep;
1901 recv_wr.sg_list = &rep->rr_iov;
1905 rep->rr_iov.addr, rep->rr_iov.length, DMA_BIDIRECTIONAL);