ath/ath12k/dp_mon.c

863 static void ath12k_dp_mon_rx_msdus_set_payload(struct ath12k *ar, struct sk_buff *msdu)
867 	rx_pkt_offset = ar->ab->hal.hal_desc_sz;
868 	l2_hdr_offset = ath12k_dp_rx_h_l3pad(ar->ab,
874 ath12k_dp_mon_rx_merg_msdus(struct ath12k *ar,
878 	struct ath12k_base *ab = ar->ab;
898 	ath12k_dp_rx_h_ppdu(ar, rx_desc, rxs);
901 		ath12k_dp_mon_rx_msdus_set_payload(ar, head_msdu);
907 			ath12k_dp_mon_rx_msdus_set_payload(ar, msdu);
932 			ath12k_dp_mon_rx_msdus_set_payload(ar, msdu);
1016 static void ath12k_dp_mon_update_radiotap(struct ath12k *ar,
1053 		sband = &ar->mac.sbands[rxs->band];
1061 static void ath12k_dp_mon_rx_deliver_msdu(struct ath12k *ar, struct napi_struct *napi,
1087 		decap = ath12k_dp_rx_h_decap_type(ar->ab, rxcb->rx_desc);
1088 	spin_lock_bh(&ar->ab->base_lock);
1089 	peer = ath12k_dp_rx_h_find_peer(ar->ab, msdu);
1092 	spin_unlock_bh(&ar->ab->base_lock);
1094 	ath12k_dbg(ar->ab, ATH12K_DBG_DATA,
1118 	ath12k_dbg_dump(ar->ab, ATH12K_DBG_DP_RX, NULL, "dp rx msdu: ",
1134 	ieee80211_rx_napi(ath12k_ar_to_hw(ar), pubsta, msdu, napi);
1137 static int ath12k_dp_mon_rx_deliver(struct ath12k *ar, u32 mac_id,
1142 	struct ath12k_pdev_dp *dp = &ar->dp;
1147 	mon_skb = ath12k_dp_mon_rx_merg_msdus(ar, mac_id, head_msdu,
1172 		ath12k_dp_mon_update_radiotap(ar, ppduinfo, mon_skb, rxs);
1173 		ath12k_dp_mon_rx_deliver_msdu(ar, napi, mon_skb, rxs);
1233 ath12k_dp_mon_rx_parse_mon_status(struct ath12k *ar,
1239 	struct ath12k_base *ab = ar->ab;
1254 			ath12k_dp_mon_rx_deliver(ar, mac_id, head_msdu,
1983 ath12k_dp_mon_tx_process_ppdu_info(struct ath12k *ar, int mac_id,
1996 			ath12k_dp_mon_rx_deliver(ar, mac_id, head_msdu,
2004 ath12k_dp_mon_tx_parse_mon_status(struct ath12k *ar,
2011 	struct ath12k_base *ab = ar->ab;
2053 	ath12k_dp_mon_tx_process_ppdu_info(ar, mac_id, napi, tx_data_ppdu_info);
2054 	ath12k_dp_mon_tx_process_ppdu_info(ar, mac_id, napi, tx_prot_ppdu_info);
2059 int ath12k_dp_mon_srng_process(struct ath12k *ar, int mac_id, int *budget,
2064 	struct ath12k_pdev_dp *pdev_dp = &ar->dp;
2066 	struct ath12k_base *ab = ar->ab;
2136 				ath12k_dp_mon_rx_parse_mon_status(ar, pmon, mac_id,
2139 				ath12k_dp_mon_tx_parse_mon_status(ar, pmon, mac_id,
2205 static void ath12k_dp_mon_rx_update_peer_su_stats(struct ath12k *ar,
2358 ath12k_dp_mon_rx_update_user_stats(struct ath12k *ar,
2371 	peer = ath12k_peer_find_by_ast(ar->ab, user_stats->ast_index);
2374 		ath12k_warn(ar->ab, "peer ast idx %d can't be found\n",
2459 ath12k_dp_mon_rx_update_peer_mu_stats(struct ath12k *ar,
2469 		ath12k_dp_mon_rx_update_user_stats(ar, ppdu_info, i);
2472 int ath12k_dp_mon_rx_process_stats(struct ath12k *ar, int mac_id,
2475 	struct ath12k_base *ab = ar->ab;
2476 	struct ath12k_pdev_dp *pdev_dp = &ar->dp;
2556 				ath12k_dp_mon_rx_update_peer_su_stats(ar, arsta,
2561 				ath12k_dp_mon_rx_update_peer_mu_stats(ar, ppdu_info);
2587 	struct ath12k *ar = ath12k_ab_to_ar(ab, mac_id);
2590 	if (!ar->monitor_started)
2591 		ath12k_dp_mon_rx_process_stats(ar, mac_id, napi, &budget);
2593 		num_buffs_reaped = ath12k_dp_mon_srng_process(ar, mac_id, &budget,