rtdef.h 55 KB

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