nan_ucfg_api.c 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446
  1. /*
  2. * Copyright (c) 2017-2018 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. /**
  19. * DOC: contains interface definitions for OS_IF layer
  20. */
  21. #include "nan_ucfg_api.h"
  22. #include "nan_public_structs.h"
  23. #include "../../core/src/nan_main_i.h"
  24. #include "scheduler_api.h"
  25. #include "wlan_objmgr_psoc_obj.h"
  26. #include "wlan_objmgr_pdev_obj.h"
  27. #include "wlan_objmgr_vdev_obj.h"
  28. struct wlan_objmgr_psoc;
  29. struct wlan_objmgr_vdev;
  30. inline QDF_STATUS ucfg_nan_set_ndi_state(struct wlan_objmgr_vdev *vdev,
  31. uint32_t state)
  32. {
  33. struct nan_vdev_priv_obj *priv_obj = nan_get_vdev_priv_obj(vdev);
  34. if (!priv_obj) {
  35. nan_err("priv_obj is null");
  36. return QDF_STATUS_E_NULL_VALUE;
  37. }
  38. qdf_spin_lock_bh(&priv_obj->lock);
  39. priv_obj->state = state;
  40. qdf_spin_unlock_bh(&priv_obj->lock);
  41. return QDF_STATUS_SUCCESS;
  42. }
  43. inline enum nan_datapath_state ucfg_nan_get_ndi_state(
  44. struct wlan_objmgr_vdev *vdev)
  45. {
  46. enum nan_datapath_state val;
  47. struct nan_vdev_priv_obj *priv_obj = nan_get_vdev_priv_obj(vdev);
  48. if (!priv_obj) {
  49. nan_err("priv_obj is null");
  50. return NAN_DATA_INVALID_STATE;
  51. }
  52. qdf_spin_lock_bh(&priv_obj->lock);
  53. val = priv_obj->state;
  54. qdf_spin_unlock_bh(&priv_obj->lock);
  55. return val;
  56. }
  57. inline QDF_STATUS ucfg_nan_set_active_peers(struct wlan_objmgr_vdev *vdev,
  58. uint32_t val)
  59. {
  60. struct nan_vdev_priv_obj *priv_obj = nan_get_vdev_priv_obj(vdev);
  61. if (!priv_obj) {
  62. nan_err("priv_obj is null");
  63. return QDF_STATUS_E_NULL_VALUE;
  64. }
  65. qdf_spin_lock_bh(&priv_obj->lock);
  66. priv_obj->active_ndp_peers = val;
  67. qdf_spin_unlock_bh(&priv_obj->lock);
  68. return QDF_STATUS_SUCCESS;
  69. }
  70. inline uint32_t ucfg_nan_get_active_peers(struct wlan_objmgr_vdev *vdev)
  71. {
  72. uint32_t val;
  73. struct nan_vdev_priv_obj *priv_obj = nan_get_vdev_priv_obj(vdev);
  74. if (!priv_obj) {
  75. nan_err("priv_obj is null");
  76. return 0;
  77. }
  78. qdf_spin_lock_bh(&priv_obj->lock);
  79. val = priv_obj->active_ndp_peers;
  80. qdf_spin_unlock_bh(&priv_obj->lock);
  81. return val;
  82. }
  83. inline QDF_STATUS ucfg_nan_set_active_ndp_sessions(
  84. struct wlan_objmgr_vdev *vdev, uint32_t val, uint8_t idx)
  85. {
  86. struct nan_vdev_priv_obj *priv_obj = nan_get_vdev_priv_obj(vdev);
  87. if (!priv_obj) {
  88. nan_err("priv_obj is null");
  89. return QDF_STATUS_E_NULL_VALUE;
  90. }
  91. if (idx >= MAX_PEERS) {
  92. nan_err("peer_idx(%d), MAX(%d)",
  93. idx, MAX_PEERS);
  94. return QDF_STATUS_E_NULL_VALUE;
  95. }
  96. qdf_spin_lock_bh(&priv_obj->lock);
  97. priv_obj->active_ndp_sessions[idx] = val;
  98. qdf_spin_unlock_bh(&priv_obj->lock);
  99. return QDF_STATUS_SUCCESS;
  100. }
  101. inline uint32_t ucfg_nan_get_active_ndp_sessions(struct wlan_objmgr_vdev *vdev,
  102. uint8_t idx)
  103. {
  104. uint32_t val;
  105. struct nan_vdev_priv_obj *priv_obj = nan_get_vdev_priv_obj(vdev);
  106. if (!priv_obj) {
  107. nan_err("priv_obj is null");
  108. return 0;
  109. }
  110. if (idx >= MAX_PEERS) {
  111. nan_err("peer_idx(%d), MAX(%d)",
  112. idx, MAX_PEERS);
  113. return 0;
  114. }
  115. qdf_spin_lock_bh(&priv_obj->lock);
  116. val = priv_obj->active_ndp_sessions[idx];
  117. qdf_spin_unlock_bh(&priv_obj->lock);
  118. return val;
  119. }
  120. inline QDF_STATUS ucfg_nan_set_ndp_create_transaction_id(
  121. struct wlan_objmgr_vdev *vdev, uint16_t val)
  122. {
  123. struct nan_vdev_priv_obj *priv_obj = nan_get_vdev_priv_obj(vdev);
  124. if (!priv_obj) {
  125. nan_err("priv_obj is null");
  126. return QDF_STATUS_E_NULL_VALUE;
  127. }
  128. qdf_spin_lock_bh(&priv_obj->lock);
  129. priv_obj->ndp_create_transaction_id = val;
  130. qdf_spin_unlock_bh(&priv_obj->lock);
  131. return QDF_STATUS_SUCCESS;
  132. }
  133. inline uint16_t ucfg_nan_get_ndp_create_transaction_id(
  134. struct wlan_objmgr_vdev *vdev)
  135. {
  136. uint16_t val;
  137. struct nan_vdev_priv_obj *priv_obj = nan_get_vdev_priv_obj(vdev);
  138. if (!priv_obj) {
  139. nan_err("priv_obj is null");
  140. return 0;
  141. }
  142. qdf_spin_lock_bh(&priv_obj->lock);
  143. val = priv_obj->ndp_create_transaction_id;
  144. qdf_spin_unlock_bh(&priv_obj->lock);
  145. return val;
  146. }
  147. inline QDF_STATUS ucfg_nan_set_ndp_delete_transaction_id(
  148. struct wlan_objmgr_vdev *vdev, uint16_t val)
  149. {
  150. struct nan_vdev_priv_obj *priv_obj = nan_get_vdev_priv_obj(vdev);
  151. if (!priv_obj) {
  152. nan_err("priv_obj is null");
  153. return QDF_STATUS_E_NULL_VALUE;
  154. }
  155. qdf_spin_lock_bh(&priv_obj->lock);
  156. priv_obj->ndp_delete_transaction_id = val;
  157. qdf_spin_unlock_bh(&priv_obj->lock);
  158. return QDF_STATUS_SUCCESS;
  159. }
  160. inline uint16_t ucfg_nan_get_ndp_delete_transaction_id(
  161. struct wlan_objmgr_vdev *vdev)
  162. {
  163. uint16_t val;
  164. struct nan_vdev_priv_obj *priv_obj = nan_get_vdev_priv_obj(vdev);
  165. if (!priv_obj) {
  166. nan_err("priv_obj is null");
  167. return 0;
  168. }
  169. qdf_spin_lock_bh(&priv_obj->lock);
  170. val = priv_obj->ndp_delete_transaction_id;
  171. qdf_spin_unlock_bh(&priv_obj->lock);
  172. return val;
  173. }
  174. inline QDF_STATUS ucfg_nan_set_ndi_delete_rsp_reason(
  175. struct wlan_objmgr_vdev *vdev, uint32_t val)
  176. {
  177. struct nan_vdev_priv_obj *priv_obj = nan_get_vdev_priv_obj(vdev);
  178. if (!priv_obj) {
  179. nan_err("priv_obj is null");
  180. return QDF_STATUS_E_NULL_VALUE;
  181. }
  182. qdf_spin_lock_bh(&priv_obj->lock);
  183. priv_obj->ndi_delete_rsp_reason = val;
  184. qdf_spin_unlock_bh(&priv_obj->lock);
  185. return QDF_STATUS_SUCCESS;
  186. }
  187. inline uint32_t ucfg_nan_get_ndi_delete_rsp_reason(
  188. struct wlan_objmgr_vdev *vdev)
  189. {
  190. uint32_t val;
  191. struct nan_vdev_priv_obj *priv_obj = nan_get_vdev_priv_obj(vdev);
  192. if (!priv_obj) {
  193. nan_err("priv_obj is null");
  194. return 0;
  195. }
  196. qdf_spin_lock_bh(&priv_obj->lock);
  197. val = priv_obj->ndi_delete_rsp_reason;
  198. qdf_spin_unlock_bh(&priv_obj->lock);
  199. return val;
  200. }
  201. inline QDF_STATUS ucfg_nan_set_ndi_delete_rsp_status(
  202. struct wlan_objmgr_vdev *vdev, uint32_t val)
  203. {
  204. struct nan_vdev_priv_obj *priv_obj = nan_get_vdev_priv_obj(vdev);
  205. if (!priv_obj) {
  206. nan_err("priv_obj is null");
  207. return QDF_STATUS_E_NULL_VALUE;
  208. }
  209. qdf_spin_lock_bh(&priv_obj->lock);
  210. priv_obj->ndi_delete_rsp_status = val;
  211. qdf_spin_unlock_bh(&priv_obj->lock);
  212. return QDF_STATUS_SUCCESS;
  213. }
  214. inline uint32_t ucfg_nan_get_ndi_delete_rsp_status(
  215. struct wlan_objmgr_vdev *vdev)
  216. {
  217. uint32_t val;
  218. struct nan_vdev_priv_obj *priv_obj = nan_get_vdev_priv_obj(vdev);
  219. if (!priv_obj) {
  220. nan_err("priv_obj is null");
  221. return QDF_STATUS_E_NULL_VALUE;
  222. }
  223. qdf_spin_lock_bh(&priv_obj->lock);
  224. val = priv_obj->ndi_delete_rsp_status;
  225. qdf_spin_unlock_bh(&priv_obj->lock);
  226. return val;
  227. }
  228. inline QDF_STATUS ucfg_nan_get_callbacks(struct wlan_objmgr_psoc *psoc,
  229. struct nan_callbacks *cb_obj)
  230. {
  231. struct nan_psoc_priv_obj *psoc_obj = nan_get_psoc_priv_obj(psoc);
  232. if (!psoc_obj) {
  233. nan_err("nan psoc priv object is NULL");
  234. return QDF_STATUS_E_NULL_VALUE;
  235. }
  236. qdf_spin_lock_bh(&psoc_obj->lock);
  237. qdf_mem_copy(cb_obj, &psoc_obj->cb_obj, sizeof(*cb_obj));
  238. qdf_spin_unlock_bh(&psoc_obj->lock);
  239. return QDF_STATUS_SUCCESS;
  240. }
  241. static QDF_STATUS ucfg_nan_sch_msg_flush_cb(struct scheduler_msg *msg)
  242. {
  243. struct wlan_objmgr_vdev *vdev = NULL;
  244. if (!msg || !msg->bodyptr)
  245. return QDF_STATUS_E_NULL_VALUE;
  246. switch (msg->type) {
  247. case NDP_INITIATOR_REQ:
  248. vdev = ((struct nan_datapath_initiator_req *)
  249. msg->bodyptr)->vdev;
  250. break;
  251. case NDP_RESPONDER_REQ:
  252. vdev = ((struct nan_datapath_responder_req *)
  253. msg->bodyptr)->vdev;
  254. break;
  255. case NDP_END_REQ:
  256. vdev = ((struct nan_datapath_end_req *)msg->bodyptr)->vdev;
  257. break;
  258. default:
  259. nan_err("Invalid NAN msg type during sch flush");
  260. return QDF_STATUS_E_INVAL;
  261. }
  262. if (vdev) {
  263. wlan_objmgr_vdev_release_ref(vdev, WLAN_NAN_ID);
  264. qdf_mem_free(msg->bodyptr);
  265. }
  266. return QDF_STATUS_SUCCESS;
  267. }
  268. QDF_STATUS ucfg_nan_req_processor(struct wlan_objmgr_vdev *vdev,
  269. void *in_req, uint32_t req_type)
  270. {
  271. uint32_t len;
  272. QDF_STATUS status;
  273. struct scheduler_msg msg = {0};
  274. if (!in_req) {
  275. nan_alert("req is null");
  276. return QDF_STATUS_E_NULL_VALUE;
  277. }
  278. switch (req_type) {
  279. case NDP_INITIATOR_REQ:
  280. len = sizeof(struct nan_datapath_initiator_req);
  281. break;
  282. case NDP_RESPONDER_REQ:
  283. len = sizeof(struct nan_datapath_responder_req);
  284. break;
  285. case NDP_END_REQ:
  286. len = sizeof(struct nan_datapath_end_req);
  287. break;
  288. default:
  289. nan_err("in correct message req type: %d", req_type);
  290. return QDF_STATUS_E_INVAL;
  291. }
  292. msg.bodyptr = qdf_mem_malloc(len);
  293. if (!msg.bodyptr) {
  294. nan_err("malloc failed");
  295. return QDF_STATUS_E_NOMEM;
  296. }
  297. qdf_mem_copy(msg.bodyptr, in_req, len);
  298. msg.type = req_type;
  299. msg.callback = nan_scheduled_msg_handler;
  300. msg.flush_callback = ucfg_nan_sch_msg_flush_cb;
  301. status = scheduler_post_message(QDF_MODULE_ID_HDD,
  302. QDF_MODULE_ID_NAN,
  303. QDF_MODULE_ID_OS_IF, &msg);
  304. if (QDF_IS_STATUS_ERROR(status)) {
  305. nan_err("failed to post msg to NAN component, status: %d",
  306. status);
  307. qdf_mem_free(msg.bodyptr);
  308. }
  309. return status;
  310. }
  311. void ucfg_nan_event_handler(struct wlan_objmgr_psoc *psoc,
  312. struct wlan_objmgr_vdev *vdev,
  313. uint32_t type, void *msg)
  314. {
  315. struct nan_psoc_priv_obj *psoc_obj = nan_get_psoc_priv_obj(psoc);
  316. if (!psoc_obj) {
  317. nan_err("nan psoc priv object is NULL");
  318. return;
  319. }
  320. psoc_obj->cb_obj.os_if_event_handler(psoc, vdev, type, msg);
  321. }
  322. int ucfg_nan_register_hdd_callbacks(struct wlan_objmgr_psoc *psoc,
  323. struct nan_callbacks *cb_obj,
  324. void (os_if_event_handler)(
  325. struct wlan_objmgr_psoc *,
  326. struct wlan_objmgr_vdev *,
  327. uint32_t, void *))
  328. {
  329. struct nan_psoc_priv_obj *psoc_obj = nan_get_psoc_priv_obj(psoc);
  330. if (!psoc_obj) {
  331. nan_err("nan psoc priv object is NULL");
  332. return -EINVAL;
  333. }
  334. psoc_obj->cb_obj.os_if_event_handler = os_if_event_handler;
  335. psoc_obj->cb_obj.ndi_open = cb_obj->ndi_open;
  336. psoc_obj->cb_obj.ndi_start = cb_obj->ndi_start;
  337. psoc_obj->cb_obj.ndi_delete = cb_obj->ndi_delete;
  338. psoc_obj->cb_obj.ndi_close = cb_obj->ndi_close;
  339. psoc_obj->cb_obj.drv_ndi_create_rsp_handler =
  340. cb_obj->drv_ndi_create_rsp_handler;
  341. psoc_obj->cb_obj.drv_ndi_delete_rsp_handler =
  342. cb_obj->drv_ndi_delete_rsp_handler;
  343. psoc_obj->cb_obj.get_peer_idx = cb_obj->get_peer_idx;
  344. psoc_obj->cb_obj.new_peer_ind = cb_obj->new_peer_ind;
  345. psoc_obj->cb_obj.peer_departed_ind = cb_obj->peer_departed_ind;
  346. return 0;
  347. }
  348. int ucfg_nan_register_lim_callbacks(struct wlan_objmgr_psoc *psoc,
  349. struct nan_callbacks *cb_obj)
  350. {
  351. struct nan_psoc_priv_obj *psoc_obj = nan_get_psoc_priv_obj(psoc);
  352. if (!psoc_obj) {
  353. nan_err("nan psoc priv object is NULL");
  354. return -EINVAL;
  355. }
  356. psoc_obj->cb_obj.add_ndi_peer = cb_obj->add_ndi_peer;
  357. psoc_obj->cb_obj.ndp_delete_peers = cb_obj->ndp_delete_peers;
  358. psoc_obj->cb_obj.delete_peers_by_addr = cb_obj->delete_peers_by_addr;
  359. return 0;
  360. }