|
@@ -404,12 +404,10 @@ static void insert_sq_cqe(struct t3_wq *wq, struct t3_cq *cq,
|
|
|
|
|
|
int cxio_flush_sq(struct t3_wq *wq, struct t3_cq *cq, int count)
|
|
|
{
|
|
|
- __u32 ptr;
|
|
|
+ __u32 ptr = wq->sq_rptr + count;
|
|
|
int flushed = 0;
|
|
|
- struct t3_swsq *sqp = wq->sq + Q_PTR2IDX(wq->sq_rptr, wq->sq_size_log2);
|
|
|
+ struct t3_swsq *sqp = wq->sq + Q_PTR2IDX(ptr, wq->sq_size_log2);
|
|
|
|
|
|
- ptr = wq->sq_rptr + count;
|
|
|
- sqp = wq->sq + Q_PTR2IDX(ptr, wq->sq_size_log2);
|
|
|
while (ptr != wq->sq_wptr) {
|
|
|
sqp->signaled = 0;
|
|
|
insert_sq_cqe(wq, cq, sqp);
|