sw/siw/siw_qp.c

111 		if (likely(qp->attrs.state == SIW_QP_STATE_RTS))
132 		   siw_qp_state_to_string[qp->attrs.state]);
138 	qp->attrs.sk = NULL;
140 	switch (qp->attrs.state) {
145 		qp->attrs.state = SIW_QP_STATE_ERROR;
155 			qp->attrs.state = SIW_QP_STATE_ERROR;
157 			qp->attrs.state = SIW_QP_STATE_IDLE;
162 			   siw_qp_state_to_string[qp->attrs.state]);
179 		   siw_qp_state_to_string[qp->attrs.state]);
209 			qp->attrs.irq_size = 0;
217 			qp->attrs.orq_size = 0;
218 			qp->attrs.irq_size = 0;
223 	qp->attrs.irq_size = irq_size;
224 	qp->attrs.orq_size = orq_size;
273 		if (qp->attrs.orq_size)
369 	struct socket *s = qp->attrs.sk;
580  * Handle all attrs other than state
583 				   struct siw_qp_attrs *attrs,
587 		if (attrs->flags & SIW_RDMA_BIND_ENABLED)
588 			qp->attrs.flags |= SIW_RDMA_BIND_ENABLED;
590 			qp->attrs.flags &= ~SIW_RDMA_BIND_ENABLED;
592 		if (attrs->flags & SIW_RDMA_WRITE_ENABLED)
593 			qp->attrs.flags |= SIW_RDMA_WRITE_ENABLED;
595 			qp->attrs.flags &= ~SIW_RDMA_WRITE_ENABLED;
597 		if (attrs->flags & SIW_RDMA_READ_ENABLED)
598 			qp->attrs.flags |= SIW_RDMA_READ_ENABLED;
600 			qp->attrs.flags &= ~SIW_RDMA_READ_ENABLED;
605 				      struct siw_qp_attrs *attrs,
610 	switch (attrs->state) {
612 		if (attrs->flags & SIW_MPA_CRC) {
646 		rv = siw_qp_readq_init(qp, attrs->irq_size,
647 				       attrs->orq_size);
651 		qp->attrs.sk = attrs->sk;
652 		qp->attrs.state = SIW_QP_STATE_RTS;
655 			   attrs->flags & SIW_MPA_CRC ? "y" : "n",
656 			   qp->attrs.orq_size, qp->attrs.irq_size);
661 		qp->attrs.state = SIW_QP_STATE_ERROR;
675 				     struct siw_qp_attrs *attrs)
679 	switch (attrs->state) {
690 			qp->attrs.state = SIW_QP_STATE_CLOSING;
692 			qp->attrs.state = SIW_QP_STATE_ERROR;
701 		qp->attrs.state = SIW_QP_STATE_TERMINATE;
725 		qp->attrs.state = SIW_QP_STATE_ERROR;
736 				       struct siw_qp_attrs *attrs)
738 	switch (attrs->state) {
741 		qp->attrs.state = SIW_QP_STATE_ERROR;
753 				       struct siw_qp_attrs *attrs)
757 	switch (attrs->state) {
760 		qp->attrs.state = SIW_QP_STATE_IDLE;
775 		qp->attrs.state = SIW_QP_STATE_ERROR;
785 			   siw_qp_state_to_string[qp->attrs.state],
786 			   siw_qp_state_to_string[attrs->state]);
796 int siw_qp_modify(struct siw_qp *qp, struct siw_qp_attrs *attrs,
805 		   siw_qp_state_to_string[qp->attrs.state],
806 		   siw_qp_state_to_string[attrs->state]);
809 		siw_qp_modify_nonstate(qp, attrs, mask);
814 	switch (qp->attrs.state) {
817 		rv = siw_qp_nextstate_from_idle(qp, attrs, mask);
821 		drop_conn = siw_qp_nextstate_from_rts(qp, attrs);
825 		siw_qp_nextstate_from_term(qp, attrs);
829 		siw_qp_nextstate_from_close(qp, attrs);
897 		if (qp->attrs.orq_size && !siw_orq_empty(qp)) {
907 		if (unlikely(!qp->attrs.orq_size)) {
953 	if (!qp->attrs.irq_size)
956 	irqe = &qp->irq[qp->irq_get % qp->attrs.irq_size];
1168 	while (qp->attrs.orq_size) {
1169 		sqe = &qp->orq[qp->orq_get % qp->attrs.orq_size];
1204 	while (qp->attrs.sq_size) {
1205 		sqe = &qp->sendq[qp->sq_get % qp->attrs.sq_size];
1267 	while (qp->attrs.rq_size) {
1269 			&qp->recvq[qp->rq_get % qp->attrs.rq_size];