dp_internal.h 42 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312
  1. /*
  2. * Copyright (c) 2016-2019 The Linux Foundation. All rights reserved.
  3. *
  4. * Permission to use, copy, modify, and/or distribute this software for
  5. * any purpose with or without fee is hereby granted, provided that the
  6. * above copyright notice and this permission notice appear in all
  7. * copies.
  8. *
  9. * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL
  10. * WARRANTIES WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED
  11. * WARRANTIES OF MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE
  12. * AUTHOR BE LIABLE FOR ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL
  13. * DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR
  14. * PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE OR OTHER
  15. * TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR
  16. * PERFORMANCE OF THIS SOFTWARE.
  17. */
  18. #ifndef _DP_INTERNAL_H_
  19. #define _DP_INTERNAL_H_
  20. #include "dp_types.h"
  21. #define RX_BUFFER_SIZE_PKTLOG_LITE 1024
  22. #define DP_RSSI_INVAL 0x80
  23. #define DP_RSSI_AVG_WEIGHT 2
  24. /*
  25. * Formula to derive avg_rssi is taken from wifi2.o firmware
  26. */
  27. #define DP_GET_AVG_RSSI(avg_rssi, last_rssi) \
  28. (((avg_rssi) - (((uint8_t)(avg_rssi)) >> DP_RSSI_AVG_WEIGHT)) \
  29. + ((((uint8_t)(last_rssi)) >> DP_RSSI_AVG_WEIGHT)))
  30. /* Macro For NYSM value received in VHT TLV */
  31. #define VHT_SGI_NYSM 3
  32. /* PPDU STATS CFG */
  33. #define DP_PPDU_STATS_CFG_ALL 0xFFFF
  34. /* PPDU stats mask sent to FW to enable enhanced stats */
  35. #define DP_PPDU_STATS_CFG_ENH_STATS 0xE67
  36. /* PPDU stats mask sent to FW to support debug sniffer feature */
  37. #define DP_PPDU_STATS_CFG_SNIFFER 0x2FFF
  38. /* PPDU stats mask sent to FW to support BPR feature*/
  39. #define DP_PPDU_STATS_CFG_BPR 0x2000
  40. /* PPDU stats mask sent to FW to support BPR and enhanced stats feature */
  41. #define DP_PPDU_STATS_CFG_BPR_ENH (DP_PPDU_STATS_CFG_BPR | \
  42. DP_PPDU_STATS_CFG_ENH_STATS)
  43. /* PPDU stats mask sent to FW to support BPR and pcktlog stats feature */
  44. #define DP_PPDU_STATS_CFG_BPR_PKTLOG (DP_PPDU_STATS_CFG_BPR | \
  45. DP_PPDU_TXLITE_STATS_BITMASK_CFG)
  46. /**
  47. * Bitmap of HTT PPDU TLV types for Default mode
  48. */
  49. #define HTT_PPDU_DEFAULT_TLV_BITMAP \
  50. (1 << HTT_PPDU_STATS_COMMON_TLV) | \
  51. (1 << HTT_PPDU_STATS_USR_COMMON_TLV) | \
  52. (1 << HTT_PPDU_STATS_USR_RATE_TLV) | \
  53. (1 << HTT_PPDU_STATS_SCH_CMD_STATUS_TLV) | \
  54. (1 << HTT_PPDU_STATS_USR_COMPLTN_COMMON_TLV) | \
  55. (1 << HTT_PPDU_STATS_USR_COMPLTN_ACK_BA_STATUS_TLV)
  56. /**
  57. * Bitmap of HTT PPDU TLV types for Sniffer mode bitmap 64
  58. */
  59. #define HTT_PPDU_SNIFFER_AMPDU_TLV_BITMAP_64 \
  60. ((1 << HTT_PPDU_STATS_COMMON_TLV) | \
  61. (1 << HTT_PPDU_STATS_USR_COMMON_TLV) | \
  62. (1 << HTT_PPDU_STATS_USR_RATE_TLV) | \
  63. (1 << HTT_PPDU_STATS_SCH_CMD_STATUS_TLV) | \
  64. (1 << HTT_PPDU_STATS_USR_COMPLTN_COMMON_TLV) | \
  65. (1 << HTT_PPDU_STATS_USR_COMPLTN_ACK_BA_STATUS_TLV) | \
  66. (1 << HTT_PPDU_STATS_USR_COMPLTN_BA_BITMAP_64_TLV) | \
  67. (1 << HTT_PPDU_STATS_USR_MPDU_ENQ_BITMAP_64_TLV))
  68. /**
  69. * Bitmap of HTT PPDU TLV types for Sniffer mode bitmap 256
  70. */
  71. #define HTT_PPDU_SNIFFER_AMPDU_TLV_BITMAP_256 \
  72. ((1 << HTT_PPDU_STATS_COMMON_TLV) | \
  73. (1 << HTT_PPDU_STATS_USR_COMMON_TLV) | \
  74. (1 << HTT_PPDU_STATS_USR_RATE_TLV) | \
  75. (1 << HTT_PPDU_STATS_SCH_CMD_STATUS_TLV) | \
  76. (1 << HTT_PPDU_STATS_USR_COMPLTN_COMMON_TLV) | \
  77. (1 << HTT_PPDU_STATS_USR_COMPLTN_ACK_BA_STATUS_TLV) | \
  78. (1 << HTT_PPDU_STATS_USR_COMPLTN_BA_BITMAP_256_TLV) | \
  79. (1 << HTT_PPDU_STATS_USR_MPDU_ENQ_BITMAP_256_TLV))
  80. #ifdef WLAN_TX_PKT_CAPTURE_ENH
  81. extern uint8_t
  82. dp_cpu_ring_map[DP_NSS_CPU_RING_MAP_MAX][WLAN_CFG_INT_NUM_CONTEXTS];
  83. #endif
  84. #if DP_PRINT_ENABLE
  85. #include <stdarg.h> /* va_list */
  86. #include <qdf_types.h> /* qdf_vprint */
  87. #include <cdp_txrx_handle.h>
  88. enum {
  89. /* FATAL_ERR - print only irrecoverable error messages */
  90. DP_PRINT_LEVEL_FATAL_ERR,
  91. /* ERR - include non-fatal err messages */
  92. DP_PRINT_LEVEL_ERR,
  93. /* WARN - include warnings */
  94. DP_PRINT_LEVEL_WARN,
  95. /* INFO1 - include fundamental, infrequent events */
  96. DP_PRINT_LEVEL_INFO1,
  97. /* INFO2 - include non-fundamental but infrequent events */
  98. DP_PRINT_LEVEL_INFO2,
  99. };
  100. #define dp_print(level, fmt, ...) do { \
  101. if (level <= g_txrx_print_level) \
  102. qdf_print(fmt, ## __VA_ARGS__); \
  103. while (0)
  104. #define DP_PRINT(level, fmt, ...) do { \
  105. dp_print(level, "DP: " fmt, ## __VA_ARGS__); \
  106. while (0)
  107. #else
  108. #define DP_PRINT(level, fmt, ...)
  109. #endif /* DP_PRINT_ENABLE */
  110. #define DP_TRACE(LVL, fmt, args ...) \
  111. QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_##LVL, \
  112. fmt, ## args)
  113. #ifdef DP_PRINT_NO_CONSOLE
  114. /* Stat prints should not go to console or kernel logs.*/
  115. #define DP_PRINT_STATS(fmt, args ...)\
  116. QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_INFO_HIGH, \
  117. fmt, ## args)
  118. #else
  119. #define DP_PRINT_STATS(fmt, args ...)\
  120. QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_FATAL,\
  121. fmt, ## args)
  122. #endif
  123. #define DP_STATS_INIT(_handle) \
  124. qdf_mem_zero(&((_handle)->stats), sizeof((_handle)->stats))
  125. #define DP_STATS_CLR(_handle) \
  126. qdf_mem_zero(&((_handle)->stats), sizeof((_handle)->stats))
  127. #ifndef DISABLE_DP_STATS
  128. #define DP_STATS_INC(_handle, _field, _delta) \
  129. { \
  130. if (likely(_handle)) \
  131. _handle->stats._field += _delta; \
  132. }
  133. #define DP_STATS_INCC(_handle, _field, _delta, _cond) \
  134. { \
  135. if (_cond && likely(_handle)) \
  136. _handle->stats._field += _delta; \
  137. }
  138. #define DP_STATS_DEC(_handle, _field, _delta) \
  139. { \
  140. if (likely(_handle)) \
  141. _handle->stats._field -= _delta; \
  142. }
  143. #define DP_STATS_UPD(_handle, _field, _delta) \
  144. { \
  145. if (likely(_handle)) \
  146. _handle->stats._field = _delta; \
  147. }
  148. #define DP_STATS_INC_PKT(_handle, _field, _count, _bytes) \
  149. { \
  150. DP_STATS_INC(_handle, _field.num, _count); \
  151. DP_STATS_INC(_handle, _field.bytes, _bytes) \
  152. }
  153. #define DP_STATS_INCC_PKT(_handle, _field, _count, _bytes, _cond) \
  154. { \
  155. DP_STATS_INCC(_handle, _field.num, _count, _cond); \
  156. DP_STATS_INCC(_handle, _field.bytes, _bytes, _cond) \
  157. }
  158. #define DP_STATS_AGGR(_handle_a, _handle_b, _field) \
  159. { \
  160. _handle_a->stats._field += _handle_b->stats._field; \
  161. }
  162. #define DP_STATS_AGGR_PKT(_handle_a, _handle_b, _field) \
  163. { \
  164. DP_STATS_AGGR(_handle_a, _handle_b, _field.num); \
  165. DP_STATS_AGGR(_handle_a, _handle_b, _field.bytes);\
  166. }
  167. #define DP_STATS_UPD_STRUCT(_handle_a, _handle_b, _field) \
  168. { \
  169. _handle_a->stats._field = _handle_b->stats._field; \
  170. }
  171. #else
  172. #define DP_STATS_INC(_handle, _field, _delta)
  173. #define DP_STATS_INCC(_handle, _field, _delta, _cond)
  174. #define DP_STATS_DEC(_handle, _field, _delta)
  175. #define DP_STATS_UPD(_handle, _field, _delta)
  176. #define DP_STATS_INC_PKT(_handle, _field, _count, _bytes)
  177. #define DP_STATS_INCC_PKT(_handle, _field, _count, _bytes, _cond)
  178. #define DP_STATS_AGGR(_handle_a, _handle_b, _field)
  179. #define DP_STATS_AGGR_PKT(_handle_a, _handle_b, _field)
  180. #endif
  181. #ifdef ENABLE_DP_HIST_STATS
  182. #define DP_HIST_INIT() \
  183. uint32_t num_of_packets[MAX_PDEV_CNT] = {0};
  184. #define DP_HIST_PACKET_COUNT_INC(_pdev_id) \
  185. { \
  186. ++num_of_packets[_pdev_id]; \
  187. }
  188. #define DP_TX_HISTOGRAM_UPDATE(_pdev, _p_cntrs) \
  189. do { \
  190. if (_p_cntrs == 1) { \
  191. DP_STATS_INC(_pdev, \
  192. tx_comp_histogram.pkts_1, 1); \
  193. } else if (_p_cntrs > 1 && _p_cntrs <= 20) { \
  194. DP_STATS_INC(_pdev, \
  195. tx_comp_histogram.pkts_2_20, 1); \
  196. } else if (_p_cntrs > 20 && _p_cntrs <= 40) { \
  197. DP_STATS_INC(_pdev, \
  198. tx_comp_histogram.pkts_21_40, 1); \
  199. } else if (_p_cntrs > 40 && _p_cntrs <= 60) { \
  200. DP_STATS_INC(_pdev, \
  201. tx_comp_histogram.pkts_41_60, 1); \
  202. } else if (_p_cntrs > 60 && _p_cntrs <= 80) { \
  203. DP_STATS_INC(_pdev, \
  204. tx_comp_histogram.pkts_61_80, 1); \
  205. } else if (_p_cntrs > 80 && _p_cntrs <= 100) { \
  206. DP_STATS_INC(_pdev, \
  207. tx_comp_histogram.pkts_81_100, 1); \
  208. } else if (_p_cntrs > 100 && _p_cntrs <= 200) { \
  209. DP_STATS_INC(_pdev, \
  210. tx_comp_histogram.pkts_101_200, 1); \
  211. } else if (_p_cntrs > 200) { \
  212. DP_STATS_INC(_pdev, \
  213. tx_comp_histogram.pkts_201_plus, 1); \
  214. } \
  215. } while (0)
  216. #define DP_RX_HISTOGRAM_UPDATE(_pdev, _p_cntrs) \
  217. do { \
  218. if (_p_cntrs == 1) { \
  219. DP_STATS_INC(_pdev, \
  220. rx_ind_histogram.pkts_1, 1); \
  221. } else if (_p_cntrs > 1 && _p_cntrs <= 20) { \
  222. DP_STATS_INC(_pdev, \
  223. rx_ind_histogram.pkts_2_20, 1); \
  224. } else if (_p_cntrs > 20 && _p_cntrs <= 40) { \
  225. DP_STATS_INC(_pdev, \
  226. rx_ind_histogram.pkts_21_40, 1); \
  227. } else if (_p_cntrs > 40 && _p_cntrs <= 60) { \
  228. DP_STATS_INC(_pdev, \
  229. rx_ind_histogram.pkts_41_60, 1); \
  230. } else if (_p_cntrs > 60 && _p_cntrs <= 80) { \
  231. DP_STATS_INC(_pdev, \
  232. rx_ind_histogram.pkts_61_80, 1); \
  233. } else if (_p_cntrs > 80 && _p_cntrs <= 100) { \
  234. DP_STATS_INC(_pdev, \
  235. rx_ind_histogram.pkts_81_100, 1); \
  236. } else if (_p_cntrs > 100 && _p_cntrs <= 200) { \
  237. DP_STATS_INC(_pdev, \
  238. rx_ind_histogram.pkts_101_200, 1); \
  239. } else if (_p_cntrs > 200) { \
  240. DP_STATS_INC(_pdev, \
  241. rx_ind_histogram.pkts_201_plus, 1); \
  242. } \
  243. } while (0)
  244. #define DP_TX_HIST_STATS_PER_PDEV() \
  245. do { \
  246. uint8_t hist_stats = 0; \
  247. for (hist_stats = 0; hist_stats < soc->pdev_count; \
  248. hist_stats++) { \
  249. DP_TX_HISTOGRAM_UPDATE(soc->pdev_list[hist_stats], \
  250. num_of_packets[hist_stats]); \
  251. } \
  252. } while (0)
  253. #define DP_RX_HIST_STATS_PER_PDEV() \
  254. do { \
  255. uint8_t hist_stats = 0; \
  256. for (hist_stats = 0; hist_stats < soc->pdev_count; \
  257. hist_stats++) { \
  258. DP_RX_HISTOGRAM_UPDATE(soc->pdev_list[hist_stats], \
  259. num_of_packets[hist_stats]); \
  260. } \
  261. } while (0)
  262. #else
  263. #define DP_HIST_INIT()
  264. #define DP_HIST_PACKET_COUNT_INC(_pdev_id)
  265. #define DP_TX_HISTOGRAM_UPDATE(_pdev, _p_cntrs)
  266. #define DP_RX_HISTOGRAM_UPDATE(_pdev, _p_cntrs)
  267. #define DP_RX_HIST_STATS_PER_PDEV()
  268. #define DP_TX_HIST_STATS_PER_PDEV()
  269. #endif
  270. #define DP_HTT_T2H_HP_PIPE 5
  271. static inline void dp_update_pdev_stats(struct dp_pdev *tgtobj,
  272. struct cdp_vdev_stats *srcobj)
  273. {
  274. uint8_t i;
  275. uint8_t pream_type;
  276. for (pream_type = 0; pream_type < DOT11_MAX; pream_type++) {
  277. for (i = 0; i < MAX_MCS; i++) {
  278. tgtobj->stats.tx.pkt_type[pream_type].
  279. mcs_count[i] +=
  280. srcobj->tx.pkt_type[pream_type].
  281. mcs_count[i];
  282. tgtobj->stats.rx.pkt_type[pream_type].
  283. mcs_count[i] +=
  284. srcobj->rx.pkt_type[pream_type].
  285. mcs_count[i];
  286. }
  287. }
  288. for (i = 0; i < MAX_BW; i++) {
  289. tgtobj->stats.tx.bw[i] += srcobj->tx.bw[i];
  290. tgtobj->stats.rx.bw[i] += srcobj->rx.bw[i];
  291. }
  292. for (i = 0; i < SS_COUNT; i++) {
  293. tgtobj->stats.tx.nss[i] += srcobj->tx.nss[i];
  294. tgtobj->stats.rx.nss[i] += srcobj->rx.nss[i];
  295. }
  296. for (i = 0; i < WME_AC_MAX; i++) {
  297. tgtobj->stats.tx.wme_ac_type[i] +=
  298. srcobj->tx.wme_ac_type[i];
  299. tgtobj->stats.rx.wme_ac_type[i] +=
  300. srcobj->rx.wme_ac_type[i];
  301. tgtobj->stats.tx.excess_retries_per_ac[i] +=
  302. srcobj->tx.excess_retries_per_ac[i];
  303. }
  304. for (i = 0; i < MAX_GI; i++) {
  305. tgtobj->stats.tx.sgi_count[i] +=
  306. srcobj->tx.sgi_count[i];
  307. tgtobj->stats.rx.sgi_count[i] +=
  308. srcobj->rx.sgi_count[i];
  309. }
  310. for (i = 0; i < MAX_RECEPTION_TYPES; i++)
  311. tgtobj->stats.rx.reception_type[i] +=
  312. srcobj->rx.reception_type[i];
  313. tgtobj->stats.tx.comp_pkt.bytes += srcobj->tx.comp_pkt.bytes;
  314. tgtobj->stats.tx.comp_pkt.num += srcobj->tx.comp_pkt.num;
  315. tgtobj->stats.tx.ucast.num += srcobj->tx.ucast.num;
  316. tgtobj->stats.tx.ucast.bytes += srcobj->tx.ucast.bytes;
  317. tgtobj->stats.tx.mcast.num += srcobj->tx.mcast.num;
  318. tgtobj->stats.tx.mcast.bytes += srcobj->tx.mcast.bytes;
  319. tgtobj->stats.tx.bcast.num += srcobj->tx.bcast.num;
  320. tgtobj->stats.tx.bcast.bytes += srcobj->tx.bcast.bytes;
  321. tgtobj->stats.tx.tx_success.num += srcobj->tx.tx_success.num;
  322. tgtobj->stats.tx.tx_success.bytes +=
  323. srcobj->tx.tx_success.bytes;
  324. tgtobj->stats.tx.nawds_mcast.num +=
  325. srcobj->tx.nawds_mcast.num;
  326. tgtobj->stats.tx.nawds_mcast.bytes +=
  327. srcobj->tx.nawds_mcast.bytes;
  328. tgtobj->stats.tx.nawds_mcast_drop +=
  329. srcobj->tx.nawds_mcast_drop;
  330. tgtobj->stats.tx.num_ppdu_cookie_valid +=
  331. srcobj->tx.num_ppdu_cookie_valid;
  332. tgtobj->stats.tx.tx_failed += srcobj->tx.tx_failed;
  333. tgtobj->stats.tx.ofdma += srcobj->tx.ofdma;
  334. tgtobj->stats.tx.stbc += srcobj->tx.stbc;
  335. tgtobj->stats.tx.ldpc += srcobj->tx.ldpc;
  336. tgtobj->stats.tx.retries += srcobj->tx.retries;
  337. tgtobj->stats.tx.non_amsdu_cnt += srcobj->tx.non_amsdu_cnt;
  338. tgtobj->stats.tx.amsdu_cnt += srcobj->tx.amsdu_cnt;
  339. tgtobj->stats.tx.non_ampdu_cnt += srcobj->tx.non_ampdu_cnt;
  340. tgtobj->stats.tx.ampdu_cnt += srcobj->tx.ampdu_cnt;
  341. tgtobj->stats.tx.dropped.fw_rem.num += srcobj->tx.dropped.fw_rem.num;
  342. tgtobj->stats.tx.dropped.fw_rem.bytes +=
  343. srcobj->tx.dropped.fw_rem.bytes;
  344. tgtobj->stats.tx.dropped.fw_rem_tx +=
  345. srcobj->tx.dropped.fw_rem_tx;
  346. tgtobj->stats.tx.dropped.fw_rem_notx +=
  347. srcobj->tx.dropped.fw_rem_notx;
  348. tgtobj->stats.tx.dropped.fw_reason1 +=
  349. srcobj->tx.dropped.fw_reason1;
  350. tgtobj->stats.tx.dropped.fw_reason2 +=
  351. srcobj->tx.dropped.fw_reason2;
  352. tgtobj->stats.tx.dropped.fw_reason3 +=
  353. srcobj->tx.dropped.fw_reason3;
  354. tgtobj->stats.tx.dropped.age_out += srcobj->tx.dropped.age_out;
  355. tgtobj->stats.rx.err.mic_err += srcobj->rx.err.mic_err;
  356. if (srcobj->rx.rssi != 0)
  357. tgtobj->stats.rx.rssi = srcobj->rx.rssi;
  358. tgtobj->stats.rx.rx_rate = srcobj->rx.rx_rate;
  359. tgtobj->stats.rx.err.decrypt_err += srcobj->rx.err.decrypt_err;
  360. tgtobj->stats.rx.non_ampdu_cnt += srcobj->rx.non_ampdu_cnt;
  361. tgtobj->stats.rx.amsdu_cnt += srcobj->rx.ampdu_cnt;
  362. tgtobj->stats.rx.non_amsdu_cnt += srcobj->rx.non_amsdu_cnt;
  363. tgtobj->stats.rx.amsdu_cnt += srcobj->rx.amsdu_cnt;
  364. tgtobj->stats.rx.nawds_mcast_drop += srcobj->rx.nawds_mcast_drop;
  365. tgtobj->stats.rx.to_stack.num += srcobj->rx.to_stack.num;
  366. tgtobj->stats.rx.to_stack.bytes += srcobj->rx.to_stack.bytes;
  367. for (i = 0; i < CDP_MAX_RX_RINGS; i++) {
  368. tgtobj->stats.rx.rcvd_reo[i].num +=
  369. srcobj->rx.rcvd_reo[i].num;
  370. tgtobj->stats.rx.rcvd_reo[i].bytes +=
  371. srcobj->rx.rcvd_reo[i].bytes;
  372. }
  373. srcobj->rx.unicast.num =
  374. srcobj->rx.to_stack.num -
  375. (srcobj->rx.multicast.num);
  376. srcobj->rx.unicast.bytes =
  377. srcobj->rx.to_stack.bytes -
  378. (srcobj->rx.multicast.bytes);
  379. tgtobj->stats.rx.unicast.num += srcobj->rx.unicast.num;
  380. tgtobj->stats.rx.unicast.bytes += srcobj->rx.unicast.bytes;
  381. tgtobj->stats.rx.multicast.num += srcobj->rx.multicast.num;
  382. tgtobj->stats.rx.multicast.bytes += srcobj->rx.multicast.bytes;
  383. tgtobj->stats.rx.bcast.num += srcobj->rx.bcast.num;
  384. tgtobj->stats.rx.bcast.bytes += srcobj->rx.bcast.bytes;
  385. tgtobj->stats.rx.raw.num += srcobj->rx.raw.num;
  386. tgtobj->stats.rx.raw.bytes += srcobj->rx.raw.bytes;
  387. tgtobj->stats.rx.intra_bss.pkts.num +=
  388. srcobj->rx.intra_bss.pkts.num;
  389. tgtobj->stats.rx.intra_bss.pkts.bytes +=
  390. srcobj->rx.intra_bss.pkts.bytes;
  391. tgtobj->stats.rx.intra_bss.fail.num +=
  392. srcobj->rx.intra_bss.fail.num;
  393. tgtobj->stats.rx.intra_bss.fail.bytes +=
  394. srcobj->rx.intra_bss.fail.bytes;
  395. tgtobj->stats.tx.last_ack_rssi =
  396. srcobj->tx.last_ack_rssi;
  397. tgtobj->stats.rx.mec_drop.num += srcobj->rx.mec_drop.num;
  398. tgtobj->stats.rx.mec_drop.bytes += srcobj->rx.mec_drop.bytes;
  399. }
  400. static inline void dp_update_pdev_ingress_stats(struct dp_pdev *tgtobj,
  401. struct dp_vdev *srcobj)
  402. {
  403. DP_STATS_AGGR_PKT(tgtobj, srcobj, tx_i.nawds_mcast);
  404. DP_STATS_AGGR_PKT(tgtobj, srcobj, tx_i.rcvd);
  405. DP_STATS_AGGR_PKT(tgtobj, srcobj, tx_i.processed);
  406. DP_STATS_AGGR_PKT(tgtobj, srcobj, tx_i.reinject_pkts);
  407. DP_STATS_AGGR_PKT(tgtobj, srcobj, tx_i.inspect_pkts);
  408. DP_STATS_AGGR_PKT(tgtobj, srcobj, tx_i.raw.raw_pkt);
  409. DP_STATS_AGGR(tgtobj, srcobj, tx_i.raw.dma_map_error);
  410. DP_STATS_AGGR_PKT(tgtobj, srcobj, tx_i.tso.tso_pkt);
  411. DP_STATS_AGGR(tgtobj, srcobj, tx_i.tso.dropped_host.num);
  412. DP_STATS_AGGR(tgtobj, srcobj, tx_i.tso.dropped_target);
  413. DP_STATS_AGGR(tgtobj, srcobj, tx_i.sg.dropped_host.num);
  414. DP_STATS_AGGR(tgtobj, srcobj, tx_i.sg.dropped_target);
  415. DP_STATS_AGGR_PKT(tgtobj, srcobj, tx_i.sg.sg_pkt);
  416. DP_STATS_AGGR_PKT(tgtobj, srcobj, tx_i.mcast_en.mcast_pkt);
  417. DP_STATS_AGGR(tgtobj, srcobj,
  418. tx_i.mcast_en.dropped_map_error);
  419. DP_STATS_AGGR(tgtobj, srcobj,
  420. tx_i.mcast_en.dropped_self_mac);
  421. DP_STATS_AGGR(tgtobj, srcobj,
  422. tx_i.mcast_en.dropped_send_fail);
  423. DP_STATS_AGGR(tgtobj, srcobj, tx_i.mcast_en.ucast);
  424. DP_STATS_AGGR(tgtobj, srcobj, tx_i.dropped.dma_error);
  425. DP_STATS_AGGR(tgtobj, srcobj, tx_i.dropped.ring_full);
  426. DP_STATS_AGGR(tgtobj, srcobj, tx_i.dropped.enqueue_fail);
  427. DP_STATS_AGGR(tgtobj, srcobj, tx_i.dropped.desc_na.num);
  428. DP_STATS_AGGR(tgtobj, srcobj, tx_i.dropped.res_full);
  429. DP_STATS_AGGR(tgtobj, srcobj, tx_i.dropped.headroom_insufficient);
  430. DP_STATS_AGGR(tgtobj, srcobj, tx_i.cce_classified);
  431. DP_STATS_AGGR(tgtobj, srcobj, tx_i.cce_classified_raw);
  432. DP_STATS_AGGR_PKT(tgtobj, srcobj, tx_i.sniffer_rcvd);
  433. DP_STATS_AGGR(tgtobj, srcobj, tx_i.mesh.exception_fw);
  434. DP_STATS_AGGR(tgtobj, srcobj, tx_i.mesh.completion_fw);
  435. tgtobj->stats.tx_i.dropped.dropped_pkt.num =
  436. tgtobj->stats.tx_i.dropped.dma_error +
  437. tgtobj->stats.tx_i.dropped.ring_full +
  438. tgtobj->stats.tx_i.dropped.enqueue_fail +
  439. tgtobj->stats.tx_i.dropped.desc_na.num +
  440. tgtobj->stats.tx_i.dropped.res_full;
  441. tgtobj->stats.tx_i.tso.num_seg =
  442. srcobj->stats.tx_i.tso.num_seg;
  443. }
  444. static inline void dp_update_vdev_stats(struct cdp_vdev_stats *tgtobj,
  445. struct dp_peer *srcobj)
  446. {
  447. uint8_t i;
  448. uint8_t pream_type;
  449. for (pream_type = 0; pream_type < DOT11_MAX; pream_type++) {
  450. for (i = 0; i < MAX_MCS; i++) {
  451. tgtobj->tx.pkt_type[pream_type].
  452. mcs_count[i] +=
  453. srcobj->stats.tx.pkt_type[pream_type].
  454. mcs_count[i];
  455. tgtobj->rx.pkt_type[pream_type].
  456. mcs_count[i] +=
  457. srcobj->stats.rx.pkt_type[pream_type].
  458. mcs_count[i];
  459. }
  460. }
  461. for (i = 0; i < MAX_BW; i++) {
  462. tgtobj->tx.bw[i] += srcobj->stats.tx.bw[i];
  463. tgtobj->rx.bw[i] += srcobj->stats.rx.bw[i];
  464. }
  465. for (i = 0; i < SS_COUNT; i++) {
  466. tgtobj->tx.nss[i] += srcobj->stats.tx.nss[i];
  467. tgtobj->rx.nss[i] += srcobj->stats.rx.nss[i];
  468. }
  469. for (i = 0; i < WME_AC_MAX; i++) {
  470. tgtobj->tx.wme_ac_type[i] +=
  471. srcobj->stats.tx.wme_ac_type[i];
  472. tgtobj->rx.wme_ac_type[i] +=
  473. srcobj->stats.rx.wme_ac_type[i];
  474. tgtobj->tx.excess_retries_per_ac[i] +=
  475. srcobj->stats.tx.excess_retries_per_ac[i];
  476. }
  477. for (i = 0; i < MAX_GI; i++) {
  478. tgtobj->tx.sgi_count[i] +=
  479. srcobj->stats.tx.sgi_count[i];
  480. tgtobj->rx.sgi_count[i] +=
  481. srcobj->stats.rx.sgi_count[i];
  482. }
  483. for (i = 0; i < MAX_RECEPTION_TYPES; i++)
  484. tgtobj->rx.reception_type[i] +=
  485. srcobj->stats.rx.reception_type[i];
  486. tgtobj->tx.comp_pkt.bytes += srcobj->stats.tx.comp_pkt.bytes;
  487. tgtobj->tx.comp_pkt.num += srcobj->stats.tx.comp_pkt.num;
  488. tgtobj->tx.ucast.num += srcobj->stats.tx.ucast.num;
  489. tgtobj->tx.ucast.bytes += srcobj->stats.tx.ucast.bytes;
  490. tgtobj->tx.mcast.num += srcobj->stats.tx.mcast.num;
  491. tgtobj->tx.mcast.bytes += srcobj->stats.tx.mcast.bytes;
  492. tgtobj->tx.bcast.num += srcobj->stats.tx.bcast.num;
  493. tgtobj->tx.bcast.bytes += srcobj->stats.tx.bcast.bytes;
  494. tgtobj->tx.tx_success.num += srcobj->stats.tx.tx_success.num;
  495. tgtobj->tx.tx_success.bytes +=
  496. srcobj->stats.tx.tx_success.bytes;
  497. tgtobj->tx.nawds_mcast.num +=
  498. srcobj->stats.tx.nawds_mcast.num;
  499. tgtobj->tx.nawds_mcast.bytes +=
  500. srcobj->stats.tx.nawds_mcast.bytes;
  501. tgtobj->tx.nawds_mcast_drop +=
  502. srcobj->stats.tx.nawds_mcast_drop;
  503. tgtobj->tx.num_ppdu_cookie_valid +=
  504. srcobj->stats.tx.num_ppdu_cookie_valid;
  505. tgtobj->tx.tx_failed += srcobj->stats.tx.tx_failed;
  506. tgtobj->tx.ofdma += srcobj->stats.tx.ofdma;
  507. tgtobj->tx.stbc += srcobj->stats.tx.stbc;
  508. tgtobj->tx.ldpc += srcobj->stats.tx.ldpc;
  509. tgtobj->tx.retries += srcobj->stats.tx.retries;
  510. tgtobj->tx.non_amsdu_cnt += srcobj->stats.tx.non_amsdu_cnt;
  511. tgtobj->tx.amsdu_cnt += srcobj->stats.tx.amsdu_cnt;
  512. tgtobj->tx.non_ampdu_cnt += srcobj->stats.tx.non_ampdu_cnt;
  513. tgtobj->tx.ampdu_cnt += srcobj->stats.tx.ampdu_cnt;
  514. tgtobj->tx.dropped.fw_rem.num += srcobj->stats.tx.dropped.fw_rem.num;
  515. tgtobj->tx.dropped.fw_rem.bytes +=
  516. srcobj->stats.tx.dropped.fw_rem.bytes;
  517. tgtobj->tx.dropped.fw_rem_tx +=
  518. srcobj->stats.tx.dropped.fw_rem_tx;
  519. tgtobj->tx.dropped.fw_rem_notx +=
  520. srcobj->stats.tx.dropped.fw_rem_notx;
  521. tgtobj->tx.dropped.fw_reason1 +=
  522. srcobj->stats.tx.dropped.fw_reason1;
  523. tgtobj->tx.dropped.fw_reason2 +=
  524. srcobj->stats.tx.dropped.fw_reason2;
  525. tgtobj->tx.dropped.fw_reason3 +=
  526. srcobj->stats.tx.dropped.fw_reason3;
  527. tgtobj->tx.dropped.age_out += srcobj->stats.tx.dropped.age_out;
  528. tgtobj->rx.err.mic_err += srcobj->stats.rx.err.mic_err;
  529. if (srcobj->stats.rx.rssi != 0)
  530. tgtobj->rx.rssi = srcobj->stats.rx.rssi;
  531. tgtobj->rx.rx_rate = srcobj->stats.rx.rx_rate;
  532. tgtobj->rx.err.decrypt_err += srcobj->stats.rx.err.decrypt_err;
  533. tgtobj->rx.non_ampdu_cnt += srcobj->stats.rx.non_ampdu_cnt;
  534. tgtobj->rx.amsdu_cnt += srcobj->stats.rx.ampdu_cnt;
  535. tgtobj->rx.non_amsdu_cnt += srcobj->stats.rx.non_amsdu_cnt;
  536. tgtobj->rx.amsdu_cnt += srcobj->stats.rx.amsdu_cnt;
  537. tgtobj->rx.nawds_mcast_drop += srcobj->stats.rx.nawds_mcast_drop;
  538. tgtobj->rx.to_stack.num += srcobj->stats.rx.to_stack.num;
  539. tgtobj->rx.to_stack.bytes += srcobj->stats.rx.to_stack.bytes;
  540. for (i = 0; i < CDP_MAX_RX_RINGS; i++) {
  541. tgtobj->rx.rcvd_reo[i].num +=
  542. srcobj->stats.rx.rcvd_reo[i].num;
  543. tgtobj->rx.rcvd_reo[i].bytes +=
  544. srcobj->stats.rx.rcvd_reo[i].bytes;
  545. }
  546. srcobj->stats.rx.unicast.num =
  547. srcobj->stats.rx.to_stack.num -
  548. srcobj->stats.rx.multicast.num;
  549. srcobj->stats.rx.unicast.bytes =
  550. srcobj->stats.rx.to_stack.bytes -
  551. srcobj->stats.rx.multicast.bytes;
  552. tgtobj->rx.unicast.num += srcobj->stats.rx.unicast.num;
  553. tgtobj->rx.unicast.bytes += srcobj->stats.rx.unicast.bytes;
  554. tgtobj->rx.multicast.num += srcobj->stats.rx.multicast.num;
  555. tgtobj->rx.multicast.bytes += srcobj->stats.rx.multicast.bytes;
  556. tgtobj->rx.bcast.num += srcobj->stats.rx.bcast.num;
  557. tgtobj->rx.bcast.bytes += srcobj->stats.rx.bcast.bytes;
  558. tgtobj->rx.raw.num += srcobj->stats.rx.raw.num;
  559. tgtobj->rx.raw.bytes += srcobj->stats.rx.raw.bytes;
  560. tgtobj->rx.intra_bss.pkts.num +=
  561. srcobj->stats.rx.intra_bss.pkts.num;
  562. tgtobj->rx.intra_bss.pkts.bytes +=
  563. srcobj->stats.rx.intra_bss.pkts.bytes;
  564. tgtobj->rx.intra_bss.fail.num +=
  565. srcobj->stats.rx.intra_bss.fail.num;
  566. tgtobj->rx.intra_bss.fail.bytes +=
  567. srcobj->stats.rx.intra_bss.fail.bytes;
  568. tgtobj->tx.last_ack_rssi =
  569. srcobj->stats.tx.last_ack_rssi;
  570. tgtobj->rx.mec_drop.num += srcobj->stats.rx.mec_drop.num;
  571. tgtobj->rx.mec_drop.bytes += srcobj->stats.rx.mec_drop.bytes;
  572. }
  573. #define DP_UPDATE_STATS(_tgtobj, _srcobj) \
  574. do { \
  575. uint8_t i; \
  576. uint8_t pream_type; \
  577. for (pream_type = 0; pream_type < DOT11_MAX; pream_type++) { \
  578. for (i = 0; i < MAX_MCS; i++) { \
  579. DP_STATS_AGGR(_tgtobj, _srcobj, \
  580. tx.pkt_type[pream_type].mcs_count[i]); \
  581. DP_STATS_AGGR(_tgtobj, _srcobj, \
  582. rx.pkt_type[pream_type].mcs_count[i]); \
  583. } \
  584. } \
  585. \
  586. for (i = 0; i < MAX_BW; i++) { \
  587. DP_STATS_AGGR(_tgtobj, _srcobj, tx.bw[i]); \
  588. DP_STATS_AGGR(_tgtobj, _srcobj, rx.bw[i]); \
  589. } \
  590. \
  591. for (i = 0; i < SS_COUNT; i++) { \
  592. DP_STATS_AGGR(_tgtobj, _srcobj, rx.nss[i]); \
  593. DP_STATS_AGGR(_tgtobj, _srcobj, tx.nss[i]); \
  594. } \
  595. for (i = 0; i < WME_AC_MAX; i++) { \
  596. DP_STATS_AGGR(_tgtobj, _srcobj, tx.wme_ac_type[i]); \
  597. DP_STATS_AGGR(_tgtobj, _srcobj, rx.wme_ac_type[i]); \
  598. DP_STATS_AGGR(_tgtobj, _srcobj, tx.excess_retries_per_ac[i]); \
  599. \
  600. } \
  601. \
  602. for (i = 0; i < MAX_GI; i++) { \
  603. DP_STATS_AGGR(_tgtobj, _srcobj, tx.sgi_count[i]); \
  604. DP_STATS_AGGR(_tgtobj, _srcobj, rx.sgi_count[i]); \
  605. } \
  606. \
  607. for (i = 0; i < MAX_RECEPTION_TYPES; i++) \
  608. DP_STATS_AGGR(_tgtobj, _srcobj, rx.reception_type[i]); \
  609. \
  610. DP_STATS_AGGR_PKT(_tgtobj, _srcobj, tx.comp_pkt); \
  611. DP_STATS_AGGR_PKT(_tgtobj, _srcobj, tx.ucast); \
  612. DP_STATS_AGGR_PKT(_tgtobj, _srcobj, tx.mcast); \
  613. DP_STATS_AGGR_PKT(_tgtobj, _srcobj, tx.bcast); \
  614. DP_STATS_AGGR_PKT(_tgtobj, _srcobj, tx.tx_success); \
  615. DP_STATS_AGGR_PKT(_tgtobj, _srcobj, tx.nawds_mcast); \
  616. DP_STATS_AGGR(_tgtobj, _srcobj, tx.nawds_mcast_drop); \
  617. DP_STATS_AGGR(_tgtobj, _srcobj, tx.tx_failed); \
  618. DP_STATS_AGGR(_tgtobj, _srcobj, tx.ofdma); \
  619. DP_STATS_AGGR(_tgtobj, _srcobj, tx.stbc); \
  620. DP_STATS_AGGR(_tgtobj, _srcobj, tx.ldpc); \
  621. DP_STATS_AGGR(_tgtobj, _srcobj, tx.retries); \
  622. DP_STATS_AGGR(_tgtobj, _srcobj, tx.non_amsdu_cnt); \
  623. DP_STATS_AGGR(_tgtobj, _srcobj, tx.amsdu_cnt); \
  624. DP_STATS_AGGR(_tgtobj, _srcobj, tx.non_ampdu_cnt); \
  625. DP_STATS_AGGR(_tgtobj, _srcobj, tx.ampdu_cnt); \
  626. DP_STATS_AGGR_PKT(_tgtobj, _srcobj, tx.dropped.fw_rem); \
  627. DP_STATS_AGGR(_tgtobj, _srcobj, tx.dropped.fw_rem_tx); \
  628. DP_STATS_AGGR(_tgtobj, _srcobj, tx.dropped.fw_rem_notx); \
  629. DP_STATS_AGGR(_tgtobj, _srcobj, tx.dropped.fw_reason1); \
  630. DP_STATS_AGGR(_tgtobj, _srcobj, tx.dropped.fw_reason2); \
  631. DP_STATS_AGGR(_tgtobj, _srcobj, tx.dropped.fw_reason3); \
  632. DP_STATS_AGGR(_tgtobj, _srcobj, tx.dropped.age_out); \
  633. \
  634. DP_STATS_AGGR(_tgtobj, _srcobj, rx.err.mic_err); \
  635. if (_srcobj->stats.rx.rssi != 0) \
  636. DP_STATS_UPD_STRUCT(_tgtobj, _srcobj, rx.rssi); \
  637. DP_STATS_UPD_STRUCT(_tgtobj, _srcobj, rx.rx_rate); \
  638. DP_STATS_AGGR(_tgtobj, _srcobj, rx.err.decrypt_err); \
  639. DP_STATS_AGGR(_tgtobj, _srcobj, rx.non_ampdu_cnt); \
  640. DP_STATS_AGGR(_tgtobj, _srcobj, rx.ampdu_cnt); \
  641. DP_STATS_AGGR(_tgtobj, _srcobj, rx.non_amsdu_cnt); \
  642. DP_STATS_AGGR(_tgtobj, _srcobj, rx.amsdu_cnt); \
  643. DP_STATS_AGGR(_tgtobj, _srcobj, rx.nawds_mcast_drop); \
  644. DP_STATS_AGGR_PKT(_tgtobj, _srcobj, rx.to_stack); \
  645. \
  646. for (i = 0; i < CDP_MAX_RX_RINGS; i++) \
  647. DP_STATS_AGGR_PKT(_tgtobj, _srcobj, rx.rcvd_reo[i]); \
  648. \
  649. _srcobj->stats.rx.unicast.num = \
  650. _srcobj->stats.rx.to_stack.num - \
  651. _srcobj->stats.rx.multicast.num; \
  652. _srcobj->stats.rx.unicast.bytes = \
  653. _srcobj->stats.rx.to_stack.bytes - \
  654. _srcobj->stats.rx.multicast.bytes; \
  655. DP_STATS_AGGR_PKT(_tgtobj, _srcobj, rx.unicast); \
  656. DP_STATS_AGGR_PKT(_tgtobj, _srcobj, rx.multicast); \
  657. DP_STATS_AGGR_PKT(_tgtobj, _srcobj, rx.bcast); \
  658. DP_STATS_AGGR_PKT(_tgtobj, _srcobj, rx.raw); \
  659. DP_STATS_AGGR_PKT(_tgtobj, _srcobj, rx.intra_bss.pkts); \
  660. DP_STATS_AGGR_PKT(_tgtobj, _srcobj, rx.intra_bss.fail); \
  661. DP_STATS_AGGR_PKT(_tgtobj, _srcobj, rx.mec_drop); \
  662. \
  663. _tgtobj->stats.tx.last_ack_rssi = \
  664. _srcobj->stats.tx.last_ack_rssi; \
  665. } while (0)
  666. extern int dp_peer_find_attach(struct dp_soc *soc);
  667. extern void dp_peer_find_detach(struct dp_soc *soc);
  668. extern void dp_peer_find_hash_add(struct dp_soc *soc, struct dp_peer *peer);
  669. extern void dp_peer_find_hash_remove(struct dp_soc *soc, struct dp_peer *peer);
  670. extern void dp_peer_find_hash_erase(struct dp_soc *soc);
  671. extern void dp_peer_rx_init(struct dp_pdev *pdev, struct dp_peer *peer);
  672. void dp_peer_tx_init(struct dp_pdev *pdev, struct dp_peer *peer);
  673. extern void dp_peer_cleanup(struct dp_vdev *vdev, struct dp_peer *peer);
  674. extern void dp_peer_rx_cleanup(struct dp_vdev *vdev, struct dp_peer *peer);
  675. extern void dp_peer_unref_delete(void *peer_handle);
  676. extern void dp_rx_discard(struct dp_vdev *vdev, struct dp_peer *peer,
  677. unsigned tid, qdf_nbuf_t msdu_list);
  678. extern void *dp_find_peer_by_addr(struct cdp_pdev *dev,
  679. uint8_t *peer_mac_addr, uint8_t *peer_id);
  680. extern struct dp_peer *dp_peer_find_hash_find(struct dp_soc *soc,
  681. uint8_t *peer_mac_addr, int mac_addr_is_aligned, uint8_t vdev_id);
  682. #ifdef DP_PEER_EXTENDED_API
  683. QDF_STATUS dp_register_peer(struct cdp_pdev *pdev_handle,
  684. struct ol_txrx_desc_type *sta_desc);
  685. QDF_STATUS dp_clear_peer(struct cdp_pdev *pdev_handle, uint8_t local_id);
  686. void *dp_find_peer_by_addr_and_vdev(struct cdp_pdev *pdev_handle,
  687. struct cdp_vdev *vdev,
  688. uint8_t *peer_addr, uint8_t *local_id);
  689. uint16_t dp_local_peer_id(void *peer);
  690. void *dp_peer_find_by_local_id(struct cdp_pdev *pdev_handle, uint8_t local_id);
  691. QDF_STATUS dp_peer_state_update(struct cdp_pdev *pdev_handle, uint8_t *peer_mac,
  692. enum ol_txrx_peer_state state);
  693. QDF_STATUS dp_get_vdevid(void *peer_handle, uint8_t *vdev_id);
  694. struct cdp_vdev *dp_get_vdev_by_sta_id(struct cdp_pdev *pdev_handle,
  695. uint8_t sta_id);
  696. struct cdp_vdev *dp_get_vdev_for_peer(void *peer);
  697. uint8_t *dp_peer_get_peer_mac_addr(void *peer);
  698. int dp_get_peer_state(void *peer_handle);
  699. void dp_local_peer_id_pool_init(struct dp_pdev *pdev);
  700. void dp_local_peer_id_alloc(struct dp_pdev *pdev, struct dp_peer *peer);
  701. void dp_local_peer_id_free(struct dp_pdev *pdev, struct dp_peer *peer);
  702. #else
  703. static inline
  704. QDF_STATUS dp_get_vdevid(void *peer_handle, uint8_t *vdev_id)
  705. {
  706. return QDF_STATUS_E_NOSUPPORT;
  707. }
  708. static inline void dp_local_peer_id_pool_init(struct dp_pdev *pdev)
  709. {
  710. }
  711. static inline
  712. void dp_local_peer_id_alloc(struct dp_pdev *pdev, struct dp_peer *peer)
  713. {
  714. }
  715. static inline
  716. void dp_local_peer_id_free(struct dp_pdev *pdev, struct dp_peer *peer)
  717. {
  718. }
  719. #endif
  720. int dp_addba_resp_tx_completion_wifi3(void *peer_handle, uint8_t tid,
  721. int status);
  722. extern int dp_addba_requestprocess_wifi3(void *peer_handle,
  723. uint8_t dialogtoken, uint16_t tid, uint16_t batimeout,
  724. uint16_t buffersize, uint16_t startseqnum);
  725. extern void dp_addba_responsesetup_wifi3(void *peer_handle, uint8_t tid,
  726. uint8_t *dialogtoken, uint16_t *statuscode,
  727. uint16_t *buffersize, uint16_t *batimeout);
  728. extern void dp_set_addba_response(void *peer_handle, uint8_t tid,
  729. uint16_t statuscode);
  730. extern int dp_delba_process_wifi3(void *peer_handle,
  731. int tid, uint16_t reasoncode);
  732. /*
  733. * dp_delba_tx_completion_wifi3() - Handle delba tx completion
  734. *
  735. * @peer_handle: Peer handle
  736. * @tid: Tid number
  737. * @status: Tx completion status
  738. * Indicate status of delba Tx to DP for stats update and retry
  739. * delba if tx failed.
  740. *
  741. */
  742. int dp_delba_tx_completion_wifi3(void *peer_handle, uint8_t tid,
  743. int status);
  744. extern int dp_rx_tid_setup_wifi3(struct dp_peer *peer, int tid,
  745. uint32_t ba_window_size, uint32_t start_seq);
  746. extern QDF_STATUS dp_reo_send_cmd(struct dp_soc *soc,
  747. enum hal_reo_cmd_type type, struct hal_reo_cmd_params *params,
  748. void (*callback_fn), void *data);
  749. extern void dp_reo_cmdlist_destroy(struct dp_soc *soc);
  750. /**
  751. * dp_reo_status_ring_handler - Handler for REO Status ring
  752. * @int_ctx: pointer to DP interrupt context
  753. * @soc: DP Soc handle
  754. *
  755. * Returns: Number of descriptors reaped
  756. */
  757. uint32_t dp_reo_status_ring_handler(struct dp_intr *int_ctx,
  758. struct dp_soc *soc);
  759. void dp_aggregate_vdev_stats(struct dp_vdev *vdev,
  760. struct cdp_vdev_stats *vdev_stats);
  761. void dp_rx_tid_stats_cb(struct dp_soc *soc, void *cb_ctxt,
  762. union hal_reo_status *reo_status);
  763. void dp_rx_bar_stats_cb(struct dp_soc *soc, void *cb_ctxt,
  764. union hal_reo_status *reo_status);
  765. QDF_STATUS dp_h2t_ext_stats_msg_send(struct dp_pdev *pdev,
  766. uint32_t stats_type_upload_mask, uint32_t config_param_0,
  767. uint32_t config_param_1, uint32_t config_param_2,
  768. uint32_t config_param_3, int cookie, int cookie_msb,
  769. uint8_t mac_id);
  770. void dp_htt_stats_print_tag(uint8_t tag_type, uint32_t *tag_buf);
  771. void dp_htt_stats_copy_tag(struct dp_pdev *pdev, uint8_t tag_type, uint32_t *tag_buf);
  772. void dp_peer_rxtid_stats(struct dp_peer *peer, void (*callback_fn),
  773. void *cb_ctxt);
  774. void dp_set_pn_check_wifi3(struct cdp_vdev *vdev_handle,
  775. struct cdp_peer *peer_handle, enum cdp_sec_type sec_type,
  776. uint32_t *rx_pn);
  777. void *dp_get_pdev_for_mac_id(struct dp_soc *soc, uint32_t mac_id);
  778. void dp_set_michael_key(struct cdp_peer *peer_handle,
  779. bool is_unicast, uint32_t *key);
  780. #ifdef QCA_ENH_V3_STATS_SUPPORT
  781. uint32_t dp_pdev_tid_stats_display(void *pdev_handle,
  782. enum _ol_ath_param_t param, uint32_t value, void *buff);
  783. #endif
  784. /**
  785. * dp_update_delay_stats() - Update delay statistics in structure
  786. * and fill min, max and avg delay
  787. * @pdev: pdev handle
  788. * @delay: delay in ms
  789. * @tid: tid value
  790. * @mode: type of tx delay mode
  791. * @ring id: ring number
  792. *
  793. * Return: none
  794. */
  795. void dp_update_delay_stats(struct dp_pdev *pdev, uint32_t delay,
  796. uint8_t tid, uint8_t mode, uint8_t ring_id);
  797. /**
  798. * dp_print_ring_stats(): Print tail and head pointer
  799. * @pdev: DP_PDEV handle
  800. *
  801. * Return:void
  802. */
  803. void dp_print_ring_stats(struct dp_pdev *pdev);
  804. /**
  805. * dp_print_pdev_cfg_params() - Print the pdev cfg parameters
  806. * @pdev_handle: DP pdev handle
  807. *
  808. * Return - void
  809. */
  810. void dp_print_pdev_cfg_params(struct dp_pdev *pdev);
  811. /**
  812. * dp_print_soc_cfg_params()- Dump soc wlan config parameters
  813. * @soc_handle: Soc handle
  814. *
  815. * Return: void
  816. */
  817. void dp_print_soc_cfg_params(struct dp_soc *soc);
  818. /**
  819. * dp_srng_get_str_from_ring_type() - Return string name for a ring
  820. * @ring_type: Ring
  821. *
  822. * Return: char const pointer
  823. */
  824. const
  825. char *dp_srng_get_str_from_hal_ring_type(enum hal_ring_type ring_type);
  826. /*
  827. * dp_txrx_path_stats() - Function to display dump stats
  828. * @soc - soc handle
  829. *
  830. * return: none
  831. */
  832. void dp_txrx_path_stats(struct dp_soc *soc);
  833. /*
  834. * dp_print_per_ring_stats(): Packet count per ring
  835. * @soc - soc handle
  836. *
  837. * Return - None
  838. */
  839. void dp_print_per_ring_stats(struct dp_soc *soc);
  840. /**
  841. * dp_aggregate_pdev_stats(): Consolidate stats at PDEV level
  842. * @pdev: DP PDEV handle
  843. *
  844. * return: void
  845. */
  846. void dp_aggregate_pdev_stats(struct dp_pdev *pdev);
  847. /**
  848. * dp_print_rx_rates(): Print Rx rate stats
  849. * @vdev: DP_VDEV handle
  850. *
  851. * Return:void
  852. */
  853. void dp_print_rx_rates(struct dp_vdev *vdev);
  854. /**
  855. * dp_print_tx_rates(): Print tx rates
  856. * @vdev: DP_VDEV handle
  857. *
  858. * Return:void
  859. */
  860. void dp_print_tx_rates(struct dp_vdev *vdev);
  861. /**
  862. * dp_print_peer_stats():print peer stats
  863. * @peer: DP_PEER handle
  864. *
  865. * return void
  866. */
  867. void dp_print_peer_stats(struct dp_peer *peer);
  868. /**
  869. * dp_print_pdev_tx_stats(): Print Pdev level TX stats
  870. * @pdev: DP_PDEV Handle
  871. *
  872. * Return:void
  873. */
  874. void
  875. dp_print_pdev_tx_stats(struct dp_pdev *pdev);
  876. /**
  877. * dp_print_pdev_rx_stats(): Print Pdev level RX stats
  878. * @pdev: DP_PDEV Handle
  879. *
  880. * Return: void
  881. */
  882. void
  883. dp_print_pdev_rx_stats(struct dp_pdev *pdev);
  884. /**
  885. * dp_print_pdev_rx_mon_stats(): Print Pdev level RX monitor stats
  886. * @pdev: DP_PDEV Handle
  887. *
  888. * Return: void
  889. */
  890. void
  891. dp_print_pdev_rx_mon_stats(struct dp_pdev *pdev);
  892. /**
  893. * dp_print_soc_tx_stats(): Print SOC level stats
  894. * @soc DP_SOC Handle
  895. *
  896. * Return: void
  897. */
  898. void dp_print_soc_tx_stats(struct dp_soc *soc);
  899. /**
  900. * dp_print_soc_interrupt_stats() - Print interrupt stats for the soc
  901. * @soc: dp_soc handle
  902. *
  903. * Return: None
  904. */
  905. void dp_print_soc_interrupt_stats(struct dp_soc *soc);
  906. /**
  907. * dp_print_soc_rx_stats: Print SOC level Rx stats
  908. * @soc: DP_SOC Handle
  909. *
  910. * Return:void
  911. */
  912. void dp_print_soc_rx_stats(struct dp_soc *soc);
  913. /**
  914. * dp_get_mac_id_for_pdev() - Return mac corresponding to pdev for mac
  915. *
  916. * @mac_id: MAC id
  917. * @pdev_id: pdev_id corresponding to pdev, 0 for MCL
  918. *
  919. * Single pdev using both MACs will operate on both MAC rings,
  920. * which is the case for MCL.
  921. * For WIN each PDEV will operate one ring, so index is zero.
  922. *
  923. */
  924. static inline int dp_get_mac_id_for_pdev(uint32_t mac_id, uint32_t pdev_id)
  925. {
  926. if (mac_id && pdev_id) {
  927. qdf_print("Both mac_id and pdev_id cannot be non zero");
  928. QDF_BUG(0);
  929. return 0;
  930. }
  931. return (mac_id + pdev_id);
  932. }
  933. /*
  934. * dp_get_mac_id_for_mac() - Return mac corresponding WIN and MCL mac_ids
  935. *
  936. * @soc: handle to DP soc
  937. * @mac_id: MAC id
  938. *
  939. * Single pdev using both MACs will operate on both MAC rings,
  940. * which is the case for MCL.
  941. * For WIN each PDEV will operate one ring, so index is zero.
  942. *
  943. */
  944. static inline int dp_get_mac_id_for_mac(struct dp_soc *soc, uint32_t mac_id)
  945. {
  946. /*
  947. * Single pdev using both MACs will operate on both MAC rings,
  948. * which is the case for MCL.
  949. */
  950. if (!wlan_cfg_per_pdev_lmac_ring(soc->wlan_cfg_ctx))
  951. return mac_id;
  952. /* For WIN each PDEV will operate one ring, so index is zero. */
  953. return 0;
  954. }
  955. bool dp_is_soc_reinit(struct dp_soc *soc);
  956. /*
  957. * dp_is_subtype_data() - check if the frame subtype is data
  958. *
  959. * @frame_ctrl: Frame control field
  960. *
  961. * check the frame control field and verify if the packet
  962. * is a data packet.
  963. *
  964. * Return: true or false
  965. */
  966. static inline bool dp_is_subtype_data(uint16_t frame_ctrl)
  967. {
  968. if (((qdf_cpu_to_le16(frame_ctrl) & QDF_IEEE80211_FC0_TYPE_MASK) ==
  969. QDF_IEEE80211_FC0_TYPE_DATA) &&
  970. (((qdf_cpu_to_le16(frame_ctrl) & QDF_IEEE80211_FC0_SUBTYPE_MASK) ==
  971. QDF_IEEE80211_FC0_SUBTYPE_DATA) ||
  972. ((qdf_cpu_to_le16(frame_ctrl) & QDF_IEEE80211_FC0_SUBTYPE_MASK) ==
  973. QDF_IEEE80211_FC0_SUBTYPE_QOS))) {
  974. return true;
  975. }
  976. return false;
  977. }
  978. #ifdef WDI_EVENT_ENABLE
  979. QDF_STATUS dp_h2t_cfg_stats_msg_send(struct dp_pdev *pdev,
  980. uint32_t stats_type_upload_mask,
  981. uint8_t mac_id);
  982. int dp_wdi_event_unsub(struct cdp_pdev *txrx_pdev_handle,
  983. void *event_cb_sub_handle,
  984. uint32_t event);
  985. int dp_wdi_event_sub(struct cdp_pdev *txrx_pdev_handle,
  986. void *event_cb_sub_handle,
  987. uint32_t event);
  988. void dp_wdi_event_handler(enum WDI_EVENT event, void *soc,
  989. void *data, u_int16_t peer_id,
  990. int status, u_int8_t pdev_id);
  991. int dp_wdi_event_attach(struct dp_pdev *txrx_pdev);
  992. int dp_wdi_event_detach(struct dp_pdev *txrx_pdev);
  993. int dp_set_pktlog_wifi3(struct dp_pdev *pdev, uint32_t event,
  994. bool enable);
  995. void *dp_get_pldev(struct cdp_pdev *txrx_pdev);
  996. void dp_pkt_log_init(struct cdp_pdev *ppdev, void *scn);
  997. static inline void dp_hif_update_pipe_callback(void *soc, void *cb_context,
  998. QDF_STATUS (*callback)(void *, qdf_nbuf_t, uint8_t), uint8_t pipe_id)
  999. {
  1000. struct hif_msg_callbacks hif_pipe_callbacks;
  1001. struct dp_soc *dp_soc = (struct dp_soc *)soc;
  1002. /* TODO: Temporary change to bypass HTC connection for this new
  1003. * HIF pipe, which will be used for packet log and other high-
  1004. * priority HTT messages. Proper HTC connection to be added
  1005. * later once required FW changes are available
  1006. */
  1007. hif_pipe_callbacks.rxCompletionHandler = callback;
  1008. hif_pipe_callbacks.Context = cb_context;
  1009. hif_update_pipe_callback(dp_soc->hif_handle,
  1010. DP_HTT_T2H_HP_PIPE, &hif_pipe_callbacks);
  1011. }
  1012. QDF_STATUS dp_peer_stats_notify(struct dp_peer *peer);
  1013. #else
  1014. static inline int dp_wdi_event_unsub(struct cdp_pdev *txrx_pdev_handle,
  1015. void *event_cb_sub_handle,
  1016. uint32_t event)
  1017. {
  1018. return 0;
  1019. }
  1020. static inline int dp_wdi_event_sub(struct cdp_pdev *txrx_pdev_handle,
  1021. void *event_cb_sub_handle,
  1022. uint32_t event)
  1023. {
  1024. return 0;
  1025. }
  1026. static inline void dp_wdi_event_handler(enum WDI_EVENT event, void *soc,
  1027. void *data, u_int16_t peer_id,
  1028. int status, u_int8_t pdev_id)
  1029. {
  1030. }
  1031. static inline int dp_wdi_event_attach(struct dp_pdev *txrx_pdev)
  1032. {
  1033. return 0;
  1034. }
  1035. static inline int dp_wdi_event_detach(struct dp_pdev *txrx_pdev)
  1036. {
  1037. return 0;
  1038. }
  1039. static inline int dp_set_pktlog_wifi3(struct dp_pdev *pdev, uint32_t event,
  1040. bool enable)
  1041. {
  1042. return 0;
  1043. }
  1044. static inline QDF_STATUS dp_h2t_cfg_stats_msg_send(struct dp_pdev *pdev,
  1045. uint32_t stats_type_upload_mask, uint8_t mac_id)
  1046. {
  1047. return 0;
  1048. }
  1049. static inline void dp_hif_update_pipe_callback(void *soc, void *cb_context,
  1050. QDF_STATUS (*callback)(void *, qdf_nbuf_t, uint8_t), uint8_t pipe_id)
  1051. {
  1052. }
  1053. static inline QDF_STATUS dp_peer_stats_notify(struct dp_peer *peer)
  1054. {
  1055. return QDF_STATUS_SUCCESS;
  1056. }
  1057. #endif /* CONFIG_WIN */
  1058. #ifdef QCA_LL_TX_FLOW_CONTROL_V2
  1059. void dp_tx_dump_flow_pool_info(void *soc);
  1060. int dp_tx_delete_flow_pool(struct dp_soc *soc, struct dp_tx_desc_pool_s *pool,
  1061. bool force);
  1062. #endif /* QCA_LL_TX_FLOW_CONTROL_V2 */
  1063. #ifdef PEER_PROTECTED_ACCESS
  1064. /**
  1065. * dp_peer_unref_del_find_by_id() - dec ref and del peer if ref count is
  1066. * taken by dp_peer_find_by_id
  1067. * @peer: peer context
  1068. *
  1069. * Return: none
  1070. */
  1071. static inline void dp_peer_unref_del_find_by_id(struct dp_peer *peer)
  1072. {
  1073. dp_peer_unref_delete(peer);
  1074. }
  1075. #else
  1076. static inline void dp_peer_unref_del_find_by_id(struct dp_peer *peer)
  1077. {
  1078. }
  1079. #endif
  1080. #ifdef WLAN_FEATURE_DP_EVENT_HISTORY
  1081. /**
  1082. * dp_srng_access_start() - Wrapper function to log access start of a hal ring
  1083. * @int_ctx: pointer to DP interrupt context
  1084. * @soc: DP Soc handle
  1085. * @hal_ring: opaque pointer to the HAL Rx Error Ring, which will be serviced
  1086. *
  1087. * Return: 0 on success; error on failure
  1088. */
  1089. int dp_srng_access_start(struct dp_intr *int_ctx, struct dp_soc *dp_soc,
  1090. void *hal_ring);
  1091. /**
  1092. * dp_srng_access_end() - Wrapper function to log access end of a hal ring
  1093. * @int_ctx: pointer to DP interrupt context
  1094. * @soc: DP Soc handle
  1095. * @hal_ring: opaque pointer to the HAL Rx Error Ring, which will be serviced
  1096. *
  1097. * Return: void
  1098. */
  1099. void dp_srng_access_end(struct dp_intr *int_ctx, struct dp_soc *dp_soc,
  1100. void *hal_ring);
  1101. #else
  1102. static inline int dp_srng_access_start(struct dp_intr *int_ctx,
  1103. struct dp_soc *dp_soc, void *hal_ring)
  1104. {
  1105. void *hal_soc = dp_soc->hal_soc;
  1106. return hal_srng_access_start(hal_soc, hal_ring);
  1107. }
  1108. static inline void dp_srng_access_end(struct dp_intr *int_ctx,
  1109. struct dp_soc *dp_soc, void *hal_ring)
  1110. {
  1111. void *hal_soc = dp_soc->hal_soc;
  1112. return hal_srng_access_end(hal_soc, hal_ring);
  1113. }
  1114. #endif /* WLAN_FEATURE_DP_EVENT_HISTORY */
  1115. #ifdef QCA_ENH_V3_STATS_SUPPORT
  1116. /**
  1117. * dp_pdev_print_delay_stats(): Print pdev level delay stats
  1118. * @pdev: DP_PDEV handle
  1119. *
  1120. * Return:void
  1121. */
  1122. void dp_pdev_print_delay_stats(struct dp_pdev *pdev);
  1123. /**
  1124. * dp_pdev_print_tid_stats(): Print pdev level tid stats
  1125. * @pdev: DP_PDEV handle
  1126. *
  1127. * Return:void
  1128. */
  1129. void dp_pdev_print_tid_stats(struct dp_pdev *pdev);
  1130. #endif /* CONFIG_WIN */
  1131. void dp_soc_set_txrx_ring_map(struct dp_soc *soc);
  1132. #ifndef WLAN_TX_PKT_CAPTURE_ENH
  1133. /**
  1134. * dp_tx_ppdu_stats_attach - Initialize Tx PPDU stats and enhanced capture
  1135. * @pdev: DP PDEV
  1136. *
  1137. * Return: none
  1138. */
  1139. static inline void dp_tx_ppdu_stats_attach(struct dp_pdev *pdev)
  1140. {
  1141. }
  1142. /**
  1143. * dp_tx_ppdu_stats_detach - Cleanup Tx PPDU stats and enhanced capture
  1144. * @pdev: DP PDEV
  1145. *
  1146. * Return: none
  1147. */
  1148. static inline void dp_tx_ppdu_stats_detach(struct dp_pdev *pdev)
  1149. {
  1150. }
  1151. /**
  1152. * dp_tx_ppdu_stats_process - Deferred PPDU stats handler
  1153. * @context: Opaque work context (PDEV)
  1154. *
  1155. * Return: none
  1156. */
  1157. static inline void dp_tx_ppdu_stats_process(void *context)
  1158. {
  1159. }
  1160. /**
  1161. * dp_tx_add_to_comp_queue() - add completion msdu to queue
  1162. * @soc: DP Soc handle
  1163. * @tx_desc: software Tx descriptor
  1164. * @ts : Tx completion status from HAL/HTT descriptor
  1165. * @peer: DP peer
  1166. *
  1167. * Return: none
  1168. */
  1169. static inline
  1170. QDF_STATUS dp_tx_add_to_comp_queue(struct dp_soc *soc,
  1171. struct dp_tx_desc_s *desc,
  1172. struct hal_tx_completion_status *ts,
  1173. struct dp_peer *peer)
  1174. {
  1175. return QDF_STATUS_E_FAILURE;
  1176. }
  1177. #endif
  1178. #endif /* #ifndef _DP_INTERNAL_H_ */