cxgbe/iw_cxgbe/cq.c

213 				 V_CQE_QPID(wq->sq.qid));
246 				 V_CQE_QPID(wq->sq.qid));
264 	if (wq->sq.flush_cidx == -1)
265 		wq->sq.flush_cidx = wq->sq.cidx;
266 	idx = wq->sq.flush_cidx;
267 	BUG_ON(idx >= wq->sq.size);
268 	while (idx != wq->sq.pidx) {
269 		swsqe = &wq->sq.sw_sq[idx];
273 		if (wq->sq.oldest_read == swsqe) {
278 		if (++idx == wq->sq.size)
281 	wq->sq.flush_cidx += flushed;
282 	if (wq->sq.flush_cidx >= wq->sq.size)
283 		wq->sq.flush_cidx -= wq->sq.size;
292 	if (wq->sq.flush_cidx == -1)
293 		wq->sq.flush_cidx = wq->sq.cidx;
294 	cidx = wq->sq.flush_cidx;
295 	BUG_ON(cidx > wq->sq.size);
297 	while (cidx != wq->sq.pidx) {
298 		swsqe = &wq->sq.sw_sq[cidx];
300 			if (++cidx == wq->sq.size)
310 				"%s moving cqe into swcq sq idx %u cq idx %u\n",
316 			if (++cidx == wq->sq.size)
318 			wq->sq.flush_cidx = cidx;
327 	read_cqe->u.scqe.cidx = wq->sq.oldest_read->idx;
328 	read_cqe->len = htonl(wq->sq.oldest_read->read_len);
339 	u32 rptr = wq->sq.oldest_read - wq->sq.sw_sq + 1;
341 	if (rptr == wq->sq.size)
343 	while (rptr != wq->sq.pidx) {
344 		wq->sq.oldest_read = &wq->sq.sw_sq[rptr];
346 		if (wq->sq.oldest_read->opcode == FW_RI_READ_REQ)
348 		if (++rptr == wq->sq.size)
351 	wq->sq.oldest_read = NULL;
404 			if (!qhp->wq.sq.oldest_read->signaled) {
422 			swsqe = &qhp->wq.sq.sw_sq[CQE_WRID_SQ_IDX(hw_cqe)];
465 		    (CQE_QPID(cqe) == wq->sq.qid) && cqe_completes_wr(cqe, wq))
577 		if (!wq->sq.oldest_read->signaled) {
633 	if (!SW_CQE(hw_cqe) && (CQE_WRID_SQ_IDX(hw_cqe) != wq->sq.cidx)) {
639 		swsqe = &wq->sq.sw_sq[CQE_WRID_SQ_IDX(hw_cqe)];
655 		BUG_ON(idx >= wq->sq.size);
665 		if (idx < wq->sq.cidx)
666 			wq->sq.in_use -= wq->sq.size + idx - wq->sq.cidx;
668 			wq->sq.in_use -= idx - wq->sq.cidx;
669 		BUG_ON(wq->sq.in_use <= 0 && wq->sq.in_use >= wq->sq.size);
671 		wq->sq.cidx = (uint16_t)idx;
672 		CTR2(KTR_IW_CXGBE, "%s completing sq idx %u",
673 				__func__, wq->sq.cidx);
674 		*cookie = wq->sq.sw_sq[wq->sq.cidx].wr_id;