Lines Matching refs:recv
70 struct rds_iw_recv_work *recv)
72 struct rds_page_frag *frag = recv->r_frag;
74 rdsdebug("recv %p frag %p page %p\n", recv, frag, frag->f_page);
84 struct rds_iw_recv_work *recv;
87 for (i = 0, recv = ic->i_recvs; i < ic->i_recv_ring.w_nr; i++, recv++) {
90 recv->r_iwinc = NULL;
91 recv->r_frag = NULL;
93 recv->r_wr.next = NULL;
94 recv->r_wr.wr_id = i;
95 recv->r_wr.sg_list = recv->r_sge;
96 recv->r_wr.num_sge = RDS_IW_RECV_SGE;
98 sge = rds_iw_data_sge(ic, recv->r_sge);
103 sge = rds_iw_header_sge(ic, recv->r_sge);
111 struct rds_iw_recv_work *recv)
113 if (recv->r_iwinc) {
114 rds_inc_put(&recv->r_iwinc->ii_inc);
115 recv->r_iwinc = NULL;
117 if (recv->r_frag) {
118 rds_iw_recv_unmap_page(ic, recv);
119 if (recv->r_frag->f_page)
120 rds_iw_frag_drop_page(recv->r_frag);
121 rds_iw_frag_free(recv->r_frag);
122 recv->r_frag = NULL;
138 struct rds_iw_recv_work *recv,
146 if (recv->r_iwinc == NULL) {
151 recv->r_iwinc = kmem_cache_alloc(rds_iw_incoming_slab,
153 if (recv->r_iwinc == NULL) {
157 INIT_LIST_HEAD(&recv->r_iwinc->ii_frags);
158 rds_inc_init(&recv->r_iwinc->ii_inc, conn, conn->c_faddr);
161 if (recv->r_frag == NULL) {
162 recv->r_frag = kmem_cache_alloc(rds_iw_frag_slab, kptr_gfp);
163 if (recv->r_frag == NULL)
165 INIT_LIST_HEAD(&recv->r_frag->f_item);
166 recv->r_frag->f_page = NULL;
186 * must be called on this recv. This happens as completions hit
189 recv->r_frag->f_page = ic->i_frag.f_page;
190 recv->r_frag->f_offset = ic->i_frag.f_offset;
191 recv->r_frag->f_mapped = dma_addr;
193 sge = rds_iw_data_sge(ic, recv->r_sge);
197 sge = rds_iw_header_sge(ic, recv->r_sge);
198 sge->addr = ic->i_recv_hdrs_dma + (recv - ic->i_recvs) * sizeof(struct rds_header);
201 get_page(recv->r_frag->f_page);
228 struct rds_iw_recv_work *recv;
243 recv = &ic->i_recvs[pos];
244 ret = rds_iw_recv_refill_one(conn, recv, kptr_gfp, page_gfp);
250 ret = ib_post_recv(ic->i_cm_id->qp, &recv->r_wr, &failed_wr);
251 rdsdebug("recv %p iwinc %p page %p addr %lu ret %d\n", recv,
252 recv->r_iwinc, recv->r_frag->f_page,
253 (long) recv->r_frag->f_mapped, ret);
255 rds_iw_conn_error(conn, "recv post on "
478 * 1. We call rds_iw_attempt_ack from the recv completion handler
511 * When we get here, we're called from the recv queue handler.
648 struct rds_iw_recv_work *recv, u32 byte_len,
656 rdsdebug("ic %p iwinc %p recv %p byte len %u\n", ic, iwinc, recv,
669 ihdr = &ic->i_recv_hdrs[recv - ic->i_recvs];
696 rds_iw_frag_drop_page(recv->r_frag);
707 iwinc = recv->r_iwinc;
708 recv->r_iwinc = NULL;
731 list_add_tail(&recv->r_frag->f_item, &iwinc->ii_frags);
732 recv->r_frag = NULL;
788 struct rds_iw_recv_work *recv;
796 recv = &ic->i_recvs[rds_iw_ring_oldest(&ic->i_recv_ring)];
798 rds_iw_recv_unmap_page(ic, recv);
802 * to get a recv completion _before_ the rdmacm ESTABLISHED
808 rds_iw_process_recv(conn, recv, wc.byte_len, state);
810 rds_iw_conn_error(conn, "recv completion on "
882 /* Default to 30% of all available RAM for recv memory */