Lines Matching refs:htt

31 	hash_for_each_possible(ar->htt.rx_ring.skb_table, rxcb, hlist, paddr)  in ath10k_htt_rx_find_skb_paddr()
39 static void ath10k_htt_rx_ring_free(struct ath10k_htt *htt) in ath10k_htt_rx_ring_free() argument
46 if (htt->rx_ring.in_ord_rx) { in ath10k_htt_rx_ring_free()
47 hash_for_each_safe(htt->rx_ring.skb_table, i, n, rxcb, hlist) { in ath10k_htt_rx_ring_free()
49 dma_unmap_single(htt->ar->dev, rxcb->paddr, in ath10k_htt_rx_ring_free()
56 for (i = 0; i < htt->rx_ring.size; i++) { in ath10k_htt_rx_ring_free()
57 skb = htt->rx_ring.netbufs_ring[i]; in ath10k_htt_rx_ring_free()
62 dma_unmap_single(htt->ar->dev, rxcb->paddr, in ath10k_htt_rx_ring_free()
69 htt->rx_ring.fill_cnt = 0; in ath10k_htt_rx_ring_free()
70 hash_init(htt->rx_ring.skb_table); in ath10k_htt_rx_ring_free()
71 memset(htt->rx_ring.netbufs_ring, 0, in ath10k_htt_rx_ring_free()
72 htt->rx_ring.size * sizeof(htt->rx_ring.netbufs_ring[0])); in ath10k_htt_rx_ring_free()
75 static size_t ath10k_htt_get_rx_ring_size_32(struct ath10k_htt *htt) in ath10k_htt_get_rx_ring_size_32() argument
77 return htt->rx_ring.size * sizeof(htt->rx_ring.paddrs_ring_32); in ath10k_htt_get_rx_ring_size_32()
80 static size_t ath10k_htt_get_rx_ring_size_64(struct ath10k_htt *htt) in ath10k_htt_get_rx_ring_size_64() argument
82 return htt->rx_ring.size * sizeof(htt->rx_ring.paddrs_ring_64); in ath10k_htt_get_rx_ring_size_64()
85 static void ath10k_htt_config_paddrs_ring_32(struct ath10k_htt *htt, in ath10k_htt_config_paddrs_ring_32() argument
88 htt->rx_ring.paddrs_ring_32 = vaddr; in ath10k_htt_config_paddrs_ring_32()
91 static void ath10k_htt_config_paddrs_ring_64(struct ath10k_htt *htt, in ath10k_htt_config_paddrs_ring_64() argument
94 htt->rx_ring.paddrs_ring_64 = vaddr; in ath10k_htt_config_paddrs_ring_64()
97 static void ath10k_htt_set_paddrs_ring_32(struct ath10k_htt *htt, in ath10k_htt_set_paddrs_ring_32() argument
100 htt->rx_ring.paddrs_ring_32[idx] = __cpu_to_le32(paddr); in ath10k_htt_set_paddrs_ring_32()
103 static void ath10k_htt_set_paddrs_ring_64(struct ath10k_htt *htt, in ath10k_htt_set_paddrs_ring_64() argument
106 htt->rx_ring.paddrs_ring_64[idx] = __cpu_to_le64(paddr); in ath10k_htt_set_paddrs_ring_64()
109 static void ath10k_htt_reset_paddrs_ring_32(struct ath10k_htt *htt, int idx) in ath10k_htt_reset_paddrs_ring_32() argument
111 htt->rx_ring.paddrs_ring_32[idx] = 0; in ath10k_htt_reset_paddrs_ring_32()
114 static void ath10k_htt_reset_paddrs_ring_64(struct ath10k_htt *htt, int idx) in ath10k_htt_reset_paddrs_ring_64() argument
116 htt->rx_ring.paddrs_ring_64[idx] = 0; in ath10k_htt_reset_paddrs_ring_64()
119 static void *ath10k_htt_get_vaddr_ring_32(struct ath10k_htt *htt) in ath10k_htt_get_vaddr_ring_32() argument
121 return (void *)htt->rx_ring.paddrs_ring_32; in ath10k_htt_get_vaddr_ring_32()
124 static void *ath10k_htt_get_vaddr_ring_64(struct ath10k_htt *htt) in ath10k_htt_get_vaddr_ring_64() argument
126 return (void *)htt->rx_ring.paddrs_ring_64; in ath10k_htt_get_vaddr_ring_64()
129 static int __ath10k_htt_rx_ring_fill_n(struct ath10k_htt *htt, int num) in __ath10k_htt_rx_ring_fill_n() argument
144 idx = __le32_to_cpu(*htt->rx_ring.alloc_idx.vaddr); in __ath10k_htt_rx_ring_fill_n()
161 paddr = dma_map_single(htt->ar->dev, skb->data, in __ath10k_htt_rx_ring_fill_n()
165 if (unlikely(dma_mapping_error(htt->ar->dev, paddr))) { in __ath10k_htt_rx_ring_fill_n()
173 htt->rx_ring.netbufs_ring[idx] = skb; in __ath10k_htt_rx_ring_fill_n()
174 ath10k_htt_set_paddrs_ring(htt, paddr, idx); in __ath10k_htt_rx_ring_fill_n()
175 htt->rx_ring.fill_cnt++; in __ath10k_htt_rx_ring_fill_n()
177 if (htt->rx_ring.in_ord_rx) { in __ath10k_htt_rx_ring_fill_n()
178 hash_add(htt->rx_ring.skb_table, in __ath10k_htt_rx_ring_fill_n()
185 idx &= htt->rx_ring.size_mask; in __ath10k_htt_rx_ring_fill_n()
194 *htt->rx_ring.alloc_idx.vaddr = __cpu_to_le32(idx); in __ath10k_htt_rx_ring_fill_n()
198 static int ath10k_htt_rx_ring_fill_n(struct ath10k_htt *htt, int num) in ath10k_htt_rx_ring_fill_n() argument
200 lockdep_assert_held(&htt->rx_ring.lock); in ath10k_htt_rx_ring_fill_n()
201 return __ath10k_htt_rx_ring_fill_n(htt, num); in ath10k_htt_rx_ring_fill_n()
204 static void ath10k_htt_rx_msdu_buff_replenish(struct ath10k_htt *htt) in ath10k_htt_rx_msdu_buff_replenish() argument
224 spin_lock_bh(&htt->rx_ring.lock); in ath10k_htt_rx_msdu_buff_replenish()
225 num_deficit = htt->rx_ring.fill_level - htt->rx_ring.fill_cnt; in ath10k_htt_rx_msdu_buff_replenish()
228 ret = ath10k_htt_rx_ring_fill_n(htt, num_to_fill); in ath10k_htt_rx_msdu_buff_replenish()
236 mod_timer(&htt->rx_ring.refill_retry_timer, jiffies + in ath10k_htt_rx_msdu_buff_replenish()
239 mod_timer(&htt->rx_ring.refill_retry_timer, jiffies + in ath10k_htt_rx_msdu_buff_replenish()
242 spin_unlock_bh(&htt->rx_ring.lock); in ath10k_htt_rx_msdu_buff_replenish()
247 struct ath10k_htt *htt = from_timer(htt, t, rx_ring.refill_retry_timer); in ath10k_htt_rx_ring_refill_retry() local
249 ath10k_htt_rx_msdu_buff_replenish(htt); in ath10k_htt_rx_ring_refill_retry()
254 struct ath10k_htt *htt = &ar->htt; in ath10k_htt_rx_ring_refill() local
260 spin_lock_bh(&htt->rx_ring.lock); in ath10k_htt_rx_ring_refill()
261 ret = ath10k_htt_rx_ring_fill_n(htt, (htt->rx_ring.fill_level - in ath10k_htt_rx_ring_refill()
262 htt->rx_ring.fill_cnt)); in ath10k_htt_rx_ring_refill()
265 ath10k_htt_rx_ring_free(htt); in ath10k_htt_rx_ring_refill()
267 spin_unlock_bh(&htt->rx_ring.lock); in ath10k_htt_rx_ring_refill()
272 void ath10k_htt_rx_free(struct ath10k_htt *htt) in ath10k_htt_rx_free() argument
274 if (htt->ar->bus_param.dev_type == ATH10K_DEV_TYPE_HL) in ath10k_htt_rx_free()
277 del_timer_sync(&htt->rx_ring.refill_retry_timer); in ath10k_htt_rx_free()
279 skb_queue_purge(&htt->rx_msdus_q); in ath10k_htt_rx_free()
280 skb_queue_purge(&htt->rx_in_ord_compl_q); in ath10k_htt_rx_free()
281 skb_queue_purge(&htt->tx_fetch_ind_q); in ath10k_htt_rx_free()
283 spin_lock_bh(&htt->rx_ring.lock); in ath10k_htt_rx_free()
284 ath10k_htt_rx_ring_free(htt); in ath10k_htt_rx_free()
285 spin_unlock_bh(&htt->rx_ring.lock); in ath10k_htt_rx_free()
287 dma_free_coherent(htt->ar->dev, in ath10k_htt_rx_free()
288 ath10k_htt_get_rx_ring_size(htt), in ath10k_htt_rx_free()
289 ath10k_htt_get_vaddr_ring(htt), in ath10k_htt_rx_free()
290 htt->rx_ring.base_paddr); in ath10k_htt_rx_free()
292 dma_free_coherent(htt->ar->dev, in ath10k_htt_rx_free()
293 sizeof(*htt->rx_ring.alloc_idx.vaddr), in ath10k_htt_rx_free()
294 htt->rx_ring.alloc_idx.vaddr, in ath10k_htt_rx_free()
295 htt->rx_ring.alloc_idx.paddr); in ath10k_htt_rx_free()
297 kfree(htt->rx_ring.netbufs_ring); in ath10k_htt_rx_free()
300 static inline struct sk_buff *ath10k_htt_rx_netbuf_pop(struct ath10k_htt *htt) in ath10k_htt_rx_netbuf_pop() argument
302 struct ath10k *ar = htt->ar; in ath10k_htt_rx_netbuf_pop()
306 lockdep_assert_held(&htt->rx_ring.lock); in ath10k_htt_rx_netbuf_pop()
308 if (htt->rx_ring.fill_cnt == 0) { in ath10k_htt_rx_netbuf_pop()
313 idx = htt->rx_ring.sw_rd_idx.msdu_payld; in ath10k_htt_rx_netbuf_pop()
314 msdu = htt->rx_ring.netbufs_ring[idx]; in ath10k_htt_rx_netbuf_pop()
315 htt->rx_ring.netbufs_ring[idx] = NULL; in ath10k_htt_rx_netbuf_pop()
316 ath10k_htt_reset_paddrs_ring(htt, idx); in ath10k_htt_rx_netbuf_pop()
319 idx &= htt->rx_ring.size_mask; in ath10k_htt_rx_netbuf_pop()
320 htt->rx_ring.sw_rd_idx.msdu_payld = idx; in ath10k_htt_rx_netbuf_pop()
321 htt->rx_ring.fill_cnt--; in ath10k_htt_rx_netbuf_pop()
323 dma_unmap_single(htt->ar->dev, in ath10k_htt_rx_netbuf_pop()
334 static int ath10k_htt_rx_amsdu_pop(struct ath10k_htt *htt, in ath10k_htt_rx_amsdu_pop() argument
337 struct ath10k *ar = htt->ar; in ath10k_htt_rx_amsdu_pop()
342 lockdep_assert_held(&htt->rx_ring.lock); in ath10k_htt_rx_amsdu_pop()
347 msdu = ath10k_htt_rx_netbuf_pop(htt); in ath10k_htt_rx_amsdu_pop()
393 msdu = ath10k_htt_rx_netbuf_pop(htt); in ath10k_htt_rx_amsdu_pop()
435 static struct sk_buff *ath10k_htt_rx_pop_paddr(struct ath10k_htt *htt, in ath10k_htt_rx_pop_paddr() argument
438 struct ath10k *ar = htt->ar; in ath10k_htt_rx_pop_paddr()
442 lockdep_assert_held(&htt->rx_ring.lock); in ath10k_htt_rx_pop_paddr()
450 htt->rx_ring.fill_cnt--; in ath10k_htt_rx_pop_paddr()
452 dma_unmap_single(htt->ar->dev, rxcb->paddr, in ath10k_htt_rx_pop_paddr()
470 static int ath10k_htt_rx_handle_amsdu_mon_32(struct ath10k_htt *htt, in ath10k_htt_rx_handle_amsdu_mon_32() argument
474 struct ath10k *ar = htt->ar; in ath10k_htt_rx_handle_amsdu_mon_32()
503 frag_buf = ath10k_htt_rx_pop_paddr(htt, paddr); in ath10k_htt_rx_handle_amsdu_mon_32()
518 frag_buf = ath10k_htt_rx_pop_paddr(htt, paddr); in ath10k_htt_rx_handle_amsdu_mon_32()
546 ath10k_htt_rx_handle_amsdu_mon_64(struct ath10k_htt *htt, in ath10k_htt_rx_handle_amsdu_mon_64() argument
550 struct ath10k *ar = htt->ar; in ath10k_htt_rx_handle_amsdu_mon_64()
579 frag_buf = ath10k_htt_rx_pop_paddr(htt, paddr); in ath10k_htt_rx_handle_amsdu_mon_64()
594 frag_buf = ath10k_htt_rx_pop_paddr(htt, paddr); in ath10k_htt_rx_handle_amsdu_mon_64()
621 static int ath10k_htt_rx_pop_paddr32_list(struct ath10k_htt *htt, in ath10k_htt_rx_pop_paddr32_list() argument
625 struct ath10k *ar = htt->ar; in ath10k_htt_rx_pop_paddr32_list()
633 lockdep_assert_held(&htt->rx_ring.lock); in ath10k_htt_rx_pop_paddr32_list()
641 msdu = ath10k_htt_rx_pop_paddr(htt, paddr); in ath10k_htt_rx_pop_paddr32_list()
648 ret = ath10k_htt_rx_handle_amsdu_mon_32(htt, msdu, in ath10k_htt_rx_pop_paddr32_list()
672 ath10k_warn(htt->ar, "tried to pop an incomplete frame, oops!\n"); in ath10k_htt_rx_pop_paddr32_list()
683 static int ath10k_htt_rx_pop_paddr64_list(struct ath10k_htt *htt, in ath10k_htt_rx_pop_paddr64_list() argument
687 struct ath10k *ar = htt->ar; in ath10k_htt_rx_pop_paddr64_list()
695 lockdep_assert_held(&htt->rx_ring.lock); in ath10k_htt_rx_pop_paddr64_list()
702 msdu = ath10k_htt_rx_pop_paddr(htt, paddr); in ath10k_htt_rx_pop_paddr64_list()
709 ret = ath10k_htt_rx_handle_amsdu_mon_64(htt, msdu, in ath10k_htt_rx_pop_paddr64_list()
733 ath10k_warn(htt->ar, "tried to pop an incomplete frame, oops!\n"); in ath10k_htt_rx_pop_paddr64_list()
744 int ath10k_htt_rx_alloc(struct ath10k_htt *htt) in ath10k_htt_rx_alloc() argument
746 struct ath10k *ar = htt->ar; in ath10k_htt_rx_alloc()
750 struct timer_list *timer = &htt->rx_ring.refill_retry_timer; in ath10k_htt_rx_alloc()
755 htt->rx_confused = false; in ath10k_htt_rx_alloc()
760 htt->rx_ring.size = HTT_RX_RING_SIZE; in ath10k_htt_rx_alloc()
761 htt->rx_ring.size_mask = htt->rx_ring.size - 1; in ath10k_htt_rx_alloc()
762 htt->rx_ring.fill_level = ar->hw_params.rx_ring_fill_level; in ath10k_htt_rx_alloc()
764 if (!is_power_of_2(htt->rx_ring.size)) { in ath10k_htt_rx_alloc()
769 htt->rx_ring.netbufs_ring = in ath10k_htt_rx_alloc()
770 kcalloc(htt->rx_ring.size, sizeof(struct sk_buff *), in ath10k_htt_rx_alloc()
772 if (!htt->rx_ring.netbufs_ring) in ath10k_htt_rx_alloc()
775 size = ath10k_htt_get_rx_ring_size(htt); in ath10k_htt_rx_alloc()
777 vaddr_ring = dma_alloc_coherent(htt->ar->dev, size, &paddr, GFP_KERNEL); in ath10k_htt_rx_alloc()
781 ath10k_htt_config_paddrs_ring(htt, vaddr_ring); in ath10k_htt_rx_alloc()
782 htt->rx_ring.base_paddr = paddr; in ath10k_htt_rx_alloc()
784 vaddr = dma_alloc_coherent(htt->ar->dev, in ath10k_htt_rx_alloc()
785 sizeof(*htt->rx_ring.alloc_idx.vaddr), in ath10k_htt_rx_alloc()
790 htt->rx_ring.alloc_idx.vaddr = vaddr; in ath10k_htt_rx_alloc()
791 htt->rx_ring.alloc_idx.paddr = paddr; in ath10k_htt_rx_alloc()
792 htt->rx_ring.sw_rd_idx.msdu_payld = htt->rx_ring.size_mask; in ath10k_htt_rx_alloc()
793 *htt->rx_ring.alloc_idx.vaddr = 0; in ath10k_htt_rx_alloc()
798 spin_lock_init(&htt->rx_ring.lock); in ath10k_htt_rx_alloc()
800 htt->rx_ring.fill_cnt = 0; in ath10k_htt_rx_alloc()
801 htt->rx_ring.sw_rd_idx.msdu_payld = 0; in ath10k_htt_rx_alloc()
802 hash_init(htt->rx_ring.skb_table); in ath10k_htt_rx_alloc()
804 skb_queue_head_init(&htt->rx_msdus_q); in ath10k_htt_rx_alloc()
805 skb_queue_head_init(&htt->rx_in_ord_compl_q); in ath10k_htt_rx_alloc()
806 skb_queue_head_init(&htt->tx_fetch_ind_q); in ath10k_htt_rx_alloc()
807 atomic_set(&htt->num_mpdus_ready, 0); in ath10k_htt_rx_alloc()
810 htt->rx_ring.size, htt->rx_ring.fill_level); in ath10k_htt_rx_alloc()
814 dma_free_coherent(htt->ar->dev, in ath10k_htt_rx_alloc()
815 ath10k_htt_get_rx_ring_size(htt), in ath10k_htt_rx_alloc()
817 htt->rx_ring.base_paddr); in ath10k_htt_rx_alloc()
819 kfree(htt->rx_ring.netbufs_ring); in ath10k_htt_rx_alloc()
1277 skb_queue_tail(&ar->htt.rx_msdus_q, skb); in ath10k_htt_rx_h_queue_msdu()
2011 static int ath10k_htt_rx_handle_amsdu(struct ath10k_htt *htt) in ath10k_htt_rx_handle_amsdu() argument
2013 struct ath10k *ar = htt->ar; in ath10k_htt_rx_handle_amsdu()
2014 struct ieee80211_rx_status *rx_status = &htt->rx_status; in ath10k_htt_rx_handle_amsdu()
2026 spin_lock_bh(&htt->rx_ring.lock); in ath10k_htt_rx_handle_amsdu()
2027 if (htt->rx_confused) { in ath10k_htt_rx_handle_amsdu()
2028 spin_unlock_bh(&htt->rx_ring.lock); in ath10k_htt_rx_handle_amsdu()
2031 ret = ath10k_htt_rx_amsdu_pop(htt, &amsdu); in ath10k_htt_rx_handle_amsdu()
2032 spin_unlock_bh(&htt->rx_ring.lock); in ath10k_htt_rx_handle_amsdu()
2040 htt->rx_confused = true; in ath10k_htt_rx_handle_amsdu()
2144 static bool ath10k_htt_rx_proc_rx_ind_hl(struct ath10k_htt *htt, in ath10k_htt_rx_proc_rx_ind_hl() argument
2150 struct ath10k *ar = htt->ar; in ath10k_htt_rx_proc_rx_ind_hl()
2438 static bool ath10k_htt_rx_proc_rx_frag_ind_hl(struct ath10k_htt *htt, in ath10k_htt_rx_proc_rx_frag_ind_hl() argument
2442 struct ath10k *ar = htt->ar; in ath10k_htt_rx_proc_rx_frag_ind_hl()
2488 return ath10k_htt_rx_proc_rx_ind_hl(htt, &resp->rx_ind_hl, skb, in ath10k_htt_rx_proc_rx_frag_ind_hl()
2552 return ath10k_htt_rx_proc_rx_ind_hl(htt, &resp->rx_ind_hl, skb, in ath10k_htt_rx_proc_rx_frag_ind_hl()
2579 return ath10k_htt_rx_proc_rx_ind_hl(htt, &resp->rx_ind_hl, skb, in ath10k_htt_rx_proc_rx_frag_ind_hl()
2591 static void ath10k_htt_rx_proc_rx_ind_ll(struct ath10k_htt *htt, in ath10k_htt_rx_proc_rx_ind_ll() argument
2594 struct ath10k *ar = htt->ar; in ath10k_htt_rx_proc_rx_ind_ll()
2614 atomic_add(mpdu_count, &htt->num_mpdus_ready); in ath10k_htt_rx_proc_rx_ind_ll()
2623 struct ath10k_htt *htt = &ar->htt; in ath10k_htt_rx_tx_compl_ind() local
2692 ath10k_txrx_tx_unref(htt, &tx_done); in ath10k_htt_rx_tx_compl_ind()
2693 } else if (!kfifo_put(&htt->txdone_fifo, tx_done)) { in ath10k_htt_rx_tx_compl_ind()
2696 ath10k_txrx_tx_unref(htt, &tx_done); in ath10k_htt_rx_tx_compl_ind()
2879 struct ath10k_htt *htt = &ar->htt; in ath10k_htt_rx_h_rx_offload() local
2880 struct ieee80211_rx_status *status = &htt->rx_status; in ath10k_htt_rx_h_rx_offload()
2928 struct ath10k_htt *htt = &ar->htt; in ath10k_htt_rx_in_ord_ind() local
2930 struct ieee80211_rx_status *status = &htt->rx_status; in ath10k_htt_rx_in_ord_ind()
2941 lockdep_assert_held(&htt->rx_ring.lock); in ath10k_htt_rx_in_ord_ind()
2943 if (htt->rx_confused) in ath10k_htt_rx_in_ord_ind()
2971 ret = ath10k_htt_rx_pop_paddr64_list(htt, &resp->rx_in_ord_ind, in ath10k_htt_rx_in_ord_ind()
2974 ret = ath10k_htt_rx_pop_paddr32_list(htt, &resp->rx_in_ord_ind, in ath10k_htt_rx_in_ord_ind()
2979 htt->rx_confused = true; in ath10k_htt_rx_in_ord_ind()
3011 htt->rx_confused = true; in ath10k_htt_rx_in_ord_ind()
3082 if (!ar->htt.tx_q_state.enabled) { in ath10k_htt_rx_tx_fetch_ind()
3087 if (ar->htt.tx_q_state.mode == HTT_TX_MODE_SWITCH_PUSH) { in ath10k_htt_rx_tx_fetch_ind()
3106 if (unlikely(peer_id >= ar->htt.tx_q_state.num_peers) || in ath10k_htt_rx_tx_fetch_ind()
3107 unlikely(tid >= ar->htt.tx_q_state.num_tids)) { in ath10k_htt_rx_tx_fetch_ind()
3258 ar->htt.tx_q_state.enabled = enable; in ath10k_htt_rx_tx_mode_switch_ind()
3259 ar->htt.tx_q_state.mode = mode; in ath10k_htt_rx_tx_mode_switch_ind()
3260 ar->htt.tx_q_state.num_push_allowed = threshold; in ath10k_htt_rx_tx_mode_switch_ind()
3270 if (unlikely(peer_id >= ar->htt.tx_q_state.num_peers) || in ath10k_htt_rx_tx_mode_switch_ind()
3271 unlikely(tid >= ar->htt.tx_q_state.num_tids)) { in ath10k_htt_rx_tx_mode_switch_ind()
3291 spin_lock_bh(&ar->htt.tx_lock); in ath10k_htt_rx_tx_mode_switch_ind()
3294 spin_unlock_bh(&ar->htt.tx_lock); in ath10k_htt_rx_tx_mode_switch_ind()
3728 struct ath10k_htt *htt = &ar->htt; in ath10k_htt_t2h_msg_handler() local
3739 if (resp->hdr.msg_type >= ar->htt.t2h_msg_types_max) { in ath10k_htt_t2h_msg_handler()
3741 resp->hdr.msg_type, ar->htt.t2h_msg_types_max); in ath10k_htt_t2h_msg_handler()
3744 type = ar->htt.t2h_msg_types[resp->hdr.msg_type]; in ath10k_htt_t2h_msg_handler()
3748 htt->target_version_major = resp->ver_resp.major; in ath10k_htt_t2h_msg_handler()
3749 htt->target_version_minor = resp->ver_resp.minor; in ath10k_htt_t2h_msg_handler()
3750 complete(&htt->target_version_received); in ath10k_htt_t2h_msg_handler()
3755 return ath10k_htt_rx_proc_rx_ind_hl(htt, in ath10k_htt_t2h_msg_handler()
3761 ath10k_htt_rx_proc_rx_ind_ll(htt, &resp->rx_ind); in ath10k_htt_t2h_msg_handler()
3769 ath10k_peer_map_event(htt, &ev); in ath10k_htt_t2h_msg_handler()
3776 ath10k_peer_unmap_event(htt, &ev); in ath10k_htt_t2h_msg_handler()
3806 status = ath10k_txrx_tx_unref(htt, &tx_done); in ath10k_htt_t2h_msg_handler()
3808 spin_lock_bh(&htt->tx_lock); in ath10k_htt_t2h_msg_handler()
3809 ath10k_htt_tx_mgmt_dec_pending(htt); in ath10k_htt_t2h_msg_handler()
3810 spin_unlock_bh(&htt->tx_lock); in ath10k_htt_t2h_msg_handler()
3815 ath10k_htt_rx_tx_compl_ind(htt->ar, skb); in ath10k_htt_t2h_msg_handler()
3818 struct ath10k *ar = htt->ar; in ath10k_htt_t2h_msg_handler()
3833 atomic_inc(&htt->num_mpdus_ready); in ath10k_htt_t2h_msg_handler()
3835 return ath10k_htt_rx_proc_rx_frag_ind(htt, in ath10k_htt_t2h_msg_handler()
3877 skb_queue_tail(&htt->rx_in_ord_compl_q, skb); in ath10k_htt_t2h_msg_handler()
3901 skb_queue_tail(&htt->tx_fetch_ind_q, tx_fetch_ind); in ath10k_htt_t2h_msg_handler()
3938 if (skb_queue_empty(&ar->htt.rx_msdus_q)) in ath10k_htt_rx_deliver_msdu()
3941 skb = skb_dequeue(&ar->htt.rx_msdus_q); in ath10k_htt_rx_deliver_msdu()
3953 struct ath10k_htt *htt = &ar->htt; in ath10k_htt_txrx_compl_task() local
3972 while ((skb = skb_dequeue(&htt->rx_in_ord_compl_q))) { in ath10k_htt_txrx_compl_task()
3973 spin_lock_bh(&htt->rx_ring.lock); in ath10k_htt_txrx_compl_task()
3975 spin_unlock_bh(&htt->rx_ring.lock); in ath10k_htt_txrx_compl_task()
3984 while (atomic_read(&htt->num_mpdus_ready)) { in ath10k_htt_txrx_compl_task()
3985 ret = ath10k_htt_rx_handle_amsdu(htt); in ath10k_htt_txrx_compl_task()
3990 atomic_dec(&htt->num_mpdus_ready); in ath10k_htt_txrx_compl_task()
4001 if ((quota < budget) && !kfifo_is_empty(&htt->txdone_fifo)) in ath10k_htt_txrx_compl_task()
4009 while (kfifo_get(&htt->txdone_fifo, &tx_done)) in ath10k_htt_txrx_compl_task()
4010 ath10k_txrx_tx_unref(htt, &tx_done); in ath10k_htt_txrx_compl_task()
4014 spin_lock_irqsave(&htt->tx_fetch_ind_q.lock, flags); in ath10k_htt_txrx_compl_task()
4015 skb_queue_splice_init(&htt->tx_fetch_ind_q, &tx_ind_q); in ath10k_htt_txrx_compl_task()
4016 spin_unlock_irqrestore(&htt->tx_fetch_ind_q.lock, flags); in ath10k_htt_txrx_compl_task()
4024 ath10k_htt_rx_msdu_buff_replenish(htt); in ath10k_htt_txrx_compl_task()
4054 void ath10k_htt_set_rx_ops(struct ath10k_htt *htt) in ath10k_htt_set_rx_ops() argument
4056 struct ath10k *ar = htt->ar; in ath10k_htt_set_rx_ops()
4059 htt->rx_ops = &htt_rx_ops_hl; in ath10k_htt_set_rx_ops()
4061 htt->rx_ops = &htt_rx_ops_64; in ath10k_htt_set_rx_ops()
4063 htt->rx_ops = &htt_rx_ops_32; in ath10k_htt_set_rx_ops()