queue.h 64 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716
  1. /*
  2. * FreeRTOS Kernel V10.4.3
  3. * Copyright (C) 2020 Amazon.com, Inc. or its affiliates. All Rights Reserved.
  4. *
  5. * Permission is hereby granted, free of charge, to any person obtaining a copy of
  6. * this software and associated documentation files (the "Software"), to deal in
  7. * the Software without restriction, including without limitation the rights to
  8. * use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of
  9. * the Software, and to permit persons to whom the Software is furnished to do so,
  10. * subject to the following conditions:
  11. *
  12. * The above copyright notice and this permission notice shall be included in all
  13. * copies or substantial portions of the Software.
  14. *
  15. * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
  16. * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
  17. * FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
  18. * COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER
  19. * IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
  20. * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
  21. *
  22. * https://www.FreeRTOS.org
  23. * https://github.com/FreeRTOS
  24. *
  25. */
  26. #ifndef QUEUE_H
  27. #define QUEUE_H
  28. #ifndef INC_FREERTOS_H
  29. #error "include FreeRTOS.h" must appear in source files before "include queue.h"
  30. #endif
  31. /* *INDENT-OFF* */
  32. #ifdef __cplusplus
  33. extern "C" {
  34. #endif
  35. /* *INDENT-ON* */
  36. #include "task.h"
  37. /**
  38. * Type by which queues are referenced. For example, a call to xQueueCreate()
  39. * returns an QueueHandle_t variable that can then be used as a parameter to
  40. * xQueueSend(), xQueueReceive(), etc.
  41. */
  42. struct QueueDefinition; /* Using old naming convention so as not to break kernel aware debuggers. */
  43. typedef struct QueueDefinition * QueueHandle_t;
  44. /**
  45. * Type by which queue sets are referenced. For example, a call to
  46. * xQueueCreateSet() returns an xQueueSet variable that can then be used as a
  47. * parameter to xQueueSelectFromSet(), xQueueAddToSet(), etc.
  48. */
  49. typedef struct QueueDefinition * QueueSetHandle_t;
  50. /**
  51. * Queue sets can contain both queues and semaphores, so the
  52. * QueueSetMemberHandle_t is defined as a type to be used where a parameter or
  53. * return value can be either an QueueHandle_t or an SemaphoreHandle_t.
  54. */
  55. typedef struct QueueDefinition * QueueSetMemberHandle_t;
  56. /* For internal use only. */
  57. #define queueSEND_TO_BACK ( ( BaseType_t ) 0 )
  58. #define queueSEND_TO_FRONT ( ( BaseType_t ) 1 )
  59. #define queueOVERWRITE ( ( BaseType_t ) 2 )
  60. /* For internal use only. These definitions *must* match those in queue.c. */
  61. #define queueQUEUE_TYPE_BASE ( ( uint8_t ) 0U )
  62. #define queueQUEUE_TYPE_SET ( ( uint8_t ) 0U )
  63. #define queueQUEUE_TYPE_MUTEX ( ( uint8_t ) 1U )
  64. #define queueQUEUE_TYPE_COUNTING_SEMAPHORE ( ( uint8_t ) 2U )
  65. #define queueQUEUE_TYPE_BINARY_SEMAPHORE ( ( uint8_t ) 3U )
  66. #define queueQUEUE_TYPE_RECURSIVE_MUTEX ( ( uint8_t ) 4U )
  67. /**
  68. * queue. h
  69. * <pre>
  70. * QueueHandle_t xQueueCreate(
  71. * UBaseType_t uxQueueLength,
  72. * UBaseType_t uxItemSize
  73. * );
  74. * </pre>
  75. *
  76. * Creates a new queue instance, and returns a handle by which the new queue
  77. * can be referenced.
  78. *
  79. * Internally, within the FreeRTOS implementation, queues use two blocks of
  80. * memory. The first block is used to hold the queue's data structures. The
  81. * second block is used to hold items placed into the queue. If a queue is
  82. * created using xQueueCreate() then both blocks of memory are automatically
  83. * dynamically allocated inside the xQueueCreate() function. (see
  84. * https://www.FreeRTOS.org/a00111.html). If a queue is created using
  85. * xQueueCreateStatic() then the application writer must provide the memory that
  86. * will get used by the queue. xQueueCreateStatic() therefore allows a queue to
  87. * be created without using any dynamic memory allocation.
  88. *
  89. * https://www.FreeRTOS.org/Embedded-RTOS-Queues.html
  90. *
  91. * @param uxQueueLength The maximum number of items that the queue can contain.
  92. *
  93. * @param uxItemSize The number of bytes each item in the queue will require.
  94. * Items are queued by copy, not by reference, so this is the number of bytes
  95. * that will be copied for each posted item. Each item on the queue must be
  96. * the same size.
  97. *
  98. * @return If the queue is successfully create then a handle to the newly
  99. * created queue is returned. If the queue cannot be created then 0 is
  100. * returned.
  101. *
  102. * Example usage:
  103. * <pre>
  104. * struct AMessage
  105. * {
  106. * char ucMessageID;
  107. * char ucData[ 20 ];
  108. * };
  109. *
  110. * void vATask( void *pvParameters )
  111. * {
  112. * QueueHandle_t xQueue1, xQueue2;
  113. *
  114. * // Create a queue capable of containing 10 uint32_t values.
  115. * xQueue1 = xQueueCreate( 10, sizeof( uint32_t ) );
  116. * if( xQueue1 == 0 )
  117. * {
  118. * // Queue was not created and must not be used.
  119. * }
  120. *
  121. * // Create a queue capable of containing 10 pointers to AMessage structures.
  122. * // These should be passed by pointer as they contain a lot of data.
  123. * xQueue2 = xQueueCreate( 10, sizeof( struct AMessage * ) );
  124. * if( xQueue2 == 0 )
  125. * {
  126. * // Queue was not created and must not be used.
  127. * }
  128. *
  129. * // ... Rest of task code.
  130. * }
  131. * </pre>
  132. * \defgroup xQueueCreate xQueueCreate
  133. * \ingroup QueueManagement
  134. */
  135. #if ( configSUPPORT_DYNAMIC_ALLOCATION == 1 )
  136. #define xQueueCreate( uxQueueLength, uxItemSize ) xQueueGenericCreate( ( uxQueueLength ), ( uxItemSize ), ( queueQUEUE_TYPE_BASE ) )
  137. #endif
  138. /**
  139. * queue. h
  140. * <pre>
  141. * QueueHandle_t xQueueCreateStatic(
  142. * UBaseType_t uxQueueLength,
  143. * UBaseType_t uxItemSize,
  144. * uint8_t *pucQueueStorageBuffer,
  145. * StaticQueue_t *pxQueueBuffer
  146. * );
  147. * </pre>
  148. *
  149. * Creates a new queue instance, and returns a handle by which the new queue
  150. * can be referenced.
  151. *
  152. * Internally, within the FreeRTOS implementation, queues use two blocks of
  153. * memory. The first block is used to hold the queue's data structures. The
  154. * second block is used to hold items placed into the queue. If a queue is
  155. * created using xQueueCreate() then both blocks of memory are automatically
  156. * dynamically allocated inside the xQueueCreate() function. (see
  157. * https://www.FreeRTOS.org/a00111.html). If a queue is created using
  158. * xQueueCreateStatic() then the application writer must provide the memory that
  159. * will get used by the queue. xQueueCreateStatic() therefore allows a queue to
  160. * be created without using any dynamic memory allocation.
  161. *
  162. * https://www.FreeRTOS.org/Embedded-RTOS-Queues.html
  163. *
  164. * @param uxQueueLength The maximum number of items that the queue can contain.
  165. *
  166. * @param uxItemSize The number of bytes each item in the queue will require.
  167. * Items are queued by copy, not by reference, so this is the number of bytes
  168. * that will be copied for each posted item. Each item on the queue must be
  169. * the same size.
  170. *
  171. * @param pucQueueStorageBuffer If uxItemSize is not zero then
  172. * pucQueueStorageBuffer must point to a uint8_t array that is at least large
  173. * enough to hold the maximum number of items that can be in the queue at any
  174. * one time - which is ( uxQueueLength * uxItemsSize ) bytes. If uxItemSize is
  175. * zero then pucQueueStorageBuffer can be NULL.
  176. *
  177. * @param pxQueueBuffer Must point to a variable of type StaticQueue_t, which
  178. * will be used to hold the queue's data structure.
  179. *
  180. * @return If the queue is created then a handle to the created queue is
  181. * returned. If pxQueueBuffer is NULL then NULL is returned.
  182. *
  183. * Example usage:
  184. * <pre>
  185. * struct AMessage
  186. * {
  187. * char ucMessageID;
  188. * char ucData[ 20 ];
  189. * };
  190. *
  191. #define QUEUE_LENGTH 10
  192. #define ITEM_SIZE sizeof( uint32_t )
  193. *
  194. * // xQueueBuffer will hold the queue structure.
  195. * StaticQueue_t xQueueBuffer;
  196. *
  197. * // ucQueueStorage will hold the items posted to the queue. Must be at least
  198. * // [(queue length) * ( queue item size)] bytes long.
  199. * uint8_t ucQueueStorage[ QUEUE_LENGTH * ITEM_SIZE ];
  200. *
  201. * void vATask( void *pvParameters )
  202. * {
  203. * QueueHandle_t xQueue1;
  204. *
  205. * // Create a queue capable of containing 10 uint32_t values.
  206. * xQueue1 = xQueueCreate( QUEUE_LENGTH, // The number of items the queue can hold.
  207. * ITEM_SIZE // The size of each item in the queue
  208. * &( ucQueueStorage[ 0 ] ), // The buffer that will hold the items in the queue.
  209. * &xQueueBuffer ); // The buffer that will hold the queue structure.
  210. *
  211. * // The queue is guaranteed to be created successfully as no dynamic memory
  212. * // allocation is used. Therefore xQueue1 is now a handle to a valid queue.
  213. *
  214. * // ... Rest of task code.
  215. * }
  216. * </pre>
  217. * \defgroup xQueueCreateStatic xQueueCreateStatic
  218. * \ingroup QueueManagement
  219. */
  220. #if ( configSUPPORT_STATIC_ALLOCATION == 1 )
  221. #define xQueueCreateStatic( uxQueueLength, uxItemSize, pucQueueStorage, pxQueueBuffer ) xQueueGenericCreateStatic( ( uxQueueLength ), ( uxItemSize ), ( pucQueueStorage ), ( pxQueueBuffer ), ( queueQUEUE_TYPE_BASE ) )
  222. #endif /* configSUPPORT_STATIC_ALLOCATION */
  223. /**
  224. * queue. h
  225. * <pre>
  226. * BaseType_t xQueueSendToToFront(
  227. * QueueHandle_t xQueue,
  228. * const void *pvItemToQueue,
  229. * TickType_t xTicksToWait
  230. * );
  231. * </pre>
  232. *
  233. * Post an item to the front of a queue. The item is queued by copy, not by
  234. * reference. This function must not be called from an interrupt service
  235. * routine. See xQueueSendFromISR () for an alternative which may be used
  236. * in an ISR.
  237. *
  238. * @param xQueue The handle to the queue on which the item is to be posted.
  239. *
  240. * @param pvItemToQueue A pointer to the item that is to be placed on the
  241. * queue. The size of the items the queue will hold was defined when the
  242. * queue was created, so this many bytes will be copied from pvItemToQueue
  243. * into the queue storage area.
  244. *
  245. * @param xTicksToWait The maximum amount of time the task should block
  246. * waiting for space to become available on the queue, should it already
  247. * be full. The call will return immediately if this is set to 0 and the
  248. * queue is full. The time is defined in tick periods so the constant
  249. * portTICK_PERIOD_MS should be used to convert to real time if this is required.
  250. *
  251. * @return pdTRUE if the item was successfully posted, otherwise errQUEUE_FULL.
  252. *
  253. * Example usage:
  254. * <pre>
  255. * struct AMessage
  256. * {
  257. * char ucMessageID;
  258. * char ucData[ 20 ];
  259. * } xMessage;
  260. *
  261. * uint32_t ulVar = 10UL;
  262. *
  263. * void vATask( void *pvParameters )
  264. * {
  265. * QueueHandle_t xQueue1, xQueue2;
  266. * struct AMessage *pxMessage;
  267. *
  268. * // Create a queue capable of containing 10 uint32_t values.
  269. * xQueue1 = xQueueCreate( 10, sizeof( uint32_t ) );
  270. *
  271. * // Create a queue capable of containing 10 pointers to AMessage structures.
  272. * // These should be passed by pointer as they contain a lot of data.
  273. * xQueue2 = xQueueCreate( 10, sizeof( struct AMessage * ) );
  274. *
  275. * // ...
  276. *
  277. * if( xQueue1 != 0 )
  278. * {
  279. * // Send an uint32_t. Wait for 10 ticks for space to become
  280. * // available if necessary.
  281. * if( xQueueSendToFront( xQueue1, ( void * ) &ulVar, ( TickType_t ) 10 ) != pdPASS )
  282. * {
  283. * // Failed to post the message, even after 10 ticks.
  284. * }
  285. * }
  286. *
  287. * if( xQueue2 != 0 )
  288. * {
  289. * // Send a pointer to a struct AMessage object. Don't block if the
  290. * // queue is already full.
  291. * pxMessage = & xMessage;
  292. * xQueueSendToFront( xQueue2, ( void * ) &pxMessage, ( TickType_t ) 0 );
  293. * }
  294. *
  295. * // ... Rest of task code.
  296. * }
  297. * </pre>
  298. * \defgroup xQueueSend xQueueSend
  299. * \ingroup QueueManagement
  300. */
  301. #define xQueueSendToFront( xQueue, pvItemToQueue, xTicksToWait ) \
  302. xQueueGenericSend( ( xQueue ), ( pvItemToQueue ), ( xTicksToWait ), queueSEND_TO_FRONT )
  303. /**
  304. * queue. h
  305. * <pre>
  306. * BaseType_t xQueueSendToBack(
  307. * QueueHandle_t xQueue,
  308. * const void *pvItemToQueue,
  309. * TickType_t xTicksToWait
  310. * );
  311. * </pre>
  312. *
  313. * This is a macro that calls xQueueGenericSend().
  314. *
  315. * Post an item to the back of a queue. The item is queued by copy, not by
  316. * reference. This function must not be called from an interrupt service
  317. * routine. See xQueueSendFromISR () for an alternative which may be used
  318. * in an ISR.
  319. *
  320. * @param xQueue The handle to the queue on which the item is to be posted.
  321. *
  322. * @param pvItemToQueue A pointer to the item that is to be placed on the
  323. * queue. The size of the items the queue will hold was defined when the
  324. * queue was created, so this many bytes will be copied from pvItemToQueue
  325. * into the queue storage area.
  326. *
  327. * @param xTicksToWait The maximum amount of time the task should block
  328. * waiting for space to become available on the queue, should it already
  329. * be full. The call will return immediately if this is set to 0 and the queue
  330. * is full. The time is defined in tick periods so the constant
  331. * portTICK_PERIOD_MS should be used to convert to real time if this is required.
  332. *
  333. * @return pdTRUE if the item was successfully posted, otherwise errQUEUE_FULL.
  334. *
  335. * Example usage:
  336. * <pre>
  337. * struct AMessage
  338. * {
  339. * char ucMessageID;
  340. * char ucData[ 20 ];
  341. * } xMessage;
  342. *
  343. * uint32_t ulVar = 10UL;
  344. *
  345. * void vATask( void *pvParameters )
  346. * {
  347. * QueueHandle_t xQueue1, xQueue2;
  348. * struct AMessage *pxMessage;
  349. *
  350. * // Create a queue capable of containing 10 uint32_t values.
  351. * xQueue1 = xQueueCreate( 10, sizeof( uint32_t ) );
  352. *
  353. * // Create a queue capable of containing 10 pointers to AMessage structures.
  354. * // These should be passed by pointer as they contain a lot of data.
  355. * xQueue2 = xQueueCreate( 10, sizeof( struct AMessage * ) );
  356. *
  357. * // ...
  358. *
  359. * if( xQueue1 != 0 )
  360. * {
  361. * // Send an uint32_t. Wait for 10 ticks for space to become
  362. * // available if necessary.
  363. * if( xQueueSendToBack( xQueue1, ( void * ) &ulVar, ( TickType_t ) 10 ) != pdPASS )
  364. * {
  365. * // Failed to post the message, even after 10 ticks.
  366. * }
  367. * }
  368. *
  369. * if( xQueue2 != 0 )
  370. * {
  371. * // Send a pointer to a struct AMessage object. Don't block if the
  372. * // queue is already full.
  373. * pxMessage = & xMessage;
  374. * xQueueSendToBack( xQueue2, ( void * ) &pxMessage, ( TickType_t ) 0 );
  375. * }
  376. *
  377. * // ... Rest of task code.
  378. * }
  379. * </pre>
  380. * \defgroup xQueueSend xQueueSend
  381. * \ingroup QueueManagement
  382. */
  383. #define xQueueSendToBack( xQueue, pvItemToQueue, xTicksToWait ) \
  384. xQueueGenericSend( ( xQueue ), ( pvItemToQueue ), ( xTicksToWait ), queueSEND_TO_BACK )
  385. /**
  386. * queue. h
  387. * <pre>
  388. * BaseType_t xQueueSend(
  389. * QueueHandle_t xQueue,
  390. * const void * pvItemToQueue,
  391. * TickType_t xTicksToWait
  392. * );
  393. * </pre>
  394. *
  395. * This is a macro that calls xQueueGenericSend(). It is included for
  396. * backward compatibility with versions of FreeRTOS.org that did not
  397. * include the xQueueSendToFront() and xQueueSendToBack() macros. It is
  398. * equivalent to xQueueSendToBack().
  399. *
  400. * Post an item on a queue. The item is queued by copy, not by reference.
  401. * This function must not be called from an interrupt service routine.
  402. * See xQueueSendFromISR () for an alternative which may be used in an ISR.
  403. *
  404. * @param xQueue The handle to the queue on which the item is to be posted.
  405. *
  406. * @param pvItemToQueue A pointer to the item that is to be placed on the
  407. * queue. The size of the items the queue will hold was defined when the
  408. * queue was created, so this many bytes will be copied from pvItemToQueue
  409. * into the queue storage area.
  410. *
  411. * @param xTicksToWait The maximum amount of time the task should block
  412. * waiting for space to become available on the queue, should it already
  413. * be full. The call will return immediately if this is set to 0 and the
  414. * queue is full. The time is defined in tick periods so the constant
  415. * portTICK_PERIOD_MS should be used to convert to real time if this is required.
  416. *
  417. * @return pdTRUE if the item was successfully posted, otherwise errQUEUE_FULL.
  418. *
  419. * Example usage:
  420. * <pre>
  421. * struct AMessage
  422. * {
  423. * char ucMessageID;
  424. * char ucData[ 20 ];
  425. * } xMessage;
  426. *
  427. * uint32_t ulVar = 10UL;
  428. *
  429. * void vATask( void *pvParameters )
  430. * {
  431. * QueueHandle_t xQueue1, xQueue2;
  432. * struct AMessage *pxMessage;
  433. *
  434. * // Create a queue capable of containing 10 uint32_t values.
  435. * xQueue1 = xQueueCreate( 10, sizeof( uint32_t ) );
  436. *
  437. * // Create a queue capable of containing 10 pointers to AMessage structures.
  438. * // These should be passed by pointer as they contain a lot of data.
  439. * xQueue2 = xQueueCreate( 10, sizeof( struct AMessage * ) );
  440. *
  441. * // ...
  442. *
  443. * if( xQueue1 != 0 )
  444. * {
  445. * // Send an uint32_t. Wait for 10 ticks for space to become
  446. * // available if necessary.
  447. * if( xQueueSend( xQueue1, ( void * ) &ulVar, ( TickType_t ) 10 ) != pdPASS )
  448. * {
  449. * // Failed to post the message, even after 10 ticks.
  450. * }
  451. * }
  452. *
  453. * if( xQueue2 != 0 )
  454. * {
  455. * // Send a pointer to a struct AMessage object. Don't block if the
  456. * // queue is already full.
  457. * pxMessage = & xMessage;
  458. * xQueueSend( xQueue2, ( void * ) &pxMessage, ( TickType_t ) 0 );
  459. * }
  460. *
  461. * // ... Rest of task code.
  462. * }
  463. * </pre>
  464. * \defgroup xQueueSend xQueueSend
  465. * \ingroup QueueManagement
  466. */
  467. #define xQueueSend( xQueue, pvItemToQueue, xTicksToWait ) \
  468. xQueueGenericSend( ( xQueue ), ( pvItemToQueue ), ( xTicksToWait ), queueSEND_TO_BACK )
  469. /**
  470. * queue. h
  471. * <pre>
  472. * BaseType_t xQueueOverwrite(
  473. * QueueHandle_t xQueue,
  474. * const void * pvItemToQueue
  475. * );
  476. * </pre>
  477. *
  478. * Only for use with queues that have a length of one - so the queue is either
  479. * empty or full.
  480. *
  481. * Post an item on a queue. If the queue is already full then overwrite the
  482. * value held in the queue. The item is queued by copy, not by reference.
  483. *
  484. * This function must not be called from an interrupt service routine.
  485. * See xQueueOverwriteFromISR () for an alternative which may be used in an ISR.
  486. *
  487. * @param xQueue The handle of the queue to which the data is being sent.
  488. *
  489. * @param pvItemToQueue A pointer to the item that is to be placed on the
  490. * queue. The size of the items the queue will hold was defined when the
  491. * queue was created, so this many bytes will be copied from pvItemToQueue
  492. * into the queue storage area.
  493. *
  494. * @return xQueueOverwrite() is a macro that calls xQueueGenericSend(), and
  495. * therefore has the same return values as xQueueSendToFront(). However, pdPASS
  496. * is the only value that can be returned because xQueueOverwrite() will write
  497. * to the queue even when the queue is already full.
  498. *
  499. * Example usage:
  500. * <pre>
  501. *
  502. * void vFunction( void *pvParameters )
  503. * {
  504. * QueueHandle_t xQueue;
  505. * uint32_t ulVarToSend, ulValReceived;
  506. *
  507. * // Create a queue to hold one uint32_t value. It is strongly
  508. * // recommended *not* to use xQueueOverwrite() on queues that can
  509. * // contain more than one value, and doing so will trigger an assertion
  510. * // if configASSERT() is defined.
  511. * xQueue = xQueueCreate( 1, sizeof( uint32_t ) );
  512. *
  513. * // Write the value 10 to the queue using xQueueOverwrite().
  514. * ulVarToSend = 10;
  515. * xQueueOverwrite( xQueue, &ulVarToSend );
  516. *
  517. * // Peeking the queue should now return 10, but leave the value 10 in
  518. * // the queue. A block time of zero is used as it is known that the
  519. * // queue holds a value.
  520. * ulValReceived = 0;
  521. * xQueuePeek( xQueue, &ulValReceived, 0 );
  522. *
  523. * if( ulValReceived != 10 )
  524. * {
  525. * // Error unless the item was removed by a different task.
  526. * }
  527. *
  528. * // The queue is still full. Use xQueueOverwrite() to overwrite the
  529. * // value held in the queue with 100.
  530. * ulVarToSend = 100;
  531. * xQueueOverwrite( xQueue, &ulVarToSend );
  532. *
  533. * // This time read from the queue, leaving the queue empty once more.
  534. * // A block time of 0 is used again.
  535. * xQueueReceive( xQueue, &ulValReceived, 0 );
  536. *
  537. * // The value read should be the last value written, even though the
  538. * // queue was already full when the value was written.
  539. * if( ulValReceived != 100 )
  540. * {
  541. * // Error!
  542. * }
  543. *
  544. * // ...
  545. * }
  546. * </pre>
  547. * \defgroup xQueueOverwrite xQueueOverwrite
  548. * \ingroup QueueManagement
  549. */
  550. #define xQueueOverwrite( xQueue, pvItemToQueue ) \
  551. xQueueGenericSend( ( xQueue ), ( pvItemToQueue ), 0, queueOVERWRITE )
  552. /**
  553. * queue. h
  554. * <pre>
  555. * BaseType_t xQueueGenericSend(
  556. * QueueHandle_t xQueue,
  557. * const void * pvItemToQueue,
  558. * TickType_t xTicksToWait
  559. * BaseType_t xCopyPosition
  560. * );
  561. * </pre>
  562. *
  563. * It is preferred that the macros xQueueSend(), xQueueSendToFront() and
  564. * xQueueSendToBack() are used in place of calling this function directly.
  565. *
  566. * Post an item on a queue. The item is queued by copy, not by reference.
  567. * This function must not be called from an interrupt service routine.
  568. * See xQueueSendFromISR () for an alternative which may be used in an ISR.
  569. *
  570. * @param xQueue The handle to the queue on which the item is to be posted.
  571. *
  572. * @param pvItemToQueue A pointer to the item that is to be placed on the
  573. * queue. The size of the items the queue will hold was defined when the
  574. * queue was created, so this many bytes will be copied from pvItemToQueue
  575. * into the queue storage area.
  576. *
  577. * @param xTicksToWait The maximum amount of time the task should block
  578. * waiting for space to become available on the queue, should it already
  579. * be full. The call will return immediately if this is set to 0 and the
  580. * queue is full. The time is defined in tick periods so the constant
  581. * portTICK_PERIOD_MS should be used to convert to real time if this is required.
  582. *
  583. * @param xCopyPosition Can take the value queueSEND_TO_BACK to place the
  584. * item at the back of the queue, or queueSEND_TO_FRONT to place the item
  585. * at the front of the queue (for high priority messages).
  586. *
  587. * @return pdTRUE if the item was successfully posted, otherwise errQUEUE_FULL.
  588. *
  589. * Example usage:
  590. * <pre>
  591. * struct AMessage
  592. * {
  593. * char ucMessageID;
  594. * char ucData[ 20 ];
  595. * } xMessage;
  596. *
  597. * uint32_t ulVar = 10UL;
  598. *
  599. * void vATask( void *pvParameters )
  600. * {
  601. * QueueHandle_t xQueue1, xQueue2;
  602. * struct AMessage *pxMessage;
  603. *
  604. * // Create a queue capable of containing 10 uint32_t values.
  605. * xQueue1 = xQueueCreate( 10, sizeof( uint32_t ) );
  606. *
  607. * // Create a queue capable of containing 10 pointers to AMessage structures.
  608. * // These should be passed by pointer as they contain a lot of data.
  609. * xQueue2 = xQueueCreate( 10, sizeof( struct AMessage * ) );
  610. *
  611. * // ...
  612. *
  613. * if( xQueue1 != 0 )
  614. * {
  615. * // Send an uint32_t. Wait for 10 ticks for space to become
  616. * // available if necessary.
  617. * if( xQueueGenericSend( xQueue1, ( void * ) &ulVar, ( TickType_t ) 10, queueSEND_TO_BACK ) != pdPASS )
  618. * {
  619. * // Failed to post the message, even after 10 ticks.
  620. * }
  621. * }
  622. *
  623. * if( xQueue2 != 0 )
  624. * {
  625. * // Send a pointer to a struct AMessage object. Don't block if the
  626. * // queue is already full.
  627. * pxMessage = & xMessage;
  628. * xQueueGenericSend( xQueue2, ( void * ) &pxMessage, ( TickType_t ) 0, queueSEND_TO_BACK );
  629. * }
  630. *
  631. * // ... Rest of task code.
  632. * }
  633. * </pre>
  634. * \defgroup xQueueSend xQueueSend
  635. * \ingroup QueueManagement
  636. */
  637. BaseType_t xQueueGenericSend( QueueHandle_t xQueue,
  638. const void * const pvItemToQueue,
  639. TickType_t xTicksToWait,
  640. const BaseType_t xCopyPosition ) PRIVILEGED_FUNCTION;
  641. /**
  642. * queue. h
  643. * <pre>
  644. * BaseType_t xQueuePeek(
  645. * QueueHandle_t xQueue,
  646. * void * const pvBuffer,
  647. * TickType_t xTicksToWait
  648. * );
  649. * </pre>
  650. *
  651. * Receive an item from a queue without removing the item from the queue.
  652. * The item is received by copy so a buffer of adequate size must be
  653. * provided. The number of bytes copied into the buffer was defined when
  654. * the queue was created.
  655. *
  656. * Successfully received items remain on the queue so will be returned again
  657. * by the next call, or a call to xQueueReceive().
  658. *
  659. * This macro must not be used in an interrupt service routine. See
  660. * xQueuePeekFromISR() for an alternative that can be called from an interrupt
  661. * service routine.
  662. *
  663. * @param xQueue The handle to the queue from which the item is to be
  664. * received.
  665. *
  666. * @param pvBuffer Pointer to the buffer into which the received item will
  667. * be copied.
  668. *
  669. * @param xTicksToWait The maximum amount of time the task should block
  670. * waiting for an item to receive should the queue be empty at the time
  671. * of the call. The time is defined in tick periods so the constant
  672. * portTICK_PERIOD_MS should be used to convert to real time if this is required.
  673. * xQueuePeek() will return immediately if xTicksToWait is 0 and the queue
  674. * is empty.
  675. *
  676. * @return pdTRUE if an item was successfully received from the queue,
  677. * otherwise pdFALSE.
  678. *
  679. * Example usage:
  680. * <pre>
  681. * struct AMessage
  682. * {
  683. * char ucMessageID;
  684. * char ucData[ 20 ];
  685. * } xMessage;
  686. *
  687. * QueueHandle_t xQueue;
  688. *
  689. * // Task to create a queue and post a value.
  690. * void vATask( void *pvParameters )
  691. * {
  692. * struct AMessage *pxMessage;
  693. *
  694. * // Create a queue capable of containing 10 pointers to AMessage structures.
  695. * // These should be passed by pointer as they contain a lot of data.
  696. * xQueue = xQueueCreate( 10, sizeof( struct AMessage * ) );
  697. * if( xQueue == 0 )
  698. * {
  699. * // Failed to create the queue.
  700. * }
  701. *
  702. * // ...
  703. *
  704. * // Send a pointer to a struct AMessage object. Don't block if the
  705. * // queue is already full.
  706. * pxMessage = & xMessage;
  707. * xQueueSend( xQueue, ( void * ) &pxMessage, ( TickType_t ) 0 );
  708. *
  709. * // ... Rest of task code.
  710. * }
  711. *
  712. * // Task to peek the data from the queue.
  713. * void vADifferentTask( void *pvParameters )
  714. * {
  715. * struct AMessage *pxRxedMessage;
  716. *
  717. * if( xQueue != 0 )
  718. * {
  719. * // Peek a message on the created queue. Block for 10 ticks if a
  720. * // message is not immediately available.
  721. * if( xQueuePeek( xQueue, &( pxRxedMessage ), ( TickType_t ) 10 ) )
  722. * {
  723. * // pcRxedMessage now points to the struct AMessage variable posted
  724. * // by vATask, but the item still remains on the queue.
  725. * }
  726. * }
  727. *
  728. * // ... Rest of task code.
  729. * }
  730. * </pre>
  731. * \defgroup xQueuePeek xQueuePeek
  732. * \ingroup QueueManagement
  733. */
  734. BaseType_t xQueuePeek( QueueHandle_t xQueue,
  735. void * const pvBuffer,
  736. TickType_t xTicksToWait ) PRIVILEGED_FUNCTION;
  737. /**
  738. * queue. h
  739. * <pre>
  740. * BaseType_t xQueuePeekFromISR(
  741. * QueueHandle_t xQueue,
  742. * void *pvBuffer,
  743. * );
  744. * </pre>
  745. *
  746. * A version of xQueuePeek() that can be called from an interrupt service
  747. * routine (ISR).
  748. *
  749. * Receive an item from a queue without removing the item from the queue.
  750. * The item is received by copy so a buffer of adequate size must be
  751. * provided. The number of bytes copied into the buffer was defined when
  752. * the queue was created.
  753. *
  754. * Successfully received items remain on the queue so will be returned again
  755. * by the next call, or a call to xQueueReceive().
  756. *
  757. * @param xQueue The handle to the queue from which the item is to be
  758. * received.
  759. *
  760. * @param pvBuffer Pointer to the buffer into which the received item will
  761. * be copied.
  762. *
  763. * @return pdTRUE if an item was successfully received from the queue,
  764. * otherwise pdFALSE.
  765. *
  766. * \defgroup xQueuePeekFromISR xQueuePeekFromISR
  767. * \ingroup QueueManagement
  768. */
  769. BaseType_t xQueuePeekFromISR( QueueHandle_t xQueue,
  770. void * const pvBuffer ) PRIVILEGED_FUNCTION;
  771. /**
  772. * queue. h
  773. * <pre>
  774. * BaseType_t xQueueReceive(
  775. * QueueHandle_t xQueue,
  776. * void *pvBuffer,
  777. * TickType_t xTicksToWait
  778. * );
  779. * </pre>
  780. *
  781. * Receive an item from a queue. The item is received by copy so a buffer of
  782. * adequate size must be provided. The number of bytes copied into the buffer
  783. * was defined when the queue was created.
  784. *
  785. * Successfully received items are removed from the queue.
  786. *
  787. * This function must not be used in an interrupt service routine. See
  788. * xQueueReceiveFromISR for an alternative that can.
  789. *
  790. * @param xQueue The handle to the queue from which the item is to be
  791. * received.
  792. *
  793. * @param pvBuffer Pointer to the buffer into which the received item will
  794. * be copied.
  795. *
  796. * @param xTicksToWait The maximum amount of time the task should block
  797. * waiting for an item to receive should the queue be empty at the time
  798. * of the call. xQueueReceive() will return immediately if xTicksToWait
  799. * is zero and the queue is empty. The time is defined in tick periods so the
  800. * constant portTICK_PERIOD_MS should be used to convert to real time if this is
  801. * required.
  802. *
  803. * @return pdTRUE if an item was successfully received from the queue,
  804. * otherwise pdFALSE.
  805. *
  806. * Example usage:
  807. * <pre>
  808. * struct AMessage
  809. * {
  810. * char ucMessageID;
  811. * char ucData[ 20 ];
  812. * } xMessage;
  813. *
  814. * QueueHandle_t xQueue;
  815. *
  816. * // Task to create a queue and post a value.
  817. * void vATask( void *pvParameters )
  818. * {
  819. * struct AMessage *pxMessage;
  820. *
  821. * // Create a queue capable of containing 10 pointers to AMessage structures.
  822. * // These should be passed by pointer as they contain a lot of data.
  823. * xQueue = xQueueCreate( 10, sizeof( struct AMessage * ) );
  824. * if( xQueue == 0 )
  825. * {
  826. * // Failed to create the queue.
  827. * }
  828. *
  829. * // ...
  830. *
  831. * // Send a pointer to a struct AMessage object. Don't block if the
  832. * // queue is already full.
  833. * pxMessage = & xMessage;
  834. * xQueueSend( xQueue, ( void * ) &pxMessage, ( TickType_t ) 0 );
  835. *
  836. * // ... Rest of task code.
  837. * }
  838. *
  839. * // Task to receive from the queue.
  840. * void vADifferentTask( void *pvParameters )
  841. * {
  842. * struct AMessage *pxRxedMessage;
  843. *
  844. * if( xQueue != 0 )
  845. * {
  846. * // Receive a message on the created queue. Block for 10 ticks if a
  847. * // message is not immediately available.
  848. * if( xQueueReceive( xQueue, &( pxRxedMessage ), ( TickType_t ) 10 ) )
  849. * {
  850. * // pcRxedMessage now points to the struct AMessage variable posted
  851. * // by vATask.
  852. * }
  853. * }
  854. *
  855. * // ... Rest of task code.
  856. * }
  857. * </pre>
  858. * \defgroup xQueueReceive xQueueReceive
  859. * \ingroup QueueManagement
  860. */
  861. BaseType_t xQueueReceive( QueueHandle_t xQueue,
  862. void * const pvBuffer,
  863. TickType_t xTicksToWait ) PRIVILEGED_FUNCTION;
  864. /**
  865. * queue. h
  866. * <pre>
  867. * UBaseType_t uxQueueMessagesWaiting( const QueueHandle_t xQueue );
  868. * </pre>
  869. *
  870. * Return the number of messages stored in a queue.
  871. *
  872. * @param xQueue A handle to the queue being queried.
  873. *
  874. * @return The number of messages available in the queue.
  875. *
  876. * \defgroup uxQueueMessagesWaiting uxQueueMessagesWaiting
  877. * \ingroup QueueManagement
  878. */
  879. UBaseType_t uxQueueMessagesWaiting( const QueueHandle_t xQueue ) PRIVILEGED_FUNCTION;
  880. /**
  881. * queue. h
  882. * <pre>
  883. * UBaseType_t uxQueueSpacesAvailable( const QueueHandle_t xQueue );
  884. * </pre>
  885. *
  886. * Return the number of free spaces available in a queue. This is equal to the
  887. * number of items that can be sent to the queue before the queue becomes full
  888. * if no items are removed.
  889. *
  890. * @param xQueue A handle to the queue being queried.
  891. *
  892. * @return The number of spaces available in the queue.
  893. *
  894. * \defgroup uxQueueMessagesWaiting uxQueueMessagesWaiting
  895. * \ingroup QueueManagement
  896. */
  897. UBaseType_t uxQueueSpacesAvailable( const QueueHandle_t xQueue ) PRIVILEGED_FUNCTION;
  898. /**
  899. * queue. h
  900. * <pre>
  901. * void vQueueDelete( QueueHandle_t xQueue );
  902. * </pre>
  903. *
  904. * Delete a queue - freeing all the memory allocated for storing of items
  905. * placed on the queue.
  906. *
  907. * @param xQueue A handle to the queue to be deleted.
  908. *
  909. * \defgroup vQueueDelete vQueueDelete
  910. * \ingroup QueueManagement
  911. */
  912. void vQueueDelete( QueueHandle_t xQueue ) PRIVILEGED_FUNCTION;
  913. /**
  914. * queue. h
  915. * <pre>
  916. * BaseType_t xQueueSendToFrontFromISR(
  917. * QueueHandle_t xQueue,
  918. * const void *pvItemToQueue,
  919. * BaseType_t *pxHigherPriorityTaskWoken
  920. * );
  921. * </pre>
  922. *
  923. * This is a macro that calls xQueueGenericSendFromISR().
  924. *
  925. * Post an item to the front of a queue. It is safe to use this macro from
  926. * within an interrupt service routine.
  927. *
  928. * Items are queued by copy not reference so it is preferable to only
  929. * queue small items, especially when called from an ISR. In most cases
  930. * it would be preferable to store a pointer to the item being queued.
  931. *
  932. * @param xQueue The handle to the queue on which the item is to be posted.
  933. *
  934. * @param pvItemToQueue A pointer to the item that is to be placed on the
  935. * queue. The size of the items the queue will hold was defined when the
  936. * queue was created, so this many bytes will be copied from pvItemToQueue
  937. * into the queue storage area.
  938. *
  939. * @param pxHigherPriorityTaskWoken xQueueSendToFrontFromISR() will set
  940. * *pxHigherPriorityTaskWoken to pdTRUE if sending to the queue caused a task
  941. * to unblock, and the unblocked task has a priority higher than the currently
  942. * running task. If xQueueSendToFromFromISR() sets this value to pdTRUE then
  943. * a context switch should be requested before the interrupt is exited.
  944. *
  945. * @return pdTRUE if the data was successfully sent to the queue, otherwise
  946. * errQUEUE_FULL.
  947. *
  948. * Example usage for buffered IO (where the ISR can obtain more than one value
  949. * per call):
  950. * <pre>
  951. * void vBufferISR( void )
  952. * {
  953. * char cIn;
  954. * BaseType_t xHigherPrioritTaskWoken;
  955. *
  956. * // We have not woken a task at the start of the ISR.
  957. * xHigherPriorityTaskWoken = pdFALSE;
  958. *
  959. * // Loop until the buffer is empty.
  960. * do
  961. * {
  962. * // Obtain a byte from the buffer.
  963. * cIn = portINPUT_BYTE( RX_REGISTER_ADDRESS );
  964. *
  965. * // Post the byte.
  966. * xQueueSendToFrontFromISR( xRxQueue, &cIn, &xHigherPriorityTaskWoken );
  967. *
  968. * } while( portINPUT_BYTE( BUFFER_COUNT ) );
  969. *
  970. * // Now the buffer is empty we can switch context if necessary.
  971. * if( xHigherPriorityTaskWoken )
  972. * {
  973. * taskYIELD ();
  974. * }
  975. * }
  976. * </pre>
  977. *
  978. * \defgroup xQueueSendFromISR xQueueSendFromISR
  979. * \ingroup QueueManagement
  980. */
  981. #define xQueueSendToFrontFromISR( xQueue, pvItemToQueue, pxHigherPriorityTaskWoken ) \
  982. xQueueGenericSendFromISR( ( xQueue ), ( pvItemToQueue ), ( pxHigherPriorityTaskWoken ), queueSEND_TO_FRONT )
  983. /**
  984. * queue. h
  985. * <pre>
  986. * BaseType_t xQueueSendToBackFromISR(
  987. * QueueHandle_t xQueue,
  988. * const void *pvItemToQueue,
  989. * BaseType_t *pxHigherPriorityTaskWoken
  990. * );
  991. * </pre>
  992. *
  993. * This is a macro that calls xQueueGenericSendFromISR().
  994. *
  995. * Post an item to the back of a queue. It is safe to use this macro from
  996. * within an interrupt service routine.
  997. *
  998. * Items are queued by copy not reference so it is preferable to only
  999. * queue small items, especially when called from an ISR. In most cases
  1000. * it would be preferable to store a pointer to the item being queued.
  1001. *
  1002. * @param xQueue The handle to the queue on which the item is to be posted.
  1003. *
  1004. * @param pvItemToQueue A pointer to the item that is to be placed on the
  1005. * queue. The size of the items the queue will hold was defined when the
  1006. * queue was created, so this many bytes will be copied from pvItemToQueue
  1007. * into the queue storage area.
  1008. *
  1009. * @param pxHigherPriorityTaskWoken xQueueSendToBackFromISR() will set
  1010. * *pxHigherPriorityTaskWoken to pdTRUE if sending to the queue caused a task
  1011. * to unblock, and the unblocked task has a priority higher than the currently
  1012. * running task. If xQueueSendToBackFromISR() sets this value to pdTRUE then
  1013. * a context switch should be requested before the interrupt is exited.
  1014. *
  1015. * @return pdTRUE if the data was successfully sent to the queue, otherwise
  1016. * errQUEUE_FULL.
  1017. *
  1018. * Example usage for buffered IO (where the ISR can obtain more than one value
  1019. * per call):
  1020. * <pre>
  1021. * void vBufferISR( void )
  1022. * {
  1023. * char cIn;
  1024. * BaseType_t xHigherPriorityTaskWoken;
  1025. *
  1026. * // We have not woken a task at the start of the ISR.
  1027. * xHigherPriorityTaskWoken = pdFALSE;
  1028. *
  1029. * // Loop until the buffer is empty.
  1030. * do
  1031. * {
  1032. * // Obtain a byte from the buffer.
  1033. * cIn = portINPUT_BYTE( RX_REGISTER_ADDRESS );
  1034. *
  1035. * // Post the byte.
  1036. * xQueueSendToBackFromISR( xRxQueue, &cIn, &xHigherPriorityTaskWoken );
  1037. *
  1038. * } while( portINPUT_BYTE( BUFFER_COUNT ) );
  1039. *
  1040. * // Now the buffer is empty we can switch context if necessary.
  1041. * if( xHigherPriorityTaskWoken )
  1042. * {
  1043. * taskYIELD ();
  1044. * }
  1045. * }
  1046. * </pre>
  1047. *
  1048. * \defgroup xQueueSendFromISR xQueueSendFromISR
  1049. * \ingroup QueueManagement
  1050. */
  1051. #define xQueueSendToBackFromISR( xQueue, pvItemToQueue, pxHigherPriorityTaskWoken ) \
  1052. xQueueGenericSendFromISR( ( xQueue ), ( pvItemToQueue ), ( pxHigherPriorityTaskWoken ), queueSEND_TO_BACK )
  1053. /**
  1054. * queue. h
  1055. * <pre>
  1056. * BaseType_t xQueueOverwriteFromISR(
  1057. * QueueHandle_t xQueue,
  1058. * const void * pvItemToQueue,
  1059. * BaseType_t *pxHigherPriorityTaskWoken
  1060. * );
  1061. * </pre>
  1062. *
  1063. * A version of xQueueOverwrite() that can be used in an interrupt service
  1064. * routine (ISR).
  1065. *
  1066. * Only for use with queues that can hold a single item - so the queue is either
  1067. * empty or full.
  1068. *
  1069. * Post an item on a queue. If the queue is already full then overwrite the
  1070. * value held in the queue. The item is queued by copy, not by reference.
  1071. *
  1072. * @param xQueue The handle to the queue on which the item is to be posted.
  1073. *
  1074. * @param pvItemToQueue A pointer to the item that is to be placed on the
  1075. * queue. The size of the items the queue will hold was defined when the
  1076. * queue was created, so this many bytes will be copied from pvItemToQueue
  1077. * into the queue storage area.
  1078. *
  1079. * @param pxHigherPriorityTaskWoken xQueueOverwriteFromISR() will set
  1080. * *pxHigherPriorityTaskWoken to pdTRUE if sending to the queue caused a task
  1081. * to unblock, and the unblocked task has a priority higher than the currently
  1082. * running task. If xQueueOverwriteFromISR() sets this value to pdTRUE then
  1083. * a context switch should be requested before the interrupt is exited.
  1084. *
  1085. * @return xQueueOverwriteFromISR() is a macro that calls
  1086. * xQueueGenericSendFromISR(), and therefore has the same return values as
  1087. * xQueueSendToFrontFromISR(). However, pdPASS is the only value that can be
  1088. * returned because xQueueOverwriteFromISR() will write to the queue even when
  1089. * the queue is already full.
  1090. *
  1091. * Example usage:
  1092. * <pre>
  1093. *
  1094. * QueueHandle_t xQueue;
  1095. *
  1096. * void vFunction( void *pvParameters )
  1097. * {
  1098. * // Create a queue to hold one uint32_t value. It is strongly
  1099. * // recommended *not* to use xQueueOverwriteFromISR() on queues that can
  1100. * // contain more than one value, and doing so will trigger an assertion
  1101. * // if configASSERT() is defined.
  1102. * xQueue = xQueueCreate( 1, sizeof( uint32_t ) );
  1103. * }
  1104. *
  1105. * void vAnInterruptHandler( void )
  1106. * {
  1107. * // xHigherPriorityTaskWoken must be set to pdFALSE before it is used.
  1108. * BaseType_t xHigherPriorityTaskWoken = pdFALSE;
  1109. * uint32_t ulVarToSend, ulValReceived;
  1110. *
  1111. * // Write the value 10 to the queue using xQueueOverwriteFromISR().
  1112. * ulVarToSend = 10;
  1113. * xQueueOverwriteFromISR( xQueue, &ulVarToSend, &xHigherPriorityTaskWoken );
  1114. *
  1115. * // The queue is full, but calling xQueueOverwriteFromISR() again will still
  1116. * // pass because the value held in the queue will be overwritten with the
  1117. * // new value.
  1118. * ulVarToSend = 100;
  1119. * xQueueOverwriteFromISR( xQueue, &ulVarToSend, &xHigherPriorityTaskWoken );
  1120. *
  1121. * // Reading from the queue will now return 100.
  1122. *
  1123. * // ...
  1124. *
  1125. * if( xHigherPrioritytaskWoken == pdTRUE )
  1126. * {
  1127. * // Writing to the queue caused a task to unblock and the unblocked task
  1128. * // has a priority higher than or equal to the priority of the currently
  1129. * // executing task (the task this interrupt interrupted). Perform a context
  1130. * // switch so this interrupt returns directly to the unblocked task.
  1131. * portYIELD_FROM_ISR(); // or portEND_SWITCHING_ISR() depending on the port.
  1132. * }
  1133. * }
  1134. * </pre>
  1135. * \defgroup xQueueOverwriteFromISR xQueueOverwriteFromISR
  1136. * \ingroup QueueManagement
  1137. */
  1138. #define xQueueOverwriteFromISR( xQueue, pvItemToQueue, pxHigherPriorityTaskWoken ) \
  1139. xQueueGenericSendFromISR( ( xQueue ), ( pvItemToQueue ), ( pxHigherPriorityTaskWoken ), queueOVERWRITE )
  1140. /**
  1141. * queue. h
  1142. * <pre>
  1143. * BaseType_t xQueueSendFromISR(
  1144. * QueueHandle_t xQueue,
  1145. * const void *pvItemToQueue,
  1146. * BaseType_t *pxHigherPriorityTaskWoken
  1147. * );
  1148. * </pre>
  1149. *
  1150. * This is a macro that calls xQueueGenericSendFromISR(). It is included
  1151. * for backward compatibility with versions of FreeRTOS.org that did not
  1152. * include the xQueueSendToBackFromISR() and xQueueSendToFrontFromISR()
  1153. * macros.
  1154. *
  1155. * Post an item to the back of a queue. It is safe to use this function from
  1156. * within an interrupt service routine.
  1157. *
  1158. * Items are queued by copy not reference so it is preferable to only
  1159. * queue small items, especially when called from an ISR. In most cases
  1160. * it would be preferable to store a pointer to the item being queued.
  1161. *
  1162. * @param xQueue The handle to the queue on which the item is to be posted.
  1163. *
  1164. * @param pvItemToQueue A pointer to the item that is to be placed on the
  1165. * queue. The size of the items the queue will hold was defined when the
  1166. * queue was created, so this many bytes will be copied from pvItemToQueue
  1167. * into the queue storage area.
  1168. *
  1169. * @param pxHigherPriorityTaskWoken xQueueSendFromISR() will set
  1170. * *pxHigherPriorityTaskWoken to pdTRUE if sending to the queue caused a task
  1171. * to unblock, and the unblocked task has a priority higher than the currently
  1172. * running task. If xQueueSendFromISR() sets this value to pdTRUE then
  1173. * a context switch should be requested before the interrupt is exited.
  1174. *
  1175. * @return pdTRUE if the data was successfully sent to the queue, otherwise
  1176. * errQUEUE_FULL.
  1177. *
  1178. * Example usage for buffered IO (where the ISR can obtain more than one value
  1179. * per call):
  1180. * <pre>
  1181. * void vBufferISR( void )
  1182. * {
  1183. * char cIn;
  1184. * BaseType_t xHigherPriorityTaskWoken;
  1185. *
  1186. * // We have not woken a task at the start of the ISR.
  1187. * xHigherPriorityTaskWoken = pdFALSE;
  1188. *
  1189. * // Loop until the buffer is empty.
  1190. * do
  1191. * {
  1192. * // Obtain a byte from the buffer.
  1193. * cIn = portINPUT_BYTE( RX_REGISTER_ADDRESS );
  1194. *
  1195. * // Post the byte.
  1196. * xQueueSendFromISR( xRxQueue, &cIn, &xHigherPriorityTaskWoken );
  1197. *
  1198. * } while( portINPUT_BYTE( BUFFER_COUNT ) );
  1199. *
  1200. * // Now the buffer is empty we can switch context if necessary.
  1201. * if( xHigherPriorityTaskWoken )
  1202. * {
  1203. * // Actual macro used here is port specific.
  1204. * portYIELD_FROM_ISR ();
  1205. * }
  1206. * }
  1207. * </pre>
  1208. *
  1209. * \defgroup xQueueSendFromISR xQueueSendFromISR
  1210. * \ingroup QueueManagement
  1211. */
  1212. #define xQueueSendFromISR( xQueue, pvItemToQueue, pxHigherPriorityTaskWoken ) \
  1213. xQueueGenericSendFromISR( ( xQueue ), ( pvItemToQueue ), ( pxHigherPriorityTaskWoken ), queueSEND_TO_BACK )
  1214. /**
  1215. * queue. h
  1216. * <pre>
  1217. * BaseType_t xQueueGenericSendFromISR(
  1218. * QueueHandle_t xQueue,
  1219. * const void *pvItemToQueue,
  1220. * BaseType_t *pxHigherPriorityTaskWoken,
  1221. * BaseType_t xCopyPosition
  1222. * );
  1223. * </pre>
  1224. *
  1225. * It is preferred that the macros xQueueSendFromISR(),
  1226. * xQueueSendToFrontFromISR() and xQueueSendToBackFromISR() be used in place
  1227. * of calling this function directly. xQueueGiveFromISR() is an
  1228. * equivalent for use by semaphores that don't actually copy any data.
  1229. *
  1230. * Post an item on a queue. It is safe to use this function from within an
  1231. * interrupt service routine.
  1232. *
  1233. * Items are queued by copy not reference so it is preferable to only
  1234. * queue small items, especially when called from an ISR. In most cases
  1235. * it would be preferable to store a pointer to the item being queued.
  1236. *
  1237. * @param xQueue The handle to the queue on which the item is to be posted.
  1238. *
  1239. * @param pvItemToQueue A pointer to the item that is to be placed on the
  1240. * queue. The size of the items the queue will hold was defined when the
  1241. * queue was created, so this many bytes will be copied from pvItemToQueue
  1242. * into the queue storage area.
  1243. *
  1244. * @param pxHigherPriorityTaskWoken xQueueGenericSendFromISR() will set
  1245. * *pxHigherPriorityTaskWoken to pdTRUE if sending to the queue caused a task
  1246. * to unblock, and the unblocked task has a priority higher than the currently
  1247. * running task. If xQueueGenericSendFromISR() sets this value to pdTRUE then
  1248. * a context switch should be requested before the interrupt is exited.
  1249. *
  1250. * @param xCopyPosition Can take the value queueSEND_TO_BACK to place the
  1251. * item at the back of the queue, or queueSEND_TO_FRONT to place the item
  1252. * at the front of the queue (for high priority messages).
  1253. *
  1254. * @return pdTRUE if the data was successfully sent to the queue, otherwise
  1255. * errQUEUE_FULL.
  1256. *
  1257. * Example usage for buffered IO (where the ISR can obtain more than one value
  1258. * per call):
  1259. * <pre>
  1260. * void vBufferISR( void )
  1261. * {
  1262. * char cIn;
  1263. * BaseType_t xHigherPriorityTaskWokenByPost;
  1264. *
  1265. * // We have not woken a task at the start of the ISR.
  1266. * xHigherPriorityTaskWokenByPost = pdFALSE;
  1267. *
  1268. * // Loop until the buffer is empty.
  1269. * do
  1270. * {
  1271. * // Obtain a byte from the buffer.
  1272. * cIn = portINPUT_BYTE( RX_REGISTER_ADDRESS );
  1273. *
  1274. * // Post each byte.
  1275. * xQueueGenericSendFromISR( xRxQueue, &cIn, &xHigherPriorityTaskWokenByPost, queueSEND_TO_BACK );
  1276. *
  1277. * } while( portINPUT_BYTE( BUFFER_COUNT ) );
  1278. *
  1279. * // Now the buffer is empty we can switch context if necessary. Note that the
  1280. * // name of the yield function required is port specific.
  1281. * if( xHigherPriorityTaskWokenByPost )
  1282. * {
  1283. * portYIELD_FROM_ISR();
  1284. * }
  1285. * }
  1286. * </pre>
  1287. *
  1288. * \defgroup xQueueSendFromISR xQueueSendFromISR
  1289. * \ingroup QueueManagement
  1290. */
  1291. BaseType_t xQueueGenericSendFromISR( QueueHandle_t xQueue,
  1292. const void * const pvItemToQueue,
  1293. BaseType_t * const pxHigherPriorityTaskWoken,
  1294. const BaseType_t xCopyPosition ) PRIVILEGED_FUNCTION;
  1295. BaseType_t xQueueGiveFromISR( QueueHandle_t xQueue,
  1296. BaseType_t * const pxHigherPriorityTaskWoken ) PRIVILEGED_FUNCTION;
  1297. /**
  1298. * queue. h
  1299. * <pre>
  1300. * BaseType_t xQueueReceiveFromISR(
  1301. * QueueHandle_t xQueue,
  1302. * void *pvBuffer,
  1303. * BaseType_t *pxTaskWoken
  1304. * );
  1305. * </pre>
  1306. *
  1307. * Receive an item from a queue. It is safe to use this function from within an
  1308. * interrupt service routine.
  1309. *
  1310. * @param xQueue The handle to the queue from which the item is to be
  1311. * received.
  1312. *
  1313. * @param pvBuffer Pointer to the buffer into which the received item will
  1314. * be copied.
  1315. *
  1316. * @param pxTaskWoken A task may be blocked waiting for space to become
  1317. * available on the queue. If xQueueReceiveFromISR causes such a task to
  1318. * unblock *pxTaskWoken will get set to pdTRUE, otherwise *pxTaskWoken will
  1319. * remain unchanged.
  1320. *
  1321. * @return pdTRUE if an item was successfully received from the queue,
  1322. * otherwise pdFALSE.
  1323. *
  1324. * Example usage:
  1325. * <pre>
  1326. *
  1327. * QueueHandle_t xQueue;
  1328. *
  1329. * // Function to create a queue and post some values.
  1330. * void vAFunction( void *pvParameters )
  1331. * {
  1332. * char cValueToPost;
  1333. * const TickType_t xTicksToWait = ( TickType_t )0xff;
  1334. *
  1335. * // Create a queue capable of containing 10 characters.
  1336. * xQueue = xQueueCreate( 10, sizeof( char ) );
  1337. * if( xQueue == 0 )
  1338. * {
  1339. * // Failed to create the queue.
  1340. * }
  1341. *
  1342. * // ...
  1343. *
  1344. * // Post some characters that will be used within an ISR. If the queue
  1345. * // is full then this task will block for xTicksToWait ticks.
  1346. * cValueToPost = 'a';
  1347. * xQueueSend( xQueue, ( void * ) &cValueToPost, xTicksToWait );
  1348. * cValueToPost = 'b';
  1349. * xQueueSend( xQueue, ( void * ) &cValueToPost, xTicksToWait );
  1350. *
  1351. * // ... keep posting characters ... this task may block when the queue
  1352. * // becomes full.
  1353. *
  1354. * cValueToPost = 'c';
  1355. * xQueueSend( xQueue, ( void * ) &cValueToPost, xTicksToWait );
  1356. * }
  1357. *
  1358. * // ISR that outputs all the characters received on the queue.
  1359. * void vISR_Routine( void )
  1360. * {
  1361. * BaseType_t xTaskWokenByReceive = pdFALSE;
  1362. * char cRxedChar;
  1363. *
  1364. * while( xQueueReceiveFromISR( xQueue, ( void * ) &cRxedChar, &xTaskWokenByReceive) )
  1365. * {
  1366. * // A character was received. Output the character now.
  1367. * vOutputCharacter( cRxedChar );
  1368. *
  1369. * // If removing the character from the queue woke the task that was
  1370. * // posting onto the queue cTaskWokenByReceive will have been set to
  1371. * // pdTRUE. No matter how many times this loop iterates only one
  1372. * // task will be woken.
  1373. * }
  1374. *
  1375. * if( cTaskWokenByPost != ( char ) pdFALSE;
  1376. * {
  1377. * taskYIELD ();
  1378. * }
  1379. * }
  1380. * </pre>
  1381. * \defgroup xQueueReceiveFromISR xQueueReceiveFromISR
  1382. * \ingroup QueueManagement
  1383. */
  1384. BaseType_t xQueueReceiveFromISR( QueueHandle_t xQueue,
  1385. void * const pvBuffer,
  1386. BaseType_t * const pxHigherPriorityTaskWoken ) PRIVILEGED_FUNCTION;
  1387. /*
  1388. * Utilities to query queues that are safe to use from an ISR. These utilities
  1389. * should be used only from witin an ISR, or within a critical section.
  1390. */
  1391. BaseType_t xQueueIsQueueEmptyFromISR( const QueueHandle_t xQueue ) PRIVILEGED_FUNCTION;
  1392. BaseType_t xQueueIsQueueFullFromISR( const QueueHandle_t xQueue ) PRIVILEGED_FUNCTION;
  1393. UBaseType_t uxQueueMessagesWaitingFromISR( const QueueHandle_t xQueue ) PRIVILEGED_FUNCTION;
  1394. /*
  1395. * The functions defined above are for passing data to and from tasks. The
  1396. * functions below are the equivalents for passing data to and from
  1397. * co-routines.
  1398. *
  1399. * These functions are called from the co-routine macro implementation and
  1400. * should not be called directly from application code. Instead use the macro
  1401. * wrappers defined within croutine.h.
  1402. */
  1403. BaseType_t xQueueCRSendFromISR( QueueHandle_t xQueue,
  1404. const void * pvItemToQueue,
  1405. BaseType_t xCoRoutinePreviouslyWoken );
  1406. BaseType_t xQueueCRReceiveFromISR( QueueHandle_t xQueue,
  1407. void * pvBuffer,
  1408. BaseType_t * pxTaskWoken );
  1409. BaseType_t xQueueCRSend( QueueHandle_t xQueue,
  1410. const void * pvItemToQueue,
  1411. TickType_t xTicksToWait );
  1412. BaseType_t xQueueCRReceive( QueueHandle_t xQueue,
  1413. void * pvBuffer,
  1414. TickType_t xTicksToWait );
  1415. /*
  1416. * For internal use only. Use xSemaphoreCreateMutex(),
  1417. * xSemaphoreCreateCounting() or xSemaphoreGetMutexHolder() instead of calling
  1418. * these functions directly.
  1419. */
  1420. QueueHandle_t xQueueCreateMutex( const uint8_t ucQueueType ) PRIVILEGED_FUNCTION;
  1421. QueueHandle_t xQueueCreateMutexStatic( const uint8_t ucQueueType,
  1422. StaticQueue_t * pxStaticQueue ) PRIVILEGED_FUNCTION;
  1423. QueueHandle_t xQueueCreateCountingSemaphore( const UBaseType_t uxMaxCount,
  1424. const UBaseType_t uxInitialCount ) PRIVILEGED_FUNCTION;
  1425. QueueHandle_t xQueueCreateCountingSemaphoreStatic( const UBaseType_t uxMaxCount,
  1426. const UBaseType_t uxInitialCount,
  1427. StaticQueue_t * pxStaticQueue ) PRIVILEGED_FUNCTION;
  1428. BaseType_t xQueueSemaphoreTake( QueueHandle_t xQueue,
  1429. TickType_t xTicksToWait ) PRIVILEGED_FUNCTION;
  1430. TaskHandle_t xQueueGetMutexHolder( QueueHandle_t xSemaphore ) PRIVILEGED_FUNCTION;
  1431. TaskHandle_t xQueueGetMutexHolderFromISR( QueueHandle_t xSemaphore ) PRIVILEGED_FUNCTION;
  1432. /*
  1433. * For internal use only. Use xSemaphoreTakeMutexRecursive() or
  1434. * xSemaphoreGiveMutexRecursive() instead of calling these functions directly.
  1435. */
  1436. BaseType_t xQueueTakeMutexRecursive( QueueHandle_t xMutex,
  1437. TickType_t xTicksToWait ) PRIVILEGED_FUNCTION;
  1438. BaseType_t xQueueGiveMutexRecursive( QueueHandle_t xMutex ) PRIVILEGED_FUNCTION;
  1439. /*
  1440. * Reset a queue back to its original empty state. The return value is now
  1441. * obsolete and is always set to pdPASS.
  1442. */
  1443. #define xQueueReset( xQueue ) xQueueGenericReset( xQueue, pdFALSE )
  1444. /*
  1445. * The registry is provided as a means for kernel aware debuggers to
  1446. * locate queues, semaphores and mutexes. Call vQueueAddToRegistry() add
  1447. * a queue, semaphore or mutex handle to the registry if you want the handle
  1448. * to be available to a kernel aware debugger. If you are not using a kernel
  1449. * aware debugger then this function can be ignored.
  1450. *
  1451. * configQUEUE_REGISTRY_SIZE defines the maximum number of handles the
  1452. * registry can hold. configQUEUE_REGISTRY_SIZE must be greater than 0
  1453. * within FreeRTOSConfig.h for the registry to be available. Its value
  1454. * does not effect the number of queues, semaphores and mutexes that can be
  1455. * created - just the number that the registry can hold.
  1456. *
  1457. * @param xQueue The handle of the queue being added to the registry. This
  1458. * is the handle returned by a call to xQueueCreate(). Semaphore and mutex
  1459. * handles can also be passed in here.
  1460. *
  1461. * @param pcName The name to be associated with the handle. This is the
  1462. * name that the kernel aware debugger will display. The queue registry only
  1463. * stores a pointer to the string - so the string must be persistent (global or
  1464. * preferably in ROM/Flash), not on the stack.
  1465. */
  1466. #if ( configQUEUE_REGISTRY_SIZE > 0 )
  1467. void vQueueAddToRegistry( QueueHandle_t xQueue,
  1468. const char * pcQueueName ) PRIVILEGED_FUNCTION; /*lint !e971 Unqualified char types are allowed for strings and single characters only. */
  1469. #endif
  1470. /*
  1471. * The registry is provided as a means for kernel aware debuggers to
  1472. * locate queues, semaphores and mutexes. Call vQueueAddToRegistry() add
  1473. * a queue, semaphore or mutex handle to the registry if you want the handle
  1474. * to be available to a kernel aware debugger, and vQueueUnregisterQueue() to
  1475. * remove the queue, semaphore or mutex from the register. If you are not using
  1476. * a kernel aware debugger then this function can be ignored.
  1477. *
  1478. * @param xQueue The handle of the queue being removed from the registry.
  1479. */
  1480. #if ( configQUEUE_REGISTRY_SIZE > 0 )
  1481. void vQueueUnregisterQueue( QueueHandle_t xQueue ) PRIVILEGED_FUNCTION;
  1482. #endif
  1483. /*
  1484. * The queue registry is provided as a means for kernel aware debuggers to
  1485. * locate queues, semaphores and mutexes. Call pcQueueGetName() to look
  1486. * up and return the name of a queue in the queue registry from the queue's
  1487. * handle.
  1488. *
  1489. * @param xQueue The handle of the queue the name of which will be returned.
  1490. * @return If the queue is in the registry then a pointer to the name of the
  1491. * queue is returned. If the queue is not in the registry then NULL is
  1492. * returned.
  1493. */
  1494. #if ( configQUEUE_REGISTRY_SIZE > 0 )
  1495. const char * pcQueueGetName( QueueHandle_t xQueue ) PRIVILEGED_FUNCTION; /*lint !e971 Unqualified char types are allowed for strings and single characters only. */
  1496. #endif
  1497. /*
  1498. * Generic version of the function used to create a queue using dynamic memory
  1499. * allocation. This is called by other functions and macros that create other
  1500. * RTOS objects that use the queue structure as their base.
  1501. */
  1502. #if ( configSUPPORT_DYNAMIC_ALLOCATION == 1 )
  1503. QueueHandle_t xQueueGenericCreate( const UBaseType_t uxQueueLength,
  1504. const UBaseType_t uxItemSize,
  1505. const uint8_t ucQueueType ) PRIVILEGED_FUNCTION;
  1506. #endif
  1507. /*
  1508. * Generic version of the function used to create a queue using dynamic memory
  1509. * allocation. This is called by other functions and macros that create other
  1510. * RTOS objects that use the queue structure as their base.
  1511. */
  1512. #if ( configSUPPORT_STATIC_ALLOCATION == 1 )
  1513. QueueHandle_t xQueueGenericCreateStatic( const UBaseType_t uxQueueLength,
  1514. const UBaseType_t uxItemSize,
  1515. uint8_t * pucQueueStorage,
  1516. StaticQueue_t * pxStaticQueue,
  1517. const uint8_t ucQueueType ) PRIVILEGED_FUNCTION;
  1518. #endif
  1519. /*
  1520. * Queue sets provide a mechanism to allow a task to block (pend) on a read
  1521. * operation from multiple queues or semaphores simultaneously.
  1522. *
  1523. * See FreeRTOS/Source/Demo/Common/Minimal/QueueSet.c for an example using this
  1524. * function.
  1525. *
  1526. * A queue set must be explicitly created using a call to xQueueCreateSet()
  1527. * before it can be used. Once created, standard FreeRTOS queues and semaphores
  1528. * can be added to the set using calls to xQueueAddToSet().
  1529. * xQueueSelectFromSet() is then used to determine which, if any, of the queues
  1530. * or semaphores contained in the set is in a state where a queue read or
  1531. * semaphore take operation would be successful.
  1532. *
  1533. * Note 1: See the documentation on https://www.FreeRTOS.org/RTOS-queue-sets.html
  1534. * for reasons why queue sets are very rarely needed in practice as there are
  1535. * simpler methods of blocking on multiple objects.
  1536. *
  1537. * Note 2: Blocking on a queue set that contains a mutex will not cause the
  1538. * mutex holder to inherit the priority of the blocked task.
  1539. *
  1540. * Note 3: An additional 4 bytes of RAM is required for each space in a every
  1541. * queue added to a queue set. Therefore counting semaphores that have a high
  1542. * maximum count value should not be added to a queue set.
  1543. *
  1544. * Note 4: A receive (in the case of a queue) or take (in the case of a
  1545. * semaphore) operation must not be performed on a member of a queue set unless
  1546. * a call to xQueueSelectFromSet() has first returned a handle to that set member.
  1547. *
  1548. * @param uxEventQueueLength Queue sets store events that occur on
  1549. * the queues and semaphores contained in the set. uxEventQueueLength specifies
  1550. * the maximum number of events that can be queued at once. To be absolutely
  1551. * certain that events are not lost uxEventQueueLength should be set to the
  1552. * total sum of the length of the queues added to the set, where binary
  1553. * semaphores and mutexes have a length of 1, and counting semaphores have a
  1554. * length set by their maximum count value. Examples:
  1555. * + If a queue set is to hold a queue of length 5, another queue of length 12,
  1556. * and a binary semaphore, then uxEventQueueLength should be set to
  1557. * (5 + 12 + 1), or 18.
  1558. * + If a queue set is to hold three binary semaphores then uxEventQueueLength
  1559. * should be set to (1 + 1 + 1 ), or 3.
  1560. * + If a queue set is to hold a counting semaphore that has a maximum count of
  1561. * 5, and a counting semaphore that has a maximum count of 3, then
  1562. * uxEventQueueLength should be set to (5 + 3), or 8.
  1563. *
  1564. * @return If the queue set is created successfully then a handle to the created
  1565. * queue set is returned. Otherwise NULL is returned.
  1566. */
  1567. QueueSetHandle_t xQueueCreateSet( const UBaseType_t uxEventQueueLength ) PRIVILEGED_FUNCTION;
  1568. /*
  1569. * Adds a queue or semaphore to a queue set that was previously created by a
  1570. * call to xQueueCreateSet().
  1571. *
  1572. * See FreeRTOS/Source/Demo/Common/Minimal/QueueSet.c for an example using this
  1573. * function.
  1574. *
  1575. * Note 1: A receive (in the case of a queue) or take (in the case of a
  1576. * semaphore) operation must not be performed on a member of a queue set unless
  1577. * a call to xQueueSelectFromSet() has first returned a handle to that set member.
  1578. *
  1579. * @param xQueueOrSemaphore The handle of the queue or semaphore being added to
  1580. * the queue set (cast to an QueueSetMemberHandle_t type).
  1581. *
  1582. * @param xQueueSet The handle of the queue set to which the queue or semaphore
  1583. * is being added.
  1584. *
  1585. * @return If the queue or semaphore was successfully added to the queue set
  1586. * then pdPASS is returned. If the queue could not be successfully added to the
  1587. * queue set because it is already a member of a different queue set then pdFAIL
  1588. * is returned.
  1589. */
  1590. BaseType_t xQueueAddToSet( QueueSetMemberHandle_t xQueueOrSemaphore,
  1591. QueueSetHandle_t xQueueSet ) PRIVILEGED_FUNCTION;
  1592. /*
  1593. * Removes a queue or semaphore from a queue set. A queue or semaphore can only
  1594. * be removed from a set if the queue or semaphore is empty.
  1595. *
  1596. * See FreeRTOS/Source/Demo/Common/Minimal/QueueSet.c for an example using this
  1597. * function.
  1598. *
  1599. * @param xQueueOrSemaphore The handle of the queue or semaphore being removed
  1600. * from the queue set (cast to an QueueSetMemberHandle_t type).
  1601. *
  1602. * @param xQueueSet The handle of the queue set in which the queue or semaphore
  1603. * is included.
  1604. *
  1605. * @return If the queue or semaphore was successfully removed from the queue set
  1606. * then pdPASS is returned. If the queue was not in the queue set, or the
  1607. * queue (or semaphore) was not empty, then pdFAIL is returned.
  1608. */
  1609. BaseType_t xQueueRemoveFromSet( QueueSetMemberHandle_t xQueueOrSemaphore,
  1610. QueueSetHandle_t xQueueSet ) PRIVILEGED_FUNCTION;
  1611. /*
  1612. * xQueueSelectFromSet() selects from the members of a queue set a queue or
  1613. * semaphore that either contains data (in the case of a queue) or is available
  1614. * to take (in the case of a semaphore). xQueueSelectFromSet() effectively
  1615. * allows a task to block (pend) on a read operation on all the queues and
  1616. * semaphores in a queue set simultaneously.
  1617. *
  1618. * See FreeRTOS/Source/Demo/Common/Minimal/QueueSet.c for an example using this
  1619. * function.
  1620. *
  1621. * Note 1: See the documentation on https://www.FreeRTOS.org/RTOS-queue-sets.html
  1622. * for reasons why queue sets are very rarely needed in practice as there are
  1623. * simpler methods of blocking on multiple objects.
  1624. *
  1625. * Note 2: Blocking on a queue set that contains a mutex will not cause the
  1626. * mutex holder to inherit the priority of the blocked task.
  1627. *
  1628. * Note 3: A receive (in the case of a queue) or take (in the case of a
  1629. * semaphore) operation must not be performed on a member of a queue set unless
  1630. * a call to xQueueSelectFromSet() has first returned a handle to that set member.
  1631. *
  1632. * @param xQueueSet The queue set on which the task will (potentially) block.
  1633. *
  1634. * @param xTicksToWait The maximum time, in ticks, that the calling task will
  1635. * remain in the Blocked state (with other tasks executing) to wait for a member
  1636. * of the queue set to be ready for a successful queue read or semaphore take
  1637. * operation.
  1638. *
  1639. * @return xQueueSelectFromSet() will return the handle of a queue (cast to
  1640. * a QueueSetMemberHandle_t type) contained in the queue set that contains data,
  1641. * or the handle of a semaphore (cast to a QueueSetMemberHandle_t type) contained
  1642. * in the queue set that is available, or NULL if no such queue or semaphore
  1643. * exists before before the specified block time expires.
  1644. */
  1645. QueueSetMemberHandle_t xQueueSelectFromSet( QueueSetHandle_t xQueueSet,
  1646. const TickType_t xTicksToWait ) PRIVILEGED_FUNCTION;
  1647. /*
  1648. * A version of xQueueSelectFromSet() that can be used from an ISR.
  1649. */
  1650. QueueSetMemberHandle_t xQueueSelectFromSetFromISR( QueueSetHandle_t xQueueSet ) PRIVILEGED_FUNCTION;
  1651. /* Not public API functions. */
  1652. void vQueueWaitForMessageRestricted( QueueHandle_t xQueue,
  1653. TickType_t xTicksToWait,
  1654. const BaseType_t xWaitIndefinitely ) PRIVILEGED_FUNCTION;
  1655. BaseType_t xQueueGenericReset( QueueHandle_t xQueue,
  1656. BaseType_t xNewQueue ) PRIVILEGED_FUNCTION;
  1657. void vQueueSetQueueNumber( QueueHandle_t xQueue,
  1658. UBaseType_t uxQueueNumber ) PRIVILEGED_FUNCTION;
  1659. UBaseType_t uxQueueGetQueueNumber( QueueHandle_t xQueue ) PRIVILEGED_FUNCTION;
  1660. uint8_t ucQueueGetQueueType( QueueHandle_t xQueue ) PRIVILEGED_FUNCTION;
  1661. /* *INDENT-OFF* */
  1662. #ifdef __cplusplus
  1663. }
  1664. #endif
  1665. /* *INDENT-ON* */
  1666. #endif /* QUEUE_H */