luat/cmsis_os2/luat_msgbus_cmsis_os2.c

   1
   2 #include "luat_msgbus.h"
   3
   4 #include "cmsis_os2.h"
   5
   6 #define LUAT_MSGBUS_MAXCOUNT 0xFF
   7 //#define LUAT_MSGBUS_MAXSIZE 8
   8 static osMessageQueueId_t queue = {0};
   9
  10 void luat_msgbus_init(void) {
  11     if (!queue) {
  12         queue = osMessageQueueNew(LUAT_MSGBUS_MAXCOUNT, sizeof(rtos_msg_t), NULL);
  13     }
  14 }
  15 uint32_t luat_msgbus_put(rtos_msg_t* msg, size_t timeout) {
  16     if (queue == NULL)
  17         return 1;
  18     return osMessageQueuePut(queue, msg, 0, timeout);
  19 }
  20 uint32_t luat_msgbus_get(rtos_msg_t* msg, size_t timeout) {
  21     if (queue == NULL)
  22         return 1;
  23     return osMessageQueueGet(queue, msg, 0, timeout);
  24 }
  25 uint32_t luat_msgbus_freesize(void) {
  26     if (queue == NULL)
  27         return 1;
  28     return osMessageQueueGetSpace(queue);
  29 }