ofed/libcxgb4/cq.c

53 				 V_CQE_QPID(wq->sq.qid));
86 			         V_CQE_QPID(wq->sq.qid));
104 	if (wq->sq.flush_cidx == -1)
105 		wq->sq.flush_cidx = wq->sq.cidx;
106 	idx = wq->sq.flush_cidx;
107 	BUG_ON(idx >= wq->sq.size);
108 	while (idx != wq->sq.pidx) {
109 		swsqe = &wq->sq.sw_sq[idx];
113 		if (wq->sq.oldest_read == swsqe) {
118 		if (++idx == wq->sq.size)
121 	wq->sq.flush_cidx += flushed;
122 	if (wq->sq.flush_cidx >= wq->sq.size)
123 		wq->sq.flush_cidx -= wq->sq.size;
131 	if (wq->sq.flush_cidx == -1)
132 		wq->sq.flush_cidx = wq->sq.cidx;
133 	cidx = wq->sq.flush_cidx;
134 	BUG_ON(cidx >= wq->sq.size);
136 	while (cidx != wq->sq.pidx) {
137 		swsqe = &wq->sq.sw_sq[cidx];
139 			if (++cidx == wq->sq.size)
148 			PDBG("%s moving cqe into swcq sq idx %u cq idx %u\n",
155 			if (++cidx == wq->sq.size)
157 			wq->sq.flush_cidx = cidx;
166 	read_cqe->u.scqe.cidx = wq->sq.oldest_read->idx;
167 	read_cqe->len = be32toh(wq->sq.oldest_read->read_len);
178 	u32 rptr = wq->sq.oldest_read - wq->sq.sw_sq + 1;
180 	if (rptr == wq->sq.size)
182 	while (rptr != wq->sq.pidx) {
183 		wq->sq.oldest_read = &wq->sq.sw_sq[rptr];
185 		if (wq->sq.oldest_read->opcode == FW_RI_READ_REQ)
187 		if (++rptr == wq->sq.size)
190 	wq->sq.oldest_read = NULL;
247 			if (!qhp->wq.sq.oldest_read->signaled) {
267 			BUG_ON(idx >= qhp->wq.sq.size);
268 			swsqe = &qhp->wq.sq.sw_sq[idx];
311 		    (CQE_QPID(cqe) == wq->sq.qid) && cqe_completes_wr(cqe, wq))
413 		if (!wq->sq.oldest_read->signaled) {
480 	if (!SW_CQE(hw_cqe) && (CQE_WRID_SQ_IDX(hw_cqe) != wq->sq.cidx)) {
486 		BUG_ON(idx >= wq->sq.size);
487 		swsqe = &wq->sq.sw_sq[idx];
503 		BUG_ON(idx >= wq->sq.size);
513 		if (idx < wq->sq.cidx)
514 			wq->sq.in_use -= wq->sq.size + idx - wq->sq.cidx;
516 			wq->sq.in_use -= idx - wq->sq.cidx;
517 		BUG_ON(wq->sq.in_use <= 0 || wq->sq.in_use >= wq->sq.size);
519 		wq->sq.cidx = (u16)idx;
520 		PDBG("%s completing sq idx %u\n", __func__, wq->sq.cidx);
521 		*cookie = wq->sq.sw_sq[wq->sq.cidx].wr_id;
604 	wc->qp_num = qhp->wq.sq.qid;