add: 添加msgbus和timer的freertos实现

luat/freertos/luat_msgbus_freertos.c

@@ -0,0 +1,23 @@
+
+#include "luat_msgbus.h"
+
+#include "cmsis_os2.h"
+
+#define LUAT_MSGBUS_MAXCOUNT 0xFF
+//#define LUAT_MSGBUS_MAXSIZE 8
+static osMessageQueueId_t queue; 
+
+void luat_msgbus_init(void) {
+    if (!queue) {
+        queue = osMessageQueueNew(LUAT_MSGBUS_MAXCOUNT, sizeof(rtos_msg_t), NULL);
+    }
+}
+uint32_t luat_msgbus_put(rtos_msg_t* msg, size_t timeout) {
+    return osMessageQueuePut(queue, msg, NULL, timeout);
+}
+uint32_t luat_msgbus_get(rtos_msg_t* msg, size_t timeout) {
+    return osMessageQueueGet(queue, msg, NULL, timeout);
+}
+uint32_t luat_msgbus_freesize(void) {
+    return osMessageQueueGetSpace(queue);
+}

luat/freertos/luat_timer_freertos.c

@@ -0,0 +1,82 @@
+
+#include "luat_base.h"
+#include "luat_malloc.h"
+#include "luat_timer.h"
+#include "cmsis_os2.h"
+#include "luat_msgbus.h"
+
+#define FREERTOS_TIMER_COUNT 32
+static luat_timer_t* timers[FREERTOS_TIMER_COUNT];
+
+static void luat_timer_callback(void* param) {
+    rtos_msg_t msg;
+    luat_timer_t *timer = (luat_timer_t*)param;
+    msg.handler = timer->func;
+    msg.ptr = param;
+    luat_msgbus_put(&msg, 1);
+}
+
+static int nextTimerSlot() {
+    for (size_t i = 0; i < FREERTOS_TIMER_COUNT; i++)
+    {
+        if (timers[i] == NULL) {
+            return i;
+        }
+    }
+    return -1;
+}
+
+int luat_timer_start(luat_timer_t* timer) {
+    osTimerId_t os_timer;
+    int timerIndex;
+    timerIndex = nextTimerSlot();
+    if (timerIndex < 0) {
+        return 1; // too many timer!!
+    }
+    timer = osTimerNew(luat_timer_callback, timer->type == 0 ? osTimerOnce : osTimerPeriodic, timer, NULL);
+    if (!timer)
+        return NULL;
+    timers[timerIndex] = timer;
+    
+    timer->os_timer = os_timer;
+    int re = osTimerStart(timer, timer->timeout);
+    if (re != 0) {
+        osTimerDelete(timer);
+        timers[timerIndex] = 0;
+    }
+    return re;
+}
+
+int luat_timer_stop(luat_timer_t* timer) {
+    if (!timer)
+        return 1;
+    for (size_t i = 0; i < FREERTOS_TIMER_COUNT; i++)
+    {
+        if (timers[i] == timer) {
+            timers[i] = NULL;
+            break;
+        }
+    }
+    osTimerStop(timer->os_timer);
+    osTimerDelete(timer->os_timer);
+    return 0;
+};
+
+luat_timer_t* luat_timer_get(size_t timer_id) {
+    for (size_t i = 0; i < FREERTOS_TIMER_COUNT; i++)
+    {
+        if (timers[i] && timers[i]->id == timer_id) {
+            return timers[i];
+        }
+    }
+    return NULL;
+}
+
+
+int luat_timer_mdelay(size_t ms) {
+    if (ms > 0) {
+        vTaskDelay(ms);
+    }
+    return 0;
+}
+