rtdef.h 53 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464
  1. /*
  2. * Copyright (c) 2006-2025 RT-Thread Development Team
  3. *
  4. * SPDX-License-Identifier: Apache-2.0
  5. *
  6. * Change Logs:
  7. * Date Author Notes
  8. * 2007-01-10 Bernard the first version
  9. * 2008-07-12 Bernard remove all rt_int8, rt_uint32_t etc typedef
  10. * 2010-10-26 yi.qiu add module support
  11. * 2010-11-10 Bernard add cleanup callback function in thread exit.
  12. * 2011-05-09 Bernard use builtin va_arg in GCC 4.x
  13. * 2012-11-16 Bernard change RT_NULL from ((void*)0) to 0.
  14. * 2012-12-29 Bernard change the RT_USING_MEMPOOL location and add
  15. * RT_USING_MEMHEAP condition.
  16. * 2012-12-30 Bernard add more control command for graphic.
  17. * 2013-01-09 Bernard change version number.
  18. * 2015-02-01 Bernard change version number to v2.1.0
  19. * 2017-08-31 Bernard change version number to v3.0.0
  20. * 2017-11-30 Bernard change version number to v3.0.1
  21. * 2017-12-27 Bernard change version number to v3.0.2
  22. * 2018-02-24 Bernard change version number to v3.0.3
  23. * 2018-04-25 Bernard change version number to v3.0.4
  24. * 2018-05-31 Bernard change version number to v3.1.0
  25. * 2018-09-04 Bernard change version number to v3.1.1
  26. * 2018-09-14 Bernard apply Apache License v2.0 to RT-Thread Kernel
  27. * 2018-10-13 Bernard change version number to v4.0.0
  28. * 2018-10-02 Bernard add 64bit arch support
  29. * 2018-11-22 Jesven add smp member to struct rt_thread
  30. * add struct rt_cpu
  31. * add smp relevant macros
  32. * 2019-01-27 Bernard change version number to v4.0.1
  33. * 2019-05-17 Bernard change version number to v4.0.2
  34. * 2019-12-20 Bernard change version number to v4.0.3
  35. * 2020-08-10 Meco Man add macro for struct rt_device_ops
  36. * 2020-10-23 Meco Man define maximum value of ipc type
  37. * 2021-03-19 Meco Man add security devices
  38. * 2021-05-10 armink change version number to v4.0.4
  39. * 2021-11-19 Meco Man change version number to v4.1.0
  40. * 2021-12-21 Meco Man re-implement RT_UNUSED
  41. * 2022-01-01 Gabriel improve hooking method
  42. * 2022-01-07 Gabriel move some __on_rt_xxxxx_hook to dedicated c source files
  43. * 2022-01-12 Meco Man remove RT_THREAD_BLOCK
  44. * 2022-04-20 Meco Man change version number to v4.1.1
  45. * 2022-04-21 THEWON add macro RT_VERSION_CHECK
  46. * 2022-06-29 Meco Man add RT_USING_LIBC and standard libc headers
  47. * 2022-08-16 Meco Man change version number to v5.0.0
  48. * 2022-09-12 Meco Man define rt_ssize_t
  49. * 2022-12-20 Meco Man add const name for rt_object
  50. * 2023-04-01 Chushicheng change version number to v5.0.1
  51. * 2023-05-20 Bernard add stdc atomic detection.
  52. * 2023-09-15 xqyjlj perf rt_hw_interrupt_disable/enable
  53. * 2023-10-10 Chushicheng change version number to v5.1.0
  54. * 2023-10-11 zmshahaha move specific devices related and driver to components/drivers
  55. * 2023-11-21 Meco Man add RT_USING_NANO macro
  56. * 2023-11-17 xqyjlj add process group and session support
  57. * 2023-12-01 Shell Support of dynamic device
  58. * 2023-12-18 xqyjlj add rt_always_inline
  59. * 2023-12-22 Shell Support hook list
  60. * 2024-01-18 Shell Seperate basical types to a rttypes.h
  61. * Seperate the compiler portings to rtcompiler.h
  62. * 2024-03-30 Meco Man update version number to v5.2.0
  63. * 2025-11-10 Rbb666 update version number to v5.3.0
  64. */
  65. #ifndef __RT_DEF_H__
  66. #define __RT_DEF_H__
  67. #include "rtsched.h"
  68. #include "rttypes.h"
  69. #include "klibc/kerrno.h"
  70. #ifdef __cplusplus
  71. extern "C" {
  72. #endif
  73. /**
  74. * @addtogroup group_basic_definition
  75. */
  76. /**@{*/
  77. /* RT-Thread version information */
  78. #define RT_VERSION_MAJOR 5 /**< Major version number (X.x.x) */
  79. #define RT_VERSION_MINOR 3 /**< Minor version number (x.X.x) */
  80. #define RT_VERSION_PATCH 0 /**< Patch version number (x.x.X) */
  81. /* e.g. #if (RTTHREAD_VERSION >= RT_VERSION_CHECK(4, 1, 0) */
  82. #define RT_VERSION_CHECK(major, minor, revise) ((major * 10000U) + (minor * 100U) + revise)
  83. /* RT-Thread version */
  84. #define RTTHREAD_VERSION RT_VERSION_CHECK(RT_VERSION_MAJOR, RT_VERSION_MINOR, RT_VERSION_PATCH)
  85. /**@}*/
  86. /* maximum value of base type */
  87. #ifdef RT_USING_LIBC
  88. #define RT_UINT8_MAX UINT8_MAX /**< Maximum number of UINT8 */
  89. #define RT_UINT16_MAX UINT16_MAX /**< Maximum number of UINT16 */
  90. #define RT_UINT32_MAX UINT32_MAX /**< Maximum number of UINT32 */
  91. #define RT_UINT64_MAX UINT64_MAX /**< Maximum number of UINT64 */
  92. #else
  93. #define RT_UINT8_MAX 0xFFU /**< Maximum number of UINT8 */
  94. #define RT_UINT16_MAX 0xFFFFU /**< Maximum number of UINT16 */
  95. #define RT_UINT32_MAX 0xFFFFFFFFUL /**< Maximum number of UINT32 */
  96. #define RT_UINT64_MAX 0xFFFFFFFFFFFFFFFFULL /**< Maximum number of UINT64 */
  97. #endif /* RT_USING_LIBC */
  98. #define RT_TICK_MAX RT_UINT32_MAX /**< Maximum number of tick */
  99. /* maximum value of ipc type */
  100. #define RT_SEM_VALUE_MAX RT_UINT16_MAX /**< Maximum number of semaphore .value */
  101. #define RT_MUTEX_VALUE_MAX RT_UINT16_MAX /**< Maximum number of mutex .value */
  102. #define RT_MUTEX_HOLD_MAX RT_UINT8_MAX /**< Maximum number of mutex .hold */
  103. #define RT_MB_ENTRY_MAX RT_UINT16_MAX /**< Maximum number of mailbox .entry */
  104. #define RT_MQ_ENTRY_MAX RT_UINT16_MAX /**< Maximum number of message queue .entry */
  105. /* Common Utilities */
  106. #define RT_UNUSED(x) ((void)(x))
  107. /* compile time assertion */
  108. #define RT_STATIC_ASSERT(name, expn) typedef char _static_assert_##name[(expn)?1:-1]
  109. /* Compiler Related Definitions */
  110. #include "rtcompiler.h"
  111. /* initialization export */
  112. #ifdef RT_USING_COMPONENTS_INIT
  113. typedef int (*init_fn_t)(void);
  114. #ifdef _MSC_VER
  115. #pragma section("rti_fn$f",read)
  116. #ifdef RT_DEBUGING_AUTO_INIT
  117. struct rt_init_desc
  118. {
  119. const char* level;
  120. const init_fn_t fn;
  121. const char* fn_name;
  122. };
  123. #define INIT_EXPORT(fn, level) \
  124. const char __rti_level_##fn[] = ".rti_fn." level; \
  125. const char __rti_##fn##_name[] = #fn; \
  126. __declspec(allocate("rti_fn$f")) \
  127. rt_used const struct rt_init_desc __rt_init_msc_##fn = \
  128. {__rti_level_##fn, fn, __rti_##fn##_name};
  129. #else
  130. struct rt_init_desc
  131. {
  132. const char* level;
  133. const init_fn_t fn;
  134. };
  135. #define INIT_EXPORT(fn, level) \
  136. const char __rti_level_##fn[] = ".rti_fn." level; \
  137. __declspec(allocate("rti_fn$f")) \
  138. rt_used const struct rt_init_desc __rt_init_msc_##fn = \
  139. {__rti_level_##fn, fn };
  140. #endif /* RT_DEBUGING_AUTO_INIT */
  141. #else
  142. #ifdef RT_DEBUGING_AUTO_INIT
  143. struct rt_init_desc
  144. {
  145. const char* fn_name;
  146. const init_fn_t fn;
  147. };
  148. #define INIT_EXPORT(fn, level) \
  149. const char __rti_##fn##_name[] = #fn; \
  150. rt_used const struct rt_init_desc __rt_init_desc_##fn rt_section(".rti_fn." level) = \
  151. { __rti_##fn##_name, fn};
  152. #else
  153. #define INIT_EXPORT(fn, level) \
  154. rt_used const init_fn_t __rt_init_##fn rt_section(".rti_fn." level) = fn
  155. #endif /* RT_DEBUGING_AUTO_INIT */
  156. #endif /* _MSC_VER */
  157. #else
  158. #define INIT_EXPORT(fn, level)
  159. #endif /* RT_USING_COMPONENTS_INIT */
  160. /* board init routines will be called in board_init() function */
  161. #define INIT_BOARD_EXPORT(fn) INIT_EXPORT(fn, "1")
  162. /* init cpu, memory, interrupt-controller, bus... */
  163. #define INIT_CORE_EXPORT(fn) INIT_EXPORT(fn, "1.0")
  164. /* init sys-timer, clk, pinctrl... */
  165. #define INIT_SUBSYS_EXPORT(fn) INIT_EXPORT(fn, "1.1")
  166. /* init platform, user code... */
  167. #define INIT_PLATFORM_EXPORT(fn) INIT_EXPORT(fn, "1.2")
  168. /* pre/device/component/env/app init routines will be called in init_thread */
  169. /* components pre-initialization (pure software initialization) */
  170. #define INIT_PREV_EXPORT(fn) INIT_EXPORT(fn, "2")
  171. /* device initialization */
  172. #define INIT_DEVICE_EXPORT(fn) INIT_EXPORT(fn, "3")
  173. /* components initialization (dfs, lwip, ...) */
  174. #define INIT_COMPONENT_EXPORT(fn) INIT_EXPORT(fn, "4")
  175. /* environment initialization (mount disk, ...) */
  176. #define INIT_ENV_EXPORT(fn) INIT_EXPORT(fn, "5")
  177. /* application initialization (rtgui application etc ...) */
  178. #define INIT_APP_EXPORT(fn) INIT_EXPORT(fn, "6")
  179. /* init after mount fs */
  180. #define INIT_FS_EXPORT(fn) INIT_EXPORT(fn, "6.0")
  181. /* init in secondary_cpu_c_start */
  182. #define INIT_SECONDARY_CPU_EXPORT(fn) INIT_EXPORT(fn, "7")
  183. #if !defined(RT_USING_FINSH)
  184. /* define these to empty, even if not include finsh.h file */
  185. #define FINSH_FUNCTION_EXPORT(name, desc)
  186. #define FINSH_FUNCTION_EXPORT_ALIAS(name, alias, desc)
  187. #define MSH_CMD_EXPORT(command, desc)
  188. #define MSH_CMD_EXPORT_ALIAS(command, alias, desc)
  189. #elif !defined(FINSH_USING_SYMTAB)
  190. #define FINSH_FUNCTION_EXPORT_CMD(name, cmd, desc)
  191. #endif
  192. /* event length */
  193. #define RT_EVENT_LENGTH 32
  194. /* memory management option */
  195. #define RT_MM_PAGE_SIZE 4096
  196. #define RT_MM_PAGE_MASK (RT_MM_PAGE_SIZE - 1)
  197. #define RT_MM_PAGE_BITS 12
  198. /* kernel malloc definitions */
  199. #ifndef RT_KERNEL_MALLOC
  200. #define RT_KERNEL_MALLOC(sz) rt_malloc(sz)
  201. #endif /* RT_KERNEL_MALLOC */
  202. #ifndef RT_KERNEL_FREE
  203. #define RT_KERNEL_FREE(ptr) rt_free(ptr)
  204. #endif /* RT_KERNEL_FREE */
  205. #ifndef RT_KERNEL_REALLOC
  206. #define RT_KERNEL_REALLOC(ptr, size) rt_realloc(ptr, size)
  207. #endif /* RT_KERNEL_REALLOC */
  208. /**
  209. * @ingroup group_basic_definition
  210. *
  211. * @def RT_IS_ALIGN(addr, align)
  212. * Return true(1) or false(0).
  213. * RT_IS_ALIGN(128, 4) is judging whether 128 aligns with 4.
  214. * The result is 1, which means 128 aligns with 4.
  215. * @note If the address is NULL, false(0) will be returned
  216. */
  217. #define RT_IS_ALIGN(addr, align) ((!(addr & (align - 1))) && (addr != RT_NULL))
  218. /**
  219. * @ingroup group_basic_definition
  220. *
  221. * @def RT_ALIGN(size, align)
  222. * Return the most contiguous size aligned at specified width. RT_ALIGN(13, 4)
  223. * would return 16.
  224. * @note align Must be an integer power of 2 or the result will be incorrect
  225. */
  226. #define RT_ALIGN(size, align) (((size) + (align) - 1) & ~((align) - 1))
  227. /**
  228. * @ingroup group_basic_definition
  229. *
  230. * @def RT_ALIGN_DOWN(size, align)
  231. * Return the down number of aligned at specified width. RT_ALIGN_DOWN(13, 4)
  232. * would return 12.
  233. * @note align Must be an integer power of 2 or the result will be incorrect
  234. */
  235. #define RT_ALIGN_DOWN(size, align) ((size) & ~((align) - 1))
  236. /**
  237. * @addtogroup group_object_management
  238. * @{
  239. */
  240. /*
  241. * kernel object macros
  242. */
  243. #define RT_OBJECT_FLAG_MODULE 0x80 /**< is module object. */
  244. /**
  245. * Base structure of Kernel object
  246. */
  247. struct rt_object
  248. {
  249. #if RT_NAME_MAX > 0
  250. char name[RT_NAME_MAX]; /**< dynamic name of kernel object */
  251. #else
  252. const char *name; /**< static name of kernel object */
  253. #endif /* RT_NAME_MAX > 0 */
  254. rt_uint8_t type; /**< type of kernel object */
  255. rt_uint8_t flag; /**< flag of kernel object */
  256. #ifdef RT_USING_MODULE
  257. void * module_id; /**< id of application module */
  258. #endif /* RT_USING_MODULE */
  259. #ifdef RT_USING_SMART
  260. rt_atomic_t lwp_ref_count; /**< ref count for lwp */
  261. #endif /* RT_USING_SMART */
  262. rt_list_t list; /**< list node of kernel object */
  263. };
  264. typedef struct rt_object *rt_object_t; /**< Type for kernel objects. */
  265. /**
  266. * iterator of rt_object_for_each()
  267. *
  268. * data is the data passing in to rt_object_for_each(). iterator can return
  269. * RT_EOK to continue the iteration; or any positive value to break the loop
  270. * successfully; or any negative errno to break the loop on failure.
  271. */
  272. typedef rt_err_t (*rt_object_iter_t)(rt_object_t object, void *data);
  273. /**
  274. * The object type can be one of the follows with specific
  275. * macros enabled:
  276. * - Thread
  277. * - Semaphore
  278. * - Mutex
  279. * - Event
  280. * - MailBox
  281. * - MessageQueue
  282. * - MemHeap
  283. * - MemPool
  284. * - Device
  285. * - Timer
  286. * - Module
  287. * - Unknown
  288. * - Static
  289. */
  290. enum rt_object_class_type
  291. {
  292. RT_Object_Class_Null = 0x00, /**< The object is not used. */
  293. RT_Object_Class_Thread = 0x01, /**< The object is a thread. */
  294. RT_Object_Class_Semaphore = 0x02, /**< The object is a semaphore. */
  295. RT_Object_Class_Mutex = 0x03, /**< The object is a mutex. */
  296. RT_Object_Class_Event = 0x04, /**< The object is a event. */
  297. RT_Object_Class_MailBox = 0x05, /**< The object is a mail box. */
  298. RT_Object_Class_MessageQueue = 0x06, /**< The object is a message queue. */
  299. RT_Object_Class_MemHeap = 0x07, /**< The object is a memory heap. */
  300. RT_Object_Class_MemPool = 0x08, /**< The object is a memory pool. */
  301. RT_Object_Class_Device = 0x09, /**< The object is a device. */
  302. RT_Object_Class_Timer = 0x0a, /**< The object is a timer. */
  303. RT_Object_Class_Module = 0x0b, /**< The object is a module. */
  304. RT_Object_Class_Memory = 0x0c, /**< The object is a memory. */
  305. RT_Object_Class_Channel = 0x0d, /**< The object is a channel */
  306. RT_Object_Class_ProcessGroup = 0x0e, /**< The object is a process group */
  307. RT_Object_Class_Session = 0x0f, /**< The object is a session */
  308. RT_Object_Class_Custom = 0x10, /**< The object is a custom object */
  309. RT_Object_Class_Unknown = 0x11, /**< The object is unknown. */
  310. RT_Object_Class_Static = 0x80 /**< The object is a static object. */
  311. };
  312. /**
  313. * The information of the kernel object
  314. */
  315. struct rt_object_information
  316. {
  317. enum rt_object_class_type type; /**< object class type */
  318. rt_list_t object_list; /**< object list */
  319. rt_size_t object_size; /**< object size */
  320. struct rt_spinlock spinlock;
  321. };
  322. /**
  323. * The hook function call macro
  324. */
  325. #ifndef RT_USING_HOOK
  326. #define RT_OBJECT_HOOK_CALL(func, argv)
  327. #else
  328. /**
  329. * @brief Add hook point in the routines
  330. * @note Usage:
  331. * void foo() {
  332. * do_something();
  333. *
  334. * RT_OBJECT_HOOK_CALL(foo);
  335. *
  336. * do_other_things();
  337. * }
  338. */
  339. #define _RT_OBJECT_HOOK_CALL(func, argv) __ON_HOOK_ARGS(func, argv)
  340. #define RT_OBJECT_HOOK_CALL(func, argv) _RT_OBJECT_HOOK_CALL(func, argv)
  341. #ifdef RT_HOOK_USING_FUNC_PTR
  342. #define __ON_HOOK_ARGS(__hook, argv) do {if ((__hook) != RT_NULL) __hook argv; } while (0)
  343. #else
  344. #define __ON_HOOK_ARGS(__hook, argv)
  345. #endif /* RT_HOOK_USING_FUNC_PTR */
  346. #endif /* RT_USING_HOOK */
  347. #ifdef RT_USING_HOOKLIST
  348. /**
  349. * @brief Add declaration for hook list types.
  350. *
  351. * @note Usage:
  352. * This is typically used in your header. In foo.h using this like:
  353. *
  354. * ```foo.h
  355. * typedef void (*bar_hook_proto_t)(arguments...);
  356. * RT_OBJECT_HOOKLIST_DECLARE(bar_hook_proto_t, bar_myhook);
  357. * ```
  358. */
  359. #define RT_OBJECT_HOOKLIST_DECLARE(handler_type, name) \
  360. typedef struct name##_hooklistnode \
  361. { \
  362. handler_type handler; \
  363. rt_list_t list_node; \
  364. } *name##_hooklistnode_t; \
  365. extern volatile rt_ubase_t name##_nested; \
  366. void name##_sethook(name##_hooklistnode_t node); \
  367. void name##_rmhook(name##_hooklistnode_t node)
  368. /**
  369. * @brief Add declaration for hook list node.
  370. *
  371. * @note Usage
  372. * You can add a hook like this.
  373. *
  374. * ```addhook.c
  375. * void myhook(arguments...) { do_something(); }
  376. * RT_OBJECT_HOOKLIST_DEFINE_NODE(bar_myhook, myhook_node, myhook);
  377. *
  378. * void addhook(void)
  379. * {
  380. * bar_myhook_sethook(myhook);
  381. * }
  382. * ```
  383. *
  384. * BTW, you can also find examples codes under
  385. * `examples/utest/testcases/kernel/hooklist_tc.c`.
  386. */
  387. #define RT_OBJECT_HOOKLIST_DEFINE_NODE(hookname, nodename, hooker_handler) \
  388. struct hookname##_hooklistnode nodename = { \
  389. .handler = hooker_handler, \
  390. .list_node = RT_LIST_OBJECT_INIT(nodename.list_node), \
  391. };
  392. /**
  393. * @note Usage
  394. * Add this macro to the source file where your hook point is inserted.
  395. */
  396. #define RT_OBJECT_HOOKLIST_DEFINE(name) \
  397. static rt_list_t name##_hooklist = RT_LIST_OBJECT_INIT(name##_hooklist); \
  398. static struct rt_spinlock name##lock = RT_SPINLOCK_INIT; \
  399. volatile rt_ubase_t name##_nested = 0; \
  400. void name##_sethook(name##_hooklistnode_t node) \
  401. { \
  402. rt_ubase_t level = rt_spin_lock_irqsave(&name##lock); \
  403. while (name##_nested) \
  404. { \
  405. rt_spin_unlock_irqrestore(&name##lock, level); \
  406. level = rt_spin_lock_irqsave(&name##lock); \
  407. } \
  408. rt_list_insert_before(&name##_hooklist, &node->list_node); \
  409. rt_spin_unlock_irqrestore(&name##lock, level); \
  410. } \
  411. void name##_rmhook(name##_hooklistnode_t node) \
  412. { \
  413. rt_ubase_t level = rt_spin_lock_irqsave(&name##lock); \
  414. while (name##_nested) \
  415. { \
  416. rt_spin_unlock_irqrestore(&name##lock, level); \
  417. level = rt_spin_lock_irqsave(&name##lock); \
  418. } \
  419. rt_list_remove(&node->list_node); \
  420. rt_spin_unlock_irqrestore(&name##lock, level); \
  421. }
  422. /**
  423. * @brief Add hook list point in the routines. Multiple hookers in the list will
  424. * be called one by one starting from head node.
  425. *
  426. * @note Usage:
  427. * void foo() {
  428. * do_something();
  429. *
  430. * RT_OBJECT_HOOKLIST_CALL(foo);
  431. *
  432. * do_other_things();
  433. * }
  434. */
  435. #define _RT_OBJECT_HOOKLIST_CALL(nodetype, nested, list, lock, argv) \
  436. do \
  437. { \
  438. nodetype iter, next; \
  439. rt_ubase_t level = rt_spin_lock_irqsave(&lock); \
  440. nested += 1; \
  441. rt_spin_unlock_irqrestore(&lock, level); \
  442. if (!rt_list_isempty(&list)) \
  443. { \
  444. rt_list_for_each_entry_safe(iter, next, &list, list_node) \
  445. { \
  446. iter->handler argv; \
  447. } \
  448. } \
  449. level = rt_spin_lock_irqsave(&lock); \
  450. nested -= 1; \
  451. rt_spin_unlock_irqrestore(&lock, level); \
  452. } while (0)
  453. #define RT_OBJECT_HOOKLIST_CALL(name, argv) \
  454. _RT_OBJECT_HOOKLIST_CALL(name##_hooklistnode_t, name##_nested, \
  455. name##_hooklist, name##lock, argv)
  456. #else
  457. #define RT_OBJECT_HOOKLIST_DECLARE(handler_type, name)
  458. #define RT_OBJECT_HOOKLIST_DEFINE_NODE(hookname, nodename, hooker_handler)
  459. #define RT_OBJECT_HOOKLIST_DEFINE(name)
  460. #define RT_OBJECT_HOOKLIST_CALL(name, argv)
  461. #endif /* RT_USING_HOOKLIST */
  462. /** @} group_object_management */
  463. /**
  464. * @addtogroup group_clock_management
  465. */
  466. /**@{*/
  467. /**
  468. * clock & timer macros
  469. */
  470. #define RT_TIMER_FLAG_DEACTIVATED 0x0 /**< timer is deactive */
  471. #define RT_TIMER_FLAG_ACTIVATED 0x1 /**< timer is active */
  472. #define RT_TIMER_FLAG_ONE_SHOT 0x0 /**< one shot timer */
  473. #define RT_TIMER_FLAG_PERIODIC 0x2 /**< periodic timer */
  474. #define RT_TIMER_FLAG_HARD_TIMER 0x0 /**< hard timer,the timer's callback function will be called in tick isr. */
  475. #define RT_TIMER_FLAG_SOFT_TIMER 0x4 /**< soft timer,the timer's callback function will be called in timer thread. */
  476. #define RT_TIMER_FLAG_THREAD_TIMER \
  477. (0x8 | RT_TIMER_FLAG_HARD_TIMER) /**< thread timer that cooperates with scheduler directly */
  478. #define RT_TIMER_CTRL_SET_TIME 0x0 /**< set timer control command */
  479. #define RT_TIMER_CTRL_GET_TIME 0x1 /**< get timer control command */
  480. #define RT_TIMER_CTRL_SET_ONESHOT 0x2 /**< change timer to one shot */
  481. #define RT_TIMER_CTRL_SET_PERIODIC 0x3 /**< change timer to periodic */
  482. #define RT_TIMER_CTRL_GET_STATE 0x4 /**< get timer run state active or deactive*/
  483. #define RT_TIMER_CTRL_GET_REMAIN_TIME 0x5 /**< get the remaining hang time */
  484. #define RT_TIMER_CTRL_GET_FUNC 0x6 /**< get timer timeout func */
  485. #define RT_TIMER_CTRL_SET_FUNC 0x7 /**< set timer timeout func */
  486. #define RT_TIMER_CTRL_GET_PARM 0x8 /**< get timer parameter */
  487. #define RT_TIMER_CTRL_SET_PARM 0x9 /**< set timer parameter */
  488. #ifndef RT_TIMER_SKIP_LIST_LEVEL
  489. #define RT_TIMER_SKIP_LIST_LEVEL 1
  490. #endif
  491. /* 1 or 3 */
  492. #ifndef RT_TIMER_SKIP_LIST_MASK
  493. #define RT_TIMER_SKIP_LIST_MASK 0x3 /**< Timer skips the list mask */
  494. #endif
  495. /**
  496. * timeout handler of rt_timer
  497. */
  498. typedef void (*rt_timer_func_t)(void *parameter);
  499. /**
  500. * timer structure
  501. */
  502. struct rt_timer
  503. {
  504. struct rt_object parent; /**< inherit from rt_object */
  505. rt_list_t row[RT_TIMER_SKIP_LIST_LEVEL];
  506. rt_timer_func_t timeout_func; /**< timeout function */
  507. void *parameter; /**< timeout function's parameter */
  508. rt_tick_t init_tick; /**< timer timeout tick */
  509. rt_tick_t timeout_tick; /**< timeout tick */
  510. };
  511. typedef struct rt_timer *rt_timer_t;
  512. /**@}*/
  513. /**
  514. * @addtogroup group_signal
  515. */
  516. /**@{*/
  517. #ifdef RT_USING_SIGNALS
  518. #define RT_SIG_MAX 32
  519. typedef unsigned long rt_sigset_t;
  520. typedef siginfo_t rt_siginfo_t;
  521. typedef void (*rt_sighandler_t)(int signo);
  522. #endif /* RT_USING_SIGNALS */
  523. /**@}*/
  524. /**
  525. * @addtogroup group_thread_management
  526. * @{
  527. */
  528. /*
  529. * Thread
  530. */
  531. /*
  532. * thread state definitions
  533. */
  534. #define RT_THREAD_INIT 0x00 /**< Initialized status */
  535. #define RT_THREAD_CLOSE 0x01 /**< Closed status */
  536. #define RT_THREAD_READY 0x02 /**< Ready status */
  537. #define RT_THREAD_RUNNING 0x03 /**< Running status */
  538. /*
  539. * for rt_thread_suspend_with_flag()
  540. */
  541. enum
  542. {
  543. RT_INTERRUPTIBLE = 0,
  544. RT_KILLABLE,
  545. RT_UNINTERRUPTIBLE,
  546. };
  547. #define RT_THREAD_SUSPEND_MASK 0x04
  548. #define RT_SIGNAL_COMMON_WAKEUP_MASK 0x02
  549. #define RT_SIGNAL_KILL_WAKEUP_MASK 0x01
  550. #define RT_THREAD_SUSPEND_INTERRUPTIBLE (RT_THREAD_SUSPEND_MASK) /**< Suspend interruptable 0x4 */
  551. #define RT_THREAD_SUSPEND RT_THREAD_SUSPEND_INTERRUPTIBLE
  552. #define RT_THREAD_SUSPEND_KILLABLE (RT_THREAD_SUSPEND_MASK | RT_SIGNAL_COMMON_WAKEUP_MASK) /**< Suspend with killable 0x6 */
  553. #define RT_THREAD_SUSPEND_UNINTERRUPTIBLE (RT_THREAD_SUSPEND_MASK | RT_SIGNAL_COMMON_WAKEUP_MASK | RT_SIGNAL_KILL_WAKEUP_MASK) /**< Suspend with uninterruptable 0x7 */
  554. #define RT_THREAD_STAT_MASK 0x07
  555. #define RT_THREAD_STAT_YIELD 0x08 /**< indicate whether remaining_tick has been reloaded since last schedule */
  556. #define RT_THREAD_STAT_YIELD_MASK RT_THREAD_STAT_YIELD
  557. #define RT_THREAD_STAT_SIGNAL 0x10 /**< task hold signals */
  558. #define RT_THREAD_STAT_SIGNAL_READY (RT_THREAD_STAT_SIGNAL | RT_THREAD_READY)
  559. #define RT_THREAD_STAT_SIGNAL_WAIT 0x20 /**< task is waiting for signals */
  560. #define RT_THREAD_STAT_SIGNAL_PENDING 0x40 /**< signals is held and it has not been procressed */
  561. #define RT_THREAD_STAT_SIGNAL_MASK 0xf0
  562. /**
  563. * thread control command definitions
  564. */
  565. #define RT_THREAD_CTRL_STARTUP 0x00 /**< Startup thread. */
  566. #define RT_THREAD_CTRL_CLOSE 0x01 /**< Close thread. */
  567. #define RT_THREAD_CTRL_CHANGE_PRIORITY 0x02 /**< Change thread priority. */
  568. #define RT_THREAD_CTRL_INFO 0x03 /**< Get thread information. */
  569. #define RT_THREAD_CTRL_BIND_CPU 0x04 /**< Set thread bind cpu. */
  570. #define RT_THREAD_CTRL_RESET_PRIORITY 0x05 /**< Reset thread priority. */
  571. /**
  572. * CPU usage statistics data
  573. */
  574. struct rt_cpu_usage_stats
  575. {
  576. rt_ubase_t user;
  577. rt_ubase_t system;
  578. rt_ubase_t irq;
  579. rt_ubase_t idle;
  580. };
  581. typedef struct rt_cpu_usage_stats *rt_cpu_usage_stats_t;
  582. #ifdef RT_USING_SMP
  583. #define RT_CPU_DETACHED RT_CPUS_NR /**< The thread not running on cpu. */
  584. #define RT_CPU_MASK ((1 << RT_CPUS_NR) - 1) /**< All CPUs mask bit. */
  585. #ifndef RT_SCHEDULE_IPI
  586. #define RT_SCHEDULE_IPI 0
  587. #endif /* RT_SCHEDULE_IPI */
  588. #ifndef RT_STOP_IPI
  589. #define RT_STOP_IPI 1
  590. #endif /* RT_STOP_IPI */
  591. #ifndef RT_SMP_CALL_IPI
  592. #define RT_SMP_CALL_IPI 2
  593. #endif
  594. #define RT_MAX_IPI 3
  595. #define _SCHEDULER_CONTEXT(fileds) fileds
  596. /**
  597. * CPUs definitions
  598. *
  599. */
  600. struct rt_cpu
  601. {
  602. /**
  603. * protected by:
  604. * - other cores: accessing from other coress is undefined behaviour
  605. * - local core: rt_enter_critical()/rt_exit_critical()
  606. */
  607. _SCHEDULER_CONTEXT(
  608. struct rt_thread *current_thread;
  609. rt_uint8_t irq_switch_flag:1;
  610. rt_uint8_t sched_lock_flag:1;
  611. #ifndef ARCH_USING_HW_THREAD_SELF
  612. rt_uint8_t critical_switch_flag:1;
  613. #endif /* ARCH_USING_HW_THREAD_SELF */
  614. rt_uint8_t current_priority;
  615. rt_list_t priority_table[RT_THREAD_PRIORITY_MAX];
  616. #if RT_THREAD_PRIORITY_MAX > 32
  617. rt_uint32_t priority_group;
  618. rt_uint8_t ready_table[32];
  619. #else
  620. rt_uint32_t priority_group;
  621. #endif /* RT_THREAD_PRIORITY_MAX > 32 */
  622. rt_atomic_t tick; /**< Passing tickes on this core */
  623. );
  624. struct rt_thread *idle_thread;
  625. rt_atomic_t irq_nest;
  626. #ifdef RT_USING_SMART
  627. struct rt_spinlock spinlock;
  628. #endif /* RT_USING_SMART */
  629. #ifdef RT_USING_CPU_USAGE_TRACER
  630. struct rt_cpu_usage_stats cpu_stat;
  631. #endif /* RT_USING_CPU_USAGE_TRACER */
  632. #ifdef ARCH_USING_IRQ_CTX_LIST
  633. rt_slist_t irq_ctx_head;
  634. #endif /* ARCH_USING_IRQ_CTX_LIST */
  635. };
  636. #else /* !RT_USING_SMP */
  637. struct rt_cpu
  638. {
  639. struct rt_thread *current_thread;
  640. struct rt_thread *idle_thread;
  641. #ifdef RT_USING_CPU_USAGE_TRACER
  642. struct rt_cpu_usage_stats cpu_stat;
  643. #endif /* RT_USING_CPU_USAGE_TRACER */
  644. #ifdef ARCH_USING_IRQ_CTX_LIST
  645. rt_slist_t irq_ctx_head;
  646. #endif /* ARCH_USING_IRQ_CTX_LIST */
  647. };
  648. #endif /* RT_USING_SMP */
  649. typedef struct rt_cpu *rt_cpu_t;
  650. /* Noted: As API to reject writing to this variable from application codes */
  651. #define rt_current_thread rt_thread_self()
  652. struct rt_thread;
  653. /**
  654. * interrupt/exception frame handling
  655. *
  656. */
  657. typedef struct rt_interrupt_context {
  658. void *context; /**< arch specific context */
  659. rt_slist_t node; /**< node for nested interrupt */
  660. } *rt_interrupt_context_t;
  661. #ifdef RT_USING_SMART
  662. typedef rt_err_t (*rt_wakeup_func_t)(void *object, struct rt_thread *thread);
  663. struct rt_wakeup
  664. {
  665. rt_wakeup_func_t func;
  666. void *user_data;
  667. };
  668. #define _LWP_NSIG 64
  669. #ifdef ARCH_CPU_64BIT
  670. #define _LWP_NSIG_BPW 64
  671. #else
  672. #define _LWP_NSIG_BPW 32
  673. #endif
  674. #define _LWP_NSIG_WORDS (RT_ALIGN(_LWP_NSIG, _LWP_NSIG_BPW) / _LWP_NSIG_BPW)
  675. typedef void (*lwp_sighandler_t)(int);
  676. typedef void (*lwp_sigaction_t)(int signo, siginfo_t *info, void *context);
  677. typedef struct {
  678. unsigned long sig[_LWP_NSIG_WORDS];
  679. } lwp_sigset_t;
  680. #if _LWP_NSIG <= 64
  681. #define lwp_sigmask(signo) ((lwp_sigset_t){.sig = {[0] = ((long)(1u << ((signo)-1)))}})
  682. #define lwp_sigset_init(mask) ((lwp_sigset_t){.sig = {[0] = (long)(mask)}})
  683. #endif /* _LWP_NSIG <= 64 */
  684. struct lwp_sigaction {
  685. union {
  686. void (*_sa_handler)(int);
  687. void (*_sa_sigaction)(int, siginfo_t *, void *);
  688. } __sa_handler;
  689. lwp_sigset_t sa_mask;
  690. int sa_flags;
  691. void (*sa_restorer)(void);
  692. };
  693. typedef struct lwp_siginfo_ext {
  694. union {
  695. /* for SIGCHLD */
  696. struct {
  697. int status;
  698. clock_t utime;
  699. clock_t stime;
  700. } sigchld;
  701. };
  702. } *lwp_siginfo_ext_t;
  703. typedef struct lwp_siginfo {
  704. rt_list_t node;
  705. struct {
  706. int signo;
  707. int code;
  708. int from_tid;
  709. pid_t from_pid;
  710. } ksiginfo;
  711. /* the signal specified extension field */
  712. struct lwp_siginfo_ext *ext;
  713. } *lwp_siginfo_t;
  714. typedef struct lwp_sigqueue {
  715. rt_list_t siginfo_list;
  716. lwp_sigset_t sigset_pending;
  717. } *lwp_sigqueue_t;
  718. struct lwp_thread_signal {
  719. lwp_sigset_t sigset_mask;
  720. struct lwp_sigqueue sig_queue;
  721. };
  722. struct rt_user_context
  723. {
  724. void *sp;
  725. void *pc;
  726. void *flag;
  727. void *ctx;
  728. };
  729. #endif /* RT_USING_SMART */
  730. typedef void (*rt_thread_cleanup_t)(struct rt_thread *tid);
  731. /**
  732. * @brief Thread Control Block
  733. */
  734. struct rt_thread
  735. {
  736. struct rt_object parent;
  737. /* stack point and entry */
  738. void *sp; /**< stack point */
  739. void *entry; /**< entry */
  740. void *parameter; /**< parameter */
  741. void *stack_addr; /**< stack address */
  742. rt_uint32_t stack_size; /**< stack size */
  743. /* error code */
  744. rt_err_t error; /**< error code */
  745. #ifdef RT_USING_SMP
  746. rt_atomic_t cpus_lock_nest; /**< cpus lock count */
  747. #endif
  748. RT_SCHED_THREAD_CTX
  749. struct rt_timer thread_timer; /**< built-in thread timer */
  750. rt_thread_cleanup_t cleanup; /**< cleanup function when thread exit */
  751. #ifdef RT_USING_MUTEX
  752. /* object for IPC */
  753. rt_list_t taken_object_list;
  754. rt_object_t pending_object;
  755. #endif /* RT_USING_MUTEX */
  756. #ifdef RT_USING_EVENT
  757. /* thread event */
  758. rt_uint32_t event_set;
  759. rt_uint8_t event_info;
  760. #endif /* RT_USING_EVENT */
  761. #ifdef RT_USING_SIGNALS
  762. rt_sigset_t sig_pending; /**< the pending signals */
  763. rt_sigset_t sig_mask; /**< the mask bits of signal */
  764. #ifndef RT_USING_SMP
  765. void *sig_ret; /**< the return stack pointer from signal */
  766. #endif /* RT_USING_SMP */
  767. rt_sighandler_t *sig_vectors; /**< vectors of signal handler */
  768. void *si_list; /**< the signal infor list */
  769. #endif /* RT_USING_SIGNALS */
  770. #ifdef RT_USING_PTHREADS
  771. void *pthread_data; /**< the handle of pthread data, adapt 32/64bit */
  772. #endif /* RT_USING_PTHREADS */
  773. /* light weight process if present */
  774. #ifdef RT_USING_SMART
  775. void *msg_ret; /**< the return msg */
  776. void *lwp; /**< the lwp reference */
  777. /* for user create */
  778. void *user_entry;
  779. void *user_stack;
  780. rt_uint32_t user_stack_size;
  781. rt_uint32_t *kernel_sp; /**< kernel stack point */
  782. rt_list_t sibling; /**< next thread of same process */
  783. struct lwp_thread_signal signal; /**< lwp signal for user-space thread */
  784. struct rt_user_context user_ctx; /**< user space context */
  785. struct rt_wakeup wakeup_handle; /**< wakeup handle for IPC */
  786. rt_atomic_t exit_request; /**< pending exit request of thread */
  787. int tid; /**< thread ID used by process */
  788. int tid_ref_count; /**< reference of tid */
  789. void *susp_recycler; /**< suspended recycler on this thread */
  790. void *robust_list; /**< pi lock, very carefully, it's a userspace list!*/
  791. #ifndef ARCH_MM_MMU
  792. lwp_sighandler_t signal_handler[32];
  793. #else
  794. int step_exec;
  795. int debug_attach_req;
  796. int debug_ret_user;
  797. int debug_suspend;
  798. struct rt_hw_exp_stack *regs;
  799. void *thread_idr; /** lwp thread indicator */
  800. int *clear_child_tid;
  801. #endif /* ARCH_MM_MMU */
  802. #endif /* RT_USING_SMART */
  803. #ifdef RT_USING_CPU_USAGE_TRACER
  804. rt_ubase_t user_time; /**< Ticks on user */
  805. rt_ubase_t system_time; /**< Ticks on system */
  806. #endif /* RT_USING_CPU_USAGE_TRACER */
  807. #ifdef RT_USING_MEM_PROTECTION
  808. void *mem_regions;
  809. #ifdef RT_USING_HW_STACK_GUARD
  810. void *stack_buf;
  811. #endif /* RT_USING_HW_STACK_GUARD */
  812. #endif /* RT_USING_MEM_PROTECTION */
  813. struct rt_spinlock spinlock;
  814. rt_ubase_t user_data; /**< private user data beyond this thread */
  815. };
  816. typedef struct rt_thread *rt_thread_t;
  817. #ifdef RT_USING_SMART
  818. #define LWP_IS_USER_MODE(t) ((t)->user_ctx.ctx == RT_NULL)
  819. #else
  820. #define LWP_IS_USER_MODE(t) (0)
  821. #endif /* RT_USING_SMART */
  822. /** @} group_thread_management */
  823. /**
  824. * @addtogroup group_thread_comm
  825. */
  826. /**@{*/
  827. /**
  828. * IPC flags and control command definitions
  829. */
  830. #define RT_IPC_FLAG_FIFO 0x00 /**< FIFOed IPC. @ref group_thread_comm. */
  831. #define RT_IPC_FLAG_PRIO 0x01 /**< PRIOed IPC. @ref group_thread_comm. */
  832. #define RT_IPC_CMD_UNKNOWN 0x00 /**< unknown IPC command */
  833. #define RT_IPC_CMD_RESET 0x01 /**< reset IPC object */
  834. #define RT_IPC_CMD_GET_STATE 0x02 /**< get the state of IPC object */
  835. #define RT_IPC_CMD_SET_VLIMIT 0x03 /**< set max limit value of IPC value */
  836. #define RT_WAITING_FOREVER -1 /**< Block forever until get resource. */
  837. #define RT_WAITING_NO 0 /**< Non-block. */
  838. /**
  839. * Base structure of IPC object
  840. */
  841. struct rt_ipc_object
  842. {
  843. struct rt_object parent; /**< inherit from rt_object */
  844. rt_list_t suspend_thread; /**< threads pended on this resource */
  845. };
  846. /**
  847. * @addtogroup group_semaphore Semaphore
  848. * @{
  849. */
  850. #ifdef RT_USING_SEMAPHORE
  851. /**
  852. * Semaphore structure
  853. */
  854. struct rt_semaphore
  855. {
  856. struct rt_ipc_object parent; /**< inherit from ipc_object */
  857. rt_uint16_t value; /**< value of semaphore. */
  858. rt_uint16_t max_value;
  859. struct rt_spinlock spinlock;
  860. };
  861. typedef struct rt_semaphore *rt_sem_t;
  862. #endif /* RT_USING_SEMAPHORE */
  863. /**@}*/
  864. /**
  865. * @addtogroup group_mutex Mutex
  866. * @{
  867. */
  868. #ifdef RT_USING_MUTEX
  869. /**
  870. * Mutual exclusion (mutex) structure
  871. */
  872. struct rt_mutex
  873. {
  874. struct rt_ipc_object parent; /**< inherit from ipc_object */
  875. rt_uint8_t ceiling_priority; /**< the priority ceiling of mutexe */
  876. rt_uint8_t priority; /**< the maximal priority for pending thread */
  877. rt_uint8_t hold; /**< numbers of thread hold the mutex */
  878. rt_uint8_t reserved; /**< reserved field */
  879. struct rt_thread *owner; /**< current owner of mutex */
  880. rt_list_t taken_list; /**< the object list taken by thread */
  881. struct rt_spinlock spinlock;
  882. };
  883. typedef struct rt_mutex *rt_mutex_t;
  884. #endif /* RT_USING_MUTEX */
  885. /**@}*/
  886. /**
  887. * @addtogroup group_event Event
  888. * @{
  889. */
  890. #ifdef RT_USING_EVENT
  891. /**
  892. * flag definitions in event
  893. */
  894. #define RT_EVENT_FLAG_AND 0x01 /**< logic and */
  895. #define RT_EVENT_FLAG_OR 0x02 /**< logic or */
  896. #define RT_EVENT_FLAG_CLEAR 0x04 /**< clear flag */
  897. /*
  898. * event structure
  899. */
  900. struct rt_event
  901. {
  902. struct rt_ipc_object parent; /**< inherit from ipc_object */
  903. rt_uint32_t set; /**< event set */
  904. struct rt_spinlock spinlock;
  905. };
  906. typedef struct rt_event *rt_event_t;
  907. #endif /* RT_USING_EVENT */
  908. /**@}*/
  909. /**
  910. * @addtogroup group_mailbox MailBox
  911. * @{
  912. */
  913. #ifdef RT_USING_MAILBOX
  914. /**
  915. * mailbox structure
  916. */
  917. struct rt_mailbox
  918. {
  919. struct rt_ipc_object parent; /**< inherit from ipc_object */
  920. rt_ubase_t *msg_pool; /**< start address of message buffer */
  921. rt_uint16_t size; /**< size of message pool */
  922. rt_uint16_t entry; /**< index of messages in msg_pool */
  923. rt_uint16_t in_offset; /**< input offset of the message buffer */
  924. rt_uint16_t out_offset; /**< output offset of the message buffer */
  925. rt_list_t suspend_sender_thread; /**< sender thread suspended on this mailbox */
  926. struct rt_spinlock spinlock;
  927. };
  928. typedef struct rt_mailbox *rt_mailbox_t;
  929. #endif /* RT_USING_MAILBOX */
  930. /**@}*/
  931. /**
  932. * @addtogroup group_messagequeue Message Queue
  933. * @{
  934. */
  935. #ifdef RT_USING_MESSAGEQUEUE
  936. /**
  937. * message queue structure
  938. */
  939. struct rt_messagequeue
  940. {
  941. struct rt_ipc_object parent; /**< inherit from ipc_object */
  942. void *msg_pool; /**< start address of message queue */
  943. rt_uint16_t msg_size; /**< message size of each message */
  944. rt_uint16_t max_msgs; /**< max number of messages */
  945. rt_uint16_t entry; /**< index of messages in the queue */
  946. void *msg_queue_head; /**< list head */
  947. void *msg_queue_tail; /**< list tail */
  948. void *msg_queue_free; /**< pointer indicated the free node of queue */
  949. rt_list_t suspend_sender_thread; /**< sender thread suspended on this message queue */
  950. struct rt_spinlock spinlock;
  951. };
  952. typedef struct rt_messagequeue *rt_mq_t;
  953. #endif /* RT_USING_MESSAGEQUEUE */
  954. /**@}*/
  955. /**@}*/
  956. /**
  957. * @addtogroup group_memory_management
  958. */
  959. /**@{*/
  960. #ifdef RT_USING_HEAP
  961. /*
  962. * memory structure
  963. */
  964. struct rt_memory
  965. {
  966. struct rt_object parent; /**< inherit from rt_object */
  967. const char * algorithm; /**< Memory management algorithm name */
  968. rt_ubase_t address; /**< memory start address */
  969. rt_size_t total; /**< memory size */
  970. rt_size_t used; /**< size used */
  971. rt_size_t max; /**< maximum usage */
  972. };
  973. typedef struct rt_memory *rt_mem_t;
  974. #endif /* RT_USING_HEAP */
  975. /*
  976. * memory management
  977. * heap & partition
  978. */
  979. #ifdef RT_USING_SMALL_MEM
  980. typedef rt_mem_t rt_smem_t;
  981. #endif /* RT_USING_SMALL_MEM */
  982. #ifdef RT_USING_SLAB
  983. typedef rt_mem_t rt_slab_t;
  984. #endif /* RT_USING_SLAB */
  985. #ifdef RT_USING_MEMHEAP
  986. /**
  987. * memory item on the heap
  988. */
  989. struct rt_memheap_item
  990. {
  991. rt_uint32_t magic; /**< magic number for memheap */
  992. struct rt_memheap *pool_ptr; /**< point of pool */
  993. struct rt_memheap_item *next; /**< next memheap item */
  994. struct rt_memheap_item *prev; /**< prev memheap item */
  995. struct rt_memheap_item *next_free; /**< next free memheap item */
  996. struct rt_memheap_item *prev_free; /**< prev free memheap item */
  997. #ifdef RT_USING_MEMTRACE
  998. rt_uint8_t owner_thread_name[4]; /**< owner thread name */
  999. #endif /* RT_USING_MEMTRACE */
  1000. };
  1001. /**
  1002. * Base structure of memory heap object
  1003. */
  1004. struct rt_memheap
  1005. {
  1006. struct rt_object parent; /**< inherit from rt_object */
  1007. void *start_addr; /**< pool start address and size */
  1008. rt_size_t pool_size; /**< pool size */
  1009. rt_size_t available_size; /**< available size */
  1010. rt_size_t max_used_size; /**< maximum allocated size */
  1011. struct rt_memheap_item *block_list; /**< used block list */
  1012. struct rt_memheap_item *free_list; /**< free block list */
  1013. struct rt_memheap_item free_header; /**< free block list header */
  1014. struct rt_semaphore lock; /**< semaphore lock */
  1015. rt_bool_t locked; /**< External lock mark */
  1016. };
  1017. #endif /* RT_USING_MEMHEAP */
  1018. #ifdef RT_USING_MEMPOOL
  1019. /**
  1020. * Base structure of Memory pool object
  1021. */
  1022. struct rt_mempool
  1023. {
  1024. struct rt_object parent; /**< inherit from rt_object */
  1025. void *start_address; /**< memory pool start */
  1026. rt_size_t size; /**< size of memory pool */
  1027. rt_size_t block_size; /**< size of memory blocks */
  1028. rt_uint8_t *block_list; /**< memory blocks list */
  1029. rt_size_t block_total_count; /**< numbers of memory block */
  1030. rt_size_t block_free_count; /**< numbers of free memory block */
  1031. rt_list_t suspend_thread; /**< threads pended on this resource */
  1032. struct rt_spinlock spinlock;
  1033. };
  1034. typedef struct rt_mempool *rt_mp_t;
  1035. #endif /* RT_USING_MEMPOOL */
  1036. /**@}*/
  1037. #ifdef RT_USING_DEVICE
  1038. /**
  1039. * @addtogroup group_device_driver
  1040. */
  1041. /**@{*/
  1042. /**
  1043. * device (I/O) class type
  1044. */
  1045. enum rt_device_class_type
  1046. {
  1047. RT_Device_Class_Char = 0, /**< character device */
  1048. RT_Device_Class_Block, /**< block device */
  1049. RT_Device_Class_NetIf, /**< net interface */
  1050. RT_Device_Class_MTD, /**< memory device */
  1051. RT_Device_Class_CAN, /**< CAN device */
  1052. RT_Device_Class_RTC, /**< RTC device */
  1053. RT_Device_Class_Sound, /**< Sound device */
  1054. RT_Device_Class_Graphic, /**< Graphic device */
  1055. RT_Device_Class_I2CBUS, /**< I2C bus device */
  1056. RT_Device_Class_USBDevice, /**< USB slave device */
  1057. RT_Device_Class_USBHost, /**< USB host bus */
  1058. RT_Device_Class_USBOTG, /**< USB OTG bus */
  1059. RT_Device_Class_SPIBUS, /**< SPI bus device */
  1060. RT_Device_Class_SPIDevice, /**< SPI device */
  1061. RT_Device_Class_SDIO, /**< SDIO bus device */
  1062. RT_Device_Class_PM, /**< PM pseudo device */
  1063. RT_Device_Class_Pipe, /**< Pipe device */
  1064. RT_Device_Class_Portal, /**< Portal device */
  1065. RT_Device_Class_Timer, /**< Timer device */
  1066. RT_Device_Class_Miscellaneous, /**< Miscellaneous device */
  1067. RT_Device_Class_Sensor, /**< Sensor device */
  1068. RT_Device_Class_Touch, /**< Touch device */
  1069. RT_Device_Class_PHY, /**< PHY device */
  1070. RT_Device_Class_Security, /**< Security device */
  1071. RT_Device_Class_WLAN, /**< WLAN device */
  1072. RT_Device_Class_Pin, /**< Pin device */
  1073. RT_Device_Class_ADC, /**< ADC device */
  1074. RT_Device_Class_DAC, /**< DAC device */
  1075. RT_Device_Class_WDT, /**< WDT device */
  1076. RT_Device_Class_PWM, /**< PWM device */
  1077. RT_Device_Class_Bus, /**< Bus device */
  1078. RT_Device_Class_Unknown /**< unknown device */
  1079. };
  1080. /**
  1081. * device flags definitions
  1082. */
  1083. #define RT_DEVICE_FLAG_DEACTIVATE 0x000 /**< device is not not initialized */
  1084. #define RT_DEVICE_FLAG_RDONLY 0x001 /**< read only */
  1085. #define RT_DEVICE_FLAG_WRONLY 0x002 /**< write only */
  1086. #define RT_DEVICE_FLAG_RDWR 0x003 /**< read and write */
  1087. #define RT_DEVICE_FLAG_REMOVABLE 0x004 /**< removable device */
  1088. #define RT_DEVICE_FLAG_STANDALONE 0x008 /**< standalone device */
  1089. #define RT_DEVICE_FLAG_ACTIVATED 0x010 /**< device is activated */
  1090. #define RT_DEVICE_FLAG_SUSPENDED 0x020 /**< device is suspended */
  1091. #define RT_DEVICE_FLAG_STREAM 0x040 /**< stream mode */
  1092. #define RT_DEVICE_FLAG_DYNAMIC 0x080 /**< device is determined when open() */
  1093. #define RT_DEVICE_FLAG_INT_RX 0x100 /**< INT mode on Rx */
  1094. #define RT_DEVICE_FLAG_DMA_RX 0x200 /**< DMA mode on Rx */
  1095. #define RT_DEVICE_FLAG_INT_TX 0x400 /**< INT mode on Tx */
  1096. #define RT_DEVICE_FLAG_DMA_TX 0x800 /**< DMA mode on Tx */
  1097. #define RT_DEVICE_OFLAG_CLOSE 0x000 /**< device is closed */
  1098. #define RT_DEVICE_OFLAG_RDONLY 0x001 /**< read only access */
  1099. #define RT_DEVICE_OFLAG_WRONLY 0x002 /**< write only access */
  1100. #define RT_DEVICE_OFLAG_RDWR 0x003 /**< read and write */
  1101. #define RT_DEVICE_OFLAG_OPEN 0x008 /**< device is opened */
  1102. #define RT_DEVICE_OFLAG_MASK 0xf0f /**< mask of open flag */
  1103. /**
  1104. * general device commands
  1105. * 0x01 - 0x1F general device control commands
  1106. * 0x20 - 0x3F udevice control commands
  1107. * 0x40 - special device control commands
  1108. */
  1109. #define RT_DEVICE_CTRL_RESUME 0x01 /**< resume device */
  1110. #define RT_DEVICE_CTRL_SUSPEND 0x02 /**< suspend device */
  1111. #define RT_DEVICE_CTRL_CONFIG 0x03 /**< configure device */
  1112. #define RT_DEVICE_CTRL_CLOSE 0x04 /**< close device */
  1113. #define RT_DEVICE_CTRL_NOTIFY_SET 0x05 /**< set notify func */
  1114. #define RT_DEVICE_CTRL_SET_INT 0x06 /**< set interrupt */
  1115. #define RT_DEVICE_CTRL_CLR_INT 0x07 /**< clear interrupt */
  1116. #define RT_DEVICE_CTRL_GET_INT 0x08 /**< get interrupt status */
  1117. #define RT_DEVICE_CTRL_CONSOLE_OFLAG 0x09 /**< get console open flag */
  1118. #define RT_DEVICE_CTRL_MASK 0x1f /**< mask for contrl commands */
  1119. /**
  1120. * device control
  1121. */
  1122. #define RT_DEVICE_CTRL_BASE(Type) ((RT_Device_Class_##Type + 1) * 0x100)
  1123. typedef struct rt_driver *rt_driver_t;
  1124. typedef struct rt_device *rt_device_t;
  1125. #ifdef RT_USING_DEVICE_OPS
  1126. /**
  1127. * operations set for device object
  1128. */
  1129. struct rt_device_ops
  1130. {
  1131. /* common device interface */
  1132. rt_err_t (*init) (rt_device_t dev);
  1133. rt_err_t (*open) (rt_device_t dev, rt_uint16_t oflag);
  1134. rt_err_t (*close) (rt_device_t dev);
  1135. rt_ssize_t (*read) (rt_device_t dev, rt_off_t pos, void *buffer, rt_size_t size);
  1136. rt_ssize_t (*write) (rt_device_t dev, rt_off_t pos, const void *buffer, rt_size_t size);
  1137. rt_err_t (*control)(rt_device_t dev, int cmd, void *args);
  1138. };
  1139. #endif /* RT_USING_DEVICE_OPS */
  1140. /**
  1141. * WaitQueue structure
  1142. */
  1143. struct rt_wqueue
  1144. {
  1145. rt_uint32_t flag;
  1146. rt_list_t waiting_list;
  1147. struct rt_spinlock spinlock;
  1148. };
  1149. typedef struct rt_wqueue rt_wqueue_t;
  1150. #ifdef RT_USING_DM
  1151. struct rt_driver;
  1152. struct rt_bus;
  1153. #endif /* RT_USING_DM */
  1154. /**
  1155. * Device structure
  1156. */
  1157. struct rt_device
  1158. {
  1159. struct rt_object parent; /**< inherit from rt_object */
  1160. #ifdef RT_USING_DM
  1161. struct rt_bus *bus; /**< the bus mounting to */
  1162. rt_list_t node; /**< to mount on bus */
  1163. struct rt_driver *drv; /**< driver for powering the device */
  1164. #ifdef RT_USING_OFW
  1165. void *ofw_node; /**< ofw node get from device tree */
  1166. #endif /* RT_USING_OFW */
  1167. void *power_domain_unit;
  1168. #ifdef RT_USING_DMA
  1169. const void *dma_ops;
  1170. #endif
  1171. #endif /* RT_USING_DM */
  1172. enum rt_device_class_type type; /**< device type */
  1173. rt_uint16_t flag; /**< device flag */
  1174. rt_uint16_t open_flag; /**< device open flag */
  1175. rt_uint8_t ref_count; /**< reference count */
  1176. #ifdef RT_USING_DM
  1177. rt_uint8_t master_id; /**< 0 - 255 */
  1178. #endif
  1179. rt_uint8_t device_id; /**< 0 - 255 */
  1180. /* device call back */
  1181. rt_err_t (*rx_indicate)(rt_device_t dev, rt_size_t size);
  1182. rt_err_t (*tx_complete)(rt_device_t dev, void *buffer);
  1183. #ifdef RT_USING_DEVICE_OPS
  1184. const struct rt_device_ops *ops;
  1185. #else
  1186. /* common device interface */
  1187. rt_err_t (*init) (rt_device_t dev);
  1188. rt_err_t (*open) (rt_device_t dev, rt_uint16_t oflag);
  1189. rt_err_t (*close) (rt_device_t dev);
  1190. rt_ssize_t (*read) (rt_device_t dev, rt_off_t pos, void *buffer, rt_size_t size);
  1191. rt_ssize_t (*write) (rt_device_t dev, rt_off_t pos, const void *buffer, rt_size_t size);
  1192. rt_err_t (*control)(rt_device_t dev, int cmd, void *args);
  1193. #endif /* RT_USING_DEVICE_OPS */
  1194. #ifdef RT_USING_POSIX_DEVIO
  1195. const struct dfs_file_ops *fops;
  1196. struct rt_wqueue wait_queue;
  1197. #endif /* RT_USING_POSIX_DEVIO */
  1198. rt_err_t (*readlink)
  1199. (rt_device_t dev, char *buf, int len); /**< for dynamic device */
  1200. void *user_data; /**< device private data */
  1201. };
  1202. /**
  1203. * Notify structure
  1204. */
  1205. struct rt_device_notify
  1206. {
  1207. void (*notify)(rt_device_t dev);
  1208. struct rt_device *dev;
  1209. };
  1210. #ifdef RT_USING_SMART
  1211. struct rt_channel
  1212. {
  1213. struct rt_ipc_object parent; /**< inherit from object */
  1214. struct rt_thread *reply; /**< the thread will be reply */
  1215. struct rt_spinlock slock; /**< spinlock of this channel */
  1216. rt_list_t wait_msg; /**< the wait queue of sender msg */
  1217. rt_list_t wait_thread; /**< the wait queue of sender thread */
  1218. rt_wqueue_t reader_queue; /**< channel poll queue */
  1219. rt_uint8_t stat; /**< the status of this channel */
  1220. rt_ubase_t ref;
  1221. };
  1222. typedef struct rt_channel *rt_channel_t;
  1223. #endif /* RT_USING_SMART */
  1224. /**@}*/
  1225. #endif /* RT_USING_DEVICE */
  1226. #ifdef __cplusplus
  1227. }
  1228. #endif
  1229. #ifdef __cplusplus
  1230. /* RT-Thread definitions for C++ */
  1231. namespace rtthread {
  1232. enum TICK_WAIT {
  1233. WAIT_NONE = 0,
  1234. WAIT_FOREVER = -1,
  1235. };
  1236. }
  1237. #endif /* __cplusplus */
  1238. #endif /* __RT_DEF_H__ */