gitops/mt76
1
0
Fork 0
mirror of https://github.com/outbackdingo/mt76.git synced 2026-10-24 13:26:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

tx: lock bigger sections

Browse Source 
Signed-off-by: Felix Fietkau <[email protected]>
This commit is contained in:
Felix Fietkau
2015-06-13 09:26:41 +02:00
parent 21c36beae4
commit 9d12daa5c3
1 changed files with 10 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
dma.c
+10 -8
View File
@@ -272,10 +272,8 @@ mt76_dma_dequeue(struct mt76_dev *dev, struct mt76_queue *q, enum mt76_dma_deque
u16 idx; u16 idx;
bool skip; bool skip;
spin_lock_bh(&q->lock);
if (!q->queued) if (!q->queued)
goto out; return -1;
switch (type) { switch (type) {
case DMA_DEQUEUE_DDONE: case DMA_DEQUEUE_DDONE:
@@ -291,14 +289,12 @@ mt76_dma_dequeue(struct mt76_dev *dev, struct mt76_queue *q, enum mt76_dma_deque
} }
if (skip) if (skip)
goto out; return -1;
ret = q->tail; ret = q->tail;
q->tail = (q->tail + 1) % q->ndesc; q->tail = (q->tail + 1) % q->ndesc;
q->queued--; q->queued--;
out:
spin_unlock_bh(&q->lock);
return ret; return ret;
} }
@@ -327,11 +323,9 @@ mt76_tx_cleanup_entry(struct mt76_dev *dev, struct mt76_queue *q, int idx,
mt76_put_txwi(dev, txwi); mt76_put_txwi(dev, txwi);
if (schedule) { if (schedule) {
spin_lock_bh(&q->lock);
q->swq_queued--; q->swq_queued--;
if (!flush) if (!flush)
mt76_txq_schedule(dev, q); mt76_txq_schedule(dev, q);
spin_unlock_bh(&q->lock);
} }
} else { } else {
dev_kfree_skb_any(skb); dev_kfree_skb_any(skb);
@@ -344,6 +338,8 @@ mt76_tx_cleanup_queue(struct mt76_dev *dev, struct mt76_queue *q, bool flush)
enum mt76_dma_dequeue type = flush ? DMA_DEQUEUE_FLUSH : DMA_DEQUEUE_IDX; enum mt76_dma_dequeue type = flush ? DMA_DEQUEUE_FLUSH : DMA_DEQUEUE_IDX;
int idx; int idx;
spin_lock_bh(&q->lock);
do { do {
idx = mt76_dma_dequeue(dev, q, type); idx = mt76_dma_dequeue(dev, q, type);
if (idx < 0) if (idx < 0)
@@ -351,6 +347,8 @@ mt76_tx_cleanup_queue(struct mt76_dev *dev, struct mt76_queue *q, bool flush)
mt76_tx_cleanup_entry(dev, q, idx, flush); mt76_tx_cleanup_entry(dev, q, idx, flush);
} while (1); } while (1);
spin_unlock_bh(&q->lock);
} }
static void * static void *
@@ -380,6 +378,8 @@ mt76_rx_cleanup(struct mt76_dev *dev, struct mt76_queue *q)
void *buf; void *buf;
int idx; int idx;
spin_lock_bh(&q->lock);
do { do {
idx = mt76_dma_dequeue(dev, q, DMA_DEQUEUE_FLUSH); idx = mt76_dma_dequeue(dev, q, DMA_DEQUEUE_FLUSH);
if (idx < 0) if (idx < 0)
@@ -388,6 +388,8 @@ mt76_rx_cleanup(struct mt76_dev *dev, struct mt76_queue *q)
buf = mt76_rx_get_buf(dev, q, idx, NULL); buf = mt76_rx_get_buf(dev, q, idx, NULL);
kfree(buf); kfree(buf);
} while (1); } while (1);
spin_unlock_bh(&q->lock);
} }
static int static int