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: add txq dequeue wrapper

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 d445950686
commit a5a095745d
1 changed files with 23 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tx.c
+23 -4
View File
@@ -179,6 +179,25 @@ mt76_txq_get_qid(struct ieee80211_txq *txq)
return txq->ac;
}
static struct sk_buff *
mt76_txq_dequeue(struct mt76_dev *dev, struct mt76_txq *mtxq, bool ps)
{
struct ieee80211_txq *txq = mtxq_to_txq(mtxq);
struct sk_buff *skb;
skb = skb_dequeue(&mtxq->retry_q);
if (skb) {
u8 tid = skb->priority & IEEE80211_QOS_CTL_TID_MASK;
if (ps && skb_queue_empty(&mtxq->retry_q));
ieee80211_sta_set_buffered(txq->sta, tid, false);
return skb;
}
return ieee80211_tx_dequeue(dev->hw, txq);
}
static int
mt76_txq_send_burst(struct mt76_dev *dev, struct mt76_queue *hwq,
struct mt76_txq *mtxq, bool *empty)
@@ -201,8 +220,8 @@ mt76_txq_send_burst(struct mt76_dev *dev, struct mt76_queue *hwq,
wcid = &mvif->group_wcid;
}
skb = ieee80211_tx_dequeue(dev->hw, txq);
if (IS_ERR_OR_NULL(skb)) {
skb = mt76_txq_dequeue(dev, mtxq, false);
if (!skb) {
*empty = true;
return 0;
}
@@ -227,8 +246,8 @@ mt76_txq_send_burst(struct mt76_dev *dev, struct mt76_queue *hwq,
if (probe)
break;
skb = ieee80211_tx_dequeue(dev->hw, txq);
if (IS_ERR_OR_NULL(skb)) {
skb = mt76_txq_dequeue(dev, mtxq, false);
if (!skb) {
*empty = true;
break;
}