update CosyOS内核文件.

Signed-off-by: 零中断延迟的RTOS <cosyos@139.com>

System/sv_int_loc.h

@@ -0,0 +1,143 @@
+/**************************************************************************//**
+ * @item     CosyOS-II Kernel
+ * @file     sv_int_loc.h
+ * @brief    中断本地服务（仅在用户中断中调用，并在本地执行）
+ * @author   迟凯峰
+ * @version  V1.3.1
+ * @date     2024.01.25
+ ******************************************************************************/
+
+#ifndef __SV_INT_LOC_H
+#define __SV_INT_LOC_H
+
+void       si_task_scheduling(void);
+void       si_taskpri_scheduling(s_tasknode_tsp node);
+s_bool_t   si_take_binary(s_binary_tsp bin);
+void       si_back_binary(s_binary_tsp bin);
+m_fetion_t si_recv_fetion(s_fetion_tsp fet);
+#if SYSCFG_MCUCORE == 8051
+s_bool_t   si_can_read_gmbox(void _OBJ_MEM_ *gm);
+s_bool_t   si_can_read_lmbox(void);
+void      *si_get_lmbox(void);
+s_bool_t   si_can_access_msgqueue(s_msgqueue_tsp queue);
+#else
+s_bool_t   si_recv_mail(void *lm, s_mailbox_tsp gm, size_t size) MCUCFG_251_REENTRANT;
+#endif
+void      *si_recv_msg (s_msgqueue_tsp queue);
+
+
+
+/*
+ * 任务优先级调度
+ */
+
+#define sISV_TaskPriScheduling(node) \
+	si_taskpri_scheduling(node)
+
+
+
+/*
+ * 二值信号量
+ */
+
+/* 获取 */
+#define sISV_TakeBin(bin) \
+	si_take_binary(&bin)
+
+/* 归还 */
+#define sISV_BackBin(bin) \
+	si_back_binary(&bin)
+
+
+
+/*
+ * 飞信（接收飞信）
+ */
+
+#define sISV_RecvFetion(tbox) \
+	si_recv_fetion(&tbox)
+
+
+
+/*
+ * 消息邮箱（接收邮件）
+ */
+#if SYSCFG_MCUCORE == 8051
+#if SYSCFG_MAILBOX_ACCESSMECHANISM == 0
+#define sISV_RecvMail(mail, mbox) \
+( \
+	si_can_read_gmbox((s_mailbox_tsp)&mbox) \
+	? mbox.gf \
+		? s_memcpy(mail, &mbox.mail0, sizeof(mbox.mail0)) || true \
+			? mbox.gf-- \
+			: mbox.gf-- \
+		: false \
+	: false \
+)
+
+#elif SYSCFG_MAILBOX_ACCESSMECHANISM == 1
+#define sISV_RecvMail(mail, mbox) \
+( \
+	si_can_read_gmbox((s_mailbox_tsp)&mbox) \
+	? mbox.gf \
+		? s_memcpy(mail, &mbox.mail0, sizeof(mbox.mail0)) || true \
+			? mbox.gf-- \
+			: mbox.gf-- \
+		: false \
+	: si_can_read_lmbox() \
+		? s_memcpy(mail, si_get_lmbox(), sizeof(mbox.mail0)) || true \
+			? true \
+			: true \
+		: false \
+)
+
+#endif
+#else
+#define sISV_RecvMail(mail, mbox) \
+	si_recv_mail(mail, (s_mailbox_tsp)&mbox, sizeof(mbox.mail0))
+
+#endif
+
+
+
+/*
+ * 消息队列（接收消息）
+ */
+#if SYSCFG_MCUCORE == 8051
+#define	sISV_RecvMsg(que) \
+( \
+	si_can_access_msgqueue(que) ? si_recv_msg(que) : NULL \
+)
+#else
+#define	sISV_RecvMsg(que) \
+	si_recv_msg(que)
+#endif
+
+
+
+/*
+ * 事件标志组
+ */
+
+ /* 查询标志组 */
+#define	sISV_QueryFlagGroup(group) \
+( \
+	  sizeof(group) == 1 ? *(s_u8_t  *)&group ? true : false \
+	: sizeof(group) == 2 ? *(s_u16_t *)&group ? true : false \
+	: sizeof(group) == 4 ? *(s_u32_t *)&group ? true : false \
+	: false \
+)
+
+
+
+/*
+ * 软件RTC
+ */
+
+/* 获取时间 */
+#define sISV_GetTime(t) \
+	s_memcpy(t, !iWhichGVar_Read ? s_rtc[0] : s_rtc[1], sizeof(s_rtc[0]))
+
+
+
+#endif

System/sv_task.h

@@ -0,0 +1,417 @@
+/**************************************************************************//**
+ * @item     CosyOS-II Kernel
+ * @file     sv_task.h
+ * @brief    任务服务（仅在任务中调用）
+ * @author   迟凯峰
+ * @version  V1.3.1
+ * @date     2024.01.25
+ ******************************************************************************/
+
+#ifndef __SV_TASK_H
+#define __SV_TASK_H
+
+void       su_enter_critical    (void);
+void       su_exit_critical     (void);
+void      *su_return_voidptr    (void *p);
+void       su_task_scheduling   (void);
+void       su_taskpri_scheduling(s_tasknode_tsp node);
+s_ecode_t  su_startup_task      (s_taskhand_tsp hand, s_u8_t status);
+s_ecode_t  su_suspend_task      (s_tasknode_tsp node);
+s_ecode_t  su_resume_task       (s_tasknode_tsp node);
+s_ecode_t  su_resume_suspend    (s_tasknode_tsp node);
+s_ecode_t  su_delete_task       (s_tasknode_tsp node);
+s_ecode_t  su_set_taskpri       (s_tasknode_tsp node, s_u8_t pri);
+s_ecode_t  su_set_block         (s_tasknode_tsp node, s_delay_t tick);
+s_ecode_t  su_clear_block       (s_tasknode_tsp node);
+void       su_delay             (s_delay_t tick);
+s_bool_t   su_take_mutex        (s_mutex_tsp mut, s_delay_t tick);
+void       su_back_mutex        (s_mutex_tsp mut);
+s_bool_t   su_take_binary       (s_binary_tsp bin, s_delay_t tick, s_bool_t type);
+void       su_give_binary       (s_binary_tsp bin);
+void       su_back_binary       (s_binary_tsp bin);
+s_bool_t   su_take_semaphore    (s_semaph_tsp sem, s_delay_t tick);
+void       su_give_semaphore    (s_semaph_tsp sem);
+void       su_back_semaphore    (s_semaph_tsp sem);
+s_bool_t   su_recv_taskmsg      (m_taskmsg_t _OBJ_MEM_ *nmf, s_delay_t tick);
+m_fetion_t su_recv_fetion       (s_fetion_tsp fet, s_delay_t tick);
+s_bool_t   su_recv_mail         (s_mailbox_tsp gm, s_delay_t tick);
+void       su_send_mail         (s_mailbox_tsp gm, void *lm, size_t size);
+void      *su_recv_msg          (s_msgqueue_tsp queue, s_delay_t tick);
+s_ecode_t  su_send_msg          (s_msgqueue_tsp queue, void *msg);
+s_bool_t   su_query_group       (void _OBJ_MEM_ *p, s_u8_t size);
+s_bool_t   su_wait_group        (void _OBJ_MEM_ *p, s_u8_t size, s_delay_t tick);
+
+s_bool_t   su_init_mempool      (s_thrmem_tsp p, size_t size);
+void _MALLOC_MEM_ *su_talloc    (s_thrmem_tsp p, size_t size);
+void _MALLOC_MEM_ *su_xalloc    (void _MALLOC_MEM_ *p);
+
+
+
+/*
+ * 任务
+ */
+
+/* 任务优先级调度 */
+#define sUSV_TaskPriScheduling(node)     su_taskpri_scheduling(node)
+
+/* 启动任务 */
+#define sUSV_StartTask(hand, status) \
+( \
+	(m_boolvoid_tf(su_enter_critical))() || true ? su_startup_task(hand, !status ? OS_STATUS_READY : OS_STATUS_SUSPENDED) : false \
+)
+
+/* 挂起任务 */
+#define	sUSV_SuspendTask(node) \
+( \
+	(m_boolvoid_tf(su_enter_critical))() || true ? su_suspend_task(node) : false \
+)
+
+/* 恢复任务 */
+#define	sUSV_ResumeTask(node) \
+( \
+	(m_boolvoid_tf(su_enter_critical))() || true ? su_resume_task(node) : false \
+)
+
+/* 恢复指定任务并挂起自身任务 */
+#define	sUSV_ResumeSuspend(node) \
+( \
+	(m_boolvoid_tf(su_enter_critical))() || true ? su_resume_suspend(node) : false \
+)
+
+/* 删除任务 */
+#define	sUSV_DeleteTask(node) \
+( \
+	(m_boolvoid_tf(su_enter_critical))() || true ? su_delete_task(node) : false \
+)
+
+/* 设置任务优先级 */
+#define	sUSV_SetTaskPri(node, pri) \
+( \
+	(m_boolvoid_tf(su_enter_critical))() || true ? su_set_taskpri(node, pri) : false \
+)
+
+/* 设置阻塞（时间）*/
+#define sUSV_SetBlock(node, tc) \
+( \
+	(m_boolvoid_tf(su_enter_critical))() || true ? su_set_block(node, tc) : false \
+)
+
+/* 清除阻塞（状态）*/
+#define sUSV_ClearBlock(node) \
+( \
+	(m_boolvoid_tf(su_enter_critical))() || true ? su_clear_block(node) : false \
+)
+
+/* 自身任务延时 */
+#define	sUSV_Delay(tc) \
+do{ \
+	uEnterCritical; \
+	su_delay(tc); \
+}while(false)
+
+
+
+/*
+ * 定时
+ */
+
+/* 定时中断 */
+#define	sUSV_TimInt(tmid, tc) \
+do{ \
+	uEnterCritical; \
+	s_timint_loader[tmid] = s_timint_reload[tmid] = tc; \
+	uExitCritical; \
+}while(false)
+
+/* 定时查询 */
+#define	sUSV_TimQry(tmid, tc) \
+do{ \
+	uEnterCritical; \
+	s_timqry_loader[tmid] = s_timqry_reload[tmid] = tc; \
+	uExitCritical; \
+}while(false)
+
+
+
+/*
+ * 互斥信号量
+ */
+
+/* 获取 */
+#define	sUSV_TakeMut(mut, tc) \
+( \
+	(m_boolvoid_tf(su_enter_critical))() || true ? su_take_mutex(&mut, tc) : false \
+)
+
+/* 归还 */
+#define sUSV_BackMut(mut) \
+do{ \
+	uEnterCritical; \
+	su_back_mutex(&mut); \
+}while(false)
+
+
+
+/*
+ * 二值信号量
+ */
+
+/* 等待 */
+#define	sUSV_WaitBin(bin, tc) \
+( \
+	(m_boolvoid_tf(su_enter_critical))() || true ? su_take_binary(&bin, tc, 0) : false \
+)
+
+/* 获取 */
+#define	sUSV_TakeBin(bin, tc) \
+( \
+	(m_boolvoid_tf(su_enter_critical))() || true ? su_take_binary(&bin, tc, 1) : false \
+)
+
+/* 给予 */
+#define sUSV_GiveBin(bin) \
+do{ \
+	uEnterCritical; \
+	su_give_binary(&bin); \
+}while(false)
+
+/* 归还 */
+#define sUSV_BackBin(bin) \
+do{ \
+	uEnterCritical; \
+	su_back_binary(&bin); \
+}while(false)
+
+
+
+/*
+ * 计数信号量
+ */
+
+/* 获取 */
+#define sUSV_TakeSem(sem, tc) \
+( \
+	(m_boolvoid_tf(su_enter_critical))() || true ? su_take_semaphore(&sem, tc) : false \
+)
+
+/* 给予 */
+#define sUSV_GiveSem(sem) \
+do{ \
+	uEnterCritical; \
+	su_give_semaphore(&sem); \
+}while(false)
+
+/* 归还 */
+#define sUSV_BackSem(sem) \
+do{ \
+	uEnterCritical; \
+	su_back_semaphore(&sem); \
+}while(false)
+
+
+
+/*
+ * 私信
+ */
+
+/* 接收私信 */
+#define	sUSV_RecvTaskMsg(tc) \
+( \
+	(m_boolvoid_tf(su_enter_critical))() || true \
+	? su_recv_taskmsg(&m0_, tc) \
+		? s_memcpy(&m0 + 1, &m0_ + 1, MCUCFG_TASKMSG_SIZE) || true \
+			? (m_boolvoid_tf(su_exit_critical))() || true \
+			: (m_boolvoid_tf(su_exit_critical))() || true \
+		: false \
+	: false \
+)
+
+/* 发送私信 */
+#define	sUSV_SendTaskMsg(task) \
+	uEnterCritical; \
+	s_sign_send_taskmsg = true; \
+	MCUCFG_TASKMSG_PSP; \
+	s_scheduling_taskmsg(sTaskNode(&u_taskhand_##task)); \
+	task(MCUCFG_TASKMSG_VAL, 
+
+
+
+/*
+ * 飞信
+ */
+
+/* 接收飞信 */
+#define sUSV_RecvFetion(tbox, tc) \
+( \
+	(m_boolvoid_tf(su_enter_critical))() || true ? su_recv_fetion(&tbox, tc) : false \
+)
+
+/* 发送飞信 */
+#define sUSV_SendFetion(tbox, tion) \
+do{ \
+	uEnterCritical; \
+	tbox.fetion = tion; \
+	if(!s_sign_scheduling) s_scheduling_notnull(tbox.node); \
+	uExitCritical; \
+}while(false)
+
+
+
+/*
+ * 消息邮箱
+ */
+
+/* 接收邮件 */
+#define sUSV_RecvMail(mail, mbox, tc) \
+( \
+	(m_boolvoid_tf(su_enter_critical))() || true \
+	? su_recv_mail((s_mailbox_tsp)&mbox, tc) \
+		? s_memcpy(mail, &mbox.mail0, sizeof(mbox.mail0)) || true \
+			? (m_boolvoid_tf(su_exit_critical))() || true \
+			: (m_boolvoid_tf(su_exit_critical))() || true \
+		: false \
+	: false \
+)
+
+/* 发送邮件 */
+#define sUSV_SendMail(mbox, mail) \
+do{ \
+	uEnterCritical; \
+	su_send_mail((s_mailbox_tsp)&mbox, mail, sizeof(mbox.mail0)); \
+}while(false)
+
+
+
+/*
+ * 消息队列
+ */
+
+/* 接收消息 */
+#define	sUSV_RecvMsg(que, tc) \
+( \
+	(m_boolvoid_tf(su_enter_critical))() || true ? su_recv_msg(que, tc) : NULL \
+)
+
+/* 发送消息 */
+#define	sUSV_SendMsg(que, msg) \
+( \
+	(m_boolvoid_tf(su_enter_critical))() || true ? su_send_msg(que, msg) : false \
+)
+
+
+
+/*
+ * 事件标志组
+ */
+
+/* 查询标志组 */
+#define	sUSV_QueryFlagGroup(group) \
+( \
+	(m_boolvoid_tf(su_enter_critical))() || true ? su_query_group((void *)&group, sizeof(group)) : false \
+)
+
+/* 等待标志组 */
+#define	sUSV_WaitFlagGroup(group, tc) \
+( \
+	(m_boolvoid_tf(su_enter_critical))() || true ? su_wait_group((void *)&group, sizeof(group), tc) : false \
+)
+
+/* 清除标志组 */
+#define sUSV_ClearFlagGroup(group) \
+do{ \
+	uEnterCritical; \
+	sizeof(group) == 1 ? *(s_u8_t  *)&group = false : OS_NOPx1; \
+	sizeof(group) == 2 ? *(s_u16_t *)&group = false : OS_NOPx1; \
+	sizeof(group) == 4 ? *(s_u32_t *)&group = false : OS_NOPx1; \
+	uExitCritical; \
+}while(false)
+
+/* 写标志位 */
+#define sUSV_WriteFlagBit(group, bit, value) \
+do{ \
+	uEnterCritical; \
+	group.bit = value; \
+	uExitCritical; \
+}while(false)
+
+
+
+/*
+ * 软件RTC
+ */
+
+/* 获取时间 */
+#define sUSV_GetTime(t) \
+( \
+	(m_boolvoid_tf(su_enter_critical))() || true ? su_return_voidptr(s_memcpy(t, s_rtc[0], sizeof(s_rtc[0]))) : NULL \
+)
+
+/* 设置时间 */
+#define sUSV_SetTime(t) \
+do{ \
+	uEnterCritical; \
+	s_memcpy(s_rtc[0], t, sizeof(s_rtc[0])); \
+	uUpdateCopy_GVar(s_memcpy(s_rtc[1], s_rtc[0], sizeof(s_rtc[0]))); \
+	uExitCritical; \
+}while(false)
+
+
+
+/*
+ * 进程内存
+ */
+
+/* malloc */
+#define	sUSV_Malloc(size) \
+( \
+	(m_boolvoid_tf(su_enter_critical))() || true ? su_xalloc(s_malloc(size)) : NULL \
+)
+
+/* calloc */
+#define	sUSV_Calloc(nmemb, size) \
+( \
+	(m_boolvoid_tf(su_enter_critical))() || true ? su_xalloc(s_calloc(nmemb, size)) : NULL \
+)
+
+/* realloc */
+#define	sUSV_Realloc(p, size) \
+( \
+	(m_boolvoid_tf(su_enter_critical))() || true ? su_xalloc(s_realloc(p, size)) : NULL \
+)
+
+/* free */
+#define	sUSV_Free(p) \
+do{ \
+	uEnterCritical; \
+	s_free(p); \
+	uExitCritical; \
+}while(false)
+
+
+
+/*
+ * 线程内存
+ */
+
+/* 初始化线程内存池 */
+#define	sUSV_InitMempool(size) \
+( \
+	(m_boolvoid_tf(su_enter_critical))() || true ? su_init_mempool(&u_thrmem, size) : false \
+)
+
+/* 线程内存分配 */
+#define	sUSV_Talloc(size) \
+( \
+	(m_boolvoid_tf(su_enter_critical))() || true ? su_xalloc(su_talloc(&u_thrmem, size)) : NULL \
+)
+
+/* 释放线程内存池 */
+#define	sUSV_FreeMempool \
+do{ \
+	sUSV_Free(u_thrmem.head); \
+	u_thrmem.head = u_thrmem.move = NULL; \
+}while(false)
+
+
+
+#endif