ofed/librdmacm/rsocket.c

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