dp_internal.h 13 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367
  1. /*
  2. * Copyright (c) 2016-2017 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. #if DP_PRINT_ENABLE
  23. #include <stdarg.h> /* va_list */
  24. #include <qdf_types.h> /* qdf_vprint */
  25. #include <cdp_txrx_handle.h>
  26. enum {
  27. /* FATAL_ERR - print only irrecoverable error messages */
  28. DP_PRINT_LEVEL_FATAL_ERR,
  29. /* ERR - include non-fatal err messages */
  30. DP_PRINT_LEVEL_ERR,
  31. /* WARN - include warnings */
  32. DP_PRINT_LEVEL_WARN,
  33. /* INFO1 - include fundamental, infrequent events */
  34. DP_PRINT_LEVEL_INFO1,
  35. /* INFO2 - include non-fundamental but infrequent events */
  36. DP_PRINT_LEVEL_INFO2,
  37. };
  38. #define dp_print(level, fmt, ...) do { \
  39. if (level <= g_txrx_print_level) \
  40. qdf_print(fmt, ## __VA_ARGS__); \
  41. while (0)
  42. #define DP_PRINT(level, fmt, ...) do { \
  43. dp_print(level, "DP: " fmt, ## __VA_ARGS__); \
  44. while (0)
  45. #else
  46. #define DP_PRINT(level, fmt, ...)
  47. #endif /* DP_PRINT_ENABLE */
  48. #define DP_TRACE(LVL, fmt, args ...) \
  49. QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_##LVL, \
  50. fmt, ## args)
  51. #define DP_TRACE_STATS(LVL, fmt, args ...) \
  52. QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_##LVL, \
  53. fmt, ## args)
  54. #define DP_STATS_INIT(_handle) \
  55. qdf_mem_set(&((_handle)->stats), sizeof((_handle)->stats), 0x0)
  56. #define DP_STATS_CLR(_handle) \
  57. qdf_mem_set(&((_handle)->stats), sizeof((_handle)->stats), 0x0)
  58. #ifndef DISABLE_DP_STATS
  59. #define DP_STATS_INC(_handle, _field, _delta) \
  60. { \
  61. if (likely(_handle)) \
  62. _handle->stats._field += _delta; \
  63. }
  64. #define DP_STATS_INCC(_handle, _field, _delta, _cond) \
  65. { \
  66. if (_cond && likely(_handle)) \
  67. _handle->stats._field += _delta; \
  68. }
  69. #define DP_STATS_DEC(_handle, _field, _delta) \
  70. { \
  71. if (likely(_handle)) \
  72. _handle->stats._field -= _delta; \
  73. }
  74. #define DP_STATS_UPD(_handle, _field, _delta) \
  75. { \
  76. if (likely(_handle)) \
  77. _handle->stats._field = _delta; \
  78. }
  79. #define DP_STATS_INC_PKT(_handle, _field, _count, _bytes) \
  80. { \
  81. DP_STATS_INC(_handle, _field.num, _count); \
  82. DP_STATS_INC(_handle, _field.bytes, _bytes) \
  83. }
  84. #define DP_STATS_INCC_PKT(_handle, _field, _count, _bytes, _cond) \
  85. { \
  86. DP_STATS_INCC(_handle, _field.num, _count, _cond); \
  87. DP_STATS_INCC(_handle, _field.bytes, _bytes, _cond) \
  88. }
  89. #define DP_STATS_AGGR(_handle_a, _handle_b, _field) \
  90. { \
  91. _handle_a->stats._field += _handle_b->stats._field; \
  92. }
  93. #define DP_STATS_AGGR_PKT(_handle_a, _handle_b, _field) \
  94. { \
  95. DP_STATS_AGGR(_handle_a, _handle_b, _field.num); \
  96. DP_STATS_AGGR(_handle_a, _handle_b, _field.bytes);\
  97. }
  98. #define DP_HIST_INIT() \
  99. uint32_t num_of_packets[MAX_PDEV_CNT] = {0};
  100. #define DP_HIST_PACKET_COUNT_INC(_pdev_id) \
  101. { \
  102. ++num_of_packets[_pdev_id]; \
  103. }
  104. #define DP_TX_HISTOGRAM_UPDATE(_pdev, _p_cntrs) \
  105. do { \
  106. if (_p_cntrs == 1) { \
  107. DP_STATS_INC(_pdev, \
  108. tx_comp_histogram.pkts_1, 1); \
  109. } else if (_p_cntrs > 1 && _p_cntrs <= 20) { \
  110. DP_STATS_INC(_pdev, \
  111. tx_comp_histogram.pkts_2_20, 1); \
  112. } else if (_p_cntrs > 20 && _p_cntrs <= 40) { \
  113. DP_STATS_INC(_pdev, \
  114. tx_comp_histogram.pkts_21_40, 1); \
  115. } else if (_p_cntrs > 40 && _p_cntrs <= 60) { \
  116. DP_STATS_INC(_pdev, \
  117. tx_comp_histogram.pkts_41_60, 1); \
  118. } else if (_p_cntrs > 60 && _p_cntrs <= 80) { \
  119. DP_STATS_INC(_pdev, \
  120. tx_comp_histogram.pkts_61_80, 1); \
  121. } else if (_p_cntrs > 80 && _p_cntrs <= 100) { \
  122. DP_STATS_INC(_pdev, \
  123. tx_comp_histogram.pkts_81_100, 1); \
  124. } else if (_p_cntrs > 100 && _p_cntrs <= 200) { \
  125. DP_STATS_INC(_pdev, \
  126. tx_comp_histogram.pkts_101_200, 1); \
  127. } else if (_p_cntrs > 200) { \
  128. DP_STATS_INC(_pdev, \
  129. tx_comp_histogram.pkts_201_plus, 1); \
  130. } \
  131. } while (0)
  132. #define DP_RX_HISTOGRAM_UPDATE(_pdev, _p_cntrs) \
  133. do { \
  134. if (_p_cntrs == 1) { \
  135. DP_STATS_INC(_pdev, \
  136. rx_ind_histogram.pkts_1, 1); \
  137. } else if (_p_cntrs > 1 && _p_cntrs <= 20) { \
  138. DP_STATS_INC(_pdev, \
  139. rx_ind_histogram.pkts_2_20, 1); \
  140. } else if (_p_cntrs > 20 && _p_cntrs <= 40) { \
  141. DP_STATS_INC(_pdev, \
  142. rx_ind_histogram.pkts_21_40, 1); \
  143. } else if (_p_cntrs > 40 && _p_cntrs <= 60) { \
  144. DP_STATS_INC(_pdev, \
  145. rx_ind_histogram.pkts_41_60, 1); \
  146. } else if (_p_cntrs > 60 && _p_cntrs <= 80) { \
  147. DP_STATS_INC(_pdev, \
  148. rx_ind_histogram.pkts_61_80, 1); \
  149. } else if (_p_cntrs > 80 && _p_cntrs <= 100) { \
  150. DP_STATS_INC(_pdev, \
  151. rx_ind_histogram.pkts_81_100, 1); \
  152. } else if (_p_cntrs > 100 && _p_cntrs <= 200) { \
  153. DP_STATS_INC(_pdev, \
  154. rx_ind_histogram.pkts_101_200, 1); \
  155. } else if (_p_cntrs > 200) { \
  156. DP_STATS_INC(_pdev, \
  157. rx_ind_histogram.pkts_201_plus, 1); \
  158. } \
  159. } while (0)
  160. #define DP_TX_HIST_STATS_PER_PDEV() \
  161. do { \
  162. uint8_t hist_stats = 0; \
  163. for (hist_stats = 0; hist_stats < soc->pdev_count; \
  164. hist_stats++) { \
  165. DP_TX_HISTOGRAM_UPDATE(soc->pdev_list[hist_stats], \
  166. num_of_packets[hist_stats]); \
  167. } \
  168. } while (0)
  169. #define DP_RX_HIST_STATS_PER_PDEV() \
  170. do { \
  171. uint8_t hist_stats = 0; \
  172. for (hist_stats = 0; hist_stats < soc->pdev_count; \
  173. hist_stats++) { \
  174. DP_RX_HISTOGRAM_UPDATE(soc->pdev_list[hist_stats], \
  175. num_of_packets[hist_stats]); \
  176. } \
  177. } while (0)
  178. #else
  179. #define DP_STATS_INC(_handle, _field, _delta)
  180. #define DP_STATS_INCC(_handle, _field, _delta, _cond)
  181. #define DP_STATS_DEC(_handle, _field, _delta)
  182. #define DP_STATS_UPD(_handle, _field, _delta)
  183. #define DP_STATS_INC_PKT(_handle, _field, _count, _bytes)
  184. #define DP_STATS_INCC_PKT(_handle, _field, _count, _bytes, _cond)
  185. #define DP_STATS_AGGR(_handle_a, _handle_b, _field)
  186. #define DP_STATS_AGGR_PKT(_handle_a, _handle_b, _field)
  187. #define DP_HIST_INIT()
  188. #define DP_HIST_PACKET_COUNT_INC(_pdev_id)
  189. #define DP_TX_HISTOGRAM_UPDATE(_pdev, _p_cntrs)
  190. #define DP_RX_HISTOGRAM_UPDATE(_pdev, _p_cntrs)
  191. #define DP_RX_HIST_STATS_PER_PDEV()
  192. #define DP_TX_HIST_STATS_PER_PDEV()
  193. #endif
  194. extern int dp_peer_find_attach(struct dp_soc *soc);
  195. extern void dp_peer_find_detach(struct dp_soc *soc);
  196. extern void dp_peer_find_hash_add(struct dp_soc *soc, struct dp_peer *peer);
  197. extern void dp_peer_find_hash_remove(struct dp_soc *soc, struct dp_peer *peer);
  198. extern void dp_peer_find_hash_erase(struct dp_soc *soc);
  199. extern void dp_peer_rx_init(struct dp_pdev *pdev, struct dp_peer *peer);
  200. extern void dp_peer_cleanup(struct dp_vdev *vdev, struct dp_peer *peer);
  201. extern void dp_peer_rx_cleanup(struct dp_vdev *vdev, struct dp_peer *peer);
  202. extern void dp_peer_unref_delete(void *peer_handle);
  203. extern void dp_rx_discard(struct dp_vdev *vdev, struct dp_peer *peer,
  204. unsigned tid, qdf_nbuf_t msdu_list);
  205. extern void *dp_find_peer_by_addr(struct cdp_pdev *dev,
  206. uint8_t *peer_mac_addr, uint8_t *peer_id);
  207. #ifndef CONFIG_WIN
  208. QDF_STATUS dp_register_peer(struct cdp_pdev *pdev_handle,
  209. struct ol_txrx_desc_type *sta_desc);
  210. QDF_STATUS dp_clear_peer(struct cdp_pdev *pdev_handle, uint8_t local_id);
  211. void *dp_find_peer_by_addr_and_vdev(struct cdp_pdev *pdev_handle,
  212. struct cdp_vdev *vdev,
  213. uint8_t *peer_addr, uint8_t *local_id);
  214. uint16_t dp_local_peer_id(void *peer);
  215. void *dp_peer_find_by_local_id(struct cdp_pdev *pdev_handle, uint8_t local_id);
  216. QDF_STATUS dp_peer_state_update(struct cdp_pdev *pdev_handle, uint8_t *peer_mac,
  217. enum ol_txrx_peer_state state);
  218. QDF_STATUS dp_get_vdevid(void *peer_handle, uint8_t *vdev_id);
  219. struct cdp_vdev *dp_get_vdev_for_peer(void *peer);
  220. uint8_t *dp_peer_get_peer_mac_addr(void *peer);
  221. int dp_get_peer_state(void *peer_handle);
  222. void dp_local_peer_id_pool_init(struct dp_pdev *pdev);
  223. void dp_local_peer_id_alloc(struct dp_pdev *pdev, struct dp_peer *peer);
  224. void dp_local_peer_id_free(struct dp_pdev *pdev, struct dp_peer *peer);
  225. qdf_time_t *dp_get_last_assoc_received(void *peer_handle);
  226. qdf_time_t *dp_get_last_disassoc_received(void *peer_handle);
  227. qdf_time_t *dp_get_last_deauth_received(void *peer_handle);
  228. #endif
  229. extern int dp_addba_requestprocess_wifi3(void *peer_handle,
  230. uint8_t dialogtoken, uint16_t tid, uint16_t batimeout,
  231. uint16_t buffersize, uint16_t startseqnum);
  232. extern void dp_addba_responsesetup_wifi3(void *peer_handle, uint8_t tid,
  233. uint8_t *dialogtoken, uint16_t *statuscode,
  234. uint16_t *buffersize, uint16_t *batimeout);
  235. extern int dp_delba_process_wifi3(void *peer_handle,
  236. int tid, uint16_t reasoncode);
  237. extern int dp_rx_tid_setup_wifi3(struct dp_peer *peer, int tid,
  238. uint32_t ba_window_size, uint32_t start_seq);
  239. extern QDF_STATUS dp_reo_send_cmd(struct dp_soc *soc,
  240. enum hal_reo_cmd_type type, struct hal_reo_cmd_params *params,
  241. void (*callback_fn), void *data);
  242. extern void dp_reo_cmdlist_destroy(struct dp_soc *soc);
  243. extern void dp_reo_status_ring_handler(struct dp_soc *soc);
  244. void dp_aggregate_vdev_stats(struct dp_vdev *vdev);
  245. uint16_t dp_tx_me_send_convert_ucast(struct cdp_vdev *vdev_handle,
  246. qdf_nbuf_t nbuf, uint8_t newmac[][DP_MAC_ADDR_LEN],
  247. uint8_t new_mac_cnt);
  248. void dp_tx_me_alloc_descriptor(struct cdp_pdev *pdev);
  249. void dp_tx_me_free_descriptor(struct cdp_pdev *pdev);
  250. QDF_STATUS dp_h2t_ext_stats_msg_send(struct dp_pdev *pdev,
  251. uint32_t stats_type_upload_mask, uint32_t config_param_0,
  252. uint32_t config_param_1, uint32_t config_param_2,
  253. uint32_t config_param_3);
  254. void dp_htt_stats_print_tag(uint8_t tag_type, uint32_t *tag_buf);
  255. int dp_peer_rxtid_stats(struct dp_peer *peer);
  256. void dp_set_pn_check_wifi3(struct cdp_vdev *vdev_handle,
  257. struct cdp_peer *peer_handle, enum cdp_sec_type sec_type,
  258. uint32_t *rx_pn);
  259. #if defined(CONFIG_WIN) && WDI_EVENT_ENABLE
  260. QDF_STATUS dp_h2t_cfg_stats_msg_send(struct dp_pdev *pdev,
  261. uint32_t stats_type_upload_mask);
  262. int dp_wdi_event_unsub(struct cdp_pdev *txrx_pdev_handle,
  263. void *event_cb_sub_handle,
  264. uint32_t event);
  265. int dp_wdi_event_sub(struct cdp_pdev *txrx_pdev_handle,
  266. void *event_cb_sub_handle,
  267. uint32_t event);
  268. void dp_wdi_event_handler(enum WDI_EVENT event, void *soc,
  269. void *data, u_int16_t peer_id,
  270. int status, u_int8_t pdev_id);
  271. int dp_wdi_event_attach(struct dp_pdev *txrx_pdev);
  272. int dp_wdi_event_detach(struct dp_pdev *txrx_pdev);
  273. int dp_set_pktlog_wifi3(struct dp_pdev *pdev, uint32_t event,
  274. bool enable);
  275. #else
  276. static inline int dp_wdi_event_unsub(struct cdp_pdev *txrx_pdev_handle,
  277. void *event_cb_sub_handle,
  278. uint32_t event)
  279. {
  280. return 0;
  281. }
  282. static inline int dp_wdi_event_sub(struct cdp_pdev *txrx_pdev_handle,
  283. void *event_cb_sub_handle,
  284. uint32_t event)
  285. {
  286. return 0;
  287. }
  288. static inline void dp_wdi_event_handler(enum WDI_EVENT event, void *soc,
  289. void *data, u_int16_t peer_id,
  290. int status, u_int8_t pdev_id)
  291. {
  292. }
  293. static inline int dp_wdi_event_attach(struct dp_pdev *txrx_pdev)
  294. {
  295. return 0;
  296. }
  297. static inline int dp_wdi_event_detach(struct dp_pdev *txrx_pdev)
  298. {
  299. return 0;
  300. }
  301. static inline int dp_set_pktlog_wifi3(struct dp_pdev *pdev, uint32_t event,
  302. bool enable)
  303. {
  304. return 0;
  305. }
  306. static inline QDF_STATUS dp_h2t_cfg_stats_msg_send(struct dp_pdev *pdev,
  307. uint32_t stats_type_upload_mask)
  308. {
  309. return 0;
  310. }
  311. #endif /* CONFIG_WIN */
  312. #ifdef QCA_LL_TX_FLOW_CONTROL_V2
  313. void dp_tx_dump_flow_pool_info(void *soc);
  314. int dp_tx_delete_flow_pool(struct dp_soc *soc, struct dp_tx_desc_pool_s *pool,
  315. bool force);
  316. #endif /* QCA_LL_TX_FLOW_CONTROL_V2 */
  317. #endif /* #ifndef _DP_INTERNAL_H_ */