dp_peer.c 36 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287
  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. #include <qdf_types.h>
  19. #include <qdf_lock.h>
  20. #include "dp_htt.h"
  21. #include "dp_types.h"
  22. #include "dp_internal.h"
  23. #include "dp_peer.h"
  24. #include <hal_api.h>
  25. #include <hal_reo.h>
  26. #ifdef CONFIG_MCL
  27. #include <cds_ieee80211_common.h>
  28. #endif
  29. /* Temporary definitions to be moved to wlan_cfg */
  30. static inline uint32_t wlan_cfg_max_peer_id(void *wlan_cfg_ctx)
  31. {
  32. /* TODO: This should be calculated based on target capabilities */
  33. return 2048;
  34. }
  35. static inline int dp_peer_find_mac_addr_cmp(
  36. union dp_align_mac_addr *mac_addr1,
  37. union dp_align_mac_addr *mac_addr2)
  38. {
  39. return !((mac_addr1->align4.bytes_abcd == mac_addr2->align4.bytes_abcd)
  40. /*
  41. * Intentionally use & rather than &&.
  42. * because the operands are binary rather than generic boolean,
  43. * the functionality is equivalent.
  44. * Using && has the advantage of short-circuited evaluation,
  45. * but using & has the advantage of no conditional branching,
  46. * which is a more significant benefit.
  47. */
  48. &
  49. (mac_addr1->align4.bytes_ef == mac_addr2->align4.bytes_ef));
  50. }
  51. static int dp_peer_find_map_attach(struct dp_soc *soc)
  52. {
  53. uint32_t max_peers, peer_map_size;
  54. /* allocate the peer ID -> peer object map */
  55. max_peers = wlan_cfg_max_peer_id(soc->wlan_cfg_ctx) + 1;
  56. soc->max_peers = max_peers;
  57. QDF_TRACE(QDF_MODULE_ID_TXRX, QDF_TRACE_LEVEL_INFO,
  58. "\n<=== cfg max peer id %d ====>\n", max_peers);
  59. peer_map_size = max_peers * sizeof(soc->peer_id_to_obj_map[0]);
  60. soc->peer_id_to_obj_map = qdf_mem_malloc(peer_map_size);
  61. if (!soc->peer_id_to_obj_map) {
  62. QDF_TRACE(QDF_MODULE_ID_TXRX, QDF_TRACE_LEVEL_ERROR,
  63. "%s: peer map memory allocation failed\n", __func__);
  64. return QDF_STATUS_E_NOMEM;
  65. }
  66. /*
  67. * The peer_id_to_obj_map doesn't really need to be initialized,
  68. * since elements are only used after they have been individually
  69. * initialized.
  70. * However, it is convenient for debugging to have all elements
  71. * that are not in use set to 0.
  72. */
  73. qdf_mem_zero(soc->peer_id_to_obj_map, peer_map_size);
  74. #ifdef notyet /* ATH_BAND_STEERING */
  75. OS_INIT_TIMER(soc->osdev, &(soc->bs_inact_timer),
  76. dp_peer_find_inact_timeout_handler, (void *)soc,
  77. QDF_TIMER_TYPE_WAKE_APPS);
  78. #endif
  79. return 0; /* success */
  80. }
  81. static int dp_log2_ceil(unsigned value)
  82. {
  83. unsigned tmp = value;
  84. int log2 = -1;
  85. while (tmp) {
  86. log2++;
  87. tmp >>= 1;
  88. }
  89. if (1 << log2 != value)
  90. log2++;
  91. return log2;
  92. }
  93. static int dp_peer_find_add_id_to_obj(
  94. struct dp_peer *peer,
  95. uint16_t peer_id)
  96. {
  97. int i;
  98. for (i = 0; i < MAX_NUM_PEER_ID_PER_PEER; i++) {
  99. if (peer->peer_ids[i] == HTT_INVALID_PEER) {
  100. peer->peer_ids[i] = peer_id;
  101. return 0; /* success */
  102. }
  103. }
  104. return QDF_STATUS_E_FAILURE; /* failure */
  105. }
  106. #define DP_PEER_HASH_LOAD_MULT 2
  107. #define DP_PEER_HASH_LOAD_SHIFT 0
  108. static int dp_peer_find_hash_attach(struct dp_soc *soc)
  109. {
  110. int i, hash_elems, log2;
  111. /* allocate the peer MAC address -> peer object hash table */
  112. hash_elems = wlan_cfg_max_peer_id(soc->wlan_cfg_ctx) + 1;
  113. hash_elems *= DP_PEER_HASH_LOAD_MULT;
  114. hash_elems >>= DP_PEER_HASH_LOAD_SHIFT;
  115. log2 = dp_log2_ceil(hash_elems);
  116. hash_elems = 1 << log2;
  117. soc->peer_hash.mask = hash_elems - 1;
  118. soc->peer_hash.idx_bits = log2;
  119. /* allocate an array of TAILQ peer object lists */
  120. soc->peer_hash.bins = qdf_mem_malloc(
  121. hash_elems * sizeof(TAILQ_HEAD(anonymous_tail_q, dp_peer)));
  122. if (!soc->peer_hash.bins)
  123. return QDF_STATUS_E_NOMEM;
  124. for (i = 0; i < hash_elems; i++)
  125. TAILQ_INIT(&soc->peer_hash.bins[i]);
  126. return 0;
  127. }
  128. static void dp_peer_find_hash_detach(struct dp_soc *soc)
  129. {
  130. qdf_mem_free(soc->peer_hash.bins);
  131. }
  132. static inline unsigned dp_peer_find_hash_index(struct dp_soc *soc,
  133. union dp_align_mac_addr *mac_addr)
  134. {
  135. unsigned index;
  136. index =
  137. mac_addr->align2.bytes_ab ^
  138. mac_addr->align2.bytes_cd ^
  139. mac_addr->align2.bytes_ef;
  140. index ^= index >> soc->peer_hash.idx_bits;
  141. index &= soc->peer_hash.mask;
  142. return index;
  143. }
  144. void dp_peer_find_hash_add(struct dp_soc *soc, struct dp_peer *peer)
  145. {
  146. unsigned index;
  147. index = dp_peer_find_hash_index(soc, &peer->mac_addr);
  148. qdf_spin_lock_bh(&soc->peer_ref_mutex);
  149. /*
  150. * It is important to add the new peer at the tail of the peer list
  151. * with the bin index. Together with having the hash_find function
  152. * search from head to tail, this ensures that if two entries with
  153. * the same MAC address are stored, the one added first will be
  154. * found first.
  155. */
  156. TAILQ_INSERT_TAIL(&soc->peer_hash.bins[index], peer, hash_list_elem);
  157. qdf_spin_unlock_bh(&soc->peer_ref_mutex);
  158. }
  159. #if ATH_SUPPORT_WRAP
  160. static struct dp_peer *dp_peer_find_hash_find(struct dp_soc *soc,
  161. uint8_t *peer_mac_addr, int mac_addr_is_aligned, uint8_t vdev_id)
  162. #else
  163. static struct dp_peer *dp_peer_find_hash_find(struct dp_soc *soc,
  164. uint8_t *peer_mac_addr, int mac_addr_is_aligned)
  165. #endif
  166. {
  167. union dp_align_mac_addr local_mac_addr_aligned, *mac_addr;
  168. unsigned index;
  169. struct dp_peer *peer;
  170. if (mac_addr_is_aligned) {
  171. mac_addr = (union dp_align_mac_addr *) peer_mac_addr;
  172. } else {
  173. qdf_mem_copy(
  174. &local_mac_addr_aligned.raw[0],
  175. peer_mac_addr, DP_MAC_ADDR_LEN);
  176. mac_addr = &local_mac_addr_aligned;
  177. }
  178. index = dp_peer_find_hash_index(soc, mac_addr);
  179. qdf_spin_lock_bh(&soc->peer_ref_mutex);
  180. TAILQ_FOREACH(peer, &soc->peer_hash.bins[index], hash_list_elem) {
  181. #if ATH_SUPPORT_WRAP
  182. /* ProxySTA may have multiple BSS peer with same MAC address,
  183. * modified find will take care of finding the correct BSS peer.
  184. */
  185. if (dp_peer_find_mac_addr_cmp(mac_addr, &peer->mac_addr) == 0 &&
  186. (peer->vdev->vdev_id == vdev_id)) {
  187. #else
  188. if (dp_peer_find_mac_addr_cmp(mac_addr, &peer->mac_addr) == 0) {
  189. #endif
  190. /* found it - increment the ref count before releasing
  191. * the lock
  192. */
  193. qdf_atomic_inc(&peer->ref_cnt);
  194. qdf_spin_unlock_bh(&soc->peer_ref_mutex);
  195. return peer;
  196. }
  197. }
  198. qdf_spin_unlock_bh(&soc->peer_ref_mutex);
  199. return NULL; /* failure */
  200. }
  201. void dp_peer_find_hash_remove(struct dp_soc *soc, struct dp_peer *peer)
  202. {
  203. unsigned index;
  204. struct dp_peer *tmppeer = NULL;
  205. int found = 0;
  206. index = dp_peer_find_hash_index(soc, &peer->mac_addr);
  207. /* Check if tail is not empty before delete*/
  208. QDF_ASSERT(!TAILQ_EMPTY(&soc->peer_hash.bins[index]));
  209. /*
  210. * DO NOT take the peer_ref_mutex lock here - it needs to be taken
  211. * by the caller.
  212. * The caller needs to hold the lock from the time the peer object's
  213. * reference count is decremented and tested up through the time the
  214. * reference to the peer object is removed from the hash table, by
  215. * this function.
  216. * Holding the lock only while removing the peer object reference
  217. * from the hash table keeps the hash table consistent, but does not
  218. * protect against a new HL tx context starting to use the peer object
  219. * if it looks up the peer object from its MAC address just after the
  220. * peer ref count is decremented to zero, but just before the peer
  221. * object reference is removed from the hash table.
  222. */
  223. TAILQ_FOREACH(tmppeer, &soc->peer_hash.bins[index], hash_list_elem) {
  224. if (tmppeer == peer) {
  225. found = 1;
  226. break;
  227. }
  228. }
  229. QDF_ASSERT(found);
  230. TAILQ_REMOVE(&soc->peer_hash.bins[index], peer, hash_list_elem);
  231. }
  232. void dp_peer_find_hash_erase(struct dp_soc *soc)
  233. {
  234. int i;
  235. /*
  236. * Not really necessary to take peer_ref_mutex lock - by this point,
  237. * it's known that the soc is no longer in use.
  238. */
  239. for (i = 0; i <= soc->peer_hash.mask; i++) {
  240. if (!TAILQ_EMPTY(&soc->peer_hash.bins[i])) {
  241. struct dp_peer *peer, *peer_next;
  242. /*
  243. * TAILQ_FOREACH_SAFE must be used here to avoid any
  244. * memory access violation after peer is freed
  245. */
  246. TAILQ_FOREACH_SAFE(peer, &soc->peer_hash.bins[i],
  247. hash_list_elem, peer_next) {
  248. /*
  249. * Don't remove the peer from the hash table -
  250. * that would modify the list we are currently
  251. * traversing, and it's not necessary anyway.
  252. */
  253. /*
  254. * Artificially adjust the peer's ref count to
  255. * 1, so it will get deleted by
  256. * dp_peer_unref_delete.
  257. */
  258. /* set to zero */
  259. qdf_atomic_init(&peer->ref_cnt);
  260. /* incr to one */
  261. qdf_atomic_inc(&peer->ref_cnt);
  262. dp_peer_unref_delete(peer);
  263. }
  264. }
  265. }
  266. }
  267. static void dp_peer_find_map_detach(struct dp_soc *soc)
  268. {
  269. #ifdef notyet /* ATH_BAND_STEERING */
  270. OS_FREE_TIMER(&(soc->bs_inact_timer));
  271. #endif
  272. qdf_mem_free(soc->peer_id_to_obj_map);
  273. }
  274. int dp_peer_find_attach(struct dp_soc *soc)
  275. {
  276. if (dp_peer_find_map_attach(soc))
  277. return 1;
  278. if (dp_peer_find_hash_attach(soc)) {
  279. dp_peer_find_map_detach(soc);
  280. return 1;
  281. }
  282. return 0; /* success */
  283. }
  284. static inline void dp_peer_find_add_id(struct dp_soc *soc,
  285. uint8_t *peer_mac_addr, uint16_t peer_id, uint8_t vdev_id)
  286. {
  287. struct dp_peer *peer;
  288. QDF_ASSERT(peer_id <= wlan_cfg_max_peer_id(soc->wlan_cfg_ctx) + 1);
  289. /* check if there's already a peer object with this MAC address */
  290. #if ATH_SUPPORT_WRAP
  291. peer = dp_peer_find_hash_find(soc, peer_mac_addr,
  292. 0 /* is aligned */, vdev_id);
  293. #else
  294. peer = dp_peer_find_hash_find(soc, peer_mac_addr, 0 /* is aligned */);
  295. #endif
  296. QDF_TRACE(QDF_MODULE_ID_TXRX, QDF_TRACE_LEVEL_ERROR,
  297. "%s: peer %p ID %d vid %d mac %02x:%02x:%02x:%02x:%02x:%02x\n",
  298. __func__, peer, peer_id, vdev_id, peer_mac_addr[0],
  299. peer_mac_addr[1], peer_mac_addr[2], peer_mac_addr[3],
  300. peer_mac_addr[4], peer_mac_addr[5]);
  301. if (peer) {
  302. /* peer's ref count was already incremented by
  303. * peer_find_hash_find
  304. */
  305. soc->peer_id_to_obj_map[peer_id] = peer;
  306. if (dp_peer_find_add_id_to_obj(peer, peer_id)) {
  307. /* TBDXXX: assert for now */
  308. QDF_ASSERT(0);
  309. }
  310. return;
  311. }
  312. }
  313. void
  314. dp_rx_peer_map_handler(void *soc_handle, uint16_t peer_id, uint8_t vdev_id,
  315. uint8_t *peer_mac_addr)
  316. {
  317. struct dp_soc *soc = (struct dp_soc *)soc_handle;
  318. QDF_TRACE(QDF_MODULE_ID_TXRX, QDF_TRACE_LEVEL_INFO_HIGH,
  319. "peer_map_event (soc:%p): peer_id %d, peer_mac "
  320. "%02x:%02x:%02x:%02x:%02x:%02x, vdev_id %d\n", soc, peer_id,
  321. peer_mac_addr[0], peer_mac_addr[1], peer_mac_addr[2],
  322. peer_mac_addr[3], peer_mac_addr[4], peer_mac_addr[5], vdev_id);
  323. dp_peer_find_add_id(soc, peer_mac_addr, peer_id, vdev_id);
  324. }
  325. void
  326. dp_rx_peer_unmap_handler(void *soc_handle, uint16_t peer_id)
  327. {
  328. struct dp_peer *peer;
  329. struct dp_soc *soc = (struct dp_soc *)soc_handle;
  330. uint8_t i;
  331. peer = dp_peer_find_by_id(soc, peer_id);
  332. QDF_TRACE(QDF_MODULE_ID_TXRX, QDF_TRACE_LEVEL_INFO_HIGH,
  333. "peer_unmap_event (soc:%p) peer_id %d peer %p\n",
  334. soc, peer_id, peer);
  335. /*
  336. * Currently peer IDs are assigned for vdevs as well as peers.
  337. * If the peer ID is for a vdev, then the peer pointer stored
  338. * in peer_id_to_obj_map will be NULL.
  339. */
  340. if (!peer)
  341. return;
  342. soc->peer_id_to_obj_map[peer_id] = NULL;
  343. for (i = 0; i < MAX_NUM_PEER_ID_PER_PEER; i++) {
  344. if (peer->peer_ids[i] == peer_id) {
  345. peer->peer_ids[i] = HTT_INVALID_PEER;
  346. break;
  347. }
  348. }
  349. /*
  350. * Remove a reference to the peer.
  351. * If there are no more references, delete the peer object.
  352. */
  353. dp_peer_unref_delete(peer);
  354. }
  355. void
  356. dp_peer_find_detach(struct dp_soc *soc)
  357. {
  358. dp_peer_find_map_detach(soc);
  359. dp_peer_find_hash_detach(soc);
  360. }
  361. static void dp_rx_tid_stats_cb(struct dp_soc *soc, void *cb_ctxt,
  362. union hal_reo_status *reo_status)
  363. {
  364. struct dp_rx_tid *rx_tid = (struct dp_rx_tid *)cb_ctxt;
  365. struct hal_reo_queue_status *queue_status = &(reo_status->queue_status);
  366. QDF_TRACE(QDF_MODULE_ID_TXRX, QDF_TRACE_LEVEL_ERROR,
  367. "%s: rx_tid: %d status: %d\n", __func__,
  368. rx_tid->tid, queue_status->header.status);
  369. QDF_TRACE(QDF_MODULE_ID_TXRX, QDF_TRACE_LEVEL_ERROR,
  370. "REO queue stats: \n"
  371. "ssn: %d\n"
  372. "curr_idx : %d\n"
  373. "pn_31_0 : %08x\n"
  374. "pn_63_32 : %08x\n"
  375. "pn_95_64 : %08x\n"
  376. "pn_127_96 : %08x\n"
  377. "last_rx_enq_tstamp : %08x\n"
  378. "last_rx_deq_tstamp : %08x\n"
  379. "rx_bitmap_31_0 : %08x\n"
  380. "rx_bitmap_63_32 : %08x\n"
  381. "rx_bitmap_95_64 : %08x\n"
  382. "rx_bitmap_127_96 : %08x\n"
  383. "rx_bitmap_159_128 : %08x\n"
  384. "rx_bitmap_191_160 : %08x\n"
  385. "rx_bitmap_223_192 : %08x\n"
  386. "rx_bitmap_255_224 : %08x\n"
  387. "curr_mpdu_cnt : %d\n"
  388. "curr_msdu_cnt : %d\n"
  389. "fwd_timeout_cnt : %d\n"
  390. "fwd_bar_cnt : %d\n"
  391. "dup_cnt : %d\n"
  392. "frms_in_order_cnt : %d\n"
  393. "bar_rcvd_cnt : %d\n"
  394. "mpdu_frms_cnt : %d\n"
  395. "msdu_frms_cnt : %d\n"
  396. "total_cnt : %d\n"
  397. "late_recv_mpdu_cnt : %d\n"
  398. "win_jump_2k : %d\n"
  399. "hole_cnt : %d\n",
  400. queue_status->ssn, queue_status->curr_idx,
  401. queue_status->pn_31_0, queue_status->pn_63_32,
  402. queue_status->pn_95_64, queue_status->pn_127_96,
  403. queue_status->last_rx_enq_tstamp,
  404. queue_status->last_rx_deq_tstamp,
  405. queue_status->rx_bitmap_31_0, queue_status->rx_bitmap_63_32,
  406. queue_status->rx_bitmap_95_64, queue_status->rx_bitmap_127_96,
  407. queue_status->rx_bitmap_159_128,
  408. queue_status->rx_bitmap_191_160,
  409. queue_status->rx_bitmap_223_192,
  410. queue_status->rx_bitmap_255_224,
  411. queue_status->curr_mpdu_cnt, queue_status->curr_msdu_cnt,
  412. queue_status->fwd_timeout_cnt, queue_status->fwd_bar_cnt,
  413. queue_status->dup_cnt, queue_status->frms_in_order_cnt,
  414. queue_status->bar_rcvd_cnt, queue_status->mpdu_frms_cnt,
  415. queue_status->msdu_frms_cnt, queue_status->total_cnt,
  416. queue_status->late_recv_mpdu_cnt, queue_status->win_jump_2k,
  417. queue_status->hole_cnt);
  418. }
  419. static void dp_rx_tid_update_cb(struct dp_soc *soc, void *cb_ctxt,
  420. union hal_reo_status *reo_status)
  421. {
  422. struct dp_rx_tid *rx_tid = (struct dp_rx_tid *)cb_ctxt;
  423. struct hal_reo_cmd_params params;
  424. if (reo_status->queue_status.header.status) {
  425. /* Should not happen normally. Just print error for now */
  426. QDF_TRACE(QDF_MODULE_ID_TXRX, QDF_TRACE_LEVEL_ERROR,
  427. "%s: Rx tid HW desc update failed(%d): tid %d\n",
  428. __func__,
  429. reo_status->rx_queue_status.header.status,
  430. rx_tid->tid);
  431. }
  432. qdf_mem_zero(&params, sizeof(params));
  433. params.std.need_status = 1;
  434. params.std.addr_lo = rx_tid->hw_qdesc_paddr & 0xffffffff;
  435. params.std.addr_hi = (uint64_t)(rx_tid->hw_qdesc_paddr) >> 32;
  436. dp_reo_send_cmd(soc, CMD_GET_QUEUE_STATS, &params, dp_rx_tid_stats_cb, rx_tid);
  437. }
  438. /*
  439. * dp_find_peer_by_addr - find peer instance by mac address
  440. * @dev: physical device instance
  441. * @peer_mac_addr: peer mac address
  442. * @local_id: local id for the peer
  443. *
  444. * Return: peer instance pointer
  445. */
  446. void *dp_find_peer_by_addr(void *dev, uint8_t *peer_mac_addr,
  447. uint8_t *local_id)
  448. {
  449. struct dp_pdev *pdev = dev;
  450. struct dp_peer *peer;
  451. #if ATH_SUPPORT_WRAP
  452. peer = dp_peer_find_hash_find(pdev->soc, peer_mac_addr, 0, 0);
  453. /* WAR, VDEV ID? TEMP 0 */
  454. #else
  455. peer = dp_peer_find_hash_find(pdev->soc, peer_mac_addr, 0);
  456. #endif
  457. if (!peer)
  458. return NULL;
  459. /* Multiple peer ids? How can know peer id? */
  460. *local_id = peer->local_id;
  461. DP_TRACE(INFO, "%s: peer %p id %d", __func__, peer, *local_id);
  462. return peer;
  463. }
  464. /*
  465. * dp_rx_tid_update_wifi3() – Update receive TID state
  466. * @peer: Datapath peer handle
  467. * @tid: TID
  468. * @ba_window_size: BlockAck window size
  469. * @start_seq: Starting sequence number
  470. *
  471. * Return: 0 on success, error code on failure
  472. */
  473. static int dp_rx_tid_update_wifi3(struct dp_peer *peer, int tid, uint32_t
  474. ba_window_size, uint32_t start_seq)
  475. {
  476. struct dp_rx_tid *rx_tid = &peer->rx_tid[tid];
  477. struct dp_soc *soc = peer->vdev->pdev->soc;
  478. struct hal_reo_cmd_params params;
  479. qdf_mem_zero(&params, sizeof(params));
  480. params.std.need_status = 1;
  481. params.std.addr_lo = rx_tid->hw_qdesc_paddr & 0xffffffff;
  482. params.std.addr_hi = (uint64_t)(rx_tid->hw_qdesc_paddr) >> 32;
  483. params.u.upd_queue_params.update_ba_window_size = 1;
  484. params.u.upd_queue_params.ba_window_size = ba_window_size;
  485. if (start_seq < IEEE80211_SEQ_MAX) {
  486. params.u.upd_queue_params.update_ssn = 1;
  487. params.u.upd_queue_params.ssn = start_seq;
  488. }
  489. dp_reo_send_cmd(soc, CMD_UPDATE_RX_REO_QUEUE, &params, dp_rx_tid_update_cb, rx_tid);
  490. return 0;
  491. }
  492. /*
  493. * dp_rx_tid_setup_wifi3() – Setup receive TID state
  494. * @peer: Datapath peer handle
  495. * @tid: TID
  496. * @ba_window_size: BlockAck window size
  497. * @start_seq: Starting sequence number
  498. *
  499. * Return: 0 on success, error code on failure
  500. */
  501. int dp_rx_tid_setup_wifi3(struct dp_peer *peer, int tid,
  502. uint32_t ba_window_size, uint32_t start_seq)
  503. {
  504. struct dp_rx_tid *rx_tid = &peer->rx_tid[tid];
  505. struct dp_vdev *vdev = peer->vdev;
  506. struct dp_soc *soc = vdev->pdev->soc;
  507. uint32_t hw_qdesc_size;
  508. uint32_t hw_qdesc_align;
  509. int hal_pn_type;
  510. void *hw_qdesc_vaddr;
  511. if (rx_tid->hw_qdesc_vaddr_unaligned != NULL)
  512. return dp_rx_tid_update_wifi3(peer, tid, ba_window_size,
  513. start_seq);
  514. #ifdef notyet
  515. hw_qdesc_size = hal_get_reo_qdesc_size(soc->hal_soc, ba_window_size);
  516. #else
  517. /* TODO: Allocating HW queue descriptors based on max BA window size
  518. * for all QOS TIDs so that same descriptor can be used later when
  519. * ADDBA request is recevied. This should be changed to allocate HW
  520. * queue descriptors based on BA window size being negotiated (0 for
  521. * non BA cases), and reallocate when BA window size changes and also
  522. * send WMI message to FW to change the REO queue descriptor in Rx
  523. * peer entry as part of dp_rx_tid_update.
  524. */
  525. if (tid != DP_NON_QOS_TID)
  526. hw_qdesc_size = hal_get_reo_qdesc_size(soc->hal_soc,
  527. HAL_RX_MAX_BA_WINDOW);
  528. else
  529. hw_qdesc_size = hal_get_reo_qdesc_size(soc->hal_soc,
  530. ba_window_size);
  531. #endif
  532. hw_qdesc_align = hal_get_reo_qdesc_align(soc->hal_soc);
  533. /* To avoid unnecessary extra allocation for alignment, try allocating
  534. * exact size and see if we already have aligned address.
  535. */
  536. rx_tid->hw_qdesc_alloc_size = hw_qdesc_size;
  537. rx_tid->hw_qdesc_vaddr_unaligned = qdf_mem_alloc_consistent(
  538. soc->osdev, soc->osdev->dev, rx_tid->hw_qdesc_alloc_size,
  539. &(rx_tid->hw_qdesc_paddr_unaligned));
  540. if (!rx_tid->hw_qdesc_vaddr_unaligned) {
  541. QDF_TRACE(QDF_MODULE_ID_TXRX, QDF_TRACE_LEVEL_ERROR,
  542. "%s: Rx tid HW desc alloc failed: tid %d\n",
  543. __func__, tid);
  544. return QDF_STATUS_E_NOMEM;
  545. }
  546. if ((unsigned long)(rx_tid->hw_qdesc_vaddr_unaligned) %
  547. hw_qdesc_align) {
  548. /* Address allocated above is not alinged. Allocate extra
  549. * memory for alignment
  550. */
  551. qdf_mem_free_consistent(soc->osdev, soc->osdev->dev,
  552. rx_tid->hw_qdesc_alloc_size,
  553. rx_tid->hw_qdesc_vaddr_unaligned,
  554. rx_tid->hw_qdesc_paddr_unaligned, 0);
  555. rx_tid->hw_qdesc_alloc_size =
  556. hw_qdesc_size + hw_qdesc_align - 1;
  557. rx_tid->hw_qdesc_vaddr_unaligned = qdf_mem_alloc_consistent(
  558. soc->osdev, soc->osdev->dev, rx_tid->hw_qdesc_alloc_size,
  559. &(rx_tid->hw_qdesc_paddr_unaligned));
  560. if (!rx_tid->hw_qdesc_vaddr_unaligned) {
  561. QDF_TRACE(QDF_MODULE_ID_TXRX, QDF_TRACE_LEVEL_ERROR,
  562. "%s: Rx tid HW desc alloc failed: tid %d\n",
  563. __func__, tid);
  564. return QDF_STATUS_E_NOMEM;
  565. }
  566. hw_qdesc_vaddr = rx_tid->hw_qdesc_vaddr_unaligned +
  567. ((unsigned long)(rx_tid->hw_qdesc_vaddr_unaligned) %
  568. hw_qdesc_align);
  569. rx_tid->hw_qdesc_paddr = rx_tid->hw_qdesc_paddr_unaligned +
  570. ((unsigned long)hw_qdesc_vaddr -
  571. (unsigned long)(rx_tid->hw_qdesc_vaddr_unaligned));
  572. } else {
  573. hw_qdesc_vaddr = rx_tid->hw_qdesc_vaddr_unaligned;
  574. rx_tid->hw_qdesc_paddr = rx_tid->hw_qdesc_paddr_unaligned;
  575. }
  576. /* TODO: Ensure that sec_type is set before ADDBA is received.
  577. * Currently this is set based on htt indication
  578. * HTT_T2H_MSG_TYPE_SEC_IND from target
  579. */
  580. switch (peer->security[dp_sec_ucast].sec_type) {
  581. case htt_sec_type_tkip_nomic:
  582. case htt_sec_type_aes_ccmp:
  583. case htt_sec_type_aes_ccmp_256:
  584. case htt_sec_type_aes_gcmp:
  585. case htt_sec_type_aes_gcmp_256:
  586. hal_pn_type = HAL_PN_WPA;
  587. break;
  588. case htt_sec_type_wapi:
  589. if (vdev->opmode == wlan_op_mode_ap)
  590. hal_pn_type = HAL_PN_WAPI_EVEN;
  591. else
  592. hal_pn_type = HAL_PN_WAPI_UNEVEN;
  593. break;
  594. default:
  595. hal_pn_type = HAL_PN_NONE;
  596. break;
  597. }
  598. hal_reo_qdesc_setup(soc->hal_soc, tid, ba_window_size, start_seq,
  599. hw_qdesc_vaddr, rx_tid->hw_qdesc_paddr, hal_pn_type);
  600. if (soc->cdp_soc.ol_ops->peer_rx_reorder_queue_setup) {
  601. soc->cdp_soc.ol_ops->peer_rx_reorder_queue_setup(soc->osif_soc,
  602. peer->vdev->vdev_id, peer->mac_addr.raw,
  603. rx_tid->hw_qdesc_paddr, tid, tid);
  604. }
  605. return 0;
  606. }
  607. /*
  608. * Rx TID deletion callback to free memory allocated for HW queue descriptor
  609. */
  610. static void dp_rx_tid_delete_cb(struct dp_soc *soc, void *cb_ctxt,
  611. union hal_reo_status *reo_status)
  612. {
  613. struct dp_rx_tid *rx_tid = (struct dp_rx_tid *)cb_ctxt;
  614. if (reo_status->rx_queue_status.header.status) {
  615. /* Should not happen normally. Just print error for now */
  616. QDF_TRACE(QDF_MODULE_ID_TXRX, QDF_TRACE_LEVEL_ERROR,
  617. "%s: Rx tid HW desc deletion failed(%d): tid %d\n",
  618. __func__,
  619. reo_status->rx_queue_status.header.status,
  620. rx_tid->tid);
  621. }
  622. QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_INFO,
  623. "%s: rx_tid: %d status: %d\n", __func__,
  624. rx_tid->tid, reo_status->rx_queue_status.header.status);
  625. qdf_mem_free_consistent(soc->osdev, soc->osdev->dev,
  626. rx_tid->hw_qdesc_alloc_size,
  627. rx_tid->hw_qdesc_vaddr_unaligned,
  628. rx_tid->hw_qdesc_paddr_unaligned, 0);
  629. rx_tid->hw_qdesc_vaddr_unaligned = NULL;
  630. rx_tid->hw_qdesc_alloc_size = 0;
  631. }
  632. /*
  633. * dp_rx_tid_delete_wifi3() – Delete receive TID queue
  634. * @peer: Datapath peer handle
  635. * @tid: TID
  636. *
  637. * Return: 0 on success, error code on failure
  638. */
  639. static int dp_rx_tid_delete_wifi3(struct dp_peer *peer, int tid)
  640. {
  641. struct dp_rx_tid *rx_tid = &(peer->rx_tid[tid]);
  642. struct dp_soc *soc = peer->vdev->pdev->soc;
  643. struct hal_reo_cmd_params params;
  644. qdf_mem_zero(&params, sizeof(params));
  645. params.std.need_status = 1;
  646. params.std.addr_lo = rx_tid->hw_qdesc_paddr & 0xffffffff;
  647. params.std.addr_hi = (uint64_t)(rx_tid->hw_qdesc_paddr) >> 32;
  648. params.u.upd_queue_params.update_vld = 1;
  649. params.u.upd_queue_params.vld = 0;
  650. dp_reo_send_cmd(soc, CMD_UPDATE_RX_REO_QUEUE, &params,
  651. dp_rx_tid_delete_cb, (void *)rx_tid);
  652. return 0;
  653. }
  654. /*
  655. * dp_peer_rx_init() – Initialize receive TID state
  656. * @pdev: Datapath pdev
  657. * @peer: Datapath peer
  658. *
  659. */
  660. void dp_peer_rx_init(struct dp_pdev *pdev, struct dp_peer *peer)
  661. {
  662. int tid;
  663. struct dp_rx_tid *rx_tid;
  664. for (tid = 0; tid < DP_MAX_TIDS; tid++) {
  665. rx_tid = &peer->rx_tid[tid];
  666. rx_tid->array = &rx_tid->base;
  667. rx_tid->base.head = rx_tid->base.tail = NULL;
  668. rx_tid->tid = tid;
  669. rx_tid->defrag_timeout_ms = 0;
  670. rx_tid->ba_win_size = 0;
  671. rx_tid->ba_status = DP_RX_BA_INACTIVE;
  672. rx_tid->defrag_waitlist_elem.tqe_next = NULL;
  673. rx_tid->defrag_waitlist_elem.tqe_prev = NULL;
  674. #ifdef notyet /* TODO: See if this is required for exception handling */
  675. /* invalid sequence number */
  676. peer->tids_last_seq[tid] = 0xffff;
  677. #endif
  678. }
  679. /* Setup default (non-qos) rx tid queue */
  680. dp_rx_tid_setup_wifi3(peer, DP_NON_QOS_TID, 1, 0);
  681. /* Setup rx tid queue for TID 0.
  682. * Other queues will be setup on receiving first packet, which will cause
  683. * NULL REO queue error
  684. */
  685. dp_rx_tid_setup_wifi3(peer, 0, 1, 0);
  686. /*
  687. * Set security defaults: no PN check, no security. The target may
  688. * send a HTT SEC_IND message to overwrite these defaults.
  689. */
  690. peer->security[dp_sec_ucast].sec_type =
  691. peer->security[dp_sec_mcast].sec_type = htt_sec_type_none;
  692. }
  693. /*
  694. * dp_peer_rx_cleanup() – Cleanup receive TID state
  695. * @vdev: Datapath vdev
  696. * @peer: Datapath peer
  697. *
  698. */
  699. void dp_peer_rx_cleanup(struct dp_vdev *vdev, struct dp_peer *peer)
  700. {
  701. int tid;
  702. uint32_t tid_delete_mask = 0;
  703. for (tid = 0; tid < DP_MAX_TIDS; tid++) {
  704. if (peer->rx_tid[tid].hw_qdesc_vaddr_unaligned != NULL) {
  705. dp_rx_tid_delete_wifi3(peer, tid);
  706. tid_delete_mask |= (1 << tid);
  707. }
  708. }
  709. #ifdef notyet /* See if FW can remove queues as part of peer cleanup */
  710. if (soc->ol_ops->peer_rx_reorder_queue_remove) {
  711. soc->ol_ops->peer_rx_reorder_queue_remove(soc->osif_soc,
  712. peer->vdev->vdev_id, peer->mac_addr.raw,
  713. tid_delete_mask);
  714. }
  715. #endif
  716. }
  717. /*
  718. * dp_rx_addba_requestprocess_wifi3() – Process ADDBA request from peer
  719. *
  720. * @peer: Datapath peer handle
  721. * @dialogtoken: dialogtoken from ADDBA frame
  722. * @tid: TID number
  723. * @startseqnum: Start seq. number received in BA sequence control
  724. * in ADDBA frame
  725. *
  726. * Return: 0 on success, error code on failure
  727. */
  728. int dp_addba_requestprocess_wifi3(void *peer_handle,
  729. uint8_t dialogtoken, uint16_t tid, uint16_t batimeout,
  730. uint16_t buffersize, uint16_t startseqnum)
  731. {
  732. struct dp_peer *peer = (struct dp_peer *)peer_handle;
  733. struct dp_rx_tid *rx_tid = &peer->rx_tid[tid];
  734. if ((rx_tid->ba_status == DP_RX_BA_ACTIVE) &&
  735. (rx_tid->hw_qdesc_vaddr_unaligned != NULL))
  736. rx_tid->ba_status = DP_RX_BA_INACTIVE;
  737. if (dp_rx_tid_setup_wifi3(peer, tid, buffersize,
  738. startseqnum)) {
  739. /* TODO: Should we send addba reject in this case */
  740. return QDF_STATUS_E_FAILURE;
  741. }
  742. rx_tid->ba_win_size = buffersize;
  743. rx_tid->dialogtoken = dialogtoken;
  744. rx_tid->statuscode = QDF_STATUS_SUCCESS;
  745. rx_tid->ba_status = DP_RX_BA_ACTIVE;
  746. return 0;
  747. }
  748. /*
  749. * dp_rx_addba_responsesetup_wifi3() – Process ADDBA request from peer
  750. *
  751. * @peer: Datapath peer handle
  752. * @tid: TID number
  753. * @dialogtoken: output dialogtoken
  754. * @statuscode: output dialogtoken
  755. * @buffersize: Ouput BA window sizze
  756. * @batimeout: Ouput BA timeout
  757. */
  758. void dp_addba_responsesetup_wifi3(void *peer_handle, uint8_t tid,
  759. uint8_t *dialogtoken, uint16_t *statuscode,
  760. uint16_t *buffersize, uint16_t *batimeout)
  761. {
  762. struct dp_peer *peer = (struct dp_peer *)peer_handle;
  763. struct dp_rx_tid *rx_tid = &peer->rx_tid[tid];
  764. /* setup ADDBA response paramters */
  765. *dialogtoken = rx_tid->dialogtoken;
  766. *statuscode = rx_tid->statuscode;
  767. *buffersize = rx_tid->ba_win_size;
  768. *batimeout = 0;
  769. }
  770. /*
  771. * dp_rx_delba_process_wifi3() – Process DELBA from peer
  772. * @peer: Datapath peer handle
  773. * @tid: TID number
  774. * @reasoncode: Reason code received in DELBA frame
  775. *
  776. * Return: 0 on success, error code on failure
  777. */
  778. int dp_delba_process_wifi3(void *peer_handle,
  779. int tid, uint16_t reasoncode)
  780. {
  781. struct dp_peer *peer = (struct dp_peer *)peer_handle;
  782. struct dp_rx_tid *rx_tid = &peer->rx_tid[tid];
  783. if (rx_tid->ba_status != DP_RX_BA_ACTIVE)
  784. return QDF_STATUS_E_FAILURE;
  785. /* TODO: See if we can delete the existing REO queue descriptor and
  786. * replace with a new one without queue extenstion descript to save
  787. * memory
  788. */
  789. dp_rx_tid_update_wifi3(peer, tid, 0, 0);
  790. rx_tid->ba_status = DP_RX_BA_INACTIVE;
  791. return 0;
  792. }
  793. void dp_rx_discard(struct dp_vdev *vdev, struct dp_peer *peer, unsigned tid,
  794. qdf_nbuf_t msdu_list)
  795. {
  796. while (msdu_list) {
  797. qdf_nbuf_t msdu = msdu_list;
  798. msdu_list = qdf_nbuf_next(msdu_list);
  799. QDF_TRACE(QDF_MODULE_ID_TXRX, QDF_TRACE_LEVEL_INFO_HIGH,
  800. "discard rx %p from partly-deleted peer %p "
  801. "(%02x:%02x:%02x:%02x:%02x:%02x)\n",
  802. msdu, peer,
  803. peer->mac_addr.raw[0], peer->mac_addr.raw[1],
  804. peer->mac_addr.raw[2], peer->mac_addr.raw[3],
  805. peer->mac_addr.raw[4], peer->mac_addr.raw[5]);
  806. qdf_nbuf_free(msdu);
  807. }
  808. }
  809. void
  810. dp_rx_sec_ind_handler(void *soc_handle, uint16_t peer_id,
  811. enum htt_sec_type sec_type, int is_unicast, u_int32_t *michael_key,
  812. u_int32_t *rx_pn)
  813. {
  814. struct dp_soc *soc = (struct dp_soc *)soc_handle;
  815. struct dp_peer *peer;
  816. int sec_index;
  817. peer = dp_peer_find_by_id(soc, peer_id);
  818. if (!peer) {
  819. QDF_TRACE(QDF_MODULE_ID_TXRX, QDF_TRACE_LEVEL_ERROR,
  820. "Couldn't find peer from ID %d - skipping security inits\n",
  821. peer_id);
  822. return;
  823. }
  824. QDF_TRACE(QDF_MODULE_ID_TXRX, QDF_TRACE_LEVEL_INFO_HIGH,
  825. "sec spec for peer %p (%02x:%02x:%02x:%02x:%02x:%02x): "
  826. "%s key of type %d\n",
  827. peer,
  828. peer->mac_addr.raw[0], peer->mac_addr.raw[1],
  829. peer->mac_addr.raw[2], peer->mac_addr.raw[3],
  830. peer->mac_addr.raw[4], peer->mac_addr.raw[5],
  831. is_unicast ? "ucast" : "mcast",
  832. sec_type);
  833. sec_index = is_unicast ? dp_sec_ucast : dp_sec_mcast;
  834. peer->security[sec_index].sec_type = sec_type;
  835. #ifdef notyet /* TODO: See if this is required for defrag support */
  836. /* michael key only valid for TKIP, but for simplicity,
  837. * copy it anyway
  838. */
  839. qdf_mem_copy(
  840. &peer->security[sec_index].michael_key[0],
  841. michael_key,
  842. sizeof(peer->security[sec_index].michael_key));
  843. #ifdef BIG_ENDIAN_HOST
  844. OL_IF_SWAPBO(peer->security[sec_index].michael_key[0],
  845. sizeof(peer->security[sec_index].michael_key));
  846. #endif /* BIG_ENDIAN_HOST */
  847. #endif
  848. #ifdef notyet /* TODO: Check if this is required for wifi3.0 */
  849. if (sec_type != htt_sec_type_wapi) {
  850. qdf_mem_set(peer->tids_last_pn_valid, _EXT_TIDS, 0x00);
  851. } else {
  852. for (i = 0; i < DP_MAX_TIDS; i++) {
  853. /*
  854. * Setting PN valid bit for WAPI sec_type,
  855. * since WAPI PN has to be started with predefined value
  856. */
  857. peer->tids_last_pn_valid[i] = 1;
  858. qdf_mem_copy(
  859. (u_int8_t *) &peer->tids_last_pn[i],
  860. (u_int8_t *) rx_pn, sizeof(union htt_rx_pn_t));
  861. peer->tids_last_pn[i].pn128[1] =
  862. qdf_cpu_to_le64(peer->tids_last_pn[i].pn128[1]);
  863. peer->tids_last_pn[i].pn128[0] =
  864. qdf_cpu_to_le64(peer->tids_last_pn[i].pn128[0]);
  865. }
  866. }
  867. #endif
  868. /* TODO: Update HW TID queue with PN check parameters (pn type for
  869. * all security types and last pn for WAPI) once REO command API
  870. * is available
  871. */
  872. }
  873. #ifndef CONFIG_WIN
  874. /**
  875. * dp_register_peer() - Register peer into physical device
  876. * @pdev - data path device instance
  877. * @sta_desc - peer description
  878. *
  879. * Register peer into physical device
  880. *
  881. * Return: QDF_STATUS_SUCCESS registration success
  882. * QDF_STATUS_E_FAULT peer not found
  883. */
  884. QDF_STATUS dp_register_peer(void *pdev_handle,
  885. struct ol_txrx_desc_type *sta_desc)
  886. {
  887. struct dp_peer *peer;
  888. struct dp_pdev *pdev = pdev_handle;
  889. peer = dp_peer_find_by_local_id(pdev, sta_desc->sta_id);
  890. if (!peer)
  891. return QDF_STATUS_E_FAULT;
  892. qdf_spin_lock_bh(&peer->peer_info_lock);
  893. peer->state = OL_TXRX_PEER_STATE_CONN;
  894. qdf_spin_unlock_bh(&peer->peer_info_lock);
  895. return QDF_STATUS_SUCCESS;
  896. }
  897. /**
  898. * dp_clear_peer() - remove peer from physical device
  899. * @pdev - data path device instance
  900. * @sta_id - local peer id
  901. *
  902. * remove peer from physical device
  903. *
  904. * Return: QDF_STATUS_SUCCESS registration success
  905. * QDF_STATUS_E_FAULT peer not found
  906. */
  907. QDF_STATUS dp_clear_peer(void *pdev_handle, uint8_t local_id)
  908. {
  909. struct dp_peer *peer;
  910. struct dp_pdev *pdev = pdev_handle;
  911. peer = dp_peer_find_by_local_id(pdev, local_id);
  912. if (!peer)
  913. return QDF_STATUS_E_FAULT;
  914. qdf_spin_lock_bh(&peer->peer_info_lock);
  915. peer->state = OL_TXRX_PEER_STATE_DISC;
  916. qdf_spin_unlock_bh(&peer->peer_info_lock);
  917. return QDF_STATUS_SUCCESS;
  918. }
  919. /**
  920. * dp_find_peer_by_addr_and_vdev() - Find peer by peer mac address within vdev
  921. * @pdev - data path device instance
  922. * @vdev - virtual interface instance
  923. * @peer_addr - peer mac address
  924. * @peer_id - local peer id with target mac address
  925. *
  926. * Find peer by peer mac address within vdev
  927. *
  928. * Return: peer instance void pointer
  929. * NULL cannot find target peer
  930. */
  931. void *dp_find_peer_by_addr_and_vdev(void *pdev_handle, void *vdev,
  932. uint8_t *peer_addr, uint8_t *local_id)
  933. {
  934. struct dp_pdev *pdev = pdev_handle;
  935. struct dp_peer *peer;
  936. DP_TRACE(INFO, "vdev %p peer_addr %p", vdev, peer_addr);
  937. peer = dp_peer_find_hash_find(pdev->soc, peer_addr, 0);
  938. DP_TRACE(INFO, "peer %p vdev %p", peer, vdev);
  939. if (!peer)
  940. return NULL;
  941. if (peer->vdev != vdev)
  942. return NULL;
  943. *local_id = peer->local_id;
  944. DP_TRACE(INFO, "peer %p vdev %p lcoal id %d",
  945. peer, vdev, *local_id);
  946. return peer;
  947. }
  948. /**
  949. * dp_local_peer_id() - Find local peer id within peer instance
  950. * @peer - peer instance
  951. *
  952. * Find local peer id within peer instance
  953. *
  954. * Return: local peer id
  955. */
  956. uint16_t dp_local_peer_id(void *peer)
  957. {
  958. return ((struct dp_peer *)peer)->local_id;
  959. }
  960. /**
  961. * dp_peer_find_by_local_id() - Find peer by local peer id
  962. * @pdev - data path device instance
  963. * @local_peer_id - local peer id want to find
  964. *
  965. * Find peer by local peer id within physical device
  966. *
  967. * Return: peer instance void pointer
  968. * NULL cannot find target peer
  969. */
  970. void *dp_peer_find_by_local_id(void *pdev_handle, uint8_t local_id)
  971. {
  972. struct dp_peer *peer;
  973. struct dp_pdev *pdev = pdev_handle;
  974. qdf_spin_lock_bh(&pdev->local_peer_ids.lock);
  975. peer = pdev->local_peer_ids.map[local_id];
  976. qdf_spin_unlock_bh(&pdev->local_peer_ids.lock);
  977. DP_TRACE(INFO, "peer %p lcoal id %d",
  978. peer, local_id);
  979. return peer;
  980. }
  981. /**
  982. * dp_peer_state_update() - update peer local state
  983. * @pdev - data path device instance
  984. * @peer_addr - peer mac address
  985. * @state - new peer local state
  986. *
  987. * update peer local state
  988. *
  989. * Return: QDF_STATUS_SUCCESS registration success
  990. */
  991. QDF_STATUS dp_peer_state_update(void *pdev_handle, uint8_t *peer_mac,
  992. enum ol_txrx_peer_state state)
  993. {
  994. struct dp_peer *peer;
  995. struct dp_pdev *pdev = pdev_handle;
  996. peer = dp_peer_find_hash_find(pdev->soc, peer_mac, 0);
  997. if (NULL == peer) {
  998. QDF_TRACE(QDF_MODULE_ID_TXRX, QDF_TRACE_LEVEL_ERROR,
  999. "Failed to find peer for: [%pM]", peer_mac);
  1000. return QDF_STATUS_E_FAILURE;
  1001. }
  1002. peer->state = state;
  1003. DP_TRACE(INFO, "peer %p state %d",
  1004. peer, peer->state);
  1005. return QDF_STATUS_SUCCESS;
  1006. }
  1007. /**
  1008. * dp_get_vdevid() - Get virtaul interface id which peer registered
  1009. * @peer - peer instance
  1010. * @vdev_id - virtaul interface id which peer registered
  1011. *
  1012. * Get virtaul interface id which peer registered
  1013. *
  1014. * Return: QDF_STATUS_SUCCESS registration success
  1015. */
  1016. QDF_STATUS dp_get_vdevid(void *peer_handle, uint8_t *vdev_id)
  1017. {
  1018. struct dp_peer *peer = peer_handle;
  1019. DP_TRACE(INFO, "peer %p vdev %p vdev id %d",
  1020. peer, peer->vdev, peer->vdev->vdev_id);
  1021. *vdev_id = peer->vdev->vdev_id;
  1022. return QDF_STATUS_SUCCESS;
  1023. }
  1024. /**
  1025. * dp_get_vdev_for_peer() - Get virtual interface instance which peer belongs
  1026. * @peer - peer instance
  1027. *
  1028. * Get virtual interface instance which peer belongs
  1029. *
  1030. * Return: virtual interface instance pointer
  1031. * NULL in case cannot find
  1032. */
  1033. void *dp_get_vdev_for_peer(void *peer_handle)
  1034. {
  1035. struct dp_peer *peer = peer_handle;
  1036. DP_TRACE(INFO, "peer %p vdev %p", peer, peer->vdev);
  1037. return (void *)peer->vdev;
  1038. }
  1039. /**
  1040. * dp_peer_get_peer_mac_addr() - Get peer mac address
  1041. * @peer - peer instance
  1042. *
  1043. * Get peer mac address
  1044. *
  1045. * Return: peer mac address pointer
  1046. * NULL in case cannot find
  1047. */
  1048. uint8_t *dp_peer_get_peer_mac_addr(void *peer_handle)
  1049. {
  1050. struct dp_peer *peer = peer_handle;
  1051. uint8_t *mac;
  1052. mac = peer->mac_addr.raw;
  1053. DP_TRACE(INFO, "peer %p mac 0x%x 0x%x 0x%x 0x%x 0x%x 0x%x",
  1054. peer, mac[0], mac[1], mac[2], mac[3], mac[4], mac[5]);
  1055. return peer->mac_addr.raw;
  1056. }
  1057. /**
  1058. * dp_get_peer_state() - Get local peer state
  1059. * @peer - peer instance
  1060. *
  1061. * Get local peer state
  1062. *
  1063. * Return: peer status
  1064. */
  1065. int dp_get_peer_state(void *peer_handle)
  1066. {
  1067. struct dp_peer *peer = peer_handle;
  1068. DP_TRACE(INFO, "peer %p stats %d", peer, peer->state);
  1069. return peer->state;
  1070. }
  1071. /**
  1072. * dp_local_peer_id_pool_init() - local peer id pool alloc for physical device
  1073. * @pdev - data path device instance
  1074. *
  1075. * local peer id pool alloc for physical device
  1076. *
  1077. * Return: none
  1078. */
  1079. void dp_local_peer_id_pool_init(struct dp_pdev *pdev)
  1080. {
  1081. int i;
  1082. /* point the freelist to the first ID */
  1083. pdev->local_peer_ids.freelist = 0;
  1084. /* link each ID to the next one */
  1085. for (i = 0; i < OL_TXRX_NUM_LOCAL_PEER_IDS; i++) {
  1086. pdev->local_peer_ids.pool[i] = i + 1;
  1087. pdev->local_peer_ids.map[i] = NULL;
  1088. }
  1089. /* link the last ID to itself, to mark the end of the list */
  1090. i = OL_TXRX_NUM_LOCAL_PEER_IDS;
  1091. pdev->local_peer_ids.pool[i] = i;
  1092. qdf_spinlock_create(&pdev->local_peer_ids.lock);
  1093. DP_TRACE(INFO, "Peer pool init");
  1094. }
  1095. /**
  1096. * dp_local_peer_id_alloc() - allocate local peer id
  1097. * @pdev - data path device instance
  1098. * @peer - new peer instance
  1099. *
  1100. * allocate local peer id
  1101. *
  1102. * Return: none
  1103. */
  1104. void dp_local_peer_id_alloc(struct dp_pdev *pdev, struct dp_peer *peer)
  1105. {
  1106. int i;
  1107. qdf_spin_lock_bh(&pdev->local_peer_ids.lock);
  1108. i = pdev->local_peer_ids.freelist;
  1109. if (pdev->local_peer_ids.pool[i] == i) {
  1110. /* the list is empty, except for the list-end marker */
  1111. peer->local_id = OL_TXRX_INVALID_LOCAL_PEER_ID;
  1112. } else {
  1113. /* take the head ID and advance the freelist */
  1114. peer->local_id = i;
  1115. pdev->local_peer_ids.freelist = pdev->local_peer_ids.pool[i];
  1116. pdev->local_peer_ids.map[i] = peer;
  1117. }
  1118. qdf_spin_unlock_bh(&pdev->local_peer_ids.lock);
  1119. DP_TRACE(INFO, "peer %p, local id %d", peer, peer->local_id);
  1120. }
  1121. /**
  1122. * dp_local_peer_id_free() - remove local peer id
  1123. * @pdev - data path device instance
  1124. * @peer - peer instance should be removed
  1125. *
  1126. * remove local peer id
  1127. *
  1128. * Return: none
  1129. */
  1130. void dp_local_peer_id_free(struct dp_pdev *pdev, struct dp_peer *peer)
  1131. {
  1132. int i = peer->local_id;
  1133. if ((i == OL_TXRX_INVALID_LOCAL_PEER_ID) ||
  1134. (i >= OL_TXRX_NUM_LOCAL_PEER_IDS)) {
  1135. return;
  1136. }
  1137. /* put this ID on the head of the freelist */
  1138. qdf_spin_lock_bh(&pdev->local_peer_ids.lock);
  1139. pdev->local_peer_ids.pool[i] = pdev->local_peer_ids.freelist;
  1140. pdev->local_peer_ids.freelist = i;
  1141. pdev->local_peer_ids.map[i] = NULL;
  1142. qdf_spin_unlock_bh(&pdev->local_peer_ids.lock);
  1143. }
  1144. #endif