mirror of
https://github.com/openwrt/openwrt.git
synced 2024-12-28 17:48:58 +00:00
160 lines
4.5 KiB
Diff
160 lines
4.5 KiB
Diff
|
From: Felix Fietkau <nbd@nbd.name>
|
||
|
Date: Mon, 17 Aug 2020 13:54:19 +0200
|
||
|
Subject: [PATCH] mac80211: unify 802.3 (offload) and 802.11 tx status
|
||
|
codepath
|
||
|
|
||
|
Make ieee80211_tx_status_8023 call ieee80211_tx_status_ext, similar to
|
||
|
ieee80211_tx_status.
|
||
|
|
||
|
Signed-off-by: Felix Fietkau <nbd@nbd.name>
|
||
|
---
|
||
|
|
||
|
--- a/net/mac80211/status.c
|
||
|
+++ b/net/mac80211/status.c
|
||
|
@@ -903,7 +903,6 @@ static void __ieee80211_tx_status(struct
|
||
|
struct ieee80211_bar *bar;
|
||
|
int shift = 0;
|
||
|
int tid = IEEE80211_NUM_TIDS;
|
||
|
- u16 tx_time_est;
|
||
|
|
||
|
sband = local->hw.wiphy->bands[info->band];
|
||
|
fc = hdr->frame_control;
|
||
|
@@ -996,17 +995,6 @@ static void __ieee80211_tx_status(struct
|
||
|
ieee80211_hw_check(&local->hw, REPORTS_TX_ACK_STATUS))
|
||
|
ieee80211_sta_tx_notify(sta->sdata, (void *) skb->data,
|
||
|
acked, info->status.tx_time);
|
||
|
-
|
||
|
- if ((tx_time_est = ieee80211_info_get_tx_time_est(info)) > 0) {
|
||
|
- /* Do this here to avoid the expensive lookup of the sta
|
||
|
- * in ieee80211_report_used_skb().
|
||
|
- */
|
||
|
- ieee80211_sta_update_pending_airtime(local, sta,
|
||
|
- skb_get_queue_mapping(skb),
|
||
|
- tx_time_est,
|
||
|
- true);
|
||
|
- ieee80211_info_set_tx_time_est(info, 0);
|
||
|
- }
|
||
|
}
|
||
|
|
||
|
/* SNMP counters
|
||
|
@@ -1102,9 +1090,11 @@ void ieee80211_tx_status_ext(struct ieee
|
||
|
struct ieee80211_tx_info *info = status->info;
|
||
|
struct ieee80211_sta *pubsta = status->sta;
|
||
|
struct ieee80211_supported_band *sband;
|
||
|
- struct sta_info *sta;
|
||
|
+ struct sk_buff *skb = status->skb;
|
||
|
+ struct sta_info *sta = NULL;
|
||
|
int rates_idx, retry_count;
|
||
|
bool acked, noack_success;
|
||
|
+ u16 tx_time_est;
|
||
|
|
||
|
if (pubsta) {
|
||
|
sta = container_of(pubsta, struct sta_info, sta);
|
||
|
@@ -1156,7 +1146,18 @@ void ieee80211_tx_status_ext(struct ieee
|
||
|
ieee80211s_update_metric(local, sta, status);
|
||
|
}
|
||
|
|
||
|
- if (status->skb)
|
||
|
+ if (skb && (tx_time_est = ieee80211_info_get_tx_time_est(info)) > 0) {
|
||
|
+ /* Do this here to avoid the expensive lookup of the sta
|
||
|
+ * in ieee80211_report_used_skb().
|
||
|
+ */
|
||
|
+ ieee80211_sta_update_pending_airtime(local, sta,
|
||
|
+ skb_get_queue_mapping(skb),
|
||
|
+ tx_time_est,
|
||
|
+ true);
|
||
|
+ ieee80211_info_set_tx_time_est(info, 0);
|
||
|
+ }
|
||
|
+
|
||
|
+ if (skb && !(info->flags & IEEE80211_TX_CTL_HW_80211_ENCAP))
|
||
|
return __ieee80211_tx_status(hw, status, rates_idx,
|
||
|
retry_count);
|
||
|
|
||
|
@@ -1171,6 +1172,12 @@ void ieee80211_tx_status_ext(struct ieee
|
||
|
} else {
|
||
|
I802_DEBUG_INC(local->dot11FailedCount);
|
||
|
}
|
||
|
+
|
||
|
+ if (!skb)
|
||
|
+ return;
|
||
|
+
|
||
|
+ ieee80211_report_used_skb(local, skb, false);
|
||
|
+ dev_kfree_skb(skb);
|
||
|
}
|
||
|
EXPORT_SYMBOL(ieee80211_tx_status_ext);
|
||
|
|
||
|
@@ -1197,66 +1204,23 @@ void ieee80211_tx_status_8023(struct iee
|
||
|
struct ieee80211_vif *vif,
|
||
|
struct sk_buff *skb)
|
||
|
{
|
||
|
- struct ieee80211_local *local = hw_to_local(hw);
|
||
|
struct ieee80211_sub_if_data *sdata;
|
||
|
- struct ieee80211_tx_info *info = IEEE80211_SKB_CB(skb);
|
||
|
+ struct ieee80211_tx_status status = {
|
||
|
+ .skb = skb,
|
||
|
+ .info = IEEE80211_SKB_CB(skb),
|
||
|
+ };
|
||
|
struct sta_info *sta;
|
||
|
- int retry_count;
|
||
|
- int rates_idx;
|
||
|
- bool acked;
|
||
|
|
||
|
sdata = vif_to_sdata(vif);
|
||
|
|
||
|
- acked = info->flags & IEEE80211_TX_STAT_ACK;
|
||
|
- rates_idx = ieee80211_tx_get_rates(hw, info, &retry_count);
|
||
|
-
|
||
|
rcu_read_lock();
|
||
|
|
||
|
- if (ieee80211_lookup_ra_sta(sdata, skb, &sta))
|
||
|
- goto counters_update;
|
||
|
-
|
||
|
- if (IS_ERR(sta))
|
||
|
- goto counters_update;
|
||
|
-
|
||
|
- if (!acked)
|
||
|
- sta->status_stats.retry_failed++;
|
||
|
-
|
||
|
- if (rates_idx != -1)
|
||
|
- sta->tx_stats.last_rate = info->status.rates[rates_idx];
|
||
|
-
|
||
|
- sta->status_stats.retry_count += retry_count;
|
||
|
-
|
||
|
- if (ieee80211_hw_check(hw, REPORTS_TX_ACK_STATUS)) {
|
||
|
- sta->status_stats.last_ack = jiffies;
|
||
|
- if (info->flags & IEEE80211_TX_STAT_ACK) {
|
||
|
- if (sta->status_stats.lost_packets)
|
||
|
- sta->status_stats.lost_packets = 0;
|
||
|
+ if (!ieee80211_lookup_ra_sta(sdata, skb, &sta) && !IS_ERR(sta))
|
||
|
+ status.sta = &sta->sta;
|
||
|
|
||
|
- sta->status_stats.last_pkt_time = jiffies;
|
||
|
- } else {
|
||
|
- ieee80211_lost_packet(sta, info);
|
||
|
- }
|
||
|
- }
|
||
|
+ ieee80211_tx_status_ext(hw, &status);
|
||
|
|
||
|
-counters_update:
|
||
|
rcu_read_unlock();
|
||
|
- ieee80211_led_tx(local);
|
||
|
-
|
||
|
- if (!(info->flags & IEEE80211_TX_STAT_ACK) &&
|
||
|
- !(info->flags & IEEE80211_TX_STAT_NOACK_TRANSMITTED))
|
||
|
- goto skip_stats_update;
|
||
|
-
|
||
|
- I802_DEBUG_INC(local->dot11TransmittedFrameCount);
|
||
|
- if (is_multicast_ether_addr(skb->data))
|
||
|
- I802_DEBUG_INC(local->dot11MulticastTransmittedFrameCount);
|
||
|
- if (retry_count > 0)
|
||
|
- I802_DEBUG_INC(local->dot11RetryCount);
|
||
|
- if (retry_count > 1)
|
||
|
- I802_DEBUG_INC(local->dot11MultipleRetryCount);
|
||
|
-
|
||
|
-skip_stats_update:
|
||
|
- ieee80211_report_used_skb(local, skb, false);
|
||
|
- dev_kfree_skb(skb);
|
||
|
}
|
||
|
EXPORT_SYMBOL(ieee80211_tx_status_8023);
|
||
|
|