Return-path: Received: from nm.newmedia-net.de ([217.113.179.122]:36384 "EHLO webmail.newmedia-net.de" rhost-flags-OK-OK-OK-OK) by vger.kernel.org with ESMTP id S1751874AbcF0XEp (ORCPT ); Mon, 27 Jun 2016 19:04:45 -0400 To: Rajkumar Manoharan , ath10k@lists.infradead.org References: <20160627055128.7005-1-rmanohar@qti.qualcomm.com> Cc: linux-wireless@vger.kernel.org, rmanohar@codeaurora.org From: Sebastian Gottschall Message-ID: <82ef94b8-69dd-7ff7-35ab-f865251528a4@dd-wrt.com> (sfid-20160628_010449_590519_9CB0C86F) Date: Tue, 28 Jun 2016 00:45:41 +0200 MIME-Version: 1.0 In-Reply-To: <20160627055128.7005-1-rmanohar@qti.qualcomm.com> Content-Type: text/plain; charset=windows-1252; format=flowed Subject: Re: [PATCH] ath10k: implement NAPI support Sender: linux-wireless-owner@vger.kernel.org List-ID: broken patch CC [M] /home/seg/DEV/pb42/src/router/private/compat-wireless-2016-05-12/drivers/net/wireless/ath/ath10k/htt_tx.o /home/seg/DEV/pb42/src/router/private/compat-wireless-2016-05-12/drivers/net/wireless/ath/ath10k/htt_tx.c: In function 'ath10k_htt_tx_free': /home/seg/DEV/pb42/src/router/private/compat-wireless-2016-05-12/drivers/net/wireless/ath/ath10k/htt_tx.c:391:19: error: 'struct ath10k_htt' has no member named 'txrx_compl_task' Sebastian Am 27.06.2016 um 07:51 schrieb Rajkumar Manoharan: > Add NAPI support for rx and tx completion. NAPI poll is scheduled > from interrupt handler. The design is as below > > - on interrupt > - schedule napi and mask interrupts > - on poll > - process all pipes (no actual Tx/Rx) > - process Rx within budget > - if quota exceeds budget reschedule napi poll by returning budget > - process Tx completions and update budget if necessary > - process Tx fetch indications (pull-push) > - push any other pending Tx (if possible) > - before resched or napi completion replenish htt rx ring buffer > - if work done < budget, complete napi poll and unmask interrupts > > This change also get rid of two tasklets (intr_tq and txrx_compl_task). > > Measured peak throughput with NAPI on IPQ4019 platform in controlled > environment. No noticeable reduction in throughput is seen and also > observed improvements in CPU usage. Approx. 15% CPU usage got reduced > in UDP uplink case. > > DL: AP DUT Tx > UL: AP DUT Rx > > IPQ4019 (avg. cpu usage %) > ======== > TOT +NAPI > =========== ============= > TCP DL 644 Mbps (42%) 645 Mbps (36%) > TCP UL 673 Mbps (30%) 675 Mbps (26%) > UDP DL 682 Mbps (49%) 680 Mbps (49%) > UDP UL 720 Mbps (28%) 717 Mbps (11%) > > Signed-off-by: Rajkumar Manoharan > --- > drivers/net/wireless/ath/ath10k/ahb.c | 4 +- > drivers/net/wireless/ath/ath10k/core.c | 2 + > drivers/net/wireless/ath/ath10k/core.h | 8 ++ > drivers/net/wireless/ath/ath10k/htt.h | 2 +- > drivers/net/wireless/ath/ath10k/htt_rx.c | 154 +++++++++++++++++++------------ > drivers/net/wireless/ath/ath10k/pci.c | 67 +++++++++----- > drivers/net/wireless/ath/ath10k/pci.h | 5 +- > 7 files changed, 149 insertions(+), 93 deletions(-) > > diff --git a/drivers/net/wireless/ath/ath10k/ahb.c b/drivers/net/wireless/ath/ath10k/ahb.c > index acec16b9cf49..9d4d5022be18 100644 > --- a/drivers/net/wireless/ath/ath10k/ahb.c > +++ b/drivers/net/wireless/ath/ath10k/ahb.c > @@ -462,13 +462,11 @@ static void ath10k_ahb_halt_chip(struct ath10k *ar) > static irqreturn_t ath10k_ahb_interrupt_handler(int irq, void *arg) > { > struct ath10k *ar = arg; > - struct ath10k_pci *ar_pci = ath10k_pci_priv(ar); > > if (!ath10k_pci_irq_pending(ar)) > return IRQ_NONE; > > ath10k_pci_disable_and_clear_legacy_irq(ar); > - tasklet_schedule(&ar_pci->intr_tq); > > return IRQ_HANDLED; > } > @@ -831,7 +829,7 @@ static int ath10k_ahb_probe(struct platform_device *pdev) > goto err_resource_deinit; > } > > - ath10k_pci_init_irq_tasklets(ar); > + ath10k_pci_init_napi(ar); > > ret = ath10k_ahb_request_irq_legacy(ar); > if (ret) > diff --git a/drivers/net/wireless/ath/ath10k/core.c b/drivers/net/wireless/ath/ath10k/core.c > index dfb3db0ee5d1..2639e7e0836b 100644 > --- a/drivers/net/wireless/ath/ath10k/core.c > +++ b/drivers/net/wireless/ath/ath10k/core.c > @@ -2223,6 +2223,8 @@ struct ath10k *ath10k_core_create(size_t priv_size, struct device *dev, > INIT_WORK(&ar->register_work, ath10k_core_register_work); > INIT_WORK(&ar->restart_work, ath10k_core_restart); > > + init_dummy_netdev(&ar->napi_dev); > + > ret = ath10k_debug_create(ar); > if (ret) > goto err_free_aux_wq; > diff --git a/drivers/net/wireless/ath/ath10k/core.h b/drivers/net/wireless/ath/ath10k/core.h > index 3da18c9dbd7a..10878926b629 100644 > --- a/drivers/net/wireless/ath/ath10k/core.h > +++ b/drivers/net/wireless/ath/ath10k/core.h > @@ -65,6 +65,10 @@ > #define ATH10K_KEEPALIVE_MAX_IDLE 3895 > #define ATH10K_KEEPALIVE_MAX_UNRESPONSIVE 3900 > > +/* NAPI poll budget */ > +#define ATH10K_NAPI_BUDGET 64 > +#define ATH10K_NAPI_QUOTA_LIMIT 60 > + > struct ath10k; > > enum ath10k_bus { > @@ -926,6 +930,10 @@ struct ath10k { > struct ath10k_thermal thermal; > struct ath10k_wow wow; > > + /* NAPI */ > + struct net_device napi_dev; > + struct napi_struct napi; > + > /* must be last */ > u8 drv_priv[0] __aligned(sizeof(void *)); > }; > diff --git a/drivers/net/wireless/ath/ath10k/htt.h b/drivers/net/wireless/ath/ath10k/htt.h > index 430a83e142aa..98c14247021b 100644 > --- a/drivers/net/wireless/ath/ath10k/htt.h > +++ b/drivers/net/wireless/ath/ath10k/htt.h > @@ -1665,7 +1665,6 @@ struct ath10k_htt { > > /* This is used to group tx/rx completions separately and process them > * in batches to reduce cache stalls */ > - struct tasklet_struct txrx_compl_task; > struct sk_buff_head rx_compl_q; > struct sk_buff_head rx_in_ord_compl_q; > struct sk_buff_head tx_fetch_ind_q; > @@ -1798,5 +1797,6 @@ int ath10k_htt_tx(struct ath10k_htt *htt, > struct sk_buff *msdu); > void ath10k_htt_rx_pktlog_completion_handler(struct ath10k *ar, > struct sk_buff *skb); > +int ath10k_htt_txrx_compl_task(struct ath10k *ar, int budget); > > #endif > diff --git a/drivers/net/wireless/ath/ath10k/htt_rx.c b/drivers/net/wireless/ath/ath10k/htt_rx.c > index 80e645302b54..c68b39bfc7bb 100644 > --- a/drivers/net/wireless/ath/ath10k/htt_rx.c > +++ b/drivers/net/wireless/ath/ath10k/htt_rx.c > @@ -34,7 +34,6 @@ > #define HTT_RX_RING_REFILL_RESCHED_MS 5 > > static int ath10k_htt_rx_get_csum_state(struct sk_buff *skb); > -static void ath10k_htt_txrx_compl_task(unsigned long ptr); > > static struct sk_buff * > ath10k_htt_rx_find_skb_paddr(struct ath10k *ar, u32 paddr) > @@ -226,7 +225,6 @@ int ath10k_htt_rx_ring_refill(struct ath10k *ar) > void ath10k_htt_rx_free(struct ath10k_htt *htt) > { > del_timer_sync(&htt->rx_ring.refill_retry_timer); > - tasklet_kill(&htt->txrx_compl_task); > > skb_queue_purge(&htt->rx_compl_q); > skb_queue_purge(&htt->rx_in_ord_compl_q); > @@ -520,9 +518,6 @@ int ath10k_htt_rx_alloc(struct ath10k_htt *htt) > skb_queue_head_init(&htt->tx_fetch_ind_q); > atomic_set(&htt->num_mpdus_ready, 0); > > - tasklet_init(&htt->txrx_compl_task, ath10k_htt_txrx_compl_task, > - (unsigned long)htt); > - > ath10k_dbg(ar, ATH10K_DBG_BOOT, "htt rx ring size %d fill_level %d\n", > htt->rx_ring.size, htt->rx_ring.fill_level); > return 0; > @@ -958,7 +953,7 @@ static void ath10k_process_rx(struct ath10k *ar, > trace_ath10k_rx_hdr(ar, skb->data, skb->len); > trace_ath10k_rx_payload(ar, skb->data, skb->len); > > - ieee80211_rx(ar->hw, skb); > + ieee80211_rx_napi(ar->hw, NULL, skb, &ar->napi); > } > > static int ath10k_htt_rx_nwifi_hdrlen(struct ath10k *ar, > @@ -1527,7 +1522,7 @@ static int ath10k_htt_rx_handle_amsdu(struct ath10k_htt *htt) > struct ath10k *ar = htt->ar; > static struct ieee80211_rx_status rx_status; > struct sk_buff_head amsdu; > - int ret; > + int ret, num_msdus; > > __skb_queue_head_init(&amsdu); > > @@ -1549,13 +1544,14 @@ static int ath10k_htt_rx_handle_amsdu(struct ath10k_htt *htt) > return ret; > } > > + num_msdus = skb_queue_len(&amsdu); > ath10k_htt_rx_h_ppdu(ar, &amsdu, &rx_status, 0xffff); > ath10k_htt_rx_h_unchain(ar, &amsdu, ret > 0); > ath10k_htt_rx_h_filter(ar, &amsdu, &rx_status); > ath10k_htt_rx_h_mpdu(ar, &amsdu, &rx_status); > ath10k_htt_rx_h_deliver(ar, &amsdu, &rx_status); > > - return 0; > + return num_msdus; > } > > static void ath10k_htt_rx_proc_rx_ind(struct ath10k_htt *htt, > @@ -1579,15 +1575,6 @@ static void ath10k_htt_rx_proc_rx_ind(struct ath10k_htt *htt, > mpdu_count += mpdu_ranges[i].mpdu_count; > > atomic_add(mpdu_count, &htt->num_mpdus_ready); > - > - tasklet_schedule(&htt->txrx_compl_task); > -} > - > -static void ath10k_htt_rx_frag_handler(struct ath10k_htt *htt) > -{ > - atomic_inc(&htt->num_mpdus_ready); > - > - tasklet_schedule(&htt->txrx_compl_task); > } > > static void ath10k_htt_rx_tx_compl_ind(struct ath10k *ar, > @@ -1772,14 +1759,15 @@ static void ath10k_htt_rx_h_rx_offload_prot(struct ieee80211_rx_status *status, > RX_FLAG_MMIC_STRIPPED; > } > > -static void ath10k_htt_rx_h_rx_offload(struct ath10k *ar, > - struct sk_buff_head *list) > +static int ath10k_htt_rx_h_rx_offload(struct ath10k *ar, > + struct sk_buff_head *list) > { > struct ath10k_htt *htt = &ar->htt; > struct ieee80211_rx_status *status = &htt->rx_status; > struct htt_rx_offload_msdu *rx; > struct sk_buff *msdu; > size_t offset; > + int num_msdu = 0; > > while ((msdu = __skb_dequeue(list))) { > /* Offloaded frames don't have Rx descriptor. Instead they have > @@ -1819,10 +1807,12 @@ static void ath10k_htt_rx_h_rx_offload(struct ath10k *ar, > ath10k_htt_rx_h_rx_offload_prot(status, msdu); > ath10k_htt_rx_h_channel(ar, status, NULL, rx->vdev_id); > ath10k_process_rx(ar, status, msdu); > + num_msdu++; > } > + return num_msdu; > } > > -static void ath10k_htt_rx_in_ord_ind(struct ath10k *ar, struct sk_buff *skb) > +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; > @@ -1835,12 +1825,12 @@ static void ath10k_htt_rx_in_ord_ind(struct ath10k *ar, struct sk_buff *skb) > u8 tid; > bool offload; > bool frag; > - int ret; > + int ret, num_msdus = 0; > > lockdep_assert_held(&htt->rx_ring.lock); > > if (htt->rx_confused) > - return; > + return -EIO; > > skb_pull(skb, sizeof(resp->hdr)); > skb_pull(skb, sizeof(resp->rx_in_ord_ind)); > @@ -1859,7 +1849,7 @@ static void ath10k_htt_rx_in_ord_ind(struct ath10k *ar, struct sk_buff *skb) > > if (skb->len < msdu_count * sizeof(*resp->rx_in_ord_ind.msdu_descs)) { > ath10k_warn(ar, "dropping invalid in order rx indication\n"); > - return; > + return -EINVAL; > } > > /* The event can deliver more than 1 A-MSDU. Each A-MSDU is later > @@ -1870,14 +1860,14 @@ static void ath10k_htt_rx_in_ord_ind(struct ath10k *ar, struct sk_buff *skb) > if (ret < 0) { > ath10k_warn(ar, "failed to pop paddr list: %d\n", ret); > htt->rx_confused = true; > - return; > + return -EIO; > } > > /* Offloaded frames are very different and need to be handled > * separately. > */ > if (offload) > - ath10k_htt_rx_h_rx_offload(ar, &list); > + num_msdus = ath10k_htt_rx_h_rx_offload(ar, &list); > > while (!skb_queue_empty(&list)) { > __skb_queue_head_init(&amsdu); > @@ -1890,6 +1880,7 @@ static void ath10k_htt_rx_in_ord_ind(struct ath10k *ar, struct sk_buff *skb) > * better to report something than nothing though. This > * should still give an idea about rx rate to the user. > */ > + num_msdus += 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); > @@ -1902,9 +1893,10 @@ static void ath10k_htt_rx_in_ord_ind(struct ath10k *ar, struct sk_buff *skb) > ath10k_warn(ar, "failed to extract amsdu: %d\n", ret); > htt->rx_confused = true; > __skb_queue_purge(&list); > - return; > + return -EIO; > } > } > + return num_msdus; > } > > static void ath10k_htt_rx_tx_fetch_resp_id_confirm(struct ath10k *ar, > @@ -2267,7 +2259,6 @@ bool ath10k_htt_t2h_msg_handler(struct ath10k *ar, struct sk_buff *skb) > } > case HTT_T2H_MSG_TYPE_TX_COMPL_IND: > ath10k_htt_rx_tx_compl_ind(htt->ar, skb); > - tasklet_schedule(&htt->txrx_compl_task); > break; > case HTT_T2H_MSG_TYPE_SEC_IND: { > struct ath10k *ar = htt->ar; > @@ -2284,7 +2275,7 @@ bool ath10k_htt_t2h_msg_handler(struct ath10k *ar, struct sk_buff *skb) > case HTT_T2H_MSG_TYPE_RX_FRAG_IND: { > ath10k_dbg_dump(ar, ATH10K_DBG_HTT_DUMP, NULL, "htt event: ", > skb->data, skb->len); > - ath10k_htt_rx_frag_handler(htt); > + atomic_inc(&htt->num_mpdus_ready); > break; > } > case HTT_T2H_MSG_TYPE_TEST: > @@ -2322,8 +2313,7 @@ bool ath10k_htt_t2h_msg_handler(struct ath10k *ar, struct sk_buff *skb) > break; > } > case HTT_T2H_MSG_TYPE_RX_IN_ORD_PADDR_IND: { > - skb_queue_tail(&htt->rx_in_ord_compl_q, skb); > - tasklet_schedule(&htt->txrx_compl_task); > + __skb_queue_tail(&htt->rx_in_ord_compl_q, skb); > return false; > } > case HTT_T2H_MSG_TYPE_TX_CREDIT_UPDATE_IND: > @@ -2349,7 +2339,6 @@ bool ath10k_htt_t2h_msg_handler(struct ath10k *ar, struct sk_buff *skb) > break; > } > skb_queue_tail(&htt->tx_fetch_ind_q, tx_fetch_ind); > - tasklet_schedule(&htt->txrx_compl_task); > break; > } > case HTT_T2H_MSG_TYPE_TX_FETCH_CONFIRM: > @@ -2378,27 +2367,77 @@ void ath10k_htt_rx_pktlog_completion_handler(struct ath10k *ar, > } > EXPORT_SYMBOL(ath10k_htt_rx_pktlog_completion_handler); > > -static void ath10k_htt_txrx_compl_task(unsigned long ptr) > +int ath10k_htt_txrx_compl_task(struct ath10k *ar, int budget) > { > - struct ath10k_htt *htt = (struct ath10k_htt *)ptr; > - struct ath10k *ar = htt->ar; > + struct ath10k_htt *htt = &ar->htt; > struct htt_tx_done tx_done = {}; > - struct sk_buff_head rx_ind_q; > struct sk_buff_head tx_ind_q; > struct sk_buff *skb; > unsigned long flags; > - int num_mpdus; > + int quota = 0, done, num_rx_msdus; > + bool resched_napi = false; > > - __skb_queue_head_init(&rx_ind_q); > __skb_queue_head_init(&tx_ind_q); > > - spin_lock_irqsave(&htt->rx_in_ord_compl_q.lock, flags); > - skb_queue_splice_init(&htt->rx_in_ord_compl_q, &rx_ind_q); > - spin_unlock_irqrestore(&htt->rx_in_ord_compl_q.lock, flags); > + /* Since in-ord-ind can deliver more than 1 A-MSDU in single event, > + * process it first to utilize full available quota. > + */ > + while (quota < budget) { > + if (skb_queue_empty(&htt->rx_in_ord_compl_q)) > + break; > > - spin_lock_irqsave(&htt->tx_fetch_ind_q.lock, flags); > - skb_queue_splice_init(&htt->tx_fetch_ind_q, &tx_ind_q); > - spin_unlock_irqrestore(&htt->tx_fetch_ind_q.lock, flags); > + skb = __skb_dequeue(&htt->rx_in_ord_compl_q); > + if (!skb) { > + resched_napi = true; > + goto exit; > + } > + > + spin_lock_bh(&htt->rx_ring.lock); > + 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; > + goto exit; > + } > + > + dev_kfree_skb_any(skb); > + if (num_rx_msdus > 0) > + quota += num_rx_msdus; > + > + if ((quota > ATH10K_NAPI_QUOTA_LIMIT) && > + !skb_queue_empty(&htt->rx_in_ord_compl_q)) { > + resched_napi = true; > + goto exit; > + } > + } > + > + while (quota < budget) { > + /* no more data to receive */ > + if (!atomic_read(&htt->num_mpdus_ready)) > + break; > + > + num_rx_msdus = ath10k_htt_rx_handle_amsdu(htt); > + if (num_rx_msdus < 0) { > + resched_napi = true; > + goto exit; > + } > + > + quota += num_rx_msdus; > + atomic_dec(&htt->num_mpdus_ready); > + if ((quota > ATH10K_NAPI_QUOTA_LIMIT) && > + atomic_read(&htt->num_mpdus_ready)) { > + resched_napi = true; > + goto exit; > + } > + } > + > + /* From NAPI documentation: > + * The napi poll() function may also process TX completions, in which > + * case if it processes the entire TX ring then it should count that > + * work as the rest of the budget. > + */ > + if ((quota < budget) && !kfifo_is_empty(&htt->txdone_fifo)) > + quota = budget; > > /* kfifo_get: called only within txrx_tasklet so it's neatly serialized. > * From kfifo_get() documentation: > @@ -2408,27 +2447,22 @@ static void ath10k_htt_txrx_compl_task(unsigned long ptr) > while (kfifo_get(&htt->txdone_fifo, &tx_done)) > ath10k_txrx_tx_unref(htt, &tx_done); > > + spin_lock_irqsave(&htt->tx_fetch_ind_q.lock, flags); > + skb_queue_splice_init(&htt->tx_fetch_ind_q, &tx_ind_q); > + spin_unlock_irqrestore(&htt->tx_fetch_ind_q.lock, flags); > + > while ((skb = __skb_dequeue(&tx_ind_q))) { > ath10k_htt_rx_tx_fetch_ind(ar, skb); > dev_kfree_skb_any(skb); > } > > - num_mpdus = atomic_read(&htt->num_mpdus_ready); > - > - while (num_mpdus) { > - if (ath10k_htt_rx_handle_amsdu(htt)) > - break; > - > - num_mpdus--; > - atomic_dec(&htt->num_mpdus_ready); > - } > - > - while ((skb = __skb_dequeue(&rx_ind_q))) { > - spin_lock_bh(&htt->rx_ring.lock); > - ath10k_htt_rx_in_ord_ind(ar, skb); > - spin_unlock_bh(&htt->rx_ring.lock); > - dev_kfree_skb_any(skb); > - } > - > +exit: > ath10k_htt_rx_msdu_buff_replenish(htt); > + /* In case of rx failure or more data to read, report budget > + * to reschedule NAPI poll > + */ > + done = resched_napi ? budget : quota; > + > + return done; > } > +EXPORT_SYMBOL(ath10k_htt_txrx_compl_task); > diff --git a/drivers/net/wireless/ath/ath10k/pci.c b/drivers/net/wireless/ath/ath10k/pci.c > index f06dd3941bac..9169ab92a16a 100644 > --- a/drivers/net/wireless/ath/ath10k/pci.c > +++ b/drivers/net/wireless/ath/ath10k/pci.c > @@ -1502,12 +1502,10 @@ void ath10k_pci_hif_send_complete_check(struct ath10k *ar, u8 pipe, > ath10k_ce_per_engine_service(ar, pipe); > } > > -void ath10k_pci_kill_tasklet(struct ath10k *ar) > +static void ath10k_pci_rx_retry_sync(struct ath10k *ar) > { > struct ath10k_pci *ar_pci = ath10k_pci_priv(ar); > > - tasklet_kill(&ar_pci->intr_tq); > - > del_timer_sync(&ar_pci->rx_post_retry); > } > > @@ -1747,7 +1745,7 @@ void ath10k_pci_ce_deinit(struct ath10k *ar) > > void ath10k_pci_flush(struct ath10k *ar) > { > - ath10k_pci_kill_tasklet(ar); > + ath10k_pci_rx_retry_sync(ar); > ath10k_pci_buffer_cleanup(ar); > } > > @@ -2754,35 +2752,53 @@ static irqreturn_t ath10k_pci_interrupt_handler(int irq, void *arg) > return IRQ_NONE; > } > > - if (ar_pci->oper_irq_mode == ATH10K_PCI_IRQ_LEGACY) { > - if (!ath10k_pci_irq_pending(ar)) > - return IRQ_NONE; > - > - ath10k_pci_disable_and_clear_legacy_irq(ar); > - } > + if ((ar_pci->oper_irq_mode == ATH10K_PCI_IRQ_LEGACY) && > + !ath10k_pci_irq_pending(ar)) > + return IRQ_NONE; > > - tasklet_schedule(&ar_pci->intr_tq); > + ath10k_pci_disable_and_clear_legacy_irq(ar); > + ath10k_pci_irq_msi_fw_mask(ar); > + napi_schedule(&ar->napi); > > return IRQ_HANDLED; > } > > -static void ath10k_pci_tasklet(unsigned long data) > +static int ath10k_pci_napi_poll(struct napi_struct *ctx, int budget) > { > - struct ath10k *ar = (struct ath10k *)data; > - struct ath10k_pci *ar_pci = ath10k_pci_priv(ar); > + struct ath10k *ar = container_of(ctx, struct ath10k, napi); > + int done = 0; > > if (ath10k_pci_has_fw_crashed(ar)) { > - ath10k_pci_irq_disable(ar); > ath10k_pci_fw_crashed_clear(ar); > ath10k_pci_fw_crashed_dump(ar); > - return; > + napi_complete(ctx); > + return done; > } > > ath10k_ce_per_engine_service_any(ar); > > - /* Re-enable legacy irq that was disabled in the irq handler */ > - if (ar_pci->oper_irq_mode == ATH10K_PCI_IRQ_LEGACY) > + done = ath10k_htt_txrx_compl_task(ar, budget); > + > + if (done < budget) { > + napi_complete(ctx); > + /* In case of MSI, it is possible that interrupts are received > + * while NAPI poll is inprogress. So pending interrupts that are > + * received after processing all copy engine pipes by NAPI poll > + * will not be handled again. This is causing failure to > + * complete boot sequence in x86 platform. So before enabling > + * interrupts safer to check for pending interrupts for > + * immediate servicing. > + */ > + if (CE_INTERRUPT_SUMMARY(ar)) { > + napi_reschedule(&ar->napi); > + goto out; > + } > ath10k_pci_enable_legacy_irq(ar); > + ath10k_pci_irq_msi_fw_unmask(ar); > + } > + > +out: > + return done; > } > > static int ath10k_pci_request_irq_msi(struct ath10k *ar) > @@ -2840,11 +2856,11 @@ static void ath10k_pci_free_irq(struct ath10k *ar) > free_irq(ar_pci->pdev->irq, ar); > } > > -void ath10k_pci_init_irq_tasklets(struct ath10k *ar) > +void ath10k_pci_init_napi(struct ath10k *ar) > { > - struct ath10k_pci *ar_pci = ath10k_pci_priv(ar); > - > - tasklet_init(&ar_pci->intr_tq, ath10k_pci_tasklet, (unsigned long)ar); > + netif_napi_add(&ar->napi_dev, &ar->napi, ath10k_pci_napi_poll, > + ATH10K_NAPI_BUDGET); > + napi_enable(&ar->napi); > } > > static int ath10k_pci_init_irq(struct ath10k *ar) > @@ -2852,7 +2868,7 @@ static int ath10k_pci_init_irq(struct ath10k *ar) > struct ath10k_pci *ar_pci = ath10k_pci_priv(ar); > int ret; > > - ath10k_pci_init_irq_tasklets(ar); > + ath10k_pci_init_napi(ar); > > if (ath10k_pci_irq_mode != ATH10K_PCI_IRQ_AUTO) > ath10k_info(ar, "limiting irq mode to: %d\n", > @@ -3113,7 +3129,8 @@ int ath10k_pci_setup_resource(struct ath10k *ar) > > void ath10k_pci_release_resource(struct ath10k *ar) > { > - ath10k_pci_kill_tasklet(ar); > + ath10k_pci_rx_retry_sync(ar); > + netif_napi_del(&ar->napi); > ath10k_pci_ce_deinit(ar); > ath10k_pci_free_pipes(ar); > } > @@ -3274,7 +3291,7 @@ static int ath10k_pci_probe(struct pci_dev *pdev, > > err_free_irq: > ath10k_pci_free_irq(ar); > - ath10k_pci_kill_tasklet(ar); > + ath10k_pci_rx_retry_sync(ar); > > err_deinit_irq: > ath10k_pci_deinit_irq(ar); > diff --git a/drivers/net/wireless/ath/ath10k/pci.h b/drivers/net/wireless/ath/ath10k/pci.h > index 6eca1df2ce60..974e463e8b95 100644 > --- a/drivers/net/wireless/ath/ath10k/pci.h > +++ b/drivers/net/wireless/ath/ath10k/pci.h > @@ -177,8 +177,6 @@ struct ath10k_pci { > /* Operating interrupt mode */ > enum ath10k_pci_irq_mode oper_irq_mode; > > - struct tasklet_struct intr_tq; > - > struct ath10k_pci_pipe pipe_info[CE_COUNT_MAX]; > > /* Copy Engine used for Diagnostic Accesses */ > @@ -294,8 +292,7 @@ void ath10k_pci_free_pipes(struct ath10k *ar); > void ath10k_pci_free_pipes(struct ath10k *ar); > void ath10k_pci_rx_replenish_retry(unsigned long ptr); > void ath10k_pci_ce_deinit(struct ath10k *ar); > -void ath10k_pci_init_irq_tasklets(struct ath10k *ar); > -void ath10k_pci_kill_tasklet(struct ath10k *ar); > +void ath10k_pci_init_napi(struct ath10k *ar); > int ath10k_pci_init_pipes(struct ath10k *ar); > int ath10k_pci_init_config(struct ath10k *ar); > void ath10k_pci_rx_post(struct ath10k *ar); -- Mit freundlichen Gr?ssen / Regards Sebastian Gottschall / CTO NewMedia-NET GmbH - DD-WRT Firmensitz: Berliner Ring 101, 64625 Bensheim Registergericht: Amtsgericht Darmstadt, HRB 25473 Gesch?ftsf?hrer: Peter Steinh?user, Christian Scheele http://www.dd-wrt.com email: s.gottschall@dd-wrt.com Tel.: +496251-582650 / Fax: +496251-5826565