hw/cxgb4/cq.c

195 				 CQE_QPID_V(wq->sq.qid));
229 				 CQE_QPID_V(wq->sq.qid));
247 	if (wq->sq.flush_cidx == -1)
248 		wq->sq.flush_cidx = wq->sq.cidx;
249 	idx = wq->sq.flush_cidx;
250 	while (idx != wq->sq.pidx) {
251 		swsqe = &wq->sq.sw_sq[idx];
254 		if (wq->sq.oldest_read == swsqe) {
258 		if (++idx == wq->sq.size)
261 	wq->sq.flush_cidx += flushed;
262 	if (wq->sq.flush_cidx >= wq->sq.size)
263 		wq->sq.flush_cidx -= wq->sq.size;
272 	if (wq->sq.flush_cidx == -1)
273 		wq->sq.flush_cidx = wq->sq.cidx;
274 	cidx = wq->sq.flush_cidx;
276 	while (cidx != wq->sq.pidx) {
277 		swsqe = &wq->sq.sw_sq[cidx];
279 			if (++cidx == wq->sq.size)
286 			pr_debug("moving cqe into swcq sq idx %u cq idx %u\n",
292 			if (++cidx == wq->sq.size)
294 			wq->sq.flush_cidx = cidx;
303 	read_cqe->u.scqe.cidx = wq->sq.oldest_read->idx;
304 	read_cqe->len = htonl(wq->sq.oldest_read->read_len);
315 	u32 rptr = wq->sq.oldest_read - wq->sq.sw_sq + 1;
317 	if (rptr == wq->sq.size)
319 	while (rptr != wq->sq.pidx) {
320 		wq->sq.oldest_read = &wq->sq.sw_sq[rptr];
322 		if (wq->sq.oldest_read->opcode == FW_RI_READ_REQ)
324 		if (++rptr == wq->sq.size)
327 	wq->sq.oldest_read = NULL;
386 			if (!qhp->wq.sq.oldest_read->signaled) {
404 			swsqe = &qhp->wq.sq.sw_sq[CQE_WRID_SQ_IDX(hw_cqe)];
425 		WARN_ONCE(1, "Unexpected DRAIN CQE qp id %u!\n", wq->sq.qid);
454 		    (CQE_QPID(cqe) == wq->sq.qid) && cqe_completes_wr(cqe, wq))
630 		if (!wq->sq.oldest_read->signaled) {
680 	if (!SW_CQE(hw_cqe) && (CQE_WRID_SQ_IDX(hw_cqe) != wq->sq.cidx)) {
685 		swsqe = &wq->sq.sw_sq[CQE_WRID_SQ_IDX(hw_cqe)];
710 		if (idx < wq->sq.cidx)
711 			wq->sq.in_use -= wq->sq.size + idx - wq->sq.cidx;
713 			wq->sq.in_use -= idx - wq->sq.cidx;
715 		wq->sq.cidx = (uint16_t)idx;
716 		pr_debug("completing sq idx %u\n", wq->sq.cidx);
717 		*cookie = wq->sq.sw_sq[wq->sq.cidx].wr_id;