371 	uint16_t	  rq_size;  member
610 		rs->rq_size = inherited_rs->rq_size;  in rs_alloc()
620 		rs->rq_size = def_rqsize;  in rs_alloc()
673 	if (rs->rq_size > max_size)  in rs_set_qp_size()
674 		rs->rq_size = max_size;  in rs_set_qp_size()
675 	else if (rs->rq_size < RS_QP_MIN_SIZE)  in rs_set_qp_size()
676 		rs->rq_size = RS_QP_MIN_SIZE;  in rs_set_qp_size()
687 	if (rs->rq_size > max_size)  in ds_set_qp_size()
688 		rs->rq_size = max_size;  in ds_set_qp_size()
690 	if (rs->rq_size > (rs->rbuf_size / RS_SNDLOWAT))  in ds_set_qp_size()
691 		rs->rq_size = rs->rbuf_size / RS_SNDLOWAT;  in ds_set_qp_size()
693 		rs->rbuf_size = rs->rq_size * RS_SNDLOWAT;  in ds_set_qp_size()
706 	rs->rmsg = calloc(rs->rq_size + 1, sizeof(*rs->rmsg));  in rs_init_bufs()
738 		total_rbuf_size += rs->rq_size * RS_MSG_SIZE;  in rs_init_bufs()
754 	rs->rseq_comp = rs->rq_size >> 1;  in rs_init_bufs()
787 	cm_id->recv_cq = ibv_create_cq(cm_id->verbs, rs->sq_size + rs->rq_size,  in rs_create_cq()
830 		if(++rs->rbuf_msg_index == rs->rq_size)  in rs_post_recv()
876 	qp_attr.cap.max_recv_wr = rs->rq_size;  in rs_create_ep()
893 	for (i = 0; i < rs->rq_size; i++) {  in rs_create_ep()
1046 	conn->credits = htobe16(rs->rq_size);  in rs_format_conn_data()
1107 	rs->dmsg = calloc(rs->rq_size + 1, sizeof(*rs->dmsg));  in ds_init_ep()
1112 	rs->rqe_avail = rs->rq_size;  in ds_init_ep()
1523 	qp_attr.cap.max_recv_wr = rs->rq_size;  in ds_create_qp()
1543 	for (i = 0; i < rs->rq_size; i++) {  in ds_create_qp()
1826 	rs->rseq_comp = rs->rseq_no + (rs->rq_size >> 1);  in rs_send_credits()
1855 			rs_msg_set(RS_OP_SGL, rs->rseq_no + rs->rq_size), flags,  in rs_send_credits()
1866 		rs_post_msg(rs, rs_msg_set(RS_OP_SGL, rs->rseq_no + rs->rq_size));  in rs_send_credits()
1945 				if (++rs->rmsg_tail == rs->rq_size + 1)  in rs_poll_cq()
1999 		if (++rs->unack_cqe >= rs->sq_size + rs->rq_size) {  in rs_get_cq_event()
2127 					if (++rs->rmsg_tail == rs->rq_size + 1)  in ds_poll_cqs()
2370 		if (++rs->rmsg_head == rs->rq_size + 1)  in ds_recvfrom()
2392 			if (++rmsg_head == rs->rq_size + 1)  in rs_peek()
2459 				if (++rs->rmsg_head == rs->rq_size + 1)  in rrecv()
3504 			rs->rq_size = min_t(uint32_t, (*(uint32_t *)optval),  in rsetsockopt()
3658 			*((int *) optval) = rs->rq_size;  in rgetsockopt()