diff --git a/mw/has_task_msg_manager/README b/mw/has_task_msg_manager/README index ce39ea4..fbac6db 100644 --- a/mw/has_task_msg_manager/README +++ b/mw/has_task_msg_manager/README @@ -2,4 +2,4 @@ 使用方法： 1. 在 has_task_msg_os_port.h 选择操作系统，更改宏MSG_OPT_OS。或选择自定义自己实现接口，如果自己定义需要自己实现has_task_msg_os_port.c的相应接口。 2. 在 has_task_msg.h 中添加自己负责的软件模块id号（has_module_ID_e），并且完成订阅表 SUBSCIBE_INFO ，要把模块的id、模块要订阅的id等信息填好。 -3. 代码中使用：初始化、发布、订阅和消息回调即可。请参考示例 msg_example.c \ No newline at end of file +3. 代码中使用：初始化、发布、订阅和消息回调即可。接口在has_task_msg.h中声明，请参考示例 msg_example.c \ No newline at end of file diff --git a/mw/has_task_msg_manager/has_task_msg.h b/mw/has_task_msg_manager/has_task_msg.h index d16fbc4..6d03f1d 100644 --- a/mw/has_task_msg_manager/has_task_msg.h +++ b/mw/has_task_msg_manager/has_task_msg.h @@ -44,11 +44,6 @@ typedef enum { */ typedef int (*has_msg_handle_cb)(unsigned char module_id, const unsigned char *buf, unsigned int len); - -/* -------------------- 注意 Attention -------------------- */ -/* 对于同一个id,不能同时在不同线程中调用 *_handle*, *_receive* 和 *delete_all* 的接口 */ -/* For the same id, the *_handle*, *_receive* and *delete_all* API cannot be called in different threads at the same time */ - /* 基础功能 */ int has_msg_init(void); int has_msg_os_init(void); diff --git a/mw/has_task_msg_manager/has_task_msg_mamanger.c b/mw/has_task_msg_manager/has_task_msg_mamanger.c index 5dfa60c..0185234 100644 --- a/mw/has_task_msg_manager/has_task_msg_mamanger.c +++ b/mw/has_task_msg_manager/has_task_msg_mamanger.c @@ -8,7 +8,6 @@ * */ #include -#include "list.h" #include "has_task_msg.h" #include "has_task_msg_os_port.h" diff --git a/mw/has_task_msg_manager/has_task_msg_os_port.c b/mw/has_task_msg_manager/has_task_msg_os_port.c index 7feb9d6..566d796 100644 --- a/mw/has_task_msg_manager/has_task_msg_os_port.c +++ b/mw/has_task_msg_manager/has_task_msg_os_port.c @@ -41,6 +41,12 @@ int msg_mutex_init(msg_mutex_t *mutex) return 0; #elif (MSG_OPT_OS == MSG_OPT_OS_USER_DEFINED) /* to be done */ + /* example:xr806 */ + if (OS_MutexCreate(mutex) != OS_OK) { + msg_printf("create mutex err!!\n\n"); + return -1; + } + return 0; #endif } @@ -62,14 +68,14 @@ int msg_sem_init(msg_sem_t *sem) sem->poll_fd.revents = 0; return 0; #elif (MSG_OPT_OS == MSG_OPT_OS_freeRTOS) - *sem = xSemaphoreCreateCounting(UINT_MAX, 0) + *sem = xSemaphoreCreateCounting(UINT_MAX, 0); if (*sem == NULL) { msg_printf("create counting sem error!\n"); return -1; } return 0; #elif (MSG_OPT_OS == MSG_OPT_OS_RT_THREAD) - *sem = rt_sem_create("has_sem", 0, RT_IPC_FLAG_FIFO) + *sem = rt_sem_create("has_sem", 0, RT_IPC_FLAG_FIFO); if (*sem == RT_NULL) { msg_printf("create counting sem error!\n"); return -1; @@ -77,6 +83,12 @@ int msg_sem_init(msg_sem_t *sem) return 0; #elif (MSG_OPT_OS == MSG_OPT_OS_USER_DEFINED) /* to be done */ + /* example:xr806 */ + if (OS_SemaphoreCreate(sem, 0, UINT_MAX) != OS_OK) { + msg_printf("create counting sem error!\n"); + return -1; + } + return 0; #endif } @@ -109,6 +121,12 @@ int msg_sem_notify(msg_sem_t *sem) return 0; #elif (MSG_OPT_OS == MSG_OPT_OS_USER_DEFINED) /* to be done */ + /* example:xr806 */ + if (OS_SemaphoreRelease(sem) != OS_OK) { + msg_printf("notify thread err!\n"); + return -1; + } + return 0; #endif } @@ -149,7 +167,7 @@ enum MSG_WAIT_RET msg_sem_wait(msg_sem_t *sem, int ms_timeout) msg_printf("something err happened,revents:%x\n", sem->poll_fd.revents); return WAIT_FAIL; #elif (MSG_OPT_OS == MSG_OPT_OS_freeRTOS) - const TickType_t xTicksToWait; + TickType_t xTicksToWait; if (ms_timeout < 0) { xTicksToWait = portMAX_DELAY; } else { @@ -157,7 +175,7 @@ enum MSG_WAIT_RET msg_sem_wait(msg_sem_t *sem, int ms_timeout) } if (xSemaphoreTake(*sem, xTicksToWait) != pdTRUE) { - msg_printf("sem take fail\n"); + // msg_printf("sem take fail\n"); return WAIT_FAIL; } return WAIT_MSG_COME; @@ -182,6 +200,19 @@ enum MSG_WAIT_RET msg_sem_wait(msg_sem_t *sem, int ms_timeout) } #elif (MSG_OPT_OS == MSG_OPT_OS_USER_DEFINED) /* to be done */ + /* example:xr806 */ + OS_Time_t waitMS; + if (ms_timeout < 0) { + waitMS = OS_WAIT_FOREVER; + } else { + waitMS = (OS_Time_t)ms_timeout; + } + + if (OS_SemaphoreWait(sem, waitMS) != OS_OK) { + // msg_printf("sem take fail\n"); + return WAIT_FAIL; + } + return WAIT_MSG_COME; #endif } diff --git a/mw/has_task_msg_manager/has_task_msg_os_port.h b/mw/has_task_msg_manager/has_task_msg_os_port.h index 4d3606e..d5b00a0 100644 --- a/mw/has_task_msg_manager/has_task_msg_os_port.h +++ b/mw/has_task_msg_manager/has_task_msg_os_port.h @@ -7,7 +7,7 @@ #define MSG_OPT_OS_NONE_OR_OSAL 4 #define MSG_OPT_OS_USER_DEFINED 5 -/* TODO:rtt和freertos未测过 */ +/* TODO:rtt未测过 */ #define MSG_OPT_OS MSG_OPT_OS_LINUX // #define MSG_OPT_OS MSG_OPT_OS_freeRTOS // #define MSG_OPT_OS MSG_OPT_OS_RT_THREAD @@ -30,6 +30,7 @@ enum MSG_WAIT_RET{ #include #include #include +#include "list.h" #ifdef MSG_OPT_MUTEX_SEM #include @@ -43,10 +44,6 @@ typedef struct { } sync_t; #define msg_sem_t sync_t -int msg_mutex_init(msg_mutex_t *mutex); -int msg_sem_init(msg_sem_t *sem); -int msg_sem_notify(msg_sem_t *sem); -enum MSG_WAIT_RET msg_sem_wait(msg_sem_t *sem, int ms_timeout); #else #define msg_mutex_t #define msg_mutex_lock(m) @@ -64,6 +61,7 @@ enum MSG_WAIT_RET msg_sem_wait(msg_sem_t *sem, int ms_timeout); #include #include "FreeRTOS.h" #include "semphr.h" +#include "list.h" #define msg_malloc pvPortMalloc #define msg_free vPortFree @@ -84,11 +82,6 @@ static inline void msg_mutex_unlock(msg_mutex_t *mutex) { #define msg_sem_t SemaphoreHandle_t -int msg_mutex_init(msg_mutex_t *mutex); -int msg_sem_init(msg_sem_t *sem); -int msg_sem_notify(msg_sem_t *sem); -enum MSG_WAIT_RET msg_sem_wait(msg_sem_t *sem, int ms_timeout); - #else #define msg_mutex_t #define msg_mutex_lock(m) @@ -99,6 +92,7 @@ enum MSG_WAIT_RET msg_sem_wait(msg_sem_t *sem, int ms_timeout); #include #include #include +#include "list.h" #define msg_malloc rt_malloc #define msg_free rt_free @@ -119,11 +113,6 @@ static inline void msg_mutex_unlock(msg_mutex_t *mutex) { #define msg_sem_t rt_sem_t -int msg_mutex_init(msg_mutex_t *mutex); -int msg_sem_init(msg_sem_t *sem); -int msg_sem_notify(msg_sem_t *sem); -enum MSG_WAIT_RET msg_sem_wait(msg_sem_t *sem, int ms_timeout); - #else #define msg_mutex_t #define msg_mutex_lock(m) @@ -133,6 +122,7 @@ enum MSG_WAIT_RET msg_sem_wait(msg_sem_t *sem, int ms_timeout); #elif (MSG_OPT_OS == MSG_OPT_OS_NONE_OR_OSAL) #include #include +#include "list.h" #undef MSG_OPT_MUTEX_SEM #define msg_mutex_t @@ -145,26 +135,33 @@ enum MSG_WAIT_RET msg_sem_wait(msg_sem_t *sem, int ms_timeout); /* ----------------------- for user define ----------------------- */ #elif (MSG_OPT_OS == MSG_OPT_OS_USER_DEFINED) +/* 下面示例是基于xr806移植 */ #include #include +#include +#include "list.h" + +#include "../has_wifi_slab.h" +#include "../kernel/os/os.h" + +#define msg_malloc test_slab_malloc +#define msg_free test_slab_free +#define msg_printf printf #ifdef MSG_OPT_MUTEX_SEM -#define msg_mutex_t int/* to be done */ +#define msg_mutex_t OS_Mutex_t static inline void msg_mutex_lock(msg_mutex_t *mutex) { - /* to be done */ + if (OS_MutexLock(mutex, OS_WAIT_FOREVER) != OS_OK) { + msg_printf("lock mutex err!!\n\n"); + } } static inline void msg_mutex_unlock(msg_mutex_t *mutex) { - /* to be done */ + OS_MutexUnlock(mutex); } -#define msg_sem_t int // to be done - -int msg_mutex_init(msg_mutex_t *mutex); -int msg_sem_init(msg_sem_t *sem); -int msg_sem_notify(msg_sem_t *sem); -enum MSG_WAIT_RET msg_sem_wait(msg_sem_t *sem, int ms_timeout); +#define msg_sem_t OS_Semaphore_t #else #define msg_mutex_t @@ -172,14 +169,16 @@ enum MSG_WAIT_RET msg_sem_wait(msg_sem_t *sem, int ms_timeout); #define msg_mutex_unlock(m) #endif - -#define msg_malloc malloc -#define msg_free free -#define msg_printf printf - #else #error "!Undefined system environment!" #endif -#endif \ No newline at end of file +#endif + +#ifdef MSG_OPT_MUTEX_SEM +int msg_mutex_init(msg_mutex_t *mutex); +int msg_sem_init(msg_sem_t *sem); +int msg_sem_notify(msg_sem_t *sem); +enum MSG_WAIT_RET msg_sem_wait(msg_sem_t *sem, int ms_timeout); +#endif