scheduler_core.h 8.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262
  1. /*
  2. * Copyright (c) 2014-2018 The Linux Foundation. All rights reserved.
  3. *
  4. * Previously licensed under the ISC license by Qualcomm Atheros, Inc.
  5. *
  6. *
  7. * Permission to use, copy, modify, and/or distribute this software for
  8. * any purpose with or without fee is hereby granted, provided that the
  9. * above copyright notice and this permission notice appear in all
  10. * copies.
  11. *
  12. * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL
  13. * WARRANTIES WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED
  14. * WARRANTIES OF MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE
  15. * AUTHOR BE LIABLE FOR ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL
  16. * DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR
  17. * PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE OR OTHER
  18. * TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR
  19. * PERFORMANCE OF THIS SOFTWARE.
  20. */
  21. /*
  22. * This file was originally distributed by Qualcomm Atheros, Inc.
  23. * under proprietary terms before Copyright ownership was assigned
  24. * to the Linux Foundation.
  25. */
  26. #if !defined(__SCHEDULER_CORE_H)
  27. #define __SCHEDULER_CORE_H
  28. #include <qdf_threads.h>
  29. #include <qdf_timer.h>
  30. #include <scheduler_api.h>
  31. #include <qdf_list.h>
  32. #ifdef CONFIG_MCL
  33. #define SCHEDULER_CORE_MAX_MESSAGES 8000
  34. #else
  35. #define SCHEDULER_CORE_MAX_MESSAGES 2000
  36. #endif
  37. #define SCHEDULER_NUMBER_OF_MSG_QUEUE 5
  38. #define SCHEDULER_WRAPPER_MAX_FAIL_COUNT (SCHEDULER_CORE_MAX_MESSAGES * 3)
  39. #define SCHEDULER_WATCHDOG_TIMEOUT (10 * 1000) /* 10s */
  40. #define __sched_log(level, format, args...) \
  41. QDF_TRACE(QDF_MODULE_ID_SCHEDULER, level, FL(format), ## args)
  42. #define sched_fatal(format, args...) \
  43. __sched_log(QDF_TRACE_LEVEL_FATAL, format, ## args)
  44. #define sched_err(format, args...) \
  45. __sched_log(QDF_TRACE_LEVEL_ERROR, format, ## args)
  46. #define sched_warn(format, args...) \
  47. __sched_log(QDF_TRACE_LEVEL_WARN, format, ## args)
  48. #define sched_info(format, args...) \
  49. __sched_log(QDF_TRACE_LEVEL_INFO, format, ## args)
  50. #define sched_debug(format, args...) \
  51. __sched_log(QDF_TRACE_LEVEL_DEBUG, format, ## args)
  52. #define sched_enter() sched_debug("Enter")
  53. #define sched_exit() sched_debug("Exit")
  54. /**
  55. * struct scheduler_mq_type - scheduler message queue
  56. * @mq_lock: message queue lock
  57. * @mq_list: message queue list
  58. * @qid: queue id
  59. */
  60. struct scheduler_mq_type {
  61. qdf_spinlock_t mq_lock;
  62. qdf_list_t mq_list;
  63. QDF_MODULE_ID qid;
  64. };
  65. /**
  66. * struct scheduler_msg_wrapper - scheduler message wrapper
  67. * @msg_node: message node
  68. * @msg_buf: message buffer pointer
  69. */
  70. struct scheduler_msg_wrapper {
  71. qdf_list_node_t msg_node;
  72. struct scheduler_msg *msg_buf;
  73. };
  74. /**
  75. * struct scheduler_mq_ctx - scheduler message queue context
  76. * @msg_buffers: array of message buffers
  77. * @msg_wrappers: array of message wrappers
  78. * @free_msg_q: free message queue
  79. * @sch_msg_q: scheduler message queue
  80. * @scheduler_msg_qid_to_qidx: message qid to qidx mapping
  81. * @scheduler_msg_process_fn: array of message queue handler function pointers
  82. */
  83. struct scheduler_mq_ctx {
  84. struct scheduler_msg msg_buffers[SCHEDULER_CORE_MAX_MESSAGES];
  85. struct scheduler_msg_wrapper msg_wrappers[SCHEDULER_CORE_MAX_MESSAGES];
  86. struct scheduler_mq_type free_msg_q;
  87. struct scheduler_mq_type sch_msg_q[SCHEDULER_NUMBER_OF_MSG_QUEUE];
  88. uint8_t scheduler_msg_qid_to_qidx[QDF_MODULE_ID_MAX];
  89. QDF_STATUS (*scheduler_msg_process_fn[SCHEDULER_NUMBER_OF_MSG_QUEUE])
  90. (struct scheduler_msg *msg);
  91. };
  92. /**
  93. * struct scheduler_ctx - scheduler context
  94. * @queue_ctx: message queue context
  95. * @sch_start_event: scheduler thread start wait event
  96. * @sch_thread: scheduler thread
  97. * @sch_shutdown: scheduler thread shutdown wait event
  98. * @sch_wait_queue: scheduler wait queue
  99. * @sch_event_flag: scheduler events flag
  100. * @resume_sch_event: scheduler resume wait event
  101. * @sch_thread_lock: scheduler thread lock
  102. * @sch_last_qidx: scheduler last qidx allocation
  103. * @hdd_callback: os if suspend callback
  104. * @legacy_wma_handler: legacy wma message handler
  105. * @legacy_sys_handler: legacy sys message handler
  106. * @watchdog_timer: timer for triggering a scheduler watchdog bite
  107. * @watchdog_msg_type: 'type' of the current msg being processed
  108. * @watchdog_callback: the callback of the current msg being processed
  109. */
  110. struct scheduler_ctx {
  111. struct scheduler_mq_ctx queue_ctx;
  112. qdf_event_t sch_start_event;
  113. qdf_thread_t *sch_thread;
  114. qdf_event_t sch_shutdown;
  115. qdf_wait_queue_head_t sch_wait_queue;
  116. unsigned long sch_event_flag;
  117. qdf_event_t resume_sch_event;
  118. qdf_spinlock_t sch_thread_lock;
  119. uint8_t sch_last_qidx;
  120. hdd_suspend_callback hdd_callback;
  121. scheduler_msg_process_fn_t legacy_wma_handler;
  122. scheduler_msg_process_fn_t legacy_sys_handler;
  123. qdf_timer_t watchdog_timer;
  124. uint16_t watchdog_msg_type;
  125. void *watchdog_callback;
  126. };
  127. /**
  128. * scheduler_get_context() - to get scheduler context
  129. *
  130. * This routine is used retrieve scheduler context
  131. *
  132. * Return: Pointer to scheduler context
  133. */
  134. struct scheduler_ctx *scheduler_get_context(void);
  135. /**
  136. * scheduler_thread() - spawned thread will execute this routine
  137. * @arg: pointer to scheduler context
  138. *
  139. * Newly created thread will use this routine to perform its duty
  140. *
  141. * Return: none
  142. */
  143. int scheduler_thread(void *arg);
  144. /**
  145. * scheduler_cleanup_queues() - to clean up the given module's queue
  146. * @sch_ctx: pointer to scheduler context
  147. * @idx: index of the queue which needs to be cleanup.
  148. *
  149. * This routine is used to clean the module's queue provided by
  150. * user through idx field
  151. *
  152. * Return: none
  153. */
  154. void scheduler_cleanup_queues(struct scheduler_ctx *sch_ctx, int idx);
  155. /**
  156. * scheduler_create_ctx() - to create scheduler context
  157. *
  158. * This routine is used to create scheduler context
  159. *
  160. * Return: QDF_STATUS based on success or failure
  161. */
  162. QDF_STATUS scheduler_create_ctx(void);
  163. /**
  164. * scheduler_destroy_ctx() - to destroy scheduler context
  165. *
  166. * This routine is used to destroy scheduler context
  167. *
  168. * Return: QDF_STATUS based on success or failure
  169. */
  170. QDF_STATUS scheduler_destroy_ctx(void);
  171. /**
  172. * scheduler_mq_init() - initialize scheduler message queue
  173. * @msg_q: Pointer to the message queue
  174. *
  175. * This function initializes the Message queue.
  176. *
  177. * Return: qdf status
  178. */
  179. QDF_STATUS scheduler_mq_init(struct scheduler_mq_type *msg_q);
  180. /**
  181. * scheduler_mq_deinit() - de-initialize scheduler message queue
  182. * @msg_q: Pointer to the message queue
  183. *
  184. * This function de-initializes scheduler message queue
  185. *
  186. * Return: none
  187. */
  188. void scheduler_mq_deinit(struct scheduler_mq_type *msg_q);
  189. /**
  190. * scheduler_mq_put() - put message in the back of queue
  191. * @msg_q: Pointer to the message queue
  192. * @msg_wrapper: pointer to message wrapper
  193. *
  194. * This function is used to put message in back of provided message
  195. * queue
  196. *
  197. * Return: none
  198. */
  199. void scheduler_mq_put(struct scheduler_mq_type *msg_q,
  200. struct scheduler_msg_wrapper *msg_wrapper);
  201. /**
  202. * scheduler_mq_put_front() - put message in the front of queue
  203. * @msg_q: Pointer to the message queue
  204. * @msg_wrapper: pointer to message wrapper
  205. *
  206. * This function is used to put message in front of provided message
  207. * queue
  208. *
  209. * Return: none
  210. */
  211. void scheduler_mq_put_front(struct scheduler_mq_type *msg_q,
  212. struct scheduler_msg_wrapper *msg_wrapper);
  213. /**
  214. * scheduler_mq_get() - to get message from message queue
  215. * @msg_q: Pointer to the message queue
  216. *
  217. * This function is used to get message from given message queue
  218. *
  219. * Return: none
  220. */
  221. struct scheduler_msg_wrapper *scheduler_mq_get(struct scheduler_mq_type *msg_q);
  222. /**
  223. * scheduler_is_mq_empty() - to check if message queue is empty
  224. * @msg_q: Pointer to the message queue
  225. *
  226. * This function is used to check if message queue is empty
  227. *
  228. * Return: true or false
  229. */
  230. bool scheduler_is_mq_empty(struct scheduler_mq_type *msg_q);
  231. /**
  232. * scheduler_queues_init() - to initialize all the modules' queues
  233. * @sched_ctx: pointer to scheduler context
  234. *
  235. * This function is used to initialize the queues for all the modules
  236. *
  237. * Return: QDF_STATUS based on success of failure
  238. */
  239. QDF_STATUS scheduler_queues_init(struct scheduler_ctx *sched_ctx);
  240. /**
  241. * scheduler_queues_deinit() - to de-initialize all the modules' queues
  242. * @sched_ctx: pointer to scheduler context
  243. *
  244. * This function is used to de-initialize the queues for all the modules
  245. *
  246. * Return: QDF_STATUS based on success of failure
  247. */
  248. QDF_STATUS scheduler_queues_deinit(struct scheduler_ctx *gp_sch_ctx);
  249. #endif