|
@@ -1818,8 +1818,7 @@ static void ath10k_htt_rx_delba(struct ath10k *ar, struct htt_resp *resp)
|
|
|
}
|
|
|
|
|
|
static int ath10k_htt_rx_extract_amsdu(struct sk_buff_head *list,
|
|
|
- struct sk_buff_head *amsdu,
|
|
|
- int budget_left)
|
|
|
+ struct sk_buff_head *amsdu)
|
|
|
{
|
|
|
struct sk_buff *msdu;
|
|
|
struct htt_rx_desc *rxd;
|
|
@@ -1830,9 +1829,8 @@ static int ath10k_htt_rx_extract_amsdu(struct sk_buff_head *list,
|
|
|
if (WARN_ON(!skb_queue_empty(amsdu)))
|
|
|
return -EINVAL;
|
|
|
|
|
|
- while ((msdu = __skb_dequeue(list)) && budget_left) {
|
|
|
+ while ((msdu = __skb_dequeue(list))) {
|
|
|
__skb_queue_tail(amsdu, msdu);
|
|
|
- budget_left--;
|
|
|
|
|
|
rxd = (void *)msdu->data - sizeof(*rxd);
|
|
|
if (rxd->msdu_end.common.info0 &
|
|
@@ -1923,8 +1921,7 @@ static int ath10k_htt_rx_h_rx_offload(struct ath10k *ar,
|
|
|
return num_msdu;
|
|
|
}
|
|
|
|
|
|
-static int ath10k_htt_rx_in_ord_ind(struct ath10k *ar, struct sk_buff *skb,
|
|
|
- int budget_left)
|
|
|
+static int ath10k_htt_rx_in_ord_ind(struct ath10k *ar, struct sk_buff *skb)
|
|
|
{
|
|
|
struct ath10k_htt *htt = &ar->htt;
|
|
|
struct htt_resp *resp = (void *)skb->data;
|
|
@@ -1981,9 +1978,9 @@ static int ath10k_htt_rx_in_ord_ind(struct ath10k *ar, struct sk_buff *skb,
|
|
|
if (offload)
|
|
|
num_msdus = ath10k_htt_rx_h_rx_offload(ar, &list);
|
|
|
|
|
|
- while (!skb_queue_empty(&list) && budget_left) {
|
|
|
+ while (!skb_queue_empty(&list)) {
|
|
|
__skb_queue_head_init(&amsdu);
|
|
|
- ret = ath10k_htt_rx_extract_amsdu(&list, &amsdu, budget_left);
|
|
|
+ ret = ath10k_htt_rx_extract_amsdu(&list, &amsdu);
|
|
|
switch (ret) {
|
|
|
case 0:
|
|
|
/* Note: The in-order indication may report interleaved
|
|
@@ -1993,7 +1990,6 @@ static int ath10k_htt_rx_in_ord_ind(struct ath10k *ar, struct sk_buff *skb,
|
|
|
* should still give an idea about rx rate to the user.
|
|
|
*/
|
|
|
num_msdus += skb_queue_len(&amsdu);
|
|
|
- budget_left -= skb_queue_len(&amsdu);
|
|
|
ath10k_htt_rx_h_ppdu(ar, &amsdu, status, vdev_id);
|
|
|
ath10k_htt_rx_h_filter(ar, &amsdu, status);
|
|
|
ath10k_htt_rx_h_mpdu(ar, &amsdu, status, false);
|
|
@@ -2636,8 +2632,7 @@ int ath10k_htt_txrx_compl_task(struct ath10k *ar, int budget)
|
|
|
}
|
|
|
|
|
|
spin_lock_bh(&htt->rx_ring.lock);
|
|
|
- num_rx_msdus = ath10k_htt_rx_in_ord_ind(ar, skb,
|
|
|
- (budget - quota));
|
|
|
+ num_rx_msdus = ath10k_htt_rx_in_ord_ind(ar, skb);
|
|
|
spin_unlock_bh(&htt->rx_ring.lock);
|
|
|
if (num_rx_msdus < 0) {
|
|
|
resched_napi = true;
|