sw/rxe/rxe_resp.c

263 	struct rxe_recv_wqe *wqe;
274 	wqe = queue_head(q, QUEUE_TYPE_FROM_CLIENT);
275 	if (!wqe) {
281 	if (unlikely(wqe->dma.num_sge > srq->rq.max_sge)) {
286 	size = sizeof(*wqe) + wqe->dma.num_sge*sizeof(struct rxe_sge);
287 	memcpy(&qp->resp.srq_wqe, wqe, size);
289 	qp->resp.wqe = &qp->resp.srq_wqe.wqe;
330 		qp->resp.wqe = queue_head(qp->rq.queue,
332 		return (qp->resp.wqe) ? RESPST_CHK_LENGTH : RESPST_ERR_RNR;
352 		for (i = 0; i < qp->resp.wqe->dma.num_sge; i++)
353 			recv_buffer_len += qp->resp.wqe->dma.sge[i].length;
570 	err = copy_data(qp->pd, IB_ACCESS_LOCAL_WRITE, &qp->resp.wqe->dma,
1075 	struct rxe_recv_wqe *wqe = qp->resp.wqe;
1079 	if (!wqe)
1087 		uwc->wr_id		= wqe->wr_id;
1091 		wc->wr_id		= wqe->wr_id;
1101 					qp->resp.length : wqe->dma.length - wqe->dma.resid;
1162 	qp->resp.wqe = NULL;
1403 		if (qp->resp.wqe) {
1415 		if (qp->resp.wqe) {
1416 			qp->resp.wqe->dma.resid = qp->resp.wqe->dma.length;
1417 			qp->resp.wqe->dma.cur_sge = 0;
1418 			qp->resp.wqe->dma.sge_offset = 0;
1443 /* complete receive wqe with flush error */
1444 static int flush_recv_wqe(struct rxe_qp *qp, struct rxe_recv_wqe *wqe)
1452 		uwc->wr_id = wqe->wr_id;
1456 		wc->wr_id = wqe->wr_id;
1469  * if unable to complete a wqe stop completing and
1475 	struct rxe_recv_wqe *wqe;
1494 	while ((wqe = queue_head(q, q->type))) {
1496 			err = flush_recv_wqe(qp, wqe);
1503 	qp->resp.wqe = NULL;