dp_internal.h 33 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970
  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_AVG_WEIGHT 2
  23. /*
  24. * Formula to derive avg_rssi is taken from wifi2.o firmware
  25. */
  26. #define DP_GET_AVG_RSSI(avg_rssi, last_rssi) \
  27. (((avg_rssi) - (((uint8_t)(avg_rssi)) >> DP_RSSI_AVG_WEIGHT)) \
  28. + ((((uint8_t)(last_rssi)) >> DP_RSSI_AVG_WEIGHT)))
  29. /* Macro For NYSM value received in VHT TLV */
  30. #define VHT_SGI_NYSM 3
  31. #if DP_PRINT_ENABLE
  32. #include <stdarg.h> /* va_list */
  33. #include <qdf_types.h> /* qdf_vprint */
  34. #include <cdp_txrx_handle.h>
  35. enum {
  36. /* FATAL_ERR - print only irrecoverable error messages */
  37. DP_PRINT_LEVEL_FATAL_ERR,
  38. /* ERR - include non-fatal err messages */
  39. DP_PRINT_LEVEL_ERR,
  40. /* WARN - include warnings */
  41. DP_PRINT_LEVEL_WARN,
  42. /* INFO1 - include fundamental, infrequent events */
  43. DP_PRINT_LEVEL_INFO1,
  44. /* INFO2 - include non-fundamental but infrequent events */
  45. DP_PRINT_LEVEL_INFO2,
  46. };
  47. #define dp_print(level, fmt, ...) do { \
  48. if (level <= g_txrx_print_level) \
  49. qdf_print(fmt, ## __VA_ARGS__); \
  50. while (0)
  51. #define DP_PRINT(level, fmt, ...) do { \
  52. dp_print(level, "DP: " fmt, ## __VA_ARGS__); \
  53. while (0)
  54. #else
  55. #define DP_PRINT(level, fmt, ...)
  56. #endif /* DP_PRINT_ENABLE */
  57. #define DP_TRACE(LVL, fmt, args ...) \
  58. QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_##LVL, \
  59. fmt, ## args)
  60. #define DP_TRACE_STATS(LVL, fmt, args ...) \
  61. QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_##LVL, \
  62. fmt, ## args)
  63. #ifdef CONFIG_MCL
  64. /* Stat prints should not go to console or kernel logs.*/
  65. #define DP_PRINT_STATS(fmt, args ...)\
  66. QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_INFO_HIGH, \
  67. fmt, ## args)
  68. #else
  69. #define DP_PRINT_STATS(fmt, args ...)\
  70. QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_FATAL,\
  71. fmt, ## args)
  72. #endif
  73. #define DP_STATS_INIT(_handle) \
  74. qdf_mem_zero(&((_handle)->stats), sizeof((_handle)->stats))
  75. #define DP_STATS_CLR(_handle) \
  76. qdf_mem_zero(&((_handle)->stats), sizeof((_handle)->stats))
  77. #ifndef DISABLE_DP_STATS
  78. #define DP_STATS_INC(_handle, _field, _delta) \
  79. { \
  80. if (likely(_handle)) \
  81. _handle->stats._field += _delta; \
  82. }
  83. #define DP_STATS_INCC(_handle, _field, _delta, _cond) \
  84. { \
  85. if (_cond && likely(_handle)) \
  86. _handle->stats._field += _delta; \
  87. }
  88. #define DP_STATS_DEC(_handle, _field, _delta) \
  89. { \
  90. if (likely(_handle)) \
  91. _handle->stats._field -= _delta; \
  92. }
  93. #define DP_STATS_UPD(_handle, _field, _delta) \
  94. { \
  95. if (likely(_handle)) \
  96. _handle->stats._field = _delta; \
  97. }
  98. #define DP_STATS_INC_PKT(_handle, _field, _count, _bytes) \
  99. { \
  100. DP_STATS_INC(_handle, _field.num, _count); \
  101. DP_STATS_INC(_handle, _field.bytes, _bytes) \
  102. }
  103. #define DP_STATS_INCC_PKT(_handle, _field, _count, _bytes, _cond) \
  104. { \
  105. DP_STATS_INCC(_handle, _field.num, _count, _cond); \
  106. DP_STATS_INCC(_handle, _field.bytes, _bytes, _cond) \
  107. }
  108. #define DP_STATS_AGGR(_handle_a, _handle_b, _field) \
  109. { \
  110. _handle_a->stats._field += _handle_b->stats._field; \
  111. }
  112. #define DP_STATS_AGGR_PKT(_handle_a, _handle_b, _field) \
  113. { \
  114. DP_STATS_AGGR(_handle_a, _handle_b, _field.num); \
  115. DP_STATS_AGGR(_handle_a, _handle_b, _field.bytes);\
  116. }
  117. #define DP_STATS_UPD_STRUCT(_handle_a, _handle_b, _field) \
  118. { \
  119. _handle_a->stats._field = _handle_b->stats._field; \
  120. }
  121. #define DP_HIST_INIT() \
  122. uint32_t num_of_packets[MAX_PDEV_CNT] = {0};
  123. #define DP_HIST_PACKET_COUNT_INC(_pdev_id) \
  124. { \
  125. ++num_of_packets[_pdev_id]; \
  126. }
  127. #define DP_TX_HISTOGRAM_UPDATE(_pdev, _p_cntrs) \
  128. do { \
  129. if (_p_cntrs == 1) { \
  130. DP_STATS_INC(_pdev, \
  131. tx_comp_histogram.pkts_1, 1); \
  132. } else if (_p_cntrs > 1 && _p_cntrs <= 20) { \
  133. DP_STATS_INC(_pdev, \
  134. tx_comp_histogram.pkts_2_20, 1); \
  135. } else if (_p_cntrs > 20 && _p_cntrs <= 40) { \
  136. DP_STATS_INC(_pdev, \
  137. tx_comp_histogram.pkts_21_40, 1); \
  138. } else if (_p_cntrs > 40 && _p_cntrs <= 60) { \
  139. DP_STATS_INC(_pdev, \
  140. tx_comp_histogram.pkts_41_60, 1); \
  141. } else if (_p_cntrs > 60 && _p_cntrs <= 80) { \
  142. DP_STATS_INC(_pdev, \
  143. tx_comp_histogram.pkts_61_80, 1); \
  144. } else if (_p_cntrs > 80 && _p_cntrs <= 100) { \
  145. DP_STATS_INC(_pdev, \
  146. tx_comp_histogram.pkts_81_100, 1); \
  147. } else if (_p_cntrs > 100 && _p_cntrs <= 200) { \
  148. DP_STATS_INC(_pdev, \
  149. tx_comp_histogram.pkts_101_200, 1); \
  150. } else if (_p_cntrs > 200) { \
  151. DP_STATS_INC(_pdev, \
  152. tx_comp_histogram.pkts_201_plus, 1); \
  153. } \
  154. } while (0)
  155. #define DP_RX_HISTOGRAM_UPDATE(_pdev, _p_cntrs) \
  156. do { \
  157. if (_p_cntrs == 1) { \
  158. DP_STATS_INC(_pdev, \
  159. rx_ind_histogram.pkts_1, 1); \
  160. } else if (_p_cntrs > 1 && _p_cntrs <= 20) { \
  161. DP_STATS_INC(_pdev, \
  162. rx_ind_histogram.pkts_2_20, 1); \
  163. } else if (_p_cntrs > 20 && _p_cntrs <= 40) { \
  164. DP_STATS_INC(_pdev, \
  165. rx_ind_histogram.pkts_21_40, 1); \
  166. } else if (_p_cntrs > 40 && _p_cntrs <= 60) { \
  167. DP_STATS_INC(_pdev, \
  168. rx_ind_histogram.pkts_41_60, 1); \
  169. } else if (_p_cntrs > 60 && _p_cntrs <= 80) { \
  170. DP_STATS_INC(_pdev, \
  171. rx_ind_histogram.pkts_61_80, 1); \
  172. } else if (_p_cntrs > 80 && _p_cntrs <= 100) { \
  173. DP_STATS_INC(_pdev, \
  174. rx_ind_histogram.pkts_81_100, 1); \
  175. } else if (_p_cntrs > 100 && _p_cntrs <= 200) { \
  176. DP_STATS_INC(_pdev, \
  177. rx_ind_histogram.pkts_101_200, 1); \
  178. } else if (_p_cntrs > 200) { \
  179. DP_STATS_INC(_pdev, \
  180. rx_ind_histogram.pkts_201_plus, 1); \
  181. } \
  182. } while (0)
  183. #define DP_TX_HIST_STATS_PER_PDEV() \
  184. do { \
  185. uint8_t hist_stats = 0; \
  186. for (hist_stats = 0; hist_stats < soc->pdev_count; \
  187. hist_stats++) { \
  188. DP_TX_HISTOGRAM_UPDATE(soc->pdev_list[hist_stats], \
  189. num_of_packets[hist_stats]); \
  190. } \
  191. } while (0)
  192. #define DP_RX_HIST_STATS_PER_PDEV() \
  193. do { \
  194. uint8_t hist_stats = 0; \
  195. for (hist_stats = 0; hist_stats < soc->pdev_count; \
  196. hist_stats++) { \
  197. DP_RX_HISTOGRAM_UPDATE(soc->pdev_list[hist_stats], \
  198. num_of_packets[hist_stats]); \
  199. } \
  200. } while (0)
  201. #else
  202. #define DP_STATS_INC(_handle, _field, _delta)
  203. #define DP_STATS_INCC(_handle, _field, _delta, _cond)
  204. #define DP_STATS_DEC(_handle, _field, _delta)
  205. #define DP_STATS_UPD(_handle, _field, _delta)
  206. #define DP_STATS_INC_PKT(_handle, _field, _count, _bytes)
  207. #define DP_STATS_INCC_PKT(_handle, _field, _count, _bytes, _cond)
  208. #define DP_STATS_AGGR(_handle_a, _handle_b, _field)
  209. #define DP_STATS_AGGR_PKT(_handle_a, _handle_b, _field)
  210. #define DP_HIST_INIT()
  211. #define DP_HIST_PACKET_COUNT_INC(_pdev_id)
  212. #define DP_TX_HISTOGRAM_UPDATE(_pdev, _p_cntrs)
  213. #define DP_RX_HISTOGRAM_UPDATE(_pdev, _p_cntrs)
  214. #define DP_RX_HIST_STATS_PER_PDEV()
  215. #define DP_TX_HIST_STATS_PER_PDEV()
  216. #endif
  217. #define DP_HTT_T2H_HP_PIPE 5
  218. static inline void dp_update_pdev_stats(struct dp_pdev *tgtobj,
  219. struct cdp_vdev_stats *srcobj)
  220. {
  221. uint8_t i;
  222. uint8_t pream_type;
  223. for (pream_type = 0; pream_type < DOT11_MAX; pream_type++) {
  224. for (i = 0; i < MAX_MCS; i++) {
  225. tgtobj->stats.tx.pkt_type[pream_type].
  226. mcs_count[i] +=
  227. srcobj->tx.pkt_type[pream_type].
  228. mcs_count[i];
  229. tgtobj->stats.rx.pkt_type[pream_type].
  230. mcs_count[i] +=
  231. srcobj->rx.pkt_type[pream_type].
  232. mcs_count[i];
  233. }
  234. }
  235. for (i = 0; i < MAX_BW; i++) {
  236. tgtobj->stats.tx.bw[i] += srcobj->tx.bw[i];
  237. tgtobj->stats.rx.bw[i] += srcobj->rx.bw[i];
  238. }
  239. for (i = 0; i < SS_COUNT; i++) {
  240. tgtobj->stats.tx.nss[i] += srcobj->tx.nss[i];
  241. tgtobj->stats.rx.nss[i] += srcobj->rx.nss[i];
  242. }
  243. for (i = 0; i < WME_AC_MAX; i++) {
  244. tgtobj->stats.tx.wme_ac_type[i] +=
  245. srcobj->tx.wme_ac_type[i];
  246. tgtobj->stats.rx.wme_ac_type[i] +=
  247. srcobj->rx.wme_ac_type[i];
  248. tgtobj->stats.tx.excess_retries_per_ac[i] +=
  249. srcobj->tx.excess_retries_per_ac[i];
  250. }
  251. for (i = 0; i < MAX_GI; i++) {
  252. tgtobj->stats.tx.sgi_count[i] +=
  253. srcobj->tx.sgi_count[i];
  254. tgtobj->stats.rx.sgi_count[i] +=
  255. srcobj->rx.sgi_count[i];
  256. }
  257. for (i = 0; i < MAX_RECEPTION_TYPES; i++)
  258. tgtobj->stats.rx.reception_type[i] +=
  259. srcobj->rx.reception_type[i];
  260. tgtobj->stats.tx.comp_pkt.bytes += srcobj->tx.comp_pkt.bytes;
  261. tgtobj->stats.tx.comp_pkt.num += srcobj->tx.comp_pkt.num;
  262. tgtobj->stats.tx.ucast.num += srcobj->tx.ucast.num;
  263. tgtobj->stats.tx.ucast.bytes += srcobj->tx.ucast.bytes;
  264. tgtobj->stats.tx.mcast.num += srcobj->tx.mcast.num;
  265. tgtobj->stats.tx.mcast.bytes += srcobj->tx.mcast.bytes;
  266. tgtobj->stats.tx.bcast.num += srcobj->tx.bcast.num;
  267. tgtobj->stats.tx.bcast.bytes += srcobj->tx.bcast.bytes;
  268. tgtobj->stats.tx.tx_success.num += srcobj->tx.tx_success.num;
  269. tgtobj->stats.tx.tx_success.bytes +=
  270. srcobj->tx.tx_success.bytes;
  271. tgtobj->stats.tx.nawds_mcast.num +=
  272. srcobj->tx.nawds_mcast.num;
  273. tgtobj->stats.tx.nawds_mcast.bytes +=
  274. srcobj->tx.nawds_mcast.bytes;
  275. tgtobj->stats.tx.nawds_mcast_drop +=
  276. srcobj->tx.nawds_mcast_drop;
  277. tgtobj->stats.tx.tx_failed += srcobj->tx.tx_failed;
  278. tgtobj->stats.tx.ofdma += srcobj->tx.ofdma;
  279. tgtobj->stats.tx.stbc += srcobj->tx.stbc;
  280. tgtobj->stats.tx.ldpc += srcobj->tx.ldpc;
  281. tgtobj->stats.tx.retries += srcobj->tx.retries;
  282. tgtobj->stats.tx.non_amsdu_cnt += srcobj->tx.non_amsdu_cnt;
  283. tgtobj->stats.tx.amsdu_cnt += srcobj->tx.amsdu_cnt;
  284. tgtobj->stats.tx.dropped.fw_rem.num += srcobj->tx.dropped.fw_rem.num;
  285. tgtobj->stats.tx.dropped.fw_rem.bytes +=
  286. srcobj->tx.dropped.fw_rem.bytes;
  287. tgtobj->stats.tx.dropped.fw_rem_tx +=
  288. srcobj->tx.dropped.fw_rem_tx;
  289. tgtobj->stats.tx.dropped.fw_rem_notx +=
  290. srcobj->tx.dropped.fw_rem_notx;
  291. tgtobj->stats.tx.dropped.fw_reason1 +=
  292. srcobj->tx.dropped.fw_reason1;
  293. tgtobj->stats.tx.dropped.fw_reason2 +=
  294. srcobj->tx.dropped.fw_reason2;
  295. tgtobj->stats.tx.dropped.fw_reason3 +=
  296. srcobj->tx.dropped.fw_reason3;
  297. tgtobj->stats.tx.dropped.age_out += srcobj->tx.dropped.age_out;
  298. tgtobj->stats.rx.err.mic_err += srcobj->rx.err.mic_err;
  299. if (srcobj->rx.rssi != 0)
  300. tgtobj->stats.rx.rssi = srcobj->rx.rssi;
  301. tgtobj->stats.rx.rx_rate = srcobj->rx.rx_rate;
  302. tgtobj->stats.rx.err.decrypt_err += srcobj->rx.err.decrypt_err;
  303. tgtobj->stats.rx.non_ampdu_cnt += srcobj->rx.non_ampdu_cnt;
  304. tgtobj->stats.rx.amsdu_cnt += srcobj->rx.ampdu_cnt;
  305. tgtobj->stats.rx.non_amsdu_cnt += srcobj->rx.non_amsdu_cnt;
  306. tgtobj->stats.rx.amsdu_cnt += srcobj->rx.amsdu_cnt;
  307. tgtobj->stats.rx.nawds_mcast_drop += srcobj->rx.nawds_mcast_drop;
  308. tgtobj->stats.rx.to_stack.num += srcobj->rx.to_stack.num;
  309. tgtobj->stats.rx.to_stack.bytes += srcobj->rx.to_stack.bytes;
  310. for (i = 0; i < CDP_MAX_RX_RINGS; i++) {
  311. tgtobj->stats.rx.rcvd_reo[i].num +=
  312. srcobj->rx.rcvd_reo[i].num;
  313. tgtobj->stats.rx.rcvd_reo[i].bytes +=
  314. srcobj->rx.rcvd_reo[i].bytes;
  315. }
  316. srcobj->rx.unicast.num =
  317. srcobj->rx.to_stack.num -
  318. (srcobj->rx.multicast.num);
  319. srcobj->rx.unicast.bytes =
  320. srcobj->rx.to_stack.bytes -
  321. (srcobj->rx.multicast.bytes);
  322. tgtobj->stats.rx.unicast.num += srcobj->rx.unicast.num;
  323. tgtobj->stats.rx.unicast.bytes += srcobj->rx.unicast.bytes;
  324. tgtobj->stats.rx.multicast.num += srcobj->rx.multicast.num;
  325. tgtobj->stats.rx.multicast.bytes += srcobj->rx.multicast.bytes;
  326. tgtobj->stats.rx.bcast.num += srcobj->rx.bcast.num;
  327. tgtobj->stats.rx.bcast.bytes += srcobj->rx.bcast.bytes;
  328. tgtobj->stats.rx.raw.num += srcobj->rx.raw.num;
  329. tgtobj->stats.rx.raw.bytes += srcobj->rx.raw.bytes;
  330. tgtobj->stats.rx.intra_bss.pkts.num +=
  331. srcobj->rx.intra_bss.pkts.num;
  332. tgtobj->stats.rx.intra_bss.pkts.bytes +=
  333. srcobj->rx.intra_bss.pkts.bytes;
  334. tgtobj->stats.rx.intra_bss.fail.num +=
  335. srcobj->rx.intra_bss.fail.num;
  336. tgtobj->stats.rx.intra_bss.fail.bytes +=
  337. srcobj->rx.intra_bss.fail.bytes;
  338. tgtobj->stats.tx.last_ack_rssi =
  339. srcobj->tx.last_ack_rssi;
  340. tgtobj->stats.rx.mec_drop.num += srcobj->rx.mec_drop.num;
  341. tgtobj->stats.rx.mec_drop.bytes += srcobj->rx.mec_drop.bytes;
  342. }
  343. static inline void dp_update_pdev_ingress_stats(struct dp_pdev *tgtobj,
  344. struct dp_vdev *srcobj)
  345. {
  346. DP_STATS_AGGR_PKT(tgtobj, srcobj, tx_i.nawds_mcast);
  347. DP_STATS_AGGR_PKT(tgtobj, srcobj, tx_i.rcvd);
  348. DP_STATS_AGGR_PKT(tgtobj, srcobj, tx_i.processed);
  349. DP_STATS_AGGR_PKT(tgtobj, srcobj, tx_i.reinject_pkts);
  350. DP_STATS_AGGR_PKT(tgtobj, srcobj, tx_i.inspect_pkts);
  351. DP_STATS_AGGR_PKT(tgtobj, srcobj, tx_i.raw.raw_pkt);
  352. DP_STATS_AGGR(tgtobj, srcobj, tx_i.raw.dma_map_error);
  353. DP_STATS_AGGR_PKT(tgtobj, srcobj, tx_i.tso.tso_pkt);
  354. DP_STATS_AGGR(tgtobj, srcobj, tx_i.tso.dropped_host.num);
  355. DP_STATS_AGGR(tgtobj, srcobj, tx_i.tso.dropped_target);
  356. DP_STATS_AGGR(tgtobj, srcobj, tx_i.sg.dropped_host.num);
  357. DP_STATS_AGGR(tgtobj, srcobj, tx_i.sg.dropped_target);
  358. DP_STATS_AGGR_PKT(tgtobj, srcobj, tx_i.sg.sg_pkt);
  359. DP_STATS_AGGR_PKT(tgtobj, srcobj, tx_i.mcast_en.mcast_pkt);
  360. DP_STATS_AGGR(tgtobj, srcobj,
  361. tx_i.mcast_en.dropped_map_error);
  362. DP_STATS_AGGR(tgtobj, srcobj,
  363. tx_i.mcast_en.dropped_self_mac);
  364. DP_STATS_AGGR(tgtobj, srcobj,
  365. tx_i.mcast_en.dropped_send_fail);
  366. DP_STATS_AGGR(tgtobj, srcobj, tx_i.mcast_en.ucast);
  367. DP_STATS_AGGR(tgtobj, srcobj, tx_i.dropped.dma_error);
  368. DP_STATS_AGGR(tgtobj, srcobj, tx_i.dropped.ring_full);
  369. DP_STATS_AGGR(tgtobj, srcobj, tx_i.dropped.enqueue_fail);
  370. DP_STATS_AGGR(tgtobj, srcobj, tx_i.dropped.desc_na.num);
  371. DP_STATS_AGGR(tgtobj, srcobj, tx_i.dropped.res_full);
  372. DP_STATS_AGGR(tgtobj, srcobj, tx_i.dropped.headroom_insufficient);
  373. DP_STATS_AGGR(tgtobj, srcobj, tx_i.cce_classified);
  374. DP_STATS_AGGR(tgtobj, srcobj, tx_i.cce_classified_raw);
  375. DP_STATS_AGGR(tgtobj, srcobj, tx_i.mesh.exception_fw);
  376. DP_STATS_AGGR(tgtobj, srcobj, tx_i.mesh.completion_fw);
  377. tgtobj->stats.tx_i.dropped.dropped_pkt.num =
  378. tgtobj->stats.tx_i.dropped.dma_error +
  379. tgtobj->stats.tx_i.dropped.ring_full +
  380. tgtobj->stats.tx_i.dropped.enqueue_fail +
  381. tgtobj->stats.tx_i.dropped.desc_na.num +
  382. tgtobj->stats.tx_i.dropped.res_full;
  383. tgtobj->stats.tx_i.tso.num_seg =
  384. srcobj->stats.tx_i.tso.num_seg;
  385. }
  386. static inline void dp_update_vdev_stats(struct cdp_vdev_stats *tgtobj,
  387. struct dp_peer *srcobj)
  388. {
  389. uint8_t i;
  390. uint8_t pream_type;
  391. for (pream_type = 0; pream_type < DOT11_MAX; pream_type++) {
  392. for (i = 0; i < MAX_MCS; i++) {
  393. tgtobj->tx.pkt_type[pream_type].
  394. mcs_count[i] +=
  395. srcobj->stats.tx.pkt_type[pream_type].
  396. mcs_count[i];
  397. tgtobj->rx.pkt_type[pream_type].
  398. mcs_count[i] +=
  399. srcobj->stats.rx.pkt_type[pream_type].
  400. mcs_count[i];
  401. }
  402. }
  403. for (i = 0; i < MAX_BW; i++) {
  404. tgtobj->tx.bw[i] += srcobj->stats.tx.bw[i];
  405. tgtobj->rx.bw[i] += srcobj->stats.rx.bw[i];
  406. }
  407. for (i = 0; i < SS_COUNT; i++) {
  408. tgtobj->tx.nss[i] += srcobj->stats.tx.nss[i];
  409. tgtobj->rx.nss[i] += srcobj->stats.rx.nss[i];
  410. }
  411. for (i = 0; i < WME_AC_MAX; i++) {
  412. tgtobj->tx.wme_ac_type[i] +=
  413. srcobj->stats.tx.wme_ac_type[i];
  414. tgtobj->rx.wme_ac_type[i] +=
  415. srcobj->stats.rx.wme_ac_type[i];
  416. tgtobj->tx.excess_retries_per_ac[i] +=
  417. srcobj->stats.tx.excess_retries_per_ac[i];
  418. }
  419. for (i = 0; i < MAX_GI; i++) {
  420. tgtobj->tx.sgi_count[i] +=
  421. srcobj->stats.tx.sgi_count[i];
  422. tgtobj->rx.sgi_count[i] +=
  423. srcobj->stats.rx.sgi_count[i];
  424. }
  425. for (i = 0; i < MAX_RECEPTION_TYPES; i++)
  426. tgtobj->rx.reception_type[i] +=
  427. srcobj->stats.rx.reception_type[i];
  428. tgtobj->tx.comp_pkt.bytes += srcobj->stats.tx.comp_pkt.bytes;
  429. tgtobj->tx.comp_pkt.num += srcobj->stats.tx.comp_pkt.num;
  430. tgtobj->tx.ucast.num += srcobj->stats.tx.ucast.num;
  431. tgtobj->tx.ucast.bytes += srcobj->stats.tx.ucast.bytes;
  432. tgtobj->tx.mcast.num += srcobj->stats.tx.mcast.num;
  433. tgtobj->tx.mcast.bytes += srcobj->stats.tx.mcast.bytes;
  434. tgtobj->tx.bcast.num += srcobj->stats.tx.bcast.num;
  435. tgtobj->tx.bcast.bytes += srcobj->stats.tx.bcast.bytes;
  436. tgtobj->tx.tx_success.num += srcobj->stats.tx.tx_success.num;
  437. tgtobj->tx.tx_success.bytes +=
  438. srcobj->stats.tx.tx_success.bytes;
  439. tgtobj->tx.nawds_mcast.num +=
  440. srcobj->stats.tx.nawds_mcast.num;
  441. tgtobj->tx.nawds_mcast.bytes +=
  442. srcobj->stats.tx.nawds_mcast.bytes;
  443. tgtobj->tx.nawds_mcast_drop +=
  444. srcobj->stats.tx.nawds_mcast_drop;
  445. tgtobj->tx.tx_failed += srcobj->stats.tx.tx_failed;
  446. tgtobj->tx.ofdma += srcobj->stats.tx.ofdma;
  447. tgtobj->tx.stbc += srcobj->stats.tx.stbc;
  448. tgtobj->tx.ldpc += srcobj->stats.tx.ldpc;
  449. tgtobj->tx.retries += srcobj->stats.tx.retries;
  450. tgtobj->tx.non_amsdu_cnt += srcobj->stats.tx.non_amsdu_cnt;
  451. tgtobj->tx.amsdu_cnt += srcobj->stats.tx.amsdu_cnt;
  452. tgtobj->tx.dropped.fw_rem.num += srcobj->stats.tx.dropped.fw_rem.num;
  453. tgtobj->tx.dropped.fw_rem.bytes +=
  454. srcobj->stats.tx.dropped.fw_rem.bytes;
  455. tgtobj->tx.dropped.fw_rem_tx +=
  456. srcobj->stats.tx.dropped.fw_rem_tx;
  457. tgtobj->tx.dropped.fw_rem_notx +=
  458. srcobj->stats.tx.dropped.fw_rem_notx;
  459. tgtobj->tx.dropped.fw_reason1 +=
  460. srcobj->stats.tx.dropped.fw_reason1;
  461. tgtobj->tx.dropped.fw_reason2 +=
  462. srcobj->stats.tx.dropped.fw_reason2;
  463. tgtobj->tx.dropped.fw_reason3 +=
  464. srcobj->stats.tx.dropped.fw_reason3;
  465. tgtobj->tx.dropped.age_out += srcobj->stats.tx.dropped.age_out;
  466. tgtobj->rx.err.mic_err += srcobj->stats.rx.err.mic_err;
  467. if (srcobj->stats.rx.rssi != 0)
  468. tgtobj->rx.rssi = srcobj->stats.rx.rssi;
  469. tgtobj->rx.rx_rate = srcobj->stats.rx.rx_rate;
  470. tgtobj->rx.err.decrypt_err += srcobj->stats.rx.err.decrypt_err;
  471. tgtobj->rx.non_ampdu_cnt += srcobj->stats.rx.non_ampdu_cnt;
  472. tgtobj->rx.amsdu_cnt += srcobj->stats.rx.ampdu_cnt;
  473. tgtobj->rx.non_amsdu_cnt += srcobj->stats.rx.non_amsdu_cnt;
  474. tgtobj->rx.amsdu_cnt += srcobj->stats.rx.amsdu_cnt;
  475. tgtobj->rx.nawds_mcast_drop += srcobj->stats.rx.nawds_mcast_drop;
  476. tgtobj->rx.to_stack.num += srcobj->stats.rx.to_stack.num;
  477. tgtobj->rx.to_stack.bytes += srcobj->stats.rx.to_stack.bytes;
  478. for (i = 0; i < CDP_MAX_RX_RINGS; i++) {
  479. tgtobj->rx.rcvd_reo[i].num +=
  480. srcobj->stats.rx.rcvd_reo[i].num;
  481. tgtobj->rx.rcvd_reo[i].bytes +=
  482. srcobj->stats.rx.rcvd_reo[i].bytes;
  483. }
  484. srcobj->stats.rx.unicast.num =
  485. srcobj->stats.rx.to_stack.num -
  486. srcobj->stats.rx.multicast.num;
  487. srcobj->stats.rx.unicast.bytes =
  488. srcobj->stats.rx.to_stack.bytes -
  489. srcobj->stats.rx.multicast.bytes;
  490. tgtobj->rx.unicast.num += srcobj->stats.rx.unicast.num;
  491. tgtobj->rx.unicast.bytes += srcobj->stats.rx.unicast.bytes;
  492. tgtobj->rx.multicast.num += srcobj->stats.rx.multicast.num;
  493. tgtobj->rx.multicast.bytes += srcobj->stats.rx.multicast.bytes;
  494. tgtobj->rx.bcast.num += srcobj->stats.rx.bcast.num;
  495. tgtobj->rx.bcast.bytes += srcobj->stats.rx.bcast.bytes;
  496. tgtobj->rx.raw.num += srcobj->stats.rx.raw.num;
  497. tgtobj->rx.raw.bytes += srcobj->stats.rx.raw.bytes;
  498. tgtobj->rx.intra_bss.pkts.num +=
  499. srcobj->stats.rx.intra_bss.pkts.num;
  500. tgtobj->rx.intra_bss.pkts.bytes +=
  501. srcobj->stats.rx.intra_bss.pkts.bytes;
  502. tgtobj->rx.intra_bss.fail.num +=
  503. srcobj->stats.rx.intra_bss.fail.num;
  504. tgtobj->rx.intra_bss.fail.bytes +=
  505. srcobj->stats.rx.intra_bss.fail.bytes;
  506. tgtobj->tx.last_ack_rssi =
  507. srcobj->stats.tx.last_ack_rssi;
  508. tgtobj->rx.mec_drop.num += srcobj->stats.rx.mec_drop.num;
  509. tgtobj->rx.mec_drop.bytes += srcobj->stats.rx.mec_drop.bytes;
  510. }
  511. #define DP_UPDATE_STATS(_tgtobj, _srcobj) \
  512. do { \
  513. uint8_t i; \
  514. uint8_t pream_type; \
  515. for (pream_type = 0; pream_type < DOT11_MAX; pream_type++) { \
  516. for (i = 0; i < MAX_MCS; i++) { \
  517. DP_STATS_AGGR(_tgtobj, _srcobj, \
  518. tx.pkt_type[pream_type].mcs_count[i]); \
  519. DP_STATS_AGGR(_tgtobj, _srcobj, \
  520. rx.pkt_type[pream_type].mcs_count[i]); \
  521. } \
  522. } \
  523. \
  524. for (i = 0; i < MAX_BW; i++) { \
  525. DP_STATS_AGGR(_tgtobj, _srcobj, tx.bw[i]); \
  526. DP_STATS_AGGR(_tgtobj, _srcobj, rx.bw[i]); \
  527. } \
  528. \
  529. for (i = 0; i < SS_COUNT; i++) { \
  530. DP_STATS_AGGR(_tgtobj, _srcobj, rx.nss[i]); \
  531. DP_STATS_AGGR(_tgtobj, _srcobj, tx.nss[i]); \
  532. } \
  533. for (i = 0; i < WME_AC_MAX; i++) { \
  534. DP_STATS_AGGR(_tgtobj, _srcobj, tx.wme_ac_type[i]); \
  535. DP_STATS_AGGR(_tgtobj, _srcobj, rx.wme_ac_type[i]); \
  536. DP_STATS_AGGR(_tgtobj, _srcobj, tx.excess_retries_per_ac[i]); \
  537. \
  538. } \
  539. \
  540. for (i = 0; i < MAX_GI; i++) { \
  541. DP_STATS_AGGR(_tgtobj, _srcobj, tx.sgi_count[i]); \
  542. DP_STATS_AGGR(_tgtobj, _srcobj, rx.sgi_count[i]); \
  543. } \
  544. \
  545. for (i = 0; i < MAX_RECEPTION_TYPES; i++) \
  546. DP_STATS_AGGR(_tgtobj, _srcobj, rx.reception_type[i]); \
  547. \
  548. DP_STATS_AGGR_PKT(_tgtobj, _srcobj, tx.comp_pkt); \
  549. DP_STATS_AGGR_PKT(_tgtobj, _srcobj, tx.ucast); \
  550. DP_STATS_AGGR_PKT(_tgtobj, _srcobj, tx.mcast); \
  551. DP_STATS_AGGR_PKT(_tgtobj, _srcobj, tx.bcast); \
  552. DP_STATS_AGGR_PKT(_tgtobj, _srcobj, tx.tx_success); \
  553. DP_STATS_AGGR_PKT(_tgtobj, _srcobj, tx.nawds_mcast); \
  554. DP_STATS_AGGR(_tgtobj, _srcobj, tx.nawds_mcast_drop); \
  555. DP_STATS_AGGR(_tgtobj, _srcobj, tx.tx_failed); \
  556. DP_STATS_AGGR(_tgtobj, _srcobj, tx.ofdma); \
  557. DP_STATS_AGGR(_tgtobj, _srcobj, tx.stbc); \
  558. DP_STATS_AGGR(_tgtobj, _srcobj, tx.ldpc); \
  559. DP_STATS_AGGR(_tgtobj, _srcobj, tx.retries); \
  560. DP_STATS_AGGR(_tgtobj, _srcobj, tx.non_amsdu_cnt); \
  561. DP_STATS_AGGR(_tgtobj, _srcobj, tx.amsdu_cnt); \
  562. DP_STATS_AGGR_PKT(_tgtobj, _srcobj, tx.dropped.fw_rem); \
  563. DP_STATS_AGGR(_tgtobj, _srcobj, tx.dropped.fw_rem_tx); \
  564. DP_STATS_AGGR(_tgtobj, _srcobj, tx.dropped.fw_rem_notx); \
  565. DP_STATS_AGGR(_tgtobj, _srcobj, tx.dropped.fw_reason1); \
  566. DP_STATS_AGGR(_tgtobj, _srcobj, tx.dropped.fw_reason2); \
  567. DP_STATS_AGGR(_tgtobj, _srcobj, tx.dropped.fw_reason3); \
  568. DP_STATS_AGGR(_tgtobj, _srcobj, tx.dropped.age_out); \
  569. \
  570. DP_STATS_AGGR(_tgtobj, _srcobj, rx.err.mic_err); \
  571. if (_srcobj->stats.rx.rssi != 0) \
  572. DP_STATS_UPD_STRUCT(_tgtobj, _srcobj, rx.rssi); \
  573. DP_STATS_UPD_STRUCT(_tgtobj, _srcobj, rx.rx_rate); \
  574. DP_STATS_AGGR(_tgtobj, _srcobj, rx.err.decrypt_err); \
  575. DP_STATS_AGGR(_tgtobj, _srcobj, rx.non_ampdu_cnt); \
  576. DP_STATS_AGGR(_tgtobj, _srcobj, rx.ampdu_cnt); \
  577. DP_STATS_AGGR(_tgtobj, _srcobj, rx.non_amsdu_cnt); \
  578. DP_STATS_AGGR(_tgtobj, _srcobj, rx.amsdu_cnt); \
  579. DP_STATS_AGGR(_tgtobj, _srcobj, rx.nawds_mcast_drop); \
  580. DP_STATS_AGGR_PKT(_tgtobj, _srcobj, rx.to_stack); \
  581. \
  582. for (i = 0; i < CDP_MAX_RX_RINGS; i++) \
  583. DP_STATS_AGGR_PKT(_tgtobj, _srcobj, rx.rcvd_reo[i]); \
  584. \
  585. _srcobj->stats.rx.unicast.num = \
  586. _srcobj->stats.rx.to_stack.num - \
  587. _srcobj->stats.rx.multicast.num; \
  588. _srcobj->stats.rx.unicast.bytes = \
  589. _srcobj->stats.rx.to_stack.bytes - \
  590. _srcobj->stats.rx.multicast.bytes; \
  591. DP_STATS_AGGR_PKT(_tgtobj, _srcobj, rx.unicast); \
  592. DP_STATS_AGGR_PKT(_tgtobj, _srcobj, rx.multicast); \
  593. DP_STATS_AGGR_PKT(_tgtobj, _srcobj, rx.bcast); \
  594. DP_STATS_AGGR_PKT(_tgtobj, _srcobj, rx.raw); \
  595. DP_STATS_AGGR_PKT(_tgtobj, _srcobj, rx.intra_bss.pkts); \
  596. DP_STATS_AGGR_PKT(_tgtobj, _srcobj, rx.intra_bss.fail); \
  597. DP_STATS_AGGR_PKT(_tgtobj, _srcobj, rx.mec_drop); \
  598. \
  599. _tgtobj->stats.tx.last_ack_rssi = \
  600. _srcobj->stats.tx.last_ack_rssi; \
  601. } while (0)
  602. extern int dp_peer_find_attach(struct dp_soc *soc);
  603. extern void dp_peer_find_detach(struct dp_soc *soc);
  604. extern void dp_peer_find_hash_add(struct dp_soc *soc, struct dp_peer *peer);
  605. extern void dp_peer_find_hash_remove(struct dp_soc *soc, struct dp_peer *peer);
  606. extern void dp_peer_find_hash_erase(struct dp_soc *soc);
  607. extern void dp_peer_rx_init(struct dp_pdev *pdev, struct dp_peer *peer);
  608. extern void dp_peer_cleanup(struct dp_vdev *vdev, struct dp_peer *peer);
  609. extern void dp_peer_rx_cleanup(struct dp_vdev *vdev, struct dp_peer *peer);
  610. extern void dp_peer_unref_delete(void *peer_handle);
  611. extern void dp_rx_discard(struct dp_vdev *vdev, struct dp_peer *peer,
  612. unsigned tid, qdf_nbuf_t msdu_list);
  613. extern void *dp_find_peer_by_addr(struct cdp_pdev *dev,
  614. uint8_t *peer_mac_addr, uint8_t *peer_id);
  615. extern struct dp_peer *dp_peer_find_hash_find(struct dp_soc *soc,
  616. uint8_t *peer_mac_addr, int mac_addr_is_aligned, uint8_t vdev_id);
  617. #ifndef CONFIG_WIN
  618. QDF_STATUS dp_register_peer(struct cdp_pdev *pdev_handle,
  619. struct ol_txrx_desc_type *sta_desc);
  620. QDF_STATUS dp_clear_peer(struct cdp_pdev *pdev_handle, uint8_t local_id);
  621. void *dp_find_peer_by_addr_and_vdev(struct cdp_pdev *pdev_handle,
  622. struct cdp_vdev *vdev,
  623. uint8_t *peer_addr, uint8_t *local_id);
  624. uint16_t dp_local_peer_id(void *peer);
  625. void *dp_peer_find_by_local_id(struct cdp_pdev *pdev_handle, uint8_t local_id);
  626. QDF_STATUS dp_peer_state_update(struct cdp_pdev *pdev_handle, uint8_t *peer_mac,
  627. enum ol_txrx_peer_state state);
  628. QDF_STATUS dp_get_vdevid(void *peer_handle, uint8_t *vdev_id);
  629. struct cdp_vdev *dp_get_vdev_by_sta_id(struct cdp_pdev *pdev_handle,
  630. uint8_t sta_id);
  631. struct cdp_vdev *dp_get_vdev_for_peer(void *peer);
  632. uint8_t *dp_peer_get_peer_mac_addr(void *peer);
  633. int dp_get_peer_state(void *peer_handle);
  634. void dp_local_peer_id_pool_init(struct dp_pdev *pdev);
  635. void dp_local_peer_id_alloc(struct dp_pdev *pdev, struct dp_peer *peer);
  636. void dp_local_peer_id_free(struct dp_pdev *pdev, struct dp_peer *peer);
  637. #else
  638. static inline void dp_local_peer_id_pool_init(struct dp_pdev *pdev)
  639. {
  640. }
  641. static inline
  642. void dp_local_peer_id_alloc(struct dp_pdev *pdev, struct dp_peer *peer)
  643. {
  644. }
  645. static inline
  646. void dp_local_peer_id_free(struct dp_pdev *pdev, struct dp_peer *peer)
  647. {
  648. }
  649. #endif
  650. int dp_addba_resp_tx_completion_wifi3(void *peer_handle, uint8_t tid,
  651. int status);
  652. extern int dp_addba_requestprocess_wifi3(void *peer_handle,
  653. uint8_t dialogtoken, uint16_t tid, uint16_t batimeout,
  654. uint16_t buffersize, uint16_t startseqnum);
  655. extern void dp_addba_responsesetup_wifi3(void *peer_handle, uint8_t tid,
  656. uint8_t *dialogtoken, uint16_t *statuscode,
  657. uint16_t *buffersize, uint16_t *batimeout);
  658. extern void dp_set_addba_response(void *peer_handle, uint8_t tid,
  659. uint16_t statuscode);
  660. extern int dp_delba_process_wifi3(void *peer_handle,
  661. int tid, uint16_t reasoncode);
  662. /*
  663. * dp_delba_tx_completion_wifi3() - Handle delba tx completion
  664. *
  665. * @peer_handle: Peer handle
  666. * @tid: Tid number
  667. * @status: Tx completion status
  668. * Indicate status of delba Tx to DP for stats update and retry
  669. * delba if tx failed.
  670. *
  671. */
  672. int dp_delba_tx_completion_wifi3(void *peer_handle, uint8_t tid,
  673. int status);
  674. extern int dp_rx_tid_setup_wifi3(struct dp_peer *peer, int tid,
  675. uint32_t ba_window_size, uint32_t start_seq);
  676. extern QDF_STATUS dp_reo_send_cmd(struct dp_soc *soc,
  677. enum hal_reo_cmd_type type, struct hal_reo_cmd_params *params,
  678. void (*callback_fn), void *data);
  679. extern void dp_reo_cmdlist_destroy(struct dp_soc *soc);
  680. extern void dp_reo_status_ring_handler(struct dp_soc *soc);
  681. void dp_aggregate_vdev_stats(struct dp_vdev *vdev,
  682. struct cdp_vdev_stats *vdev_stats);
  683. void dp_rx_tid_stats_cb(struct dp_soc *soc, void *cb_ctxt,
  684. union hal_reo_status *reo_status);
  685. void dp_rx_bar_stats_cb(struct dp_soc *soc, void *cb_ctxt,
  686. union hal_reo_status *reo_status);
  687. uint16_t dp_tx_me_send_convert_ucast(struct cdp_vdev *vdev_handle,
  688. qdf_nbuf_t nbuf, uint8_t newmac[][QDF_MAC_ADDR_SIZE],
  689. uint8_t new_mac_cnt);
  690. void dp_tx_me_alloc_descriptor(struct cdp_pdev *pdev);
  691. void dp_tx_me_free_descriptor(struct cdp_pdev *pdev);
  692. QDF_STATUS dp_h2t_ext_stats_msg_send(struct dp_pdev *pdev,
  693. uint32_t stats_type_upload_mask, uint32_t config_param_0,
  694. uint32_t config_param_1, uint32_t config_param_2,
  695. uint32_t config_param_3, int cookie, int cookie_msb,
  696. uint8_t mac_id);
  697. void dp_htt_stats_print_tag(uint8_t tag_type, uint32_t *tag_buf);
  698. void dp_htt_stats_copy_tag(struct dp_pdev *pdev, uint8_t tag_type, uint32_t *tag_buf);
  699. void dp_peer_rxtid_stats(struct dp_peer *peer, void (*callback_fn),
  700. void *cb_ctxt);
  701. void dp_set_pn_check_wifi3(struct cdp_vdev *vdev_handle,
  702. struct cdp_peer *peer_handle, enum cdp_sec_type sec_type,
  703. uint32_t *rx_pn);
  704. void *dp_get_pdev_for_mac_id(struct dp_soc *soc, uint32_t mac_id);
  705. void dp_set_michael_key(struct cdp_peer *peer_handle,
  706. bool is_unicast, uint32_t *key);
  707. #ifdef CONFIG_WIN
  708. uint32_t dp_pdev_tid_stats_display(void *pdev_handle,
  709. enum _ol_ath_param_t param, uint32_t value, void *buff);
  710. #endif
  711. void dp_update_delay_stats(struct dp_pdev *pdev, uint32_t delay,
  712. uint8_t tid, uint8_t mode);
  713. /*
  714. * dp_get_mac_id_for_pdev() - Return mac corresponding to pdev for mac
  715. *
  716. * @mac_id: MAC id
  717. * @pdev_id: pdev_id corresponding to pdev, 0 for MCL
  718. *
  719. * Single pdev using both MACs will operate on both MAC rings,
  720. * which is the case for MCL.
  721. * For WIN each PDEV will operate one ring, so index is zero.
  722. *
  723. */
  724. static inline int dp_get_mac_id_for_pdev(uint32_t mac_id, uint32_t pdev_id)
  725. {
  726. if (mac_id && pdev_id) {
  727. qdf_print("Both mac_id and pdev_id cannot be non zero");
  728. QDF_BUG(0);
  729. return 0;
  730. }
  731. return (mac_id + pdev_id);
  732. }
  733. /*
  734. * dp_get_mac_id_for_mac() - Return mac corresponding WIN and MCL mac_ids
  735. *
  736. * @soc: handle to DP soc
  737. * @mac_id: MAC id
  738. *
  739. * Single pdev using both MACs will operate on both MAC rings,
  740. * which is the case for MCL.
  741. * For WIN each PDEV will operate one ring, so index is zero.
  742. *
  743. */
  744. static inline int dp_get_mac_id_for_mac(struct dp_soc *soc, uint32_t mac_id)
  745. {
  746. /*
  747. * Single pdev using both MACs will operate on both MAC rings,
  748. * which is the case for MCL.
  749. */
  750. if (!wlan_cfg_per_pdev_lmac_ring(soc->wlan_cfg_ctx))
  751. return mac_id;
  752. /* For WIN each PDEV will operate one ring, so index is zero. */
  753. return 0;
  754. }
  755. bool dp_is_soc_reinit(struct dp_soc *soc);
  756. #ifdef WDI_EVENT_ENABLE
  757. QDF_STATUS dp_h2t_cfg_stats_msg_send(struct dp_pdev *pdev,
  758. uint32_t stats_type_upload_mask,
  759. uint8_t mac_id);
  760. int dp_wdi_event_unsub(struct cdp_pdev *txrx_pdev_handle,
  761. void *event_cb_sub_handle,
  762. uint32_t event);
  763. int dp_wdi_event_sub(struct cdp_pdev *txrx_pdev_handle,
  764. void *event_cb_sub_handle,
  765. uint32_t event);
  766. void dp_wdi_event_handler(enum WDI_EVENT event, void *soc,
  767. void *data, u_int16_t peer_id,
  768. int status, u_int8_t pdev_id);
  769. int dp_wdi_event_attach(struct dp_pdev *txrx_pdev);
  770. int dp_wdi_event_detach(struct dp_pdev *txrx_pdev);
  771. int dp_set_pktlog_wifi3(struct dp_pdev *pdev, uint32_t event,
  772. bool enable);
  773. void *dp_get_pldev(struct cdp_pdev *txrx_pdev);
  774. void dp_pkt_log_init(struct cdp_pdev *ppdev, void *scn);
  775. static inline void dp_hif_update_pipe_callback(void *soc, void *cb_context,
  776. QDF_STATUS (*callback)(void *, qdf_nbuf_t, uint8_t), uint8_t pipe_id)
  777. {
  778. struct hif_msg_callbacks hif_pipe_callbacks;
  779. struct dp_soc *dp_soc = (struct dp_soc *)soc;
  780. /* TODO: Temporary change to bypass HTC connection for this new
  781. * HIF pipe, which will be used for packet log and other high-
  782. * priority HTT messages. Proper HTC connection to be added
  783. * later once required FW changes are available
  784. */
  785. hif_pipe_callbacks.rxCompletionHandler = callback;
  786. hif_pipe_callbacks.Context = cb_context;
  787. hif_update_pipe_callback(dp_soc->hif_handle,
  788. DP_HTT_T2H_HP_PIPE, &hif_pipe_callbacks);
  789. }
  790. QDF_STATUS dp_peer_stats_notify(struct dp_peer *peer);
  791. #else
  792. static inline int dp_wdi_event_unsub(struct cdp_pdev *txrx_pdev_handle,
  793. void *event_cb_sub_handle,
  794. uint32_t event)
  795. {
  796. return 0;
  797. }
  798. static inline int dp_wdi_event_sub(struct cdp_pdev *txrx_pdev_handle,
  799. void *event_cb_sub_handle,
  800. uint32_t event)
  801. {
  802. return 0;
  803. }
  804. static inline void dp_wdi_event_handler(enum WDI_EVENT event, void *soc,
  805. void *data, u_int16_t peer_id,
  806. int status, u_int8_t pdev_id)
  807. {
  808. }
  809. static inline int dp_wdi_event_attach(struct dp_pdev *txrx_pdev)
  810. {
  811. return 0;
  812. }
  813. static inline int dp_wdi_event_detach(struct dp_pdev *txrx_pdev)
  814. {
  815. return 0;
  816. }
  817. static inline int dp_set_pktlog_wifi3(struct dp_pdev *pdev, uint32_t event,
  818. bool enable)
  819. {
  820. return 0;
  821. }
  822. static inline QDF_STATUS dp_h2t_cfg_stats_msg_send(struct dp_pdev *pdev,
  823. uint32_t stats_type_upload_mask, uint8_t mac_id)
  824. {
  825. return 0;
  826. }
  827. static inline void dp_hif_update_pipe_callback(void *soc, void *cb_context,
  828. QDF_STATUS (*callback)(void *, qdf_nbuf_t, uint8_t), uint8_t pipe_id)
  829. {
  830. }
  831. static inline QDF_STATUS dp_peer_stats_notify(struct dp_peer *peer)
  832. {
  833. return QDF_STATUS_SUCCESS;
  834. }
  835. #endif /* CONFIG_WIN */
  836. #ifdef QCA_LL_TX_FLOW_CONTROL_V2
  837. void dp_tx_dump_flow_pool_info(void *soc);
  838. int dp_tx_delete_flow_pool(struct dp_soc *soc, struct dp_tx_desc_pool_s *pool,
  839. bool force);
  840. #endif /* QCA_LL_TX_FLOW_CONTROL_V2 */
  841. #ifdef PEER_PROTECTED_ACCESS
  842. /**
  843. * dp_peer_unref_del_find_by_id() - dec ref and del peer if ref count is
  844. * taken by dp_peer_find_by_id
  845. * @peer: peer context
  846. *
  847. * Return: none
  848. */
  849. static inline void dp_peer_unref_del_find_by_id(struct dp_peer *peer)
  850. {
  851. dp_peer_unref_delete(peer);
  852. }
  853. #else
  854. static inline void dp_peer_unref_del_find_by_id(struct dp_peer *peer)
  855. {
  856. }
  857. #endif
  858. #ifdef CONFIG_WIN
  859. /**
  860. * dp_pdev_print_delay_stats(): Print pdev level delay stats
  861. * @pdev: DP_PDEV handle
  862. *
  863. * Return:void
  864. */
  865. void dp_pdev_print_delay_stats(struct dp_pdev *pdev);
  866. /**
  867. * dp_pdev_print_tid_stats(): Print pdev level tid stats
  868. * @pdev: DP_PDEV handle
  869. *
  870. * Return:void
  871. */
  872. void dp_pdev_print_tid_stats(struct dp_pdev *pdev);
  873. #endif /* CONFIG_WIN */
  874. #endif /* #ifndef _DP_INTERNAL_H_ */