Commit 95f61e17 authored by Felix Fietkau's avatar Felix Fietkau

mt76: usb: fix use of q->head and q->tail

Their use is reversed compared to DMA. The order for DMA makes more sense,
so let's use that
Signed-off-by: default avatarFelix Fietkau <nbd@nbd.name>
parent d407afcb
...@@ -497,8 +497,8 @@ mt76u_get_next_rx_entry(struct mt76_queue *q) ...@@ -497,8 +497,8 @@ mt76u_get_next_rx_entry(struct mt76_queue *q)
spin_lock_irqsave(&q->lock, flags); spin_lock_irqsave(&q->lock, flags);
if (q->queued > 0) { if (q->queued > 0) {
urb = q->entry[q->head].urb; urb = q->entry[q->tail].urb;
q->head = (q->head + 1) % q->ndesc; q->tail = (q->tail + 1) % q->ndesc;
q->queued--; q->queued--;
} }
spin_unlock_irqrestore(&q->lock, flags); spin_unlock_irqrestore(&q->lock, flags);
...@@ -622,10 +622,10 @@ static void mt76u_complete_rx(struct urb *urb) ...@@ -622,10 +622,10 @@ static void mt76u_complete_rx(struct urb *urb)
} }
spin_lock_irqsave(&q->lock, flags); spin_lock_irqsave(&q->lock, flags);
if (WARN_ONCE(q->entry[q->tail].urb != urb, "rx urb mismatch")) if (WARN_ONCE(q->entry[q->head].urb != urb, "rx urb mismatch"))
goto out; goto out;
q->tail = (q->tail + 1) % q->ndesc; q->head = (q->head + 1) % q->ndesc;
q->queued++; q->queued++;
tasklet_schedule(&dev->usb.rx_tasklet); tasklet_schedule(&dev->usb.rx_tasklet);
out: out:
...@@ -808,17 +808,17 @@ static void mt76u_tx_tasklet(unsigned long data) ...@@ -808,17 +808,17 @@ static void mt76u_tx_tasklet(unsigned long data)
q = sq->q; q = sq->q;
while (q->queued > n_dequeued) { while (q->queued > n_dequeued) {
if (!q->entry[q->head].done) if (!q->entry[q->tail].done)
break; break;
if (q->entry[q->head].schedule) { if (q->entry[q->tail].schedule) {
q->entry[q->head].schedule = false; q->entry[q->tail].schedule = false;
n_sw_dequeued++; n_sw_dequeued++;
} }
entry = q->entry[q->head]; entry = q->entry[q->tail];
q->entry[q->head].done = false; q->entry[q->tail].done = false;
q->head = (q->head + 1) % q->ndesc; q->tail = (q->tail + 1) % q->ndesc;
n_dequeued++; n_dequeued++;
dev->drv->tx_complete_skb(dev, i, &entry); dev->drv->tx_complete_skb(dev, i, &entry);
...@@ -913,7 +913,7 @@ mt76u_tx_queue_skb(struct mt76_dev *dev, enum mt76_txq_id qid, ...@@ -913,7 +913,7 @@ mt76u_tx_queue_skb(struct mt76_dev *dev, enum mt76_txq_id qid,
struct mt76_tx_info tx_info = { struct mt76_tx_info tx_info = {
.skb = skb, .skb = skb,
}; };
u16 idx = q->tail; u16 idx = q->head;
int err; int err;
if (q->queued == q->ndesc) if (q->queued == q->ndesc)
...@@ -932,7 +932,7 @@ mt76u_tx_queue_skb(struct mt76_dev *dev, enum mt76_txq_id qid, ...@@ -932,7 +932,7 @@ mt76u_tx_queue_skb(struct mt76_dev *dev, enum mt76_txq_id qid,
q->entry[idx].urb, mt76u_complete_tx, q->entry[idx].urb, mt76u_complete_tx,
&q->entry[idx]); &q->entry[idx]);
q->tail = (q->tail + 1) % q->ndesc; q->head = (q->head + 1) % q->ndesc;
q->entry[idx].skb = tx_info.skb; q->entry[idx].skb = tx_info.skb;
q->queued++; q->queued++;
...@@ -944,7 +944,7 @@ static void mt76u_tx_kick(struct mt76_dev *dev, struct mt76_queue *q) ...@@ -944,7 +944,7 @@ static void mt76u_tx_kick(struct mt76_dev *dev, struct mt76_queue *q)
struct urb *urb; struct urb *urb;
int err; int err;
while (q->first != q->tail) { while (q->first != q->head) {
urb = q->entry[q->first].urb; urb = q->entry[q->first].urb;
trace_submit_urb(dev, urb); trace_submit_urb(dev, urb);
...@@ -1071,8 +1071,8 @@ void mt76u_stop_tx(struct mt76_dev *dev) ...@@ -1071,8 +1071,8 @@ void mt76u_stop_tx(struct mt76_dev *dev)
/* Assure we are in sync with killed tasklet. */ /* Assure we are in sync with killed tasklet. */
spin_lock_bh(&q->lock); spin_lock_bh(&q->lock);
while (q->queued) { while (q->queued) {
entry = q->entry[q->head]; entry = q->entry[q->tail];
q->head = (q->head + 1) % q->ndesc; q->tail = (q->tail + 1) % q->ndesc;
q->queued--; q->queued--;
dev->drv->tx_complete_skb(dev, i, &entry); dev->drv->tx_complete_skb(dev, i, &entry);
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment