mirror of
https://gitee.com/cosyos/cosyos.git
synced 2026-09-26 13:13:37 +08:00
零中断延迟的RTOS
+171
@@ -0,0 +1,171 @@
|
||||
/**************************************************************************//**
|
||||
* @item CosyOS-II Kernel
|
||||
* @file os_api.c
|
||||
* @brief 内核服务公共函数
|
||||
* @details 在服务层临界区中，由内核服务调用。
|
||||
* @author 迟凯峰
|
||||
* @version V3.4.0
|
||||
* @date 2025.01.06
|
||||
******************************************************************************/
|
||||
|
||||
#include "os_var.h"
|
||||
|
||||
#if SYSCFG_MCUCORE == 8051
|
||||
#pragma NOAREGS /* 相对寄存器访问 for C51 */
|
||||
#endif
|
||||
|
||||
/**
|
||||
\brief 任务优先级切换
|
||||
\details 如果该任务的优先级高于当前任务的优先级，立即切换任务。
|
||||
\param[in] htask 任务句柄
|
||||
\return 无
|
||||
\note 直接关联服务（非滴答中）：切换任务、恢复指定任务并挂起自身任务、设置阻塞（时间）、清除阻塞（状态）。
|
||||
*/
|
||||
void s_switch_taskpri(s_tasknode_tsp htask)
|
||||
{
|
||||
if(htask->pri > s_task_current->pri){
|
||||
if(s_task_switch == OS_NULL){
|
||||
s_task_switch = htask;
|
||||
s_sign_schedule = true;
|
||||
}
|
||||
else if(htask->pri > s_task_switch->pri){
|
||||
s_task_switch = htask;
|
||||
s_sign_switch_prigroup = false;
|
||||
}
|
||||
else if(htask->pri == s_task_switch->pri){
|
||||
s_sign_switch_prigroup = true;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
\brief 非空切换
|
||||
\details 当任务非空时，实行任务优先级切换。
|
||||
\param[in] htask 任务句柄
|
||||
\return 无
|
||||
\note 关联服务（非滴答中）：给予/归还二值信号量、给予/归还计数信号量、发送飞信、发送邮件、发送消息。
|
||||
*/
|
||||
void s_switch_notnull(s_tasknode_tsp htask)
|
||||
{
|
||||
if(htask != OS_NULL){
|
||||
s_switch_taskpri(htask);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
\brief 就绪切换
|
||||
\details 当任务状态为就绪时，实行任务优先级切换。
|
||||
\param[in] htask 任务句柄
|
||||
\return 无
|
||||
\note 关联服务（非滴答中）：恢复任务。
|
||||
*/
|
||||
void s_switch_ready(s_tasknode_tsp htask)
|
||||
{
|
||||
if(htask->status == OS_STATUS_READY){
|
||||
s_switch_taskpri(htask);
|
||||
}
|
||||
}
|
||||
|
||||
#if SYSCFG_TASKMSG == __ENABLED__
|
||||
/**
|
||||
\brief 私信切换
|
||||
\details 当任务阻塞类型为接收私信阻塞时，实行任务优先级切换。
|
||||
\param[in] htask 任务句柄
|
||||
\return 无
|
||||
\note 关联服务（非滴答中）：发送私信。
|
||||
*/
|
||||
void s_switch_taskmsg(s_tasknode_tsp htask)
|
||||
{
|
||||
if(htask->blocktype & OS_BLOCKED_TASKMSG){
|
||||
s_switch_taskpri(htask);
|
||||
}
|
||||
}
|
||||
#endif
|
||||
|
||||
/**
|
||||
\brief 移除 from 任务队列
|
||||
\details 从任务队列中移除任务节点。
|
||||
\param[in] htask 任务句柄
|
||||
\return 移除的是否为队列尾节点？[true：是，false：不是]
|
||||
*/
|
||||
bool s_remove_taskque(s_tasknode_tsp htask)
|
||||
{
|
||||
s_u8_t pri = htask->pri;
|
||||
s_tasknode_tsp node_tail = s_taskque_head[pri]->last;
|
||||
if(s_taskque_head[pri] == node_tail){
|
||||
s_taskque_head[pri] = OS_NULL;
|
||||
return true;
|
||||
}
|
||||
else{
|
||||
htask->last->next = htask->next;
|
||||
htask->next->last = htask->last;
|
||||
if(htask == node_tail){
|
||||
return true;
|
||||
}
|
||||
else if(htask == s_taskque_head[pri]){
|
||||
s_taskque_head[pri] = htask->next;
|
||||
}
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
\brief 插入 to 任务队列
|
||||
\details 插入任务节点至任务队列尾。
|
||||
\param[in] htask 任务句柄
|
||||
\return 无
|
||||
*/
|
||||
void s_insert_taskque(s_tasknode_tsp htask)
|
||||
{
|
||||
s_u8_t pri = htask->pri;
|
||||
if(s_taskque_head[pri] == OS_NULL){
|
||||
s_taskque_head[pri] = htask->last = htask->next = htask;
|
||||
}
|
||||
else{
|
||||
htask->last = s_taskque_head[pri]->last;
|
||||
htask->next = s_taskque_head[pri];
|
||||
s_taskque_head[pri]->last->next = htask;
|
||||
s_taskque_head[pri]->last = htask;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
\brief 设置任务优先级
|
||||
\details 从任务队列中移除该任务并重新加入队列。
|
||||
\param[in] htask 任务句柄
|
||||
\param[in] npri 新优先级
|
||||
\return 无
|
||||
\note 关联服务：设置任务优先级、获取互斥信号量、归还互斥信号量。
|
||||
*/
|
||||
void s_set_taskpri(s_tasknode_tsp htask, s_u8_t npri)
|
||||
{
|
||||
s_remove_taskque(htask);
|
||||
htask->pri = npri;
|
||||
s_insert_taskque(htask);
|
||||
s_sign_schedule_all = true;
|
||||
}
|
||||
|
||||
#if SYSCFG_GETRTC_INT == __ENABLED__
|
||||
/**
|
||||
\brief 更新RTC副本
|
||||
\param 无
|
||||
\return 无
|
||||
*/
|
||||
void s_update_rtccopy(void)
|
||||
{
|
||||
s_sign_updatecopy = true;
|
||||
#if SYSCFG_MCUCORE == 8051
|
||||
s_rtc_copy.yeah = s_rtc.yeah;
|
||||
s_rtc_copy.year = s_rtc.year;
|
||||
s_rtc_copy.month = s_rtc.month;
|
||||
s_rtc_copy.date = s_rtc.date;
|
||||
s_rtc_copy.hour = s_rtc.hour;
|
||||
s_rtc_copy.minute = s_rtc.minute;
|
||||
s_rtc_copy.second = s_rtc.second;
|
||||
s_rtc_copy.day = s_rtc.day;
|
||||
#else
|
||||
s_rtc_copy = s_rtc;
|
||||
#endif
|
||||
s_sign_updatecopy = false;
|
||||
}
|
||||
#endif
|
||||
+473
@@ -0,0 +1,473 @@
|
||||
/**************************************************************************//**
|
||||
* @item CosyOS-II Kernel
|
||||
* @file os_api.h
|
||||
* @brief 系统内核专用API
|
||||
* @author 迟凯峰
|
||||
* @version V3.4.0
|
||||
* @date 2025.01.06
|
||||
******************************************************************************/
|
||||
|
||||
#ifndef __OS_API_H
|
||||
#define __OS_API_H
|
||||
|
||||
void s_switch_taskpri(s_tasknode_tsp htask);
|
||||
void s_switch_taskmsg(s_tasknode_tsp htask);
|
||||
void s_switch_notnull(s_tasknode_tsp htask);
|
||||
void s_switch_ready (s_tasknode_tsp htask);
|
||||
bool s_remove_taskque(s_tasknode_tsp htask);
|
||||
void s_insert_taskque(s_tasknode_tsp htask);
|
||||
void s_set_taskpri (s_tasknode_tsp htask, s_u8_t npri);
|
||||
void s_update_rtccopy(void);
|
||||
|
||||
|
||||
|
||||
/*
|
||||
* 引用.标准库函数
|
||||
*/
|
||||
|
||||
#define s_init_mempool init_mempool
|
||||
#define s_malloc malloc
|
||||
#define s_calloc calloc
|
||||
#define s_realloc realloc
|
||||
#define s_free free
|
||||
#define s_memcpy memcpy
|
||||
#define s_memcmp memcmp
|
||||
#define s_strcpy strcpy
|
||||
#define s_strcmp strcmp
|
||||
#define s_strlen strlen
|
||||
|
||||
|
||||
|
||||
/*
|
||||
* 操作.定时中断/查询
|
||||
*/
|
||||
|
||||
/** 启动定时中断任务 */
|
||||
#define sStartTask_TimInt(tmid) \
|
||||
sUSV_StartTask((s_taskhand_tsp)s_timint_handle[tmid]->hookorhand, OS_NULL, OS_STATUS_SUSPENDED)
|
||||
|
||||
/** 启动定时查询任务 */
|
||||
#define sStartTask_TimQry(tmid) \
|
||||
sUSV_StartTask((s_taskhand_tsp)s_timqry_handle[tmid]->hookorhand, OS_NULL, OS_STATUS_SUSPENDED)
|
||||
|
||||
/** 恢复定时中断任务 */
|
||||
#define sResumeTask_TimInt(tmid) \
|
||||
sTSV_ResumeTask(*((s_taskhand_tsp)s_timint_handle[tmid]->hookorhand)->dualhandle)
|
||||
|
||||
/** 恢复定时查询任务 */
|
||||
#define sResumeTask_TimQry(tmid) \
|
||||
sTSV_ResumeTask(*((s_taskhand_tsp)s_timqry_handle[tmid]->hookorhand)->dualhandle)
|
||||
|
||||
/** 调用定时中断钩子 */
|
||||
#define sCallHook_TimInt(tmid) \
|
||||
(*(s_voidvoid_tfp)s_timint_handle[tmid]->hookorhand)()
|
||||
|
||||
/** 调用定时查询钩子 */
|
||||
#define sCallHook_TimQry(tmid) \
|
||||
(*(s_voidvoid_tfp)s_timqry_handle[tmid]->hookorhand)()
|
||||
|
||||
|
||||
|
||||
/*
|
||||
* 更新.全局变量副本
|
||||
*/
|
||||
|
||||
#define sUpdateCopy(code) \
|
||||
do{ \
|
||||
s_sign_updatecopy = true; \
|
||||
code; \
|
||||
s_sign_updatecopy = false; \
|
||||
}while(false)
|
||||
|
||||
|
||||
|
||||
/*
|
||||
* 私信 - 创建信箱
|
||||
*/
|
||||
|
||||
#define m0__ MCUCFG_TASKMSG_VAR
|
||||
|
||||
#if MCUCFG_TASKMSG_TYPE == 0
|
||||
|
||||
#define __dm static
|
||||
|
||||
#define sTaskMsg_Init \
|
||||
if(s_sign_send_taskmsg){ \
|
||||
s_sign_send_taskmsg = false; \
|
||||
if(s_kernellock_counter){ \
|
||||
su_kernel_unlock(); \
|
||||
} \
|
||||
return; \
|
||||
} \
|
||||
else{ \
|
||||
m0_ = false; \
|
||||
}
|
||||
|
||||
#define sCreateTaskMsg_0 \
|
||||
(void) \
|
||||
{ \
|
||||
do
|
||||
|
||||
#define sCreateTaskMsg_1(m1) \
|
||||
(m0__, m1##_) \
|
||||
{ \
|
||||
__dm m_taskmsg_t m0; \
|
||||
__dm m1; \
|
||||
__dm m_taskmsg_t mx; \
|
||||
sTaskMsg_Init; \
|
||||
do
|
||||
|
||||
#define sCreateTaskMsg_2(m1, m2) \
|
||||
(m0__, m1##_, m2##_) \
|
||||
{ \
|
||||
__dm m_taskmsg_t m0; \
|
||||
__dm m1; __dm m2; \
|
||||
__dm m_taskmsg_t mx; \
|
||||
sTaskMsg_Init; \
|
||||
do
|
||||
|
||||
#define sCreateTaskMsg_3(m1, m2, m3) \
|
||||
(m0__, m1##_, m2##_, m3##_) \
|
||||
{ \
|
||||
__dm m_taskmsg_t m0; \
|
||||
__dm m1; __dm m2; __dm m3; \
|
||||
__dm m_taskmsg_t mx; \
|
||||
sTaskMsg_Init; \
|
||||
do
|
||||
|
||||
#define sCreateTaskMsg_4(m1, m2, m3, m4) \
|
||||
(m0__, m1##_, m2##_, m3##_, m4##_) \
|
||||
{ \
|
||||
__dm m_taskmsg_t m0; \
|
||||
__dm m1; __dm m2; __dm m3; __dm m4; \
|
||||
__dm m_taskmsg_t mx; \
|
||||
sTaskMsg_Init; \
|
||||
do
|
||||
|
||||
#define sCreateTaskMsg_5(m1, m2, m3, m4, m5) \
|
||||
(m0__, m1##_, m2##_, m3##_, m4##_, m5##_) \
|
||||
{ \
|
||||
__dm m_taskmsg_t m0; \
|
||||
__dm m1; __dm m2; __dm m3; __dm m4; __dm m5; \
|
||||
__dm m_taskmsg_t mx; \
|
||||
sTaskMsg_Init; \
|
||||
do
|
||||
|
||||
#define sCreateTaskMsg_6(m1, m2, m3, m4, m5, m6) \
|
||||
(m0__, m1##_, m2##_, m3##_, m4##_, m5##_, m6##_) \
|
||||
{ \
|
||||
__dm m_taskmsg_t m0; \
|
||||
__dm m1; __dm m2; __dm m3; __dm m4; __dm m5; __dm m6; \
|
||||
__dm m_taskmsg_t mx; \
|
||||
sTaskMsg_Init; \
|
||||
do
|
||||
|
||||
#define sCreateTaskMsg_7(m1, m2, m3, m4, m5, m6, m7) \
|
||||
(m0__, m1##_, m2##_, m3##_, m4##_, m5##_, m6##_, m7##_) \
|
||||
{ \
|
||||
__dm m_taskmsg_t m0; \
|
||||
__dm m1; __dm m2; __dm m3; __dm m4; __dm m5; __dm m6; __dm m7; \
|
||||
__dm m_taskmsg_t mx; \
|
||||
sTaskMsg_Init; \
|
||||
do
|
||||
|
||||
#define sCreateTaskMsg_8(m1, m2, m3, m4, m5, m6, m7, m8) \
|
||||
(m0__, m1##_, m2##_, m3##_, m4##_, m5##_, m6##_, m7##_, m8##_) \
|
||||
{ \
|
||||
__dm m_taskmsg_t m0; \
|
||||
__dm m1; __dm m2; __dm m3; __dm m4; __dm m5; __dm m6; __dm m7; __dm m8; \
|
||||
__dm m_taskmsg_t mx; \
|
||||
sTaskMsg_Init; \
|
||||
do
|
||||
|
||||
#elif MCUCFG_TASKMSG_TYPE == 1
|
||||
|
||||
#define __dm __align(4) static
|
||||
|
||||
#define sTaskMsg_Init \
|
||||
if(s_sign_send_taskmsg){ \
|
||||
register s_u32_t *p; \
|
||||
register s_u8_t size; \
|
||||
m0_ = true; \
|
||||
p = &m0_ + 1; \
|
||||
size = &m0 - &m0_ - 1; \
|
||||
do{ \
|
||||
*p++ = *m_taskmsg_psp++; \
|
||||
}while(--size); \
|
||||
s_sign_send_taskmsg = false; \
|
||||
if(s_taskcri_counter){ \
|
||||
uExitCritical; \
|
||||
} \
|
||||
return; \
|
||||
}
|
||||
|
||||
#define sCreateTaskMsg_0 \
|
||||
(void) \
|
||||
{ \
|
||||
do
|
||||
|
||||
#define sCreateTaskMsg_1(m1) \
|
||||
(m0__, m1##__) \
|
||||
{ \
|
||||
__dm m_taskmsg_t m0_ = false; \
|
||||
__dm m1##_; \
|
||||
__dm m_taskmsg_t m0; \
|
||||
__dm m1; \
|
||||
sTaskMsg_Init; \
|
||||
do
|
||||
|
||||
#define sCreateTaskMsg_2(m1, m2) \
|
||||
(m0__, m1##__, m2##__) \
|
||||
{ \
|
||||
__dm m_taskmsg_t m0_ = false; \
|
||||
__dm m1##_; __dm m2##_; \
|
||||
__dm m_taskmsg_t m0; \
|
||||
__dm m1; __dm m2; \
|
||||
sTaskMsg_Init; \
|
||||
do
|
||||
|
||||
#define sCreateTaskMsg_3(m1, m2, m3) \
|
||||
(m0__, m1##__, m2##__, m3##__) \
|
||||
{ \
|
||||
__dm m_taskmsg_t m0_ = false; \
|
||||
__dm m1##_; __dm m2##_; __dm m3##_; \
|
||||
__dm m_taskmsg_t m0; \
|
||||
__dm m1; __dm m2; __dm m3; \
|
||||
sTaskMsg_Init; \
|
||||
do
|
||||
|
||||
#define sCreateTaskMsg_4(m1, m2, m3, m4) \
|
||||
(m0__, m1##__, m2##__, m3##__, m4##__) \
|
||||
{ \
|
||||
__dm m_taskmsg_t m0_ = false; \
|
||||
__dm m1##_; __dm m2##_; __dm m3##_; __dm m4##_; \
|
||||
__dm m_taskmsg_t m0; \
|
||||
__dm m1; __dm m2; __dm m3; __dm m4; \
|
||||
sTaskMsg_Init; \
|
||||
do
|
||||
|
||||
#define sCreateTaskMsg_5(m1, m2, m3, m4, m5) \
|
||||
(m0__, m1##__, m2##__, m3##__, m4##__, m5##__) \
|
||||
{ \
|
||||
__dm m_taskmsg_t m0_ = false; \
|
||||
__dm m1##_; __dm m2##_; __dm m3##_; __dm m4##_; __dm m5##_; \
|
||||
__dm m_taskmsg_t m0; \
|
||||
__dm m1; __dm m2; __dm m3; __dm m4; __dm m5; \
|
||||
sTaskMsg_Init; \
|
||||
do
|
||||
|
||||
#define sCreateTaskMsg_6(m1, m2, m3, m4, m5, m6) \
|
||||
(m0__, m1##__, m2##__, m3##__, m4##__, m5##__, m6##__) \
|
||||
{ \
|
||||
__dm m_taskmsg_t m0_ = false; \
|
||||
__dm m1##_; __dm m2##_; __dm m3##_; __dm m4##_; __dm m5##_; __dm m6##_; \
|
||||
__dm m_taskmsg_t m0; \
|
||||
__dm m1; __dm m2; __dm m3; __dm m4; __dm m5; __dm m6; \
|
||||
sTaskMsg_Init; \
|
||||
do
|
||||
|
||||
#define sCreateTaskMsg_7(m1, m2, m3, m4, m5, m6, m7) \
|
||||
(m0__, m1##__, m2##__, m3##__, m4##__, m5##__, m6##__, m7##__) \
|
||||
{ \
|
||||
__dm m_taskmsg_t m0_ = false; \
|
||||
__dm m1##_; __dm m2##_; __dm m3##_; __dm m4##_; __dm m5##_; __dm m6##_; __dm m7##_; \
|
||||
__dm m_taskmsg_t m0; \
|
||||
__dm m1; __dm m2; __dm m3; __dm m4; __dm m5; __dm m6; __dm m7; \
|
||||
sTaskMsg_Init; \
|
||||
do
|
||||
|
||||
#define sCreateTaskMsg_8(m1, m2, m3, m4, m5, m6, m7, m8) \
|
||||
(m0__, m1##__, m2##__, m3##__, m4##__, m5##__, m6##__, m7##__, m8##__) \
|
||||
{ \
|
||||
__dm m_taskmsg_t m0_ = false; \
|
||||
__dm m1##_; __dm m2##_; __dm m3##_; __dm m4##_; __dm m5##_; __dm m6##_; __dm m7##_; __dm m8##_; \
|
||||
__dm m_taskmsg_t m0; \
|
||||
__dm m1; __dm m2; __dm m3; __dm m4; __dm m5; __dm m6; __dm m7; __dm m8; \
|
||||
sTaskMsg_Init; \
|
||||
do
|
||||
|
||||
#endif
|
||||
|
||||
|
||||
|
||||
/*
|
||||
* 事件标志组 - 写标志位
|
||||
*/
|
||||
|
||||
#define siWriteFlagBits \
|
||||
u_psv.value = ( \
|
||||
sizeof(lv) == 1 ? *(s_u8_t *)&lv \
|
||||
: sizeof(lv) == 2 ? *(s_u16_t *)&lv \
|
||||
: sizeof(lv) == 4 ? *(s_u32_t *)&lv \
|
||||
: 0 \
|
||||
); \
|
||||
} \
|
||||
mPendSV_FIFOLoad; \
|
||||
}while(false)
|
||||
|
||||
#define siWriteFlagBits_1(bit1) \
|
||||
lv.bit1 = true; \
|
||||
siWriteFlagBits
|
||||
|
||||
#define siWriteFlagBits_2(bit1, bit2) \
|
||||
lv.bit1 = lv.bit2 = true; \
|
||||
siWriteFlagBits
|
||||
|
||||
#define siWriteFlagBits_3(bit1, bit2, bit3) \
|
||||
lv.bit1 = lv.bit2 = lv.bit3 = true; \
|
||||
siWriteFlagBits
|
||||
|
||||
#define siWriteFlagBits_4(bit1, bit2, bit3, bit4) \
|
||||
lv.bit1 = lv.bit2 = lv.bit3 = lv.bit4 = true; \
|
||||
siWriteFlagBits
|
||||
|
||||
#define siWriteFlagBits_5(bit1, bit2, bit3, bit4, bit5) \
|
||||
lv.bit1 = lv.bit2 = lv.bit3 = lv.bit4 = lv.bit5 = true; \
|
||||
siWriteFlagBits
|
||||
|
||||
#define siWriteFlagBits_6(bit1, bit2, bit3, bit4, bit5, bit6) \
|
||||
lv.bit1 = lv.bit2 = lv.bit3 = lv.bit4 = lv.bit5 = lv.bit6 = true; \
|
||||
siWriteFlagBits
|
||||
|
||||
#define siWriteFlagBits_7(bit1, bit2, bit3, bit4, bit5, bit6, bit7) \
|
||||
lv.bit1 = lv.bit2 = lv.bit3 = lv.bit4 = lv.bit5 = lv.bit6 = lv.bit7 = true; \
|
||||
siWriteFlagBits
|
||||
|
||||
#define siWriteFlagBits_8(bit1, bit2, bit3, bit4, bit5, bit6, bit7, bit8) \
|
||||
lv.bit1 = lv.bit2 = lv.bit3 = lv.bit4 = lv.bit5 = lv.bit6 = lv.bit7 = lv.bit8 = true; \
|
||||
siWriteFlagBits
|
||||
|
||||
#define siWriteFlagBits_9(bit1, bit2, bit3, bit4, bit5, bit6, bit7, bit8, bit9) \
|
||||
lv.bit1 = lv.bit2 = lv.bit3 = lv.bit4 = lv.bit5 = lv.bit6 = lv.bit7 = lv.bit8 = true; \
|
||||
lv.bit9 = true; \
|
||||
siWriteFlagBits
|
||||
|
||||
#define siWriteFlagBits_10(bit1, bit2, bit3, bit4, bit5, bit6, bit7, bit8, bit9, bit10) \
|
||||
lv.bit1 = lv.bit2 = lv.bit3 = lv.bit4 = lv.bit5 = lv.bit6 = lv.bit7 = lv.bit8 = true; \
|
||||
lv.bit9 = lv.bit10 = true; \
|
||||
siWriteFlagBits
|
||||
|
||||
#define siWriteFlagBits_11(bit1, bit2, bit3, bit4, bit5, bit6, bit7, bit8, bit9, bit10, bit11) \
|
||||
lv.bit1 = lv.bit2 = lv.bit3 = lv.bit4 = lv.bit5 = lv.bit6 = lv.bit7 = lv.bit8 = true; \
|
||||
lv.bit9 = lv.bit10 = lv.bit11 = true; \
|
||||
siWriteFlagBits
|
||||
|
||||
#define siWriteFlagBits_12(bit1, bit2, bit3, bit4, bit5, bit6, bit7, bit8, bit9, bit10, bit11, bit12) \
|
||||
lv.bit1 = lv.bit2 = lv.bit3 = lv.bit4 = lv.bit5 = lv.bit6 = lv.bit7 = lv.bit8 = true; \
|
||||
lv.bit9 = lv.bit10 = lv.bit11 = lv.bit12 = true; \
|
||||
siWriteFlagBits
|
||||
|
||||
#define siWriteFlagBits_13(bit1, bit2, bit3, bit4, bit5, bit6, bit7, bit8, bit9, bit10, bit11, bit12, bit13) \
|
||||
lv.bit1 = lv.bit2 = lv.bit3 = lv.bit4 = lv.bit5 = lv.bit6 = lv.bit7 = lv.bit8 = true; \
|
||||
lv.bit9 = lv.bit10 = lv.bit11 = lv.bit12 = lv.bit13 = true; \
|
||||
siWriteFlagBits
|
||||
|
||||
#define siWriteFlagBits_14(bit1, bit2, bit3, bit4, bit5, bit6, bit7, bit8, bit9, bit10, bit11, bit12, bit13, bit14) \
|
||||
lv.bit1 = lv.bit2 = lv.bit3 = lv.bit4 = lv.bit5 = lv.bit6 = lv.bit7 = lv.bit8 = true; \
|
||||
lv.bit9 = lv.bit10 = lv.bit11 = lv.bit12 = lv.bit13 = lv.bit14 = true; \
|
||||
siWriteFlagBits
|
||||
|
||||
#define siWriteFlagBits_15(bit1, bit2, bit3, bit4, bit5, bit6, bit7, bit8, bit9, bit10, bit11, bit12, bit13, bit14, bit15) \
|
||||
lv.bit1 = lv.bit2 = lv.bit3 = lv.bit4 = lv.bit5 = lv.bit6 = lv.bit7 = lv.bit8 = true; \
|
||||
lv.bit9 = lv.bit10 = lv.bit11 = lv.bit12 = lv.bit13 = lv.bit14 = lv.bit15 = true; \
|
||||
siWriteFlagBits
|
||||
|
||||
#define siWriteFlagBits_16(bit1, bit2, bit3, bit4, bit5, bit6, bit7, bit8, bit9, bit10, bit11, bit12, bit13, bit14, bit15, bit16) \
|
||||
lv.bit1 = lv.bit2 = lv.bit3 = lv.bit4 = lv.bit5 = lv.bit6 = lv.bit7 = lv.bit8 = true; \
|
||||
lv.bit9 = lv.bit10 = lv.bit11 = lv.bit12 = lv.bit13 = lv.bit14 = lv.bit15 = lv.bit16 = true; \
|
||||
siWriteFlagBits
|
||||
|
||||
|
||||
|
||||
/*
|
||||
* 消息队列
|
||||
*/
|
||||
|
||||
/** 动态队列 - 发送消息 */
|
||||
#define sSendMsg_Dynamic(p) \
|
||||
do{ \
|
||||
hmsg->msg = p; \
|
||||
hmsg->next = OS_NULL; \
|
||||
hmsg->last = ((sd_queue_tsp)hque)->tail; \
|
||||
if(((sd_queue_tsp)hque)->tail != OS_NULL){ \
|
||||
((sd_queue_tsp)hque)->tail->next = hmsg; \
|
||||
} \
|
||||
((sd_queue_tsp)hque)->tail = hmsg; \
|
||||
if(((sd_queue_tsp)hque)->head == OS_NULL){ \
|
||||
((sd_queue_tsp)hque)->head = hmsg; \
|
||||
} \
|
||||
hque->counter++; \
|
||||
}while(false)
|
||||
|
||||
/** 动态队列 - 接收消息 */
|
||||
#define sRecvMsg_Dynamic(p) \
|
||||
do{ \
|
||||
if(hque->mode == __QUE_LIFO__){ \
|
||||
hmsg = ((sd_queue_tsp)hque)->tail; \
|
||||
p = hmsg->msg; \
|
||||
hmsg = hmsg->last; \
|
||||
s_free(((sd_queue_tsp)hque)->tail); \
|
||||
((sd_queue_tsp)hque)->tail = hmsg; \
|
||||
if(hmsg == OS_NULL){ \
|
||||
((sd_queue_tsp)hque)->head = OS_NULL; \
|
||||
} \
|
||||
else{ \
|
||||
hmsg->next = OS_NULL; \
|
||||
} \
|
||||
} \
|
||||
else{ \
|
||||
hmsg = ((sd_queue_tsp)hque)->head; \
|
||||
p = hmsg->msg; \
|
||||
hmsg = hmsg->next; \
|
||||
s_free(((sd_queue_tsp)hque)->head); \
|
||||
((sd_queue_tsp)hque)->head = hmsg; \
|
||||
if(hmsg == OS_NULL){ \
|
||||
((sd_queue_tsp)hque)->tail = OS_NULL; \
|
||||
} \
|
||||
else{ \
|
||||
hmsg->last = OS_NULL; \
|
||||
} \
|
||||
} \
|
||||
hque->counter--; \
|
||||
}while(false)
|
||||
|
||||
/** 静态队列 - 发送消息 */
|
||||
#define sSendMsg_Static(p) \
|
||||
do{ \
|
||||
if(((ss_queue_tsp)hque)->tail < ((ss_queue_tsp)hque)->base + hque->len - 1){ \
|
||||
((ss_queue_tsp)hque)->tail++; \
|
||||
} \
|
||||
else{ \
|
||||
((ss_queue_tsp)hque)->tail = ((ss_queue_tsp)hque)->base; \
|
||||
} \
|
||||
*((ss_queue_tsp)hque)->tail = p; \
|
||||
hque->counter++; \
|
||||
}while(false)
|
||||
|
||||
/** 静态队列 - 接收消息 */
|
||||
#define sRecvMsg_Static(p) \
|
||||
do{ \
|
||||
if(hque->mode == __QUE_LIFO__){ \
|
||||
p = *((ss_queue_tsp)hque)->tail; \
|
||||
if(((ss_queue_tsp)hque)->tail > ((ss_queue_tsp)hque)->base){ \
|
||||
((ss_queue_tsp)hque)->tail--; \
|
||||
} \
|
||||
else{ \
|
||||
((ss_queue_tsp)hque)->tail = ((ss_queue_tsp)hque)->base + hque->len - 1; \
|
||||
} \
|
||||
} \
|
||||
else{ \
|
||||
p = *((ss_queue_tsp)hque)->head; \
|
||||
if(((ss_queue_tsp)hque)->head < ((ss_queue_tsp)hque)->base + hque->len - 1){ \
|
||||
((ss_queue_tsp)hque)->head++; \
|
||||
} \
|
||||
else{ \
|
||||
((ss_queue_tsp)hque)->head = ((ss_queue_tsp)hque)->base; \
|
||||
} \
|
||||
} \
|
||||
hque->counter--; \
|
||||
}while(false)
|
||||
|
||||
|
||||
|
||||
#endif
|
||||
File diff suppressed because it is too large
Load Diff
File diff suppressed because it is too large
Load Diff
@@ -0,0 +1,478 @@
|
||||
/**************************************************************************//**
|
||||
* @item CosyOS-II Kernel
|
||||
* @file sv_int_pend_fifo.c
|
||||
* @brief 中断挂起服务_FIFO - 执行函数
|
||||
* @details 仅在 PendSV 中由系统调用并执行。
|
||||
* @author 迟凯峰
|
||||
* @version V3.4.0
|
||||
* @date 2025.01.06
|
||||
******************************************************************************/
|
||||
|
||||
#include "os_link.h"
|
||||
#if MCUCFG_PENDSVFIFO_DEPTH > 0
|
||||
|
||||
/**
|
||||
@addtogroup CosyOS_内核服务
|
||||
@{
|
||||
*//**
|
||||
\defgroup 中断挂起服务_FIFO
|
||||
\brief 在中断中调用的服务，不在本地执行，而是把服务的内容写入局部的结构体中，
|
||||
再把结构体指针入 PendSV_FIFO，再触发 PendSV，而后在 PendSV 中执行。
|
||||
@{
|
||||
*/
|
||||
|
||||
/**
|
||||
\page 手动裁剪说明：
|
||||
|
||||
\li 本页中的各个执行函数，任何编译器都无法自动移除未使用，原因是<br>
|
||||
它们是通过函数指针间接调用的。
|
||||
|
||||
\li 如果您希望做到极致的裁剪，可逐一查看这些函数，确定不使用的，<br>
|
||||
可通过 手动开关 进行手动移除。
|
||||
*/
|
||||
|
||||
/**
|
||||
\brief 清除就绪延时
|
||||
\param[in] sv 服务的结构体指针
|
||||
\return 无
|
||||
\note 关联服务：iClearDelay。
|
||||
*/
|
||||
#if 1 /* 手动开关 *//* 如果用户不会调用关联服务，可手动移除该函数（1 改为 0）*/
|
||||
static void _clear_delay_(void _STATIC_MEM_ *sv) MCUCFG_C51USING
|
||||
{
|
||||
if(sv == OS_NULL) return; /* 该句无实际用途，只为屏蔽可能的编译器警告 */
|
||||
if(s_sign_ready_delay){
|
||||
s_sign_ready_delay = false;
|
||||
s_task_current->timer = 0;
|
||||
}
|
||||
}
|
||||
#else
|
||||
#define _clear_delay_ OS_NULL
|
||||
#endif
|
||||
|
||||
/**
|
||||
\brief 切换任务
|
||||
\param[in] sv 服务的结构体指针
|
||||
\return 无
|
||||
\note 关联服务：iSwitchTask(task)。
|
||||
*/
|
||||
#if 1 /* 手动开关 *//* 如果用户不会调用关联服务，可手动移除该函数（1 改为 0）*/
|
||||
static void _switch_task_(void _STATIC_MEM_ *sv) MCUCFG_C51USING
|
||||
{
|
||||
s_tasknode_tsp htask = ((sp_task_tsp)sv)->htask;
|
||||
if(htask == OS_NULL) return;
|
||||
if(htask->status < OS_STATUS_STOPPED){
|
||||
s_switch_taskpri(htask);
|
||||
}
|
||||
}
|
||||
#else
|
||||
#define _switch_task_ OS_NULL
|
||||
#endif
|
||||
|
||||
/**
|
||||
\brief 恢复任务
|
||||
\param[in] sv 服务的结构体指针
|
||||
\return 无
|
||||
\note 关联服务：iResumeTask(task)。
|
||||
*/
|
||||
#if 1 /* 手动开关 *//* 如果用户不会调用关联服务，可手动移除该函数（1 改为 0）*/
|
||||
static void _resume_task_(void _STATIC_MEM_ *sv) MCUCFG_C51USING
|
||||
{
|
||||
s_tasknode_tsp htask = ((sp_task_tsp)sv)->htask;
|
||||
if(htask == OS_NULL) return;
|
||||
if(htask->status & OS_STATUS_SUSPENDED){
|
||||
htask->status &= (~OS_STATUS_SUSPENDED & 0xFF);
|
||||
#if SYSCFG_SAMEPRISCHEDULE == __TIMESHARING__
|
||||
htask->tc_counter = 0;
|
||||
#endif
|
||||
s_switch_ready(htask);
|
||||
}
|
||||
}
|
||||
#else
|
||||
#define _resume_task_ OS_NULL
|
||||
#endif
|
||||
|
||||
/**
|
||||
\brief 挂起任务
|
||||
\param[in] sv 服务的结构体指针
|
||||
\return 无
|
||||
\note 关联服务：iSuspendTask(task)。
|
||||
*/
|
||||
#if 1 /* 手动开关 *//* 如果用户不会调用关联服务，可手动移除该函数（1 改为 0）*/
|
||||
static void _suspend_task_(void _STATIC_MEM_ *sv) MCUCFG_C51USING
|
||||
{
|
||||
s_tasknode_tsp htask = ((sp_task_tsp)sv)->htask;
|
||||
if(htask == OS_NULL) return;
|
||||
if(htask->status < OS_STATUS_SUSPENDED){
|
||||
htask->status |= OS_STATUS_SUSPENDED;
|
||||
if(htask == s_task_current){
|
||||
s_sign_schedule = true;
|
||||
}
|
||||
}
|
||||
}
|
||||
#else
|
||||
#define _suspend_task_ OS_NULL
|
||||
#endif
|
||||
|
||||
/**
|
||||
\brief 删除任务
|
||||
\param[in] sv 服务的结构体指针
|
||||
\return 无
|
||||
\note 关联服务：iDeleteTask(task)。
|
||||
*/
|
||||
#if 1 /* 手动开关 *//* 如果用户不会调用关联服务，可手动移除该函数（1 改为 0）*/
|
||||
static void _delete_task_(void _STATIC_MEM_ *sv) MCUCFG_C51USING
|
||||
{
|
||||
s_tasknode_tsp htask = ((sp_task_tsp)sv)->htask;
|
||||
if(htask == OS_NULL) return;
|
||||
if(htask->status < OS_STATUS_DELETED){
|
||||
htask->status = OS_STATUS_DELETED;
|
||||
if(htask == s_task_current){
|
||||
s_sign_schedule = true;
|
||||
}
|
||||
}
|
||||
}
|
||||
#else
|
||||
#define _delete_task_ OS_NULL
|
||||
#endif
|
||||
|
||||
/**
|
||||
\brief 设置任务优先级
|
||||
\param[in] sv 服务的结构体指针
|
||||
\return 无
|
||||
\note 关联服务：iSetTaskPri(task, pri)。
|
||||
*/
|
||||
#if 1 /* 手动开关 *//* 如果用户不会调用关联服务，可手动移除该函数（1 改为 0）*/
|
||||
static void _set_taskpri_(void _STATIC_MEM_ *sv) MCUCFG_C51USING
|
||||
{
|
||||
s_tasknode_tsp htask = ((sp_taskpri_tsp)sv)->htask;
|
||||
if(htask == OS_NULL) return;
|
||||
if(htask->status < OS_STATUS_STOPPED){
|
||||
s_u8_t npri = ((sp_taskpri_tsp)sv)->npri;
|
||||
if(htask->pri != npri){
|
||||
s_set_taskpri(htask, npri);
|
||||
s_sign_schedule = true;
|
||||
}
|
||||
}
|
||||
}
|
||||
#else
|
||||
#define _set_taskpri_ OS_NULL
|
||||
#endif
|
||||
|
||||
/**
|
||||
\brief 设置阻塞（时间）
|
||||
\param[in] sv 服务的结构体指针
|
||||
\return 无
|
||||
\note 关联服务：iSetBlock_tc(task, tc)、iSetBlock_ms(task, ms)、
|
||||
iSetBlock_s(task, s)、iSetBlock_m(task, m)、iSetBlock_h(task, h)。
|
||||
*/
|
||||
#if 1 /* 手动开关 *//* 如果用户不会调用关联服务，可手动移除该函数（1 改为 0）*/
|
||||
static void _set_block_(void _STATIC_MEM_ *sv) MCUCFG_C51USING
|
||||
{
|
||||
s_tasknode_tsp htask = ((sp_blocktime_tsp)sv)->htask;
|
||||
if(htask == OS_NULL) return;
|
||||
if(htask->status == OS_STATUS_BLOCKED){
|
||||
if(!((sp_blocktime_tsp)sv)->tick){
|
||||
htask->status = OS_STATUS_READY;
|
||||
htask->timer = 0;
|
||||
#if SYSCFG_SAMEPRISCHEDULE == __TIMESHARING__
|
||||
htask->tc_counter = 0;
|
||||
#endif
|
||||
s_switch_taskpri(htask);
|
||||
}
|
||||
else{
|
||||
htask->timer = ((sp_blocktime_tsp)sv)->tick;
|
||||
}
|
||||
}
|
||||
}
|
||||
#else
|
||||
#define _set_block_ OS_NULL
|
||||
#endif
|
||||
|
||||
/**
|
||||
\brief 清除阻塞（状态）
|
||||
\param[in] sv 服务的结构体指针
|
||||
\return 无
|
||||
\note 关联服务：iClearBlock(task)。
|
||||
*/
|
||||
#if 1 /* 手动开关 *//* 如果用户不会调用关联服务，可手动移除该函数（1 改为 0）*/
|
||||
static void _clear_block_(void _STATIC_MEM_ *sv) MCUCFG_C51USING
|
||||
{
|
||||
s_tasknode_tsp htask = ((sp_task_tsp)sv)->htask;
|
||||
if(htask == OS_NULL) return;
|
||||
if(htask->status == OS_STATUS_BLOCKED){
|
||||
htask->status = OS_STATUS_READY;
|
||||
htask->timer = 0;
|
||||
#if SYSCFG_SAMEPRISCHEDULE == __TIMESHARING__
|
||||
htask->tc_counter = 0;
|
||||
#endif
|
||||
s_switch_taskpri(htask);
|
||||
}
|
||||
}
|
||||
#else
|
||||
#define _clear_block_ OS_NULL
|
||||
#endif
|
||||
|
||||
/**
|
||||
\brief 定时中断
|
||||
\param[in] sv 服务的结构体指针
|
||||
\return 无
|
||||
\note 关联服务：iTimInt_tc(tmid, tc)、iTimInt_ms(tmid, ms)、iTimInt_s(tmid, s)、
|
||||
iTimInt_m(tmid, m)、iTimInt_h(tmid, h)、iTimInt_Cancel(tmid)。
|
||||
*/
|
||||
#if 1 /* 手动开关 *//* 如果用户不会调用关联服务，可手动移除该函数（1 改为 0）*/ \
|
||||
&& OS_TIMINTTOTAL
|
||||
static void _timint_(void _STATIC_MEM_ *sv) MCUCFG_C51USING
|
||||
{
|
||||
s_timint_handle[((sp_timint_tsp)sv)->tmid]->timer
|
||||
= s_timint_handle[((sp_timint_tsp)sv)->tmid]->reload
|
||||
= ((sp_timint_tsp)sv)->tick;
|
||||
}
|
||||
#else
|
||||
#define _timint_ OS_NULL
|
||||
#endif
|
||||
|
||||
/**
|
||||
\brief 定时查询
|
||||
\param[in] sv 服务的结构体指针
|
||||
\return 无
|
||||
\note 关联服务：iTimQry_tc(tmid, tc)、iTimQry_ms(tmid, ms)、iTimQry_s(tmid, s)、
|
||||
iTimQry_m(tmid, m)、iTimQry_h(tmid, h)、iTimQry_Cancel(tmid)。
|
||||
*/
|
||||
#if 1 /* 手动开关 *//* 如果用户不会调用关联服务，可手动移除该函数（1 改为 0）*/ \
|
||||
&& OS_TIMQRYTOTAL
|
||||
static void _timqry_(void _STATIC_MEM_ *sv) MCUCFG_C51USING
|
||||
{
|
||||
s_timqry_handle[((sp_timqry_tsp)sv)->tmid]->timer
|
||||
= s_timqry_handle[((sp_timqry_tsp)sv)->tmid]->reload
|
||||
= ((sp_timqry_tsp)sv)->tick;
|
||||
}
|
||||
#else
|
||||
#define _timqry_ OS_NULL
|
||||
#endif
|
||||
|
||||
/**
|
||||
\brief 上锁or给予二值信号量
|
||||
\param[in] sv 服务的结构体指针
|
||||
\return 无
|
||||
\note 关联服务：iLockBin(bin)、iGiveBin(bin)、iBackBin(bin)。
|
||||
*/
|
||||
#if 1 /* 手动开关 *//* 如果用户不会调用关联服务，可手动移除该函数（1 改为 0）*/ \
|
||||
&& SYSCFG_BINARY == __ENABLED__
|
||||
static void _binary_(void _STATIC_MEM_ *sv) MCUCFG_C51USING
|
||||
{
|
||||
s_binary_tsp hbin = ((sp_binary_tsp)sv)->hbin;
|
||||
hbin->binary = ((sp_binary_tsp)sv)->value;
|
||||
if(!hbin->binary) return;
|
||||
s_switch_notnull(hbin->htask);
|
||||
}
|
||||
#else
|
||||
#define _binary_ OS_NULL
|
||||
#endif
|
||||
|
||||
/**
|
||||
\brief 给予计数信号量
|
||||
\param[in] sv 服务的结构体指针
|
||||
\return 无
|
||||
\note 关联服务：iGiveSem(sem)。
|
||||
*/
|
||||
#if 1 /* 手动开关 *//* 如果用户不会调用关联服务，可手动移除该函数（1 改为 0）*/ \
|
||||
&& SYSCFG_SEMAPHORE == __ENABLED__
|
||||
static void _give_sem_(void _STATIC_MEM_ *sv) MCUCFG_C51USING
|
||||
{
|
||||
s_semaph_tsp hsem = ((sp_semaph_tsp)sv)->hsem;
|
||||
if(hsem->counter < hsem->maximum){
|
||||
hsem->counter++;
|
||||
}
|
||||
s_switch_notnull(hsem->htask);
|
||||
}
|
||||
#else
|
||||
#define _give_sem_ OS_NULL
|
||||
#endif
|
||||
|
||||
/**
|
||||
\brief 发送飞信
|
||||
\param[in] sv 服务的结构体指针
|
||||
\return 无
|
||||
\note 关联服务：iSendFetion(tbox, tion)。
|
||||
*/
|
||||
#if 1 /* 手动开关 *//* 如果用户不会调用关联服务，可手动移除该函数（1 改为 0）*/ \
|
||||
&& SYSCFG_FETION == __ENABLED__
|
||||
static void _send_fetion_(void _STATIC_MEM_ *sv) MCUCFG_C51USING
|
||||
{
|
||||
s_tionbox_tsp htbox = ((sp_tionbox_tsp)sv)->htbox;
|
||||
htbox->fetion = ((sp_tionbox_tsp)sv)->fetion;
|
||||
s_switch_notnull(htbox->htask);
|
||||
}
|
||||
#else
|
||||
#define _send_fetion_ OS_NULL
|
||||
#endif
|
||||
|
||||
/**
|
||||
\brief 发送邮件
|
||||
\param[in] sv 服务的结构体指针
|
||||
\return 无
|
||||
\note 关联服务：iSendMail(mbox, mail)。
|
||||
*/
|
||||
#if 1 /* 手动开关 *//* 如果用户不会调用关联服务，可手动移除该函数（1 改为 0）*/ \
|
||||
&& SYSCFG_MAILBOX == __ENABLED__
|
||||
static void _send_mail_(void _STATIC_MEM_ *sv) MCUCFG_C51USING
|
||||
{
|
||||
s_mailbox_tsp hmbox = ((sp_mailbox_tsp)sv)->hmbox;
|
||||
hmbox->flag = false;
|
||||
hmbox->mail = ((sp_mailbox_tsp)sv)->mail;
|
||||
hmbox->flag = true;
|
||||
s_switch_notnull(hmbox->htask);
|
||||
}
|
||||
#else
|
||||
#define _send_mail_ OS_NULL
|
||||
#endif
|
||||
|
||||
/**
|
||||
\brief 发送消息
|
||||
\param[in] sv 服务的结构体指针
|
||||
\return 无
|
||||
\note 关联服务：iSendMsg(que, msg)。
|
||||
*/
|
||||
#if 1 /* 手动开关 *//* 如果用户不会调用关联服务，可手动移除该函数（1 改为 0）*/ \
|
||||
&& SYSCFG_MSGQUEUE == __ENABLED__
|
||||
static void _send_msg_(void _STATIC_MEM_ *sv) MCUCFG_C51USING
|
||||
{
|
||||
s_queue_tsp hque = ((sp_msg_tsp)sv)->hque;
|
||||
hque->mutex = false;
|
||||
|
||||
if(hque->counter == hque->len){
|
||||
#if SYSCFG_DEBUGGING == __ENABLED__
|
||||
s_alarm.overflow_msgqueue = true;
|
||||
#endif
|
||||
hque->mutex = true;
|
||||
return;
|
||||
}
|
||||
if(hque->type == __DYNAMIC__){
|
||||
s_msgnode_tsp hmsg = OS_NULL;
|
||||
hmsg = (s_msgnode_tsp)s_malloc(sizeof(s_msgnode_ts));
|
||||
if(hmsg == OS_NULL){
|
||||
#if SYSCFG_DEBUGGING == __ENABLED__
|
||||
s_fault.mallocfailed_msgnode = true;
|
||||
#endif
|
||||
hque->mutex = true;
|
||||
return;
|
||||
}
|
||||
sSendMsg_Dynamic(((sp_msg_tsp)sv)->msg);
|
||||
}
|
||||
else
|
||||
sSendMsg_Static(((sp_msg_tsp)sv)->msg);
|
||||
|
||||
s_switch_notnull(hque->htask);
|
||||
hque->mutex = true;
|
||||
}
|
||||
#else
|
||||
#define _send_msg_ OS_NULL
|
||||
#endif
|
||||
|
||||
/**
|
||||
\brief 写标志组
|
||||
\param[in] sv 服务的结构体指针
|
||||
\return 无
|
||||
\note 关联服务：iClearFlagGroup(group)、
|
||||
iSetFlagBit(group, bit)、iSetFlagBits(group, nbit) ...)、
|
||||
iClearFlagBit(group, bit)、iClearFlagBits(group, nbit) ...)。
|
||||
*/
|
||||
#if 1 /* 手动开关 *//* 如果用户不会调用关联服务，可手动移除该函数（1 改为 0）*/ \
|
||||
&& SYSCFG_FLAGGROUP == __ENABLED__
|
||||
static void _group_(void _STATIC_MEM_ *sv) MCUCFG_C51USING
|
||||
{
|
||||
switch(((sp_group_tsp)sv)->size){
|
||||
case +1: *(s_u8_t *)((sp_group_tsp)sv)->hgrp |= ((sp_group_tsp)sv)->value; break;
|
||||
case +2: *(s_u16_t *)((sp_group_tsp)sv)->hgrp |= ((sp_group_tsp)sv)->value; break;
|
||||
case +4: *(s_u32_t *)((sp_group_tsp)sv)->hgrp |= ((sp_group_tsp)sv)->value; break;
|
||||
case -1: *(s_u8_t *)((sp_group_tsp)sv)->hgrp &=~((sp_group_tsp)sv)->value; break;
|
||||
case -2: *(s_u16_t *)((sp_group_tsp)sv)->hgrp &=~((sp_group_tsp)sv)->value; break;
|
||||
case -4: *(s_u32_t *)((sp_group_tsp)sv)->hgrp &=~((sp_group_tsp)sv)->value; break;
|
||||
}
|
||||
}
|
||||
#else
|
||||
#define _group_ OS_NULL
|
||||
#endif
|
||||
|
||||
/**
|
||||
\brief 全局变量写访问
|
||||
\param[in] sv 服务的结构体指针
|
||||
\return 无
|
||||
\note 关联服务：iWriteGVar(gv, lv)、iWriteGAry(gp, lp, size)、iWriteGStr(gs, ls)。
|
||||
*/
|
||||
#if 1 /* 手动开关 *//* 如果用户不会调用关联服务，可手动移除该函数（1 改为 0）*/
|
||||
static void _gvar_write_(void _STATIC_MEM_ *sv) MCUCFG_C51USING
|
||||
{
|
||||
((sp_gvar_tsp)sv)->size
|
||||
? s_memcpy(((sp_gvar_tsp)sv)->gp, ((sp_gvar_tsp)sv)->lp, ((sp_gvar_tsp)sv)->size)
|
||||
: s_strcpy((char *)((sp_gvar_tsp)sv)->gp, (char *)((sp_gvar_tsp)sv)->lp);
|
||||
}
|
||||
#else
|
||||
#define _gvar_write_ OS_NULL
|
||||
#endif
|
||||
|
||||
/**
|
||||
\brief 挂起服务调用
|
||||
\param[in] sv 服务的结构体指针
|
||||
\return 无
|
||||
\note 关联服务：iPendSVC(fp)。
|
||||
*/
|
||||
#if 1 /* 手动开关 *//* 如果用户不会调用关联服务，可手动移除该函数（1 改为 0）*/
|
||||
static void _pendsvc_(void _STATIC_MEM_ *sv) MCUCFG_C51USING
|
||||
{
|
||||
(*((sp_pendsvc_tsp)sv)->fp)();
|
||||
}
|
||||
#else
|
||||
#define _pendsvc_ OS_NULL
|
||||
#endif
|
||||
|
||||
/**
|
||||
\brief 发送信号
|
||||
\param[in] sv 服务的结构体指针
|
||||
\return 无
|
||||
\note 关联服务：iSendSign(sign)；
|
||||
iSetTime(t) [系统配置中，当 中断中获取RTC 选项为启用，
|
||||
即 SYSCFG_GETRTC_INT == 1 时，调用该服务]。
|
||||
*/
|
||||
#if 1 /* 手动开关 *//* 如果用户不会调用关联服务，可手动移除该函数（1 改为 0）*/
|
||||
static void _send_sign_(void _STATIC_MEM_ *sv) MCUCFG_C51USING
|
||||
{
|
||||
*((sp_sign_tsp)sv)->sign = true;
|
||||
}
|
||||
#else
|
||||
#define _send_sign_ OS_NULL
|
||||
#endif
|
||||
|
||||
/**
|
||||
\brief 中断挂起服务_FIFO - 执行总函数（函数指针数组）
|
||||
\param[in] [SVID] 服务ID
|
||||
\param[in] sv 服务的结构体指针
|
||||
\return 无
|
||||
*/
|
||||
void (_CODE_MEM_ * const _CONST_MEM_ sPendSV_FIFOHandler[OS_SVID_END])(void _STATIC_MEM_ *sv) =
|
||||
{
|
||||
_clear_delay_,
|
||||
_switch_task_,
|
||||
_resume_task_,
|
||||
_suspend_task_,
|
||||
_delete_task_,
|
||||
_set_taskpri_,
|
||||
_set_block_,
|
||||
_clear_block_,
|
||||
_timint_,
|
||||
_timqry_,
|
||||
_binary_,
|
||||
_give_sem_,
|
||||
_send_fetion_,
|
||||
_send_mail_,
|
||||
_send_msg_,
|
||||
_group_,
|
||||
_gvar_write_,
|
||||
_pendsvc_,
|
||||
_send_sign_
|
||||
};
|
||||
|
||||
/** @} */
|
||||
/** @} */
|
||||
#endif
|
||||
@@ -0,0 +1,192 @@
|
||||
/**************************************************************************//**
|
||||
* @item CosyOS-II Kernel
|
||||
* @file sv_int_pend_fifo.h
|
||||
* @brief 中断挂起服务_FIFO - 调用宏
|
||||
* @details 仅在用户中断中调用，而后挂起到 PendSV 中执行。
|
||||
* @author 迟凯峰
|
||||
* @version V3.4.0
|
||||
* @date 2025.01.06
|
||||
******************************************************************************/
|
||||
|
||||
#ifndef __SV_INT_PEND_FIFO_H
|
||||
#define __SV_INT_PEND_FIFO_H
|
||||
|
||||
/**
|
||||
@addtogroup 中断挂起服务_FIFO
|
||||
@{
|
||||
*/
|
||||
|
||||
/** 清除就绪延时 */
|
||||
#define sPSV_ClearDelay \
|
||||
do{ \
|
||||
static sp_task_ts u_psv = {OS_SVID_CLEARDELAY, OS_NULL}; \
|
||||
mPendSV_FIFOLoad; \
|
||||
}while(false)
|
||||
|
||||
/** 切换任务 */
|
||||
#define sPSV_SwitchTask(_htask) \
|
||||
do{ \
|
||||
static sp_task_ts u_psv = {OS_SVID_SWITCHTASK, OS_NULL}; \
|
||||
u_psv.htask = _htask; \
|
||||
mPendSV_FIFOLoad; \
|
||||
}while(false)
|
||||
|
||||
/** 恢复任务 */
|
||||
#define sPSV_ResumeTask(_htask) \
|
||||
do{ \
|
||||
static sp_task_ts u_psv = {OS_SVID_RESUMETASK, OS_NULL}; \
|
||||
u_psv.htask = _htask; \
|
||||
mPendSV_FIFOLoad; \
|
||||
}while(false)
|
||||
|
||||
/** 挂起任务 */
|
||||
#define sPSV_SuspendTask(_htask) \
|
||||
do{ \
|
||||
static sp_task_ts u_psv = {OS_SVID_SUSPENDTASK, OS_NULL}; \
|
||||
u_psv.htask = _htask; \
|
||||
mPendSV_FIFOLoad; \
|
||||
}while(false)
|
||||
|
||||
/** 删除任务 */
|
||||
#define sPSV_DeleteTask(_htask) \
|
||||
do{ \
|
||||
static sp_task_ts u_psv = {OS_SVID_DELETETASK, OS_NULL}; \
|
||||
u_psv.htask = _htask; \
|
||||
mPendSV_FIFOLoad; \
|
||||
}while(false)
|
||||
|
||||
/** 设置任务优先级 */
|
||||
#define sPSV_SetTaskPri(_htask, _npri) \
|
||||
do{ \
|
||||
static sp_taskpri_ts u_psv = {OS_SVID_SETTASKPRI, OS_NULL, _npri}; \
|
||||
u_psv.htask = _htask; \
|
||||
mPendSV_FIFOLoad; \
|
||||
}while(false)
|
||||
|
||||
/** 设置阻塞（时间）*/
|
||||
#define sPSV_SetBlock(_htask, _tick) \
|
||||
do{ \
|
||||
static sp_blocktime_ts u_psv = {OS_SVID_SETBLOCK, OS_NULL, _tick}; \
|
||||
u_psv.htask = _htask; \
|
||||
mPendSV_FIFOLoad; \
|
||||
}while(false)
|
||||
|
||||
/** 清除阻塞（状态）*/
|
||||
#define sPSV_ClearBlock(_htask) \
|
||||
do{ \
|
||||
static sp_task_ts u_psv = {OS_SVID_CLEARBLOCK, OS_NULL}; \
|
||||
u_psv.htask = _htask; \
|
||||
mPendSV_FIFOLoad; \
|
||||
}while(false)
|
||||
|
||||
/** 定时中断 */
|
||||
#define sPSV_TimInt(_tmid, _tick) \
|
||||
do{ \
|
||||
static sp_timint_ts u_psv = {OS_SVID_TIMINT, _tmid, 0}; \
|
||||
u_psv.tick = _tick; \
|
||||
mPendSV_FIFOLoad; \
|
||||
}while(false)
|
||||
|
||||
/** 定时查询 */
|
||||
#define sPSV_TimQry(_tmid, _tick) \
|
||||
do{ \
|
||||
static sp_timqry_ts u_psv = {OS_SVID_TIMQRY, _tmid, 0}; \
|
||||
u_psv.tick = _tick; \
|
||||
mPendSV_FIFOLoad; \
|
||||
}while(false)
|
||||
|
||||
/** 上锁or给予二值信号量 */
|
||||
#define sPSV_WriteBin(_bin, _val) \
|
||||
do{ \
|
||||
static sp_binary_ts u_psv = {OS_SVID_BINARY, &_bin, _val}; \
|
||||
mPendSV_FIFOLoad; \
|
||||
}while(false)
|
||||
|
||||
/** 给予计数信号量 */
|
||||
#define sPSV_GiveSem(_sem) \
|
||||
do{ \
|
||||
static sp_semaph_ts u_psv = {OS_SVID_GIVESEM, &_sem}; \
|
||||
mPendSV_FIFOLoad; \
|
||||
}while(false)
|
||||
|
||||
/** 发送飞信 */
|
||||
#define sPSV_SendFetion(_tbox, _tion) \
|
||||
do{ \
|
||||
static sp_tionbox_ts u_psv = {OS_SVID_SENDFETION, &_tbox, 0}; \
|
||||
u_psv.fetion = _tion; \
|
||||
mPendSV_FIFOLoad; \
|
||||
}while(false)
|
||||
|
||||
/** 发送邮件 */
|
||||
#define sPSV_SendMail(_mbox, _mail) \
|
||||
do{ \
|
||||
static sp_mailbox_ts u_psv = {OS_SVID_SENDMAIL, &_mbox, OS_NULL}; \
|
||||
u_psv.mail = _mail; \
|
||||
mPendSV_FIFOLoad; \
|
||||
}while(false)
|
||||
|
||||
/** 发送消息 */
|
||||
#define sPSV_SendMsg(_que, _msg) \
|
||||
do{ \
|
||||
static sp_msg_ts u_psv = {OS_SVID_SENDMSG, (s_queue_tsp)&_que, OS_NULL}; \
|
||||
u_psv.msg = _msg; \
|
||||
mPendSV_FIFOLoad; \
|
||||
}while(false)
|
||||
|
||||
/** 清除标志组 */
|
||||
#define sPSV_ClearFlagGroup(_group) \
|
||||
do{ \
|
||||
static sp_group_ts u_psv = {OS_SVID_GROUP, (void *)&_group, -sizeof(_group), ~0}; \
|
||||
mPendSV_FIFOLoad; \
|
||||
}while(false)
|
||||
|
||||
/** 写多标志位 */
|
||||
#define sPSV_WriteFlagBits(_group, _sign, _nbit) \
|
||||
do{ \
|
||||
static sp_group_ts u_psv = {OS_SVID_GROUP, (void *)&_group, _sign##sizeof(_group), 0}; \
|
||||
u_##_group##_ts lv; \
|
||||
miWriteFlagBits; \
|
||||
sizeof(lv) == 1 ? *(s_u8_t *)&lv = false : MCUCFG_TERNARYMASK \
|
||||
sizeof(lv) == 2 ? *(s_u16_t *)&lv = false : MCUCFG_TERNARYMASK \
|
||||
sizeof(lv) == 4 ? *(s_u32_t *)&lv = false : false; \
|
||||
siWriteFlagBits_##_nbit(
|
||||
|
||||
/** 全局变量写访问 */
|
||||
#define sPSV_WriteGVar(_gp, _lp, _size) \
|
||||
do{ \
|
||||
static sp_gvar_ts u_psv = {OS_SVID_GVARWRITE, _gp, _lp, _size}; \
|
||||
mPendSV_FIFOLoad; \
|
||||
}while(false)
|
||||
|
||||
/** 挂起服务调用 */
|
||||
#define sPSV_PendSVC(_fp) \
|
||||
do{ \
|
||||
static sp_pendsvc_ts u_psv = {OS_SVID_PENDSVC, _fp}; \
|
||||
mPendSV_FIFOLoad; \
|
||||
}while(false)
|
||||
|
||||
/** 发送信号 */
|
||||
#define sPSV_SendSign(_sign) \
|
||||
do{ \
|
||||
static sp_sign_ts u_psv = {OS_SVID_SENDSIGN, (s_bool_t *)&_sign}; \
|
||||
mPendSV_FIFOLoad; \
|
||||
}while(false)
|
||||
|
||||
/** 设置时间 */
|
||||
#if SYSCFG_GETRTC_INT == __ENABLED__
|
||||
#define sPSV_SetTime(_t) \
|
||||
do{ \
|
||||
iWriteGAry(&s_rtc, _t, sizeof(s_rtc_ts)); \
|
||||
s_sign_every.set = true; \
|
||||
iSendSign(s_sign_rtc); \
|
||||
}while(false)
|
||||
#else
|
||||
#define sPSV_SetTime(_t) \
|
||||
do{ \
|
||||
iWriteGAry(&s_rtc, _t, sizeof(s_rtc_ts)); \
|
||||
s_sign_every.set = true; \
|
||||
}while(false)
|
||||
#endif
|
||||
/** @} */
|
||||
|
||||
#endif
|
||||
@@ -0,0 +1,175 @@
|
||||
/**************************************************************************//**
|
||||
* @item CosyOS-II Kernel
|
||||
* @file sv_int_pend_flag.c
|
||||
* @brief 中断挂起服务_FLAG
|
||||
* @details 仅在 pendsv_hook 中调用并执行。
|
||||
* @author 迟凯峰
|
||||
* @version V3.4.0
|
||||
* @date 2025.01.06
|
||||
******************************************************************************/
|
||||
|
||||
#include "os_link.h"
|
||||
#if SYSCFG_PENDSVHOOK == __ENABLED__
|
||||
|
||||
/**
|
||||
@addtogroup CosyOS_内核服务
|
||||
@{
|
||||
*//**
|
||||
\defgroup 中断挂起服务_FLAG
|
||||
\brief 当需要在中断中完成特定的服务功能时，可先设置一个标志位，再触发 PendSV；
|
||||
而后在 pendsv_hook 中查询该标志位，为真就清除标志位，而后调用服务。
|
||||
@{
|
||||
*/
|
||||
|
||||
/**
|
||||
\brief 清除就绪延时
|
||||
\param 无
|
||||
\return 无
|
||||
*/
|
||||
void sp_clear_delay(void) MCUCFG_C51USING
|
||||
{
|
||||
if(s_sign_ready_delay){
|
||||
s_sign_ready_delay = false;
|
||||
s_task_current->timer = 0;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
\brief 切换任务
|
||||
\param[in] htask 任务句柄
|
||||
\return 无
|
||||
*/
|
||||
void sp_switch_task(s_tasknode_tsp htask) MCUCFG_C51USING
|
||||
{
|
||||
if(htask == OS_NULL) return;
|
||||
if(htask->status < OS_STATUS_STOPPED){
|
||||
s_switch_taskpri(htask);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
\brief 恢复任务
|
||||
\param[in] htask 任务句柄
|
||||
\return 无
|
||||
*/
|
||||
void sp_resume_task(s_tasknode_tsp htask) MCUCFG_C51USING
|
||||
{
|
||||
if(htask == OS_NULL) return;
|
||||
if(htask->status & OS_STATUS_SUSPENDED){
|
||||
htask->status &= (~OS_STATUS_SUSPENDED & 0xFF);
|
||||
#if SYSCFG_SAMEPRISCHEDULE == __TIMESHARING__
|
||||
htask->tc_counter = 0;
|
||||
#endif
|
||||
s_switch_ready(htask);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
\brief 挂起任务
|
||||
\param[in] htask 任务句柄
|
||||
\return 无
|
||||
*/
|
||||
void sp_suspend_task(s_tasknode_tsp htask) MCUCFG_C51USING
|
||||
{
|
||||
if(htask == OS_NULL) return;
|
||||
if(htask->status < OS_STATUS_SUSPENDED){
|
||||
htask->status |= OS_STATUS_SUSPENDED;
|
||||
if(htask == s_task_current){
|
||||
s_sign_schedule = true;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
\brief 删除任务
|
||||
\param[in] htask 任务句柄
|
||||
\return 无
|
||||
*/
|
||||
void sp_delete_task(s_tasknode_tsp htask) MCUCFG_C51USING
|
||||
{
|
||||
if(htask == OS_NULL) return;
|
||||
if(htask->status < OS_STATUS_DELETED){
|
||||
htask->status = OS_STATUS_DELETED;
|
||||
if(htask == s_task_current){
|
||||
s_sign_schedule = true;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
\brief 设置任务优先级
|
||||
\param[in] htask 任务句柄
|
||||
\param[in] npri 新优先级
|
||||
\return 无
|
||||
*/
|
||||
void sp_set_taskpri(s_tasknode_tsp htask, s_u8_t npri) MCUCFG_C51USING
|
||||
{
|
||||
if(htask == OS_NULL) return;
|
||||
if(htask->status < OS_STATUS_STOPPED){
|
||||
if(htask->pri != npri){
|
||||
s_set_taskpri(htask, npri);
|
||||
s_sign_schedule = true;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
\brief 设置阻塞（时间）
|
||||
\param[in] htask 任务句柄
|
||||
\param[in] tick 阻塞时间 [单位：滴答周期，0：等效于清除阻塞，~0：无限阻塞]
|
||||
\return 无
|
||||
*/
|
||||
void sp_set_block(s_tasknode_tsp htask, s_delay_t tick) MCUCFG_C51USING
|
||||
{
|
||||
if(htask == OS_NULL) return;
|
||||
if(htask->status == OS_STATUS_BLOCKED){
|
||||
if(!tick){
|
||||
htask->status = OS_STATUS_READY;
|
||||
htask->timer = 0;
|
||||
#if SYSCFG_SAMEPRISCHEDULE == __TIMESHARING__
|
||||
htask->tc_counter = 0;
|
||||
#endif
|
||||
s_switch_taskpri(htask);
|
||||
}
|
||||
else{
|
||||
htask->timer = tick;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
\brief 清除阻塞（状态）
|
||||
\param[in] htask 任务句柄
|
||||
\return 无
|
||||
*/
|
||||
void sp_clear_block(s_tasknode_tsp htask) MCUCFG_C51USING
|
||||
{
|
||||
if(htask == OS_NULL) return;
|
||||
if(htask->status == OS_STATUS_BLOCKED){
|
||||
htask->status = OS_STATUS_READY;
|
||||
htask->timer = 0;
|
||||
#if SYSCFG_SAMEPRISCHEDULE == __TIMESHARING__
|
||||
htask->tc_counter = 0;
|
||||
#endif
|
||||
s_switch_taskpri(htask);
|
||||
}
|
||||
}
|
||||
|
||||
#if SYSCFG_BINARY == __ENABLED__
|
||||
/**
|
||||
\brief 上锁or给予二值信号量
|
||||
\param[in] hbin 二值信号量句柄
|
||||
\param[in] val 0：上锁，1：给予
|
||||
\return 无
|
||||
*/
|
||||
void sp_write_binary(s_binary_tsp hbin, bool val) MCUCFG_C51USING
|
||||
{
|
||||
hbin->binary = val;
|
||||
if(!val) return;
|
||||
s_switch_notnull(hbin->htask);
|
||||
}
|
||||
#endif
|
||||
|
||||
/** @} */
|
||||
/** @} */
|
||||
#endif
|
||||
@@ -0,0 +1,41 @@
|
||||
/**************************************************************************//**
|
||||
* @item CosyOS-II Kernel
|
||||
* @file sv_int_pend_flag.h
|
||||
* @brief 中断挂起服务_FLAG
|
||||
* @details 仅在 pendsv_hook 中调用并执行。
|
||||
* @author 迟凯峰
|
||||
* @version V3.4.0
|
||||
* @date 2025.01.06
|
||||
******************************************************************************/
|
||||
|
||||
#ifndef __SV_INT_PEND_FLAG_H
|
||||
#define __SV_INT_PEND_FLAG_H
|
||||
|
||||
void sp_clear_delay (void);
|
||||
void sp_switch_task (s_tasknode_tsp htask);
|
||||
void sp_resume_task (s_tasknode_tsp htask);
|
||||
void sp_suspend_task(s_tasknode_tsp htask);
|
||||
void sp_delete_task (s_tasknode_tsp htask);
|
||||
void sp_set_taskpri (s_tasknode_tsp htask, s_u8_t npri);
|
||||
void sp_set_block (s_tasknode_tsp htask, s_delay_t tick);
|
||||
void sp_clear_block (s_tasknode_tsp htask);
|
||||
void sp_write_binary(s_binary_tsp hbin, bool val);
|
||||
|
||||
/**
|
||||
@addtogroup 中断挂起服务_FLAG
|
||||
@{
|
||||
*/
|
||||
|
||||
#define sPS2_ClearDelay sp_clear_delay() /*!< 清除就绪延时 */
|
||||
#define sPS2_SwitchTask(htask) sp_switch_task(htask) /*!< 切换任务 */
|
||||
#define sPS2_ResumeTask(htask) sp_resume_task(htask) /*!< 恢复任务 */
|
||||
#define sPS2_SuspendTask(htask) sp_suspend_task(htask) /*!< 挂起任务 */
|
||||
#define sPS2_DeleteTask(htask) sp_delete_task(htask) /*!< 删除任务 */
|
||||
#define sPS2_SetTaskPri(htask, npri) sp_set_taskpri(htask, npri) /*!< 设置任务优先级 */
|
||||
#define sPS2_SetBlock(htask, tick) sp_set_block(htask, tick) /*!< 设置阻塞（时间）*/
|
||||
#define sPS2_ClearBlock(htask) sp_clear_block(htask) /*!< 清除阻塞（状态）*/
|
||||
#define sPS2_WriteBin(bin, val) sp_write_binary(&bin, val) /*!< 上锁or给予二值信号量 */
|
||||
|
||||
/** @} */
|
||||
|
||||
#endif
|
||||
+1007
File diff suppressed because it is too large
Load Diff
@@ -0,0 +1,419 @@
|
||||
/**************************************************************************//**
|
||||
* @item CosyOS-II Kernel
|
||||
* @file sv_task.h
|
||||
* @brief 任务服务
|
||||
* @details 仅在任务中调用并执行。
|
||||
* @author 迟凯峰
|
||||
* @version V3.4.0
|
||||
* @date 2025.01.06
|
||||
******************************************************************************/
|
||||
|
||||
#ifndef __SV_TASK_H
|
||||
#define __SV_TASK_H
|
||||
|
||||
void su_schedule_lock (void);
|
||||
void su_schedule_unlock (void);
|
||||
void su_kernel_lock (void);
|
||||
void su_kernel_unlock (void);
|
||||
void *su_kernel_unlock_ret (void *p);
|
||||
void su_kernel_lock_ (void);
|
||||
void su_kernel_unlock_ (void);
|
||||
void su_kernel_unlock_psv (void);
|
||||
s_ecode_t su_startup_task (s_taskhand_tsp hhand, s_voidvoid_tfp entry, s_u8_t status);
|
||||
s_ecode_t su_suspend_task (s_tasknode_tsp htask);
|
||||
s_ecode_t su_resume_task (s_tasknode_tsp htask);
|
||||
s_ecode_t su_resume_suspend (s_tasknode_tsp htask);
|
||||
s_ecode_t su_delete_task (s_tasknode_tsp htask);
|
||||
s_ecode_t su_set_taskpri (s_tasknode_tsp htask, s_u8_t npri);
|
||||
s_ecode_t su_set_block (s_tasknode_tsp htask, s_delay_t tick);
|
||||
s_ecode_t su_clear_block (s_tasknode_tsp htask);
|
||||
void su_switch_task (s_tasknode_tsp htask);
|
||||
void su_yield_tasking (void);
|
||||
void su_delay (s_delay_t tick);
|
||||
bool su_take_mutex (s_mutex_tsp hmut, s_delay_t tick);
|
||||
void su_back_mutex (s_mutex_tsp hmut);
|
||||
bool su_wait_binary (s_binary_tsp hbin, s_delay_t tick);
|
||||
bool su_take_binary (s_binary_tsp hbin, s_delay_t tick);
|
||||
void su_give_binary (s_binary_tsp hbin);
|
||||
bool su_take_semaphore (s_semaph_tsp hsem, s_delay_t tick);
|
||||
void su_give_semaphore (s_semaph_tsp hsem);
|
||||
bool su_recv_taskmsg (m_taskmsg_t _STATIC_MEM_ *flag, s_delay_t tick);
|
||||
m_fetion_t su_recv_fetion (s_tionbox_tsp htbox, s_delay_t tick);
|
||||
void *su_recv_mail (s_mailbox_tsp hmbox, s_delay_t tick);
|
||||
void su_send_mail (s_mailbox_tsp hmbox, void *mail);
|
||||
void *su_recv_msg (s_queue_tsp hque, s_delay_t tick);
|
||||
s_ecode_t su_send_msg (s_queue_tsp hque, void *msg);
|
||||
bool su_query_group (void _STATIC_MEM_ *hgrp, s_u8_t size);
|
||||
bool su_wait_group (void _STATIC_MEM_ *hgrp, s_u8_t size, s_delay_t tick);
|
||||
bool su_init_mempool (s_thrmem_tsp hmem, size_t size);
|
||||
void _MALLOC_MEM_ *su_talloc (s_thrmem_tsp hmem, size_t size);
|
||||
void _MALLOC_MEM_ *su_xalloc (void _MALLOC_MEM_ *p);
|
||||
|
||||
/**
|
||||
@addtogroup 任务服务
|
||||
@{
|
||||
*/
|
||||
|
||||
/*
|
||||
* 操作任务
|
||||
*/
|
||||
|
||||
/** 启动任务 */
|
||||
#define sUSV_StartTask(hhand, entry, status) \
|
||||
( \
|
||||
(m_boolvoid_tf(su_kernel_lock_))() || true ? su_startup_task((s_taskhand_tsp)hhand, entry, !status ? OS_STATUS_READY : OS_STATUS_SUSPENDED) : OS_ECODE_NOERROR \
|
||||
)
|
||||
|
||||
/** 挂起任务 */
|
||||
#define sUSV_SuspendTask(htask) \
|
||||
( \
|
||||
(m_boolvoid_tf(su_kernel_lock))() || true ? su_suspend_task(htask) : OS_ECODE_NOERROR \
|
||||
)
|
||||
|
||||
/** 恢复任务 */
|
||||
#define sUSV_ResumeTask(htask) \
|
||||
( \
|
||||
(m_boolvoid_tf(su_kernel_lock))() || true ? su_resume_task(htask) : OS_ECODE_NOERROR \
|
||||
)
|
||||
|
||||
/** 恢复指定任务并挂起自身任务 */
|
||||
#define sUSV_ResumeSuspend(htask) \
|
||||
( \
|
||||
(m_boolvoid_tf(su_kernel_lock))() || true ? su_resume_suspend(htask) : OS_ECODE_NOERROR \
|
||||
)
|
||||
|
||||
/** 删除任务 */
|
||||
#define sUSV_DeleteTask(htask) \
|
||||
( \
|
||||
(m_boolvoid_tf(su_kernel_lock))() || true ? su_delete_task(htask) : OS_ECODE_NOERROR \
|
||||
)
|
||||
|
||||
/** 设置任务优先级 */
|
||||
#define sUSV_SetTaskPri(htask, npri) \
|
||||
( \
|
||||
(m_boolvoid_tf(su_kernel_lock))() || true ? su_set_taskpri(htask, npri) : OS_ECODE_NOERROR \
|
||||
)
|
||||
|
||||
/** 设置阻塞（时间）*/
|
||||
#define sUSV_SetBlock(htask, tick) \
|
||||
( \
|
||||
(m_boolvoid_tf(su_kernel_lock))() || true ? su_set_block(htask, tick) : OS_ECODE_NOERROR \
|
||||
)
|
||||
|
||||
/** 清除阻塞（状态）*/
|
||||
#define sUSV_ClearBlock(htask) \
|
||||
( \
|
||||
(m_boolvoid_tf(su_kernel_lock))() || true ? su_clear_block(htask) : OS_ECODE_NOERROR \
|
||||
)
|
||||
|
||||
/** 自身任务延时 */
|
||||
#define sUSV_Delay(tick) \
|
||||
do{ \
|
||||
mSysIRQ_Disable; \
|
||||
su_delay(tick); \
|
||||
}while(false)
|
||||
|
||||
/** 切换任务 */
|
||||
#define sUSV_SwitchTask(htask) \
|
||||
do{ \
|
||||
su_kernel_lock(); \
|
||||
su_switch_task(htask); \
|
||||
}while(false)
|
||||
|
||||
|
||||
|
||||
/*
|
||||
* 定时
|
||||
*/
|
||||
|
||||
/** 定时中断 */
|
||||
#define sUSV_TimInt(tmid, tick) \
|
||||
do{ \
|
||||
su_kernel_lock(); \
|
||||
s_timint_handle[tmid]->timer = s_timint_handle[tmid]->reload = tick; \
|
||||
su_kernel_unlock(); \
|
||||
}while(false)
|
||||
|
||||
/** 定时查询 */
|
||||
#define sUSV_TimQry(tmid, tick) \
|
||||
do{ \
|
||||
su_kernel_lock(); \
|
||||
s_timqry_handle[tmid]->timer = s_timqry_handle[tmid]->reload = tick; \
|
||||
su_kernel_unlock(); \
|
||||
}while(false)
|
||||
|
||||
|
||||
|
||||
/*
|
||||
* 互斥信号量
|
||||
*/
|
||||
|
||||
/** 获取互斥信号量 */
|
||||
#define sUSV_TakeMut(mut, tick) \
|
||||
( \
|
||||
(m_boolvoid_tf(su_kernel_lock_))() || true ? su_take_mutex(&mut, tick) : false \
|
||||
)
|
||||
|
||||
/** 归还互斥信号量 */
|
||||
#define sUSV_BackMut(mut) \
|
||||
do{ \
|
||||
su_kernel_lock(); \
|
||||
su_back_mutex(&mut); \
|
||||
}while(false)
|
||||
|
||||
|
||||
|
||||
/*
|
||||
* 二值信号量
|
||||
*/
|
||||
|
||||
/** 等待二值信号量 */
|
||||
#define sUSV_WaitBin(bin, tick) \
|
||||
( \
|
||||
(m_boolvoid_tf(su_kernel_lock_))() || true ? su_wait_binary(&bin, tick) : false \
|
||||
)
|
||||
|
||||
/** 获取二值信号量 */
|
||||
#define sUSV_TakeBin(bin, tick) \
|
||||
( \
|
||||
(m_boolvoid_tf(su_kernel_lock_))() || true ? su_take_binary(&bin, tick) : false \
|
||||
)
|
||||
|
||||
/** 给予二值信号量 */
|
||||
#define sUSV_GiveBin(bin) \
|
||||
do{ \
|
||||
su_kernel_lock(); \
|
||||
su_give_binary(&bin); \
|
||||
}while(false)
|
||||
|
||||
|
||||
|
||||
/*
|
||||
* 计数信号量
|
||||
*/
|
||||
|
||||
/** 获取计数信号量 */
|
||||
#define sUSV_TakeSem(sem, tick) \
|
||||
( \
|
||||
(m_boolvoid_tf(su_kernel_lock_))() || true ? su_take_semaphore(&sem, tick) : false \
|
||||
)
|
||||
|
||||
/** 给予计数信号量 */
|
||||
#define sUSV_GiveSem(sem) \
|
||||
do{ \
|
||||
su_kernel_lock(); \
|
||||
su_give_semaphore(&sem); \
|
||||
}while(false)
|
||||
|
||||
|
||||
|
||||
/*
|
||||
* 私信
|
||||
*/
|
||||
|
||||
/** 接收私信 */
|
||||
#define sUSV_RecvTaskMsg(tick) \
|
||||
( \
|
||||
(m_boolvoid_tf(su_kernel_lock_))() || true \
|
||||
? su_recv_taskmsg(&m0_, tick) \
|
||||
? s_memcpy(&m0 + 1, &m0_ + 1, MCUCFG_TASKMSG_SIZE) || true \
|
||||
? (m_boolvoid_tf(su_kernel_unlock_))() || true \
|
||||
: (m_boolvoid_tf(su_kernel_unlock_))() || true \
|
||||
: false \
|
||||
: false \
|
||||
)
|
||||
|
||||
/** 发送私信 */
|
||||
#define sUSV_SendTaskMsg(task) \
|
||||
su_kernel_lock(); \
|
||||
s_sign_send_taskmsg = true; \
|
||||
MCUCFG_TASKMSG_PSP; \
|
||||
s_switch_taskmsg(u_taskhandle_##task); \
|
||||
task(MCUCFG_TASKMSG_VAL,
|
||||
|
||||
|
||||
|
||||
/*
|
||||
* 飞信
|
||||
*/
|
||||
|
||||
/** 接收飞信 */
|
||||
#define sUSV_RecvFetion(tbox, tick) \
|
||||
( \
|
||||
(m_boolvoid_tf(su_kernel_lock_))() || true ? su_recv_fetion(&tbox, tick) : false \
|
||||
)
|
||||
|
||||
/** 发送飞信 */
|
||||
#define sUSV_SendFetion(tbox, tion) \
|
||||
do{ \
|
||||
su_kernel_lock(); \
|
||||
tbox.fetion = tion; \
|
||||
s_switch_notnull(tbox.htask); \
|
||||
su_kernel_unlock(); \
|
||||
}while(false)
|
||||
|
||||
|
||||
|
||||
/*
|
||||
* 邮箱
|
||||
*/
|
||||
|
||||
/** 接收邮件 */
|
||||
#define sUSV_RecvMail(mbox, tick) \
|
||||
( \
|
||||
(m_boolvoid_tf(su_kernel_lock_))() || true ? su_recv_mail(&mbox, tick) : OS_NULL \
|
||||
)
|
||||
|
||||
/** 发送邮件 */
|
||||
#define sUSV_SendMail(mbox, mail) \
|
||||
do{ \
|
||||
su_kernel_lock(); \
|
||||
su_send_mail(&mbox, mail); \
|
||||
}while(false)
|
||||
|
||||
|
||||
|
||||
/*
|
||||
* 消息队列
|
||||
*/
|
||||
|
||||
/** 接收消息 */
|
||||
#define sUSV_RecvMsg(que, tick) \
|
||||
( \
|
||||
(m_boolvoid_tf(su_kernel_lock_))() || true ? su_recv_msg((s_queue_tsp)&que, tick) : OS_NULL \
|
||||
)
|
||||
|
||||
/** 发送消息 */
|
||||
#define sUSV_SendMsg(que, msg) \
|
||||
( \
|
||||
(m_boolvoid_tf(su_kernel_lock))() || true ? su_send_msg((s_queue_tsp)&que, msg) : OS_ECODE_NOERROR \
|
||||
)
|
||||
|
||||
|
||||
|
||||
/*
|
||||
* 事件标志组
|
||||
*/
|
||||
|
||||
/** 查询标志组 */
|
||||
#define sUSV_QueryFlagGroup(group) \
|
||||
( \
|
||||
(m_boolvoid_tf(su_kernel_lock))() || true ? su_query_group((void *)&group, sizeof(group)) : false \
|
||||
)
|
||||
|
||||
/** 等待标志组 */
|
||||
#define sUSV_WaitFlagGroup(group, tick) \
|
||||
( \
|
||||
(m_boolvoid_tf(su_kernel_lock_))() || true ? su_wait_group((void *)&group, sizeof(group), tick) : false \
|
||||
)
|
||||
|
||||
/** 清除标志组 */
|
||||
#define sUSV_ClearFlagGroup(group) \
|
||||
do{ \
|
||||
su_kernel_lock(); \
|
||||
sizeof(group) == 1 ? *(s_u8_t *)&group = false : MCUCFG_TERNARYMASK \
|
||||
sizeof(group) == 2 ? *(s_u16_t *)&group = false : MCUCFG_TERNARYMASK \
|
||||
sizeof(group) == 4 ? *(s_u32_t *)&group = false : false; \
|
||||
su_kernel_unlock(); \
|
||||
}while(false)
|
||||
|
||||
/** 写标志位 */
|
||||
#define sUSV_WriteFlagBit(group, bit, value) \
|
||||
do{ \
|
||||
su_kernel_lock(); \
|
||||
group.bit = value; \
|
||||
su_kernel_unlock(); \
|
||||
}while(false)
|
||||
|
||||
|
||||
|
||||
/*
|
||||
* 软件RTC
|
||||
*/
|
||||
|
||||
/** 获取时间 */
|
||||
#define sUSV_GetTime(t) \
|
||||
( \
|
||||
(m_boolvoid_tf(su_kernel_lock))() || true ? su_kernel_unlock_ret(s_memcpy(t, &s_rtc, sizeof(s_rtc_ts))) : OS_NULL \
|
||||
)
|
||||
|
||||
/** 设置时间 */
|
||||
#if SYSCFG_GETRTC_INT == __ENABLED__
|
||||
#define sUSV_SetTime(t) \
|
||||
do{ \
|
||||
su_kernel_lock(); \
|
||||
s_memcpy(&s_rtc, t, sizeof(s_rtc_ts)); \
|
||||
s_sign_every.set = true; \
|
||||
s_update_rtccopy(); \
|
||||
su_kernel_unlock(); \
|
||||
}while(false)
|
||||
#else
|
||||
#define sUSV_SetTime(t) \
|
||||
do{ \
|
||||
su_kernel_lock(); \
|
||||
s_memcpy(&s_rtc, t, sizeof(s_rtc_ts)); \
|
||||
s_sign_every.set = true; \
|
||||
su_kernel_unlock(); \
|
||||
}while(false)
|
||||
#endif
|
||||
|
||||
|
||||
|
||||
/*
|
||||
* 进程内存
|
||||
*/
|
||||
|
||||
/** malloc */
|
||||
#define sUSV_Malloc(size) \
|
||||
( \
|
||||
(m_boolvoid_tf(su_kernel_lock))() || true ? su_xalloc((void _MALLOC_MEM_ *)s_malloc(size)) : OS_NULL \
|
||||
)
|
||||
|
||||
/** calloc */
|
||||
#define sUSV_Calloc(nmemb, size) \
|
||||
( \
|
||||
(m_boolvoid_tf(su_kernel_lock))() || true ? su_xalloc((void _MALLOC_MEM_ *)s_calloc(nmemb, size)) : OS_NULL \
|
||||
)
|
||||
|
||||
/** realloc */
|
||||
#define sUSV_Realloc(p, size) \
|
||||
( \
|
||||
(m_boolvoid_tf(su_kernel_lock))() || true ? su_xalloc((void _MALLOC_MEM_ *)s_realloc(p, size)) : OS_NULL \
|
||||
)
|
||||
|
||||
/** free */
|
||||
#define sUSV_Free(p) \
|
||||
do{ \
|
||||
su_kernel_lock(); \
|
||||
s_free(p); \
|
||||
su_kernel_unlock(); \
|
||||
}while(false)
|
||||
|
||||
|
||||
|
||||
/*
|
||||
* 线程内存
|
||||
*/
|
||||
|
||||
/** 初始化线程内存池 */
|
||||
#define sUSV_InitMempool(size) \
|
||||
( \
|
||||
(m_boolvoid_tf(su_kernel_lock))() || true ? su_init_mempool(&u_thrmem, size) : false \
|
||||
)
|
||||
|
||||
/** 线程内存分配 */
|
||||
#define sUSV_Talloc(size) \
|
||||
( \
|
||||
(m_boolvoid_tf(su_kernel_lock))() || true ? su_xalloc(su_talloc(&u_thrmem, size)) : OS_NULL \
|
||||
)
|
||||
|
||||
/** 释放线程内存池 */
|
||||
#define sUSV_FreeMempool \
|
||||
do{ \
|
||||
sUSV_Free(u_thrmem.head); \
|
||||
u_thrmem.head = u_thrmem.move = OS_NULL; \
|
||||
}while(false)
|
||||
|
||||
/** @} */
|
||||
|
||||
#endif
|
||||
@@ -0,0 +1,347 @@
|
||||
/**************************************************************************//**
|
||||
* @item CosyOS-II Kernel
|
||||
* @file sv_tick.c
|
||||
* @brief 滴答服务
|
||||
* @details 仅在 SysTick 中调用并执行，包括在滴答钩子、定时中断钩子、
|
||||
定时查询钩子、定时查询事件等处调用。
|
||||
* @author 迟凯峰
|
||||
* @version V3.4.0
|
||||
* @date 2025.01.06
|
||||
******************************************************************************/
|
||||
|
||||
#include "os_var.h"
|
||||
#include "os_api.h"
|
||||
|
||||
/**
|
||||
@addtogroup CosyOS_内核服务
|
||||
@{
|
||||
*//**
|
||||
\defgroup 滴答服务
|
||||
\brief 仅在 SysTick 中调用并执行，包括在滴答钩子、定时中断钩子、
|
||||
定时查询钩子、定时查询事件等处调用。
|
||||
@{
|
||||
*/
|
||||
|
||||
/**
|
||||
\brief 清除就绪延时
|
||||
\param 无
|
||||
\return 结果 [true：成功，false：失败]
|
||||
*/
|
||||
bool st_clear_delay(void) MCUCFG_C51USING
|
||||
{
|
||||
if(s_sign_ready_delay){
|
||||
s_sign_ready_delay = false;
|
||||
s_task_current->timer = 0;
|
||||
return true;
|
||||
}
|
||||
return false;
|
||||
}
|
||||
|
||||
/**
|
||||
\brief 挂起任务
|
||||
\param[in] htask 任务句柄
|
||||
\return 错误码 [0：无错误]
|
||||
*/
|
||||
s_ecode_t st_suspend_task(s_tasknode_tsp htask) MCUCFG_C51USING
|
||||
{
|
||||
if(htask == OS_NULL){
|
||||
return OS_ECODE_TASKNOTSTARTED;
|
||||
}
|
||||
if(htask->status < OS_STATUS_SUSPENDED){
|
||||
htask->status |= OS_STATUS_SUSPENDED;
|
||||
return OS_ECODE_NOERROR;
|
||||
}
|
||||
if(htask->status & OS_STATUS_SUSPENDED){
|
||||
return OS_ECODE_TASKSUSPENDED;
|
||||
}
|
||||
if(htask->status & OS_STATUS_STOPPED){
|
||||
return OS_ECODE_TASKSTOPPED;
|
||||
}
|
||||
if(htask->status == OS_STATUS_DELETED){
|
||||
return OS_ECODE_TASKNOTSTARTED;
|
||||
}
|
||||
else{
|
||||
return OS_ECODE_DONOTKNOW;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
\brief 恢复任务
|
||||
\param[in] htask 任务句柄
|
||||
\return 错误码 [0：无错误]
|
||||
*/
|
||||
s_ecode_t st_resume_task(s_tasknode_tsp htask) MCUCFG_C51USING
|
||||
{
|
||||
if(htask == OS_NULL){
|
||||
return OS_ECODE_TASKNOTSTARTED;
|
||||
}
|
||||
if(htask->status & OS_STATUS_SUSPENDED){
|
||||
htask->status &= (~OS_STATUS_SUSPENDED & 0xFF);
|
||||
#if SYSCFG_SAMEPRISCHEDULE == __TIMESHARING__
|
||||
htask->tc_counter = 0;
|
||||
#endif
|
||||
return OS_ECODE_NOERROR;
|
||||
}
|
||||
if(htask->status < OS_STATUS_STOPPED){
|
||||
return OS_ECODE_TASKNOTSUSPENDED;
|
||||
}
|
||||
if(htask->status & OS_STATUS_STOPPED){
|
||||
return OS_ECODE_TASKSTOPPED;
|
||||
}
|
||||
if(htask->status == OS_STATUS_DELETED){
|
||||
return OS_ECODE_TASKNOTSTARTED;
|
||||
}
|
||||
else{
|
||||
return OS_ECODE_DONOTKNOW;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
\brief 删除任务
|
||||
\param[in] htask 任务句柄
|
||||
\return 错误码 [0：无错误]
|
||||
*/
|
||||
s_ecode_t st_delete_task(s_tasknode_tsp htask) MCUCFG_C51USING
|
||||
{
|
||||
if(htask == OS_NULL){
|
||||
return OS_ECODE_TASKNOTSTARTED;
|
||||
}
|
||||
if(htask->status < OS_STATUS_DELETED){
|
||||
htask->status = OS_STATUS_DELETED;
|
||||
return OS_ECODE_NOERROR;
|
||||
}
|
||||
if(htask->status == OS_STATUS_DELETED){
|
||||
return OS_ECODE_TASKNOTSTARTED;
|
||||
}
|
||||
else{
|
||||
return OS_ECODE_DONOTKNOW;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
\brief 设置任务优先级
|
||||
\param[in] htask 任务句柄
|
||||
\param[in] npri 新优先级
|
||||
\return 错误码 [0：无错误]
|
||||
*/
|
||||
s_ecode_t st_set_taskpri(s_tasknode_tsp htask, s_u8_t npri) MCUCFG_C51USING
|
||||
{
|
||||
if(htask == OS_NULL){
|
||||
return OS_ECODE_TASKNOTSTARTED;
|
||||
}
|
||||
if(htask->status < OS_STATUS_STOPPED){
|
||||
if(htask->pri != npri){
|
||||
s_set_taskpri(htask, npri);
|
||||
return OS_ECODE_NOERROR;
|
||||
}
|
||||
else{
|
||||
return OS_ECODE_TASKPRIUNCHANGED;
|
||||
}
|
||||
}
|
||||
if(htask->status & OS_STATUS_STOPPED){
|
||||
return OS_ECODE_TASKSTOPPED;
|
||||
}
|
||||
if(htask->status == OS_STATUS_DELETED){
|
||||
return OS_ECODE_TASKNOTSTARTED;
|
||||
}
|
||||
else{
|
||||
return OS_ECODE_DONOTKNOW;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
\brief 设置阻塞（时间）
|
||||
\param[in] htask 任务句柄
|
||||
\param[in] tick 阻塞时间 [单位：滴答周期，0：等效于清除阻塞，~0：无限阻塞]
|
||||
\return 错误码 [0：无错误]
|
||||
*/
|
||||
s_ecode_t st_set_block(s_tasknode_tsp htask, s_delay_t tick) MCUCFG_C51USING
|
||||
{
|
||||
if(htask == OS_NULL){
|
||||
return OS_ECODE_TASKNOTSTARTED;
|
||||
}
|
||||
if(htask->status == OS_STATUS_BLOCKED){
|
||||
if(!tick){
|
||||
htask->status = OS_STATUS_READY;
|
||||
htask->timer = 0;
|
||||
#if SYSCFG_SAMEPRISCHEDULE == __TIMESHARING__
|
||||
htask->tc_counter = 0;
|
||||
#endif
|
||||
}
|
||||
else{
|
||||
htask->timer = tick;
|
||||
}
|
||||
return OS_ECODE_NOERROR;
|
||||
}
|
||||
return OS_ECODE_TASKNOTBLOCKED;
|
||||
}
|
||||
|
||||
/**
|
||||
\brief 清除阻塞（状态）
|
||||
\param[in] htask 任务句柄
|
||||
\return 错误码 [0：无错误]
|
||||
*/
|
||||
s_ecode_t st_clear_block(s_tasknode_tsp htask) MCUCFG_C51USING
|
||||
{
|
||||
if(htask == OS_NULL){
|
||||
return OS_ECODE_TASKNOTSTARTED;
|
||||
}
|
||||
if(htask->status == OS_STATUS_BLOCKED){
|
||||
htask->status = OS_STATUS_READY;
|
||||
htask->timer = 0;
|
||||
#if SYSCFG_SAMEPRISCHEDULE == __TIMESHARING__
|
||||
htask->tc_counter = 0;
|
||||
#endif
|
||||
return OS_ECODE_NOERROR;
|
||||
}
|
||||
return OS_ECODE_TASKNOTBLOCKED;
|
||||
}
|
||||
|
||||
#if SYSCFG_BINARY == __ENABLED__
|
||||
/**
|
||||
\brief 获取二值信号量
|
||||
\param[in] hbin 二值信号量句柄
|
||||
\return 结果 [true：成功，false：失败]
|
||||
*/
|
||||
bool st_take_binary(s_binary_tsp hbin) MCUCFG_C51USING
|
||||
{
|
||||
if(hbin->binary){
|
||||
hbin->binary = false;
|
||||
return true;
|
||||
}
|
||||
return false;
|
||||
}
|
||||
#endif
|
||||
|
||||
#if SYSCFG_SEMAPHORE == __ENABLED__
|
||||
/**
|
||||
\brief 获取计数信号量
|
||||
\param[in] hsem 计数信号量句柄
|
||||
\return 结果 [true：成功，false：失败]
|
||||
*/
|
||||
bool st_take_semaphore(s_semaph_tsp hsem) MCUCFG_C51USING
|
||||
{
|
||||
if(hsem->counter){
|
||||
(hsem->counter)--;
|
||||
return true;
|
||||
}
|
||||
return false;
|
||||
}
|
||||
|
||||
/**
|
||||
\brief 给予计数信号量
|
||||
\param[in] hsem 计数信号量句柄
|
||||
\return 无
|
||||
*/
|
||||
void st_give_semaphore(s_semaph_tsp hsem) MCUCFG_C51USING
|
||||
{
|
||||
if(hsem->counter < hsem->maximum){
|
||||
hsem->counter++;
|
||||
}
|
||||
}
|
||||
#endif
|
||||
|
||||
#if SYSCFG_FETION == __ENABLED__
|
||||
/**
|
||||
\brief 接收飞信
|
||||
\param[in] htbox 信箱句柄
|
||||
\return 飞信数据 [false：失败]
|
||||
*/
|
||||
m_fetion_t st_recv_fetion(s_tionbox_tsp htbox) MCUCFG_C51USING
|
||||
{
|
||||
m_fetion_t fetion = htbox->fetion;
|
||||
htbox->fetion = false;
|
||||
return fetion;
|
||||
}
|
||||
#endif
|
||||
|
||||
#if SYSCFG_MAILBOX == __ENABLED__
|
||||
/**
|
||||
\brief 接收邮件
|
||||
\param[in] hmbox 邮箱句柄
|
||||
\return 邮件指针 [NULL：失败]
|
||||
*/
|
||||
void *st_recv_mail(s_mailbox_tsp hmbox) MCUCFG_C51USING
|
||||
{
|
||||
if(hmbox->flag){
|
||||
hmbox->flag = false;
|
||||
return hmbox->mail;
|
||||
}
|
||||
return OS_NULL;
|
||||
}
|
||||
|
||||
/**
|
||||
\brief 发送邮件
|
||||
\param[in] hmbox 邮箱句柄
|
||||
\param[in] mail 邮件指针
|
||||
\return 无
|
||||
*/
|
||||
void st_send_mail(s_mailbox_tsp hmbox, void *mail) MCUCFG_C51USING
|
||||
{
|
||||
hmbox->flag = false;
|
||||
hmbox->mail = mail;
|
||||
hmbox->flag = true;
|
||||
}
|
||||
#endif
|
||||
|
||||
#if SYSCFG_MSGQUEUE == __ENABLED__
|
||||
/**
|
||||
\brief 接收消息
|
||||
\param[in] hque 队列句柄
|
||||
\return 消息指针 [NULL：失败]
|
||||
*/
|
||||
void *st_recv_msg(s_queue_tsp hque) MCUCFG_C51USING
|
||||
{
|
||||
void *msg = OS_NULL;
|
||||
s_msgnode_tsp hmsg;
|
||||
hque->mutex = false;
|
||||
|
||||
if(!hque->counter);
|
||||
else if(hque->type == __DYNAMIC__)
|
||||
sRecvMsg_Dynamic(msg);
|
||||
else
|
||||
sRecvMsg_Static(msg);
|
||||
|
||||
hque->mutex = true;
|
||||
return msg;
|
||||
}
|
||||
|
||||
/**
|
||||
\brief 发送消息
|
||||
\param[in] hque 队列句柄
|
||||
\param[in] msg 消息指针
|
||||
\return 错误码 [0：无错误]
|
||||
*/
|
||||
s_ecode_t st_send_msg(s_queue_tsp hque, void *msg) MCUCFG_C51USING
|
||||
{
|
||||
hque->mutex = false;
|
||||
|
||||
if(hque->counter == hque->len){
|
||||
#if SYSCFG_DEBUGGING == __ENABLED__
|
||||
s_alarm.overflow_msgqueue = true;
|
||||
#endif
|
||||
hque->mutex = true;
|
||||
return OS_ECODE_OVERFLOW_MSGQUEUE;
|
||||
}
|
||||
if(hque->type == __DYNAMIC__){
|
||||
s_msgnode_tsp hmsg = OS_NULL;
|
||||
hmsg = (s_msgnode_tsp)s_malloc(sizeof(s_msgnode_ts));
|
||||
if(hmsg == OS_NULL){
|
||||
#if SYSCFG_DEBUGGING == __ENABLED__
|
||||
s_fault.mallocfailed_msgnode = true;
|
||||
#endif
|
||||
hque->mutex = true;
|
||||
return OS_ECODE_MALLOCFAIL_MSGNODE;
|
||||
}
|
||||
sSendMsg_Dynamic(msg);
|
||||
}
|
||||
else
|
||||
sSendMsg_Static(msg);
|
||||
|
||||
hque->mutex = true;
|
||||
return OS_ECODE_NOERROR;
|
||||
}
|
||||
#endif
|
||||
|
||||
/** @} */
|
||||
/** @} */
|
||||
@@ -0,0 +1,96 @@
|
||||
/**************************************************************************//**
|
||||
* @item CosyOS-II Kernel
|
||||
* @file sv_tick.h
|
||||
* @brief 滴答服务
|
||||
* @details 仅在 SysTick 中调用并执行，包括在滴答钩子、定时中断钩子、
|
||||
定时查询钩子、定时查询事件等处调用。
|
||||
* @author 迟凯峰
|
||||
* @version V3.4.0
|
||||
* @date 2025.01.06
|
||||
******************************************************************************/
|
||||
|
||||
#ifndef __SV_TICK_H
|
||||
#define __SV_TICK_H
|
||||
|
||||
bool st_clear_delay (void);
|
||||
s_ecode_t st_suspend_task (s_tasknode_tsp htask);
|
||||
s_ecode_t st_resume_task (s_tasknode_tsp htask);
|
||||
s_ecode_t st_delete_task (s_tasknode_tsp htask);
|
||||
s_ecode_t st_set_taskpri (s_tasknode_tsp htask, s_u8_t npri);
|
||||
s_ecode_t st_set_block (s_tasknode_tsp htask, s_delay_t tick);
|
||||
s_ecode_t st_clear_block (s_tasknode_tsp htask);
|
||||
bool st_take_binary (s_binary_tsp hbin);
|
||||
bool st_take_semaphore (s_semaph_tsp hsem);
|
||||
void st_give_semaphore (s_semaph_tsp hsem);
|
||||
m_fetion_t st_recv_fetion (s_tionbox_tsp htbox);
|
||||
void *st_recv_mail (s_mailbox_tsp hmbox);
|
||||
void st_send_mail (s_mailbox_tsp hmbox, void *mail);
|
||||
void *st_recv_msg (s_queue_tsp hque);
|
||||
s_ecode_t st_send_msg (s_queue_tsp hque, void *msg);
|
||||
|
||||
/**
|
||||
@addtogroup 滴答服务
|
||||
@{
|
||||
*/
|
||||
|
||||
#define sTSV_ClearDelay st_clear_delay() /*!< 清除就绪延时 */
|
||||
#define sTSV_SuspendTask(htask) st_suspend_task(htask) /*!< 挂起任务 */
|
||||
#define sTSV_ResumeTask(htask) st_resume_task(htask) /*!< 恢复任务 */
|
||||
#define sTSV_DeleteTask(htask) st_delete_task(htask) /*!< 删除任务 */
|
||||
#define sTSV_SetTaskPri(htask, npri) st_set_taskpri(htask, npri) /*!< 设置任务优先级 */
|
||||
#define sTSV_SetBlock(htask, tick) st_set_block(htask, tick) /*!< 设置阻塞（时间）*/
|
||||
#define sTSV_ClearBlock(htask) st_clear_block(htask) /*!< 清除阻塞（状态）*/
|
||||
#define sTSV_TakeBin(bin) st_take_binary(&bin) /*!< 获取二值信号量 */
|
||||
#define sTSV_TakeSem(sem) st_take_semaphore(&sem) /*!< 获取计数信号量 */
|
||||
#define sTSV_GiveSem(sem) st_give_semaphore(&sem) /*!< 给予计数信号量 */
|
||||
#define sTSV_RecvFetion(tbox) st_recv_fetion(&tbox) /*!< 接收飞信 */
|
||||
#define sTSV_RecvMail(mbox) st_recv_mail(&mbox) /*!< 接收邮件 */
|
||||
#define sTSV_SendMail(mbox, mail) st_send_mail(&mbox, mail) /*!< 发送邮件 */
|
||||
#define sTSV_RecvMsg(que) st_recv_msg((s_queue_tsp)&que) /*!< 接收消息 */
|
||||
#define sTSV_SendMsg(que, msg) st_send_msg((s_queue_tsp)&que, msg) /*!< 发送消息 */
|
||||
#define sTSV_TimInt(tmid, tick) s_timint_handle[tmid]->timer = s_timint_handle[tmid]->reload = tick /*!< 定时中断 */
|
||||
#define sTSV_TimQry(tmid, tick) s_timqry_handle[tmid]->timer = s_timqry_handle[tmid]->reload = tick /*!< 定时查询 */
|
||||
#define sTSV_GetTime(t) s_memcpy(t, &s_rtc, sizeof(s_rtc_ts)) /*!< 获取时间 */
|
||||
|
||||
/** 设置时间 */
|
||||
#if SYSCFG_GETRTC_INT == __ENABLED__
|
||||
#define sTSV_SetTime(t) \
|
||||
do{ \
|
||||
s_memcpy(&s_rtc, t, sizeof(s_rtc_ts)); \
|
||||
s_sign_every.set = true; \
|
||||
s_update_rtccopy(); \
|
||||
}while(false)
|
||||
#else
|
||||
#define sTSV_SetTime(t) \
|
||||
do{ \
|
||||
s_memcpy(&s_rtc, t, sizeof(s_rtc_ts)); \
|
||||
s_sign_every.set = true; \
|
||||
}while(false)
|
||||
#endif
|
||||
|
||||
/** 发送私信 */
|
||||
#define sTSV_SendTaskMsg(task) \
|
||||
s_sign_send_taskmsg = true; \
|
||||
MCUCFG_TASKMSG_PSP; \
|
||||
task(MCUCFG_TASKMSG_VAL,
|
||||
|
||||
/** 查询标志组 */
|
||||
#define sTSV_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 \
|
||||
)
|
||||
|
||||
/** 清除标志组 */
|
||||
#define sTSV_ClearFlagGroup(group) \
|
||||
do{ \
|
||||
sizeof(group) == 1 ? *(s_u8_t *)&group = false : MCUCFG_TERNARYMASK \
|
||||
sizeof(group) == 2 ? *(s_u16_t *)&group = false : MCUCFG_TERNARYMASK \
|
||||
sizeof(group) == 4 ? *(s_u32_t *)&group = false : false; \
|
||||
}while(false)
|
||||
|
||||
/** @} */
|
||||
|
||||
#endif
|
||||
+1805
File diff suppressed because it is too large
Load Diff
@@ -0,0 +1,217 @@
|
||||
/**************************************************************************//**
|
||||
* @item CosyOS-II Kernel
|
||||
* @file ur_eapi.h
|
||||
* @brief 用户API扩展
|
||||
* @details 用户API的补充扩展定义，仅是定义无注释说明，所有内核服务的API说明
|
||||
均在 ur_api.h 中，并支持 doxygen。
|
||||
* @author 迟凯峰
|
||||
* @version V3.4.0
|
||||
* @date 2025.01.06
|
||||
******************************************************************************/
|
||||
|
||||
#ifndef __UR_EAPI_H
|
||||
#define __UR_EAPI_H
|
||||
|
||||
|
||||
|
||||
/* 清除就绪延时 */
|
||||
#define iClearDelay sPSV_ClearDelay
|
||||
#define pClearDelay sPS2_ClearDelay
|
||||
|
||||
/* 切换任务 */
|
||||
#define iSwitchTask(task) sPSV_SwitchTask(u_taskhandle_##task)
|
||||
#define pSwitchTask(task) sPS2_SwitchTask(u_taskhandle_##task)
|
||||
|
||||
/* 恢复任务 */
|
||||
#define tResumeTask(task) sTSV_ResumeTask(u_taskhandle_##task)
|
||||
#define iResumeTask(task) sPSV_ResumeTask(u_taskhandle_##task)
|
||||
#define pResumeTask(task) sPS2_ResumeTask(u_taskhandle_##task)
|
||||
|
||||
/* 挂起任务 */
|
||||
#define tSuspendTask(task) sTSV_SuspendTask(u_taskhandle_##task)
|
||||
#define iSuspendTask(task) sPSV_SuspendTask(u_taskhandle_##task)
|
||||
#define pSuspendTask(task) sPS2_SuspendTask(u_taskhandle_##task)
|
||||
|
||||
/* 删除任务 */
|
||||
#define tDeleteTask(task) sTSV_DeleteTask(u_taskhandle_##task)
|
||||
#define iDeleteTask(task) sPSV_DeleteTask(u_taskhandle_##task)
|
||||
#define pDeleteTask(task) sPS2_DeleteTask(u_taskhandle_##task)
|
||||
|
||||
/* 设置任务优先级 */
|
||||
#define tSetTaskPri(task, npri) sTSV_SetTaskPri(u_taskhandle_##task, npri)
|
||||
#define iSetTaskPri(task, npri) sPSV_SetTaskPri(u_taskhandle_##task, npri)
|
||||
#define pSetTaskPri(task, npri) sPS2_SetTaskPri(u_taskhandle_##task, npri)
|
||||
|
||||
/* 清除阻塞（状态）*/
|
||||
#define tClearBlock(task) sTSV_ClearBlock(u_taskhandle_##task)
|
||||
#define iClearBlock(task) sPSV_ClearBlock(u_taskhandle_##task)
|
||||
#define pClearBlock(task) sPS2_ClearBlock(u_taskhandle_##task)
|
||||
|
||||
/* 设置阻塞-滴答周期 */
|
||||
#define tSetBlock_tc(task, tc) sTSV_SetBlock(u_taskhandle_##task, tc)
|
||||
#define iSetBlock_tc(task, tc) sPSV_SetBlock(u_taskhandle_##task, tc)
|
||||
#define pSetBlock_tc(task, tc) sPS2_SetBlock(u_taskhandle_##task, tc)
|
||||
|
||||
/* 设置阻塞-毫秒 */
|
||||
#define tSetBlock_ms(task, ms) tSetBlock_tc(task, (1000UL * (ms)) / SYSCFG_SYSTICKCYCLE)
|
||||
#define iSetBlock_ms(task, ms) iSetBlock_tc(task, (1000UL * (ms)) / SYSCFG_SYSTICKCYCLE)
|
||||
#define pSetBlock_ms(task, ms) pSetBlock_tc(task, (1000UL * (ms)) / SYSCFG_SYSTICKCYCLE)
|
||||
|
||||
/* 设置阻塞-秒钟 */
|
||||
#define tSetBlock_s(task, s) tSetBlock_ms(task, 1000UL * (s))
|
||||
#define iSetBlock_s(task, s) iSetBlock_ms(task, 1000UL * (s))
|
||||
#define pSetBlock_s(task, s) pSetBlock_ms(task, 1000UL * (s))
|
||||
|
||||
/* 设置阻塞-分钟 */
|
||||
#define tSetBlock_m(task, m) tSetBlock_s(task, 60UL * (m))
|
||||
#define iSetBlock_m(task, m) iSetBlock_s(task, 60UL * (m))
|
||||
#define pSetBlock_m(task, m) pSetBlock_s(task, 60UL * (m))
|
||||
|
||||
/* 设置阻塞-小时 */
|
||||
#define tSetBlock_h(task, h) tSetBlock_m(task, 60UL * (h))
|
||||
#define iSetBlock_h(task, h) iSetBlock_m(task, 60UL * (h))
|
||||
#define pSetBlock_h(task, h) pSetBlock_m(task, 60UL * (h))
|
||||
|
||||
/* 定时中断-滴答周期 */
|
||||
#define tTimInt_tc(tmid, tc) sTSV_TimInt(tmid, tc)
|
||||
#define iTimInt_tc(tmid, tc) sPSV_TimInt(tmid, tc)
|
||||
|
||||
/* 定时中断-毫秒 */
|
||||
#define tTimInt_ms(tmid, ms) tTimInt_tc(tmid, (1000UL * (ms)) / SYSCFG_SYSTICKCYCLE)
|
||||
#define iTimInt_ms(tmid, ms) iTimInt_tc(tmid, (1000UL * (ms)) / SYSCFG_SYSTICKCYCLE)
|
||||
|
||||
/* 定时中断-秒钟 */
|
||||
#define tTimInt_s(tmid, s) tTimInt_ms(tmid, 1000UL * (s))
|
||||
#define iTimInt_s(tmid, s) iTimInt_ms(tmid, 1000UL * (s))
|
||||
|
||||
/* 定时中断-分钟 */
|
||||
#define tTimInt_m(tmid, m) tTimInt_s(tmid, 60UL * (m))
|
||||
#define iTimInt_m(tmid, m) iTimInt_s(tmid, 60UL * (m))
|
||||
|
||||
/* 定时中断-小时 */
|
||||
#define tTimInt_h(tmid, h) tTimInt_m(tmid, 60UL * (h))
|
||||
#define iTimInt_h(tmid, h) iTimInt_m(tmid, 60UL * (h))
|
||||
|
||||
/* 终止定时中断 */
|
||||
#define tTimInt_Cancel(tmid) tTimInt_tc(tmid, 0)
|
||||
#define iTimInt_Cancel(tmid) iTimInt_tc(tmid, 0)
|
||||
|
||||
/* 定时查询-滴答周期 */
|
||||
#define tTimQry_tc(tmid, tc) sTSV_TimQry(tmid, tc)
|
||||
#define iTimQry_tc(tmid, tc) sPSV_TimQry(tmid, tc)
|
||||
|
||||
/* 定时查询-毫秒 */
|
||||
#define tTimQry_ms(tmid, ms) tTimQry_tc(tmid, (1000UL * (ms)) / SYSCFG_SYSTICKCYCLE)
|
||||
#define iTimQry_ms(tmid, ms) iTimQry_tc(tmid, (1000UL * (ms)) / SYSCFG_SYSTICKCYCLE)
|
||||
|
||||
/* 定时查询-秒钟 */
|
||||
#define tTimQry_s(tmid, s) tTimQry_ms(tmid, 1000UL * (s))
|
||||
#define iTimQry_s(tmid, s) iTimQry_ms(tmid, 1000UL * (s))
|
||||
|
||||
/* 定时查询-分钟 */
|
||||
#define tTimQry_m(tmid, m) tTimQry_s(tmid, 60UL * (m))
|
||||
#define iTimQry_m(tmid, m) iTimQry_s(tmid, 60UL * (m))
|
||||
|
||||
/* 定时查询-小时 */
|
||||
#define tTimQry_h(tmid, h) tTimQry_m(tmid, 60UL * (h))
|
||||
#define iTimQry_h(tmid, h) iTimQry_m(tmid, 60UL * (h))
|
||||
|
||||
/* 终止定时查询 */
|
||||
#define tTimQry_Cancel(tmid) tTimQry_tc(tmid, ~0)
|
||||
#define iTimQry_Cancel(tmid) iTimQry_tc(tmid, ~0)
|
||||
|
||||
/* 上锁二值信号量 */
|
||||
#define tLockBin(bin) bin.binary = false
|
||||
#define iLockBin(bin) sPSV_WriteBin(bin, false)
|
||||
#define pLockBin(bin) sPS2_WriteBin(bin, false)
|
||||
|
||||
/* 给予二值信号量 */
|
||||
#define tGiveBin(bin) bin.binary = true
|
||||
#define iGiveBin(bin) sPSV_WriteBin(bin, true)
|
||||
#define pGiveBin(bin) sPS2_WriteBin(bin, true)
|
||||
|
||||
/* 获取二值信号量 */
|
||||
#define tTakeBin(bin) sTSV_TakeBin(bin)
|
||||
#define iTakeBin(bin) sISV_TakeBin(bin)
|
||||
|
||||
/* 归还二值信号量 */
|
||||
#define tBackBin(bin) bin.binary = true
|
||||
#define iBackBin(bin) \
|
||||
do{ \
|
||||
bin.binary = true; \
|
||||
iGiveBin(bin); \
|
||||
}while(false)
|
||||
|
||||
/* 给予计数信号量 */
|
||||
#define tGiveSem(sem) sTSV_GiveSem(sem)
|
||||
#define iGiveSem(sem) sPSV_GiveSem(sem)
|
||||
|
||||
/* 获取计数信号量 */
|
||||
#define tTakeSem(sem) sTSV_TakeSem(sem)
|
||||
|
||||
/* 归还计数信号量 */
|
||||
#define tBackSem(sem) tGiveSem(sem)
|
||||
|
||||
/* 发送私信 */
|
||||
#define tSendTaskMsg(task) sTSV_SendTaskMsg(task)
|
||||
|
||||
/* 接收飞信 */
|
||||
#define tRecvFetion(tbox) sTSV_RecvFetion(tbox)
|
||||
#define iRecvFetion(tbox) sISV_RecvFetion(tbox)
|
||||
|
||||
/* 发送飞信 */
|
||||
#define tSendFetion(tbox, tion) tbox.fetion = tion
|
||||
#define iSendFetion(tbox, tion) sPSV_SendFetion(tbox, tion)
|
||||
|
||||
/* 接收邮件 */
|
||||
#define tRecvMail(mbox) sTSV_RecvMail(mbox)
|
||||
#define iRecvMail(mbox) sISV_RecvMail(mbox)
|
||||
|
||||
/* 发送邮件 */
|
||||
#define tSendMail(mbox, mail) sTSV_SendMail(mbox, mail)
|
||||
#define iSendMail(mbox, mail) sPSV_SendMail(mbox, mail)
|
||||
|
||||
/* 接收消息 */
|
||||
#define tRecvMsg(que) sTSV_RecvMsg(que)
|
||||
#define iRecvMsg(que) sISV_RecvMsg(que)
|
||||
|
||||
/* 发送消息 */
|
||||
#define tSendMsg(que, msg) sTSV_SendMsg(que, msg)
|
||||
#define iSendMsg(que, msg) sPSV_SendMsg(que, msg)
|
||||
|
||||
/* 查询标志组 */
|
||||
#define tQueryFlagGroup(group) sTSV_QueryFlagGroup(group)
|
||||
#define iQueryFlagGroup(group) sISV_QueryFlagGroup(group)
|
||||
|
||||
/* 清除标志组 */
|
||||
#define tClearFlagGroup(group) sTSV_ClearFlagGroup(group)
|
||||
#define iClearFlagGroup(group) sPSV_ClearFlagGroup(group)
|
||||
|
||||
/* 设置标志位 */
|
||||
#define iSetFlagBit(group, bit) iSetFlagBits(group, 1) bit)
|
||||
|
||||
/* 清除标志位 */
|
||||
#define iClearFlagBit(group, bit) iClearFlagBits(group, 1) bit)
|
||||
|
||||
/* 获取时间 */
|
||||
#define tGetTime(t) sTSV_GetTime(t)
|
||||
#define iGetTime(t) sISV_GetTime(t)
|
||||
|
||||
/* 设置时间 */
|
||||
#define tSetTime(t) sTSV_SetTime(t)
|
||||
#define iSetTime(t) sPSV_SetTime(t)
|
||||
|
||||
/* 别名定义（API简化）*/
|
||||
#define uRecvTM uRecvTaskMsg
|
||||
#define uSendTM uSendTaskMsg
|
||||
#define tSendTM tSendTaskMsg
|
||||
#define uRecvFet uRecvFetion
|
||||
#define tRecvFet tRecvFetion
|
||||
#define iRecvFet iRecvFetion
|
||||
#define uSendFet uSendFetion
|
||||
#define tSendFet tSendFetion
|
||||
#define iSendFet iSendFetion
|
||||
|
||||
|
||||
|
||||
#endif
|
||||
Reference in New Issue
Block a user