mirror of
https://gitee.com/cosyos/cosyos.git
synced 2026-02-06 03:41:41 +08:00
零中断延迟的RTOS
Gitee
54
System/os_api.c
Normal file
54
System/os_api.c
Normal file
@@ -0,0 +1,54 @@
|
||||
/**************************************************************************//**
|
||||
* @item CosyOS-II Kernel
|
||||
* @file os_api.c
|
||||
* @brief 系统内核专用API
|
||||
* @author 迟凯峰
|
||||
* @version V2.0.0
|
||||
* @date 2024.03.17
|
||||
******************************************************************************/
|
||||
|
||||
#include "os_var.h"
|
||||
|
||||
#if SYSCFG_MCUCORE == 8051
|
||||
#pragma NOAREGS
|
||||
#endif
|
||||
|
||||
void s_scheduling_taskpri(s_tasknode_tsp node)
|
||||
{
|
||||
if(node->pri > s_task_current->pri){
|
||||
s_sign_scheduling = true;
|
||||
}
|
||||
}
|
||||
|
||||
void s_scheduling_notnull(s_tasknode_tsp node)
|
||||
{
|
||||
if(node != NULL){
|
||||
s_scheduling_taskpri(node);
|
||||
}
|
||||
}
|
||||
|
||||
void s_scheduling_ready(s_tasknode_tsp node)
|
||||
{
|
||||
if(node->status <= OS_STATUS_FLOATING){
|
||||
s_scheduling_taskpri(node);
|
||||
}
|
||||
}
|
||||
|
||||
void s_scheduling_taskmsg(s_tasknode_tsp node)
|
||||
{
|
||||
if(node->status == OS_STATUS_BLOCKED && (node->blocktype & OS_BLOCKED_TASKMSG)){
|
||||
s_scheduling_taskpri(node);
|
||||
}
|
||||
}
|
||||
|
||||
void s_set_taskpri(s_tasknode_tsp node)
|
||||
{
|
||||
node->last->next = node->next;
|
||||
node->next->last = node->last;
|
||||
node->next = node->last = NULL;
|
||||
if(s_taskpri_tail != NULL){
|
||||
s_taskpri_tail->next = node;
|
||||
node->last = s_taskpri_tail;
|
||||
}
|
||||
s_taskpri_tail = node;
|
||||
}
|
||||
481
System/os_api.h
Normal file
481
System/os_api.h
Normal file
@@ -0,0 +1,481 @@
|
||||
/**************************************************************************//**
|
||||
* @item CosyOS-II Kernel
|
||||
* @file os_api.h
|
||||
* @brief 系统内核专用API
|
||||
* @author 迟凯峰
|
||||
* @version V2.0.0
|
||||
* @date 2024.03.17
|
||||
******************************************************************************/
|
||||
|
||||
#ifndef __OS_API_H
|
||||
#define __OS_API_H
|
||||
|
||||
void s_scheduling_taskpri(s_tasknode_tsp node);
|
||||
void s_scheduling_notnull(s_tasknode_tsp node);
|
||||
void s_scheduling_ready (s_tasknode_tsp node);
|
||||
void s_scheduling_taskmsg(s_tasknode_tsp node);
|
||||
void s_set_taskpri (s_tasknode_tsp node);
|
||||
|
||||
|
||||
|
||||
/*
|
||||
* 标准库
|
||||
*/
|
||||
|
||||
#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_strcpy strcpy
|
||||
#define s_strlen strlen
|
||||
#define s_strcmp strcmp
|
||||
|
||||
|
||||
|
||||
/*
|
||||
* 任务
|
||||
*/
|
||||
|
||||
/* 启动定时中断任务 */
|
||||
#define sStartTask_TimInt(tmid) \
|
||||
sUSV_StartTask((s_taskhand_tsp)s_timint_handle[tmid]->hookorhand, OS_STATUS_SUSPENDED)
|
||||
|
||||
/* 启动定时查询任务 */
|
||||
#define sStartTask_TimQry(tmid) \
|
||||
sUSV_StartTask((s_taskhand_tsp)s_timqry_handle[tmid]->hookorhand, OS_STATUS_SUSPENDED)
|
||||
|
||||
/* 恢复定时中断任务 */
|
||||
#define sResumeTask_TimInt(tmid) \
|
||||
sTSV_ResumeTask(*((s_taskhand_tsp)s_timint_handle[tmid]->hookorhand)->handle)
|
||||
|
||||
/* 恢复定时查询任务 */
|
||||
#define sResumeTask_TimQry(tmid) \
|
||||
sTSV_ResumeTask(*((s_taskhand_tsp)s_timqry_handle[tmid]->hookorhand)->handle)
|
||||
|
||||
|
||||
|
||||
/*
|
||||
* 更新全局变量副本
|
||||
*/
|
||||
|
||||
#define sUpdateCopy(code) \
|
||||
do{ \
|
||||
s_sign_updatecopy = true; \
|
||||
code; \
|
||||
s_sign_updatecopy = false; \
|
||||
}while(false)
|
||||
|
||||
|
||||
|
||||
/*
|
||||
* 写消息邮箱访问器
|
||||
*/
|
||||
|
||||
#if SYSCFG_MCUCORE == 8051
|
||||
#define sWrite_MBoxAccessor(p) \
|
||||
do{ \
|
||||
s_sign_write_mbox_accessor = true; \
|
||||
s_mbox_accessor = p; \
|
||||
s_sign_write_mbox_accessor = false; \
|
||||
}while(false)
|
||||
|
||||
#else
|
||||
#define sWrite_MBoxAccessor(p) \
|
||||
s_mbox_accessor = p
|
||||
|
||||
#endif
|
||||
|
||||
|
||||
|
||||
/*
|
||||
* 私信 - 创建信箱
|
||||
*/
|
||||
|
||||
#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_taskcri_counter){ \
|
||||
uExitCritical; \
|
||||
} \
|
||||
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_Load; \
|
||||
}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{ \
|
||||
node->msg = p; \
|
||||
node->next = NULL; \
|
||||
node->last = ((s_msgqueue_dynamic_tsp)queue)->tail; \
|
||||
if(((s_msgqueue_dynamic_tsp)queue)->tail != NULL){ \
|
||||
((s_msgqueue_dynamic_tsp)queue)->tail->next = node; \
|
||||
} \
|
||||
((s_msgqueue_dynamic_tsp)queue)->tail = node; \
|
||||
if(((s_msgqueue_dynamic_tsp)queue)->head == NULL){ \
|
||||
((s_msgqueue_dynamic_tsp)queue)->head = node; \
|
||||
} \
|
||||
queue->counter++; \
|
||||
}while(false)
|
||||
|
||||
/* 动态队列 - 接收消息 */
|
||||
#define sRecvMsg_Dynamic(p) \
|
||||
do{ \
|
||||
if(queue->mode == __MSGQUE_LIFO__){ \
|
||||
node = ((s_msgqueue_dynamic_tsp)queue)->tail; \
|
||||
p = node->msg; \
|
||||
node = node->last; \
|
||||
s_free(((s_msgqueue_dynamic_tsp)queue)->tail); \
|
||||
((s_msgqueue_dynamic_tsp)queue)->tail = node; \
|
||||
if(node == NULL){ \
|
||||
((s_msgqueue_dynamic_tsp)queue)->head = NULL; \
|
||||
} \
|
||||
else{ \
|
||||
node->next = NULL; \
|
||||
} \
|
||||
} \
|
||||
else{ \
|
||||
node = ((s_msgqueue_dynamic_tsp)queue)->head; \
|
||||
p = node->msg; \
|
||||
node = node->next; \
|
||||
s_free(((s_msgqueue_dynamic_tsp)queue)->head); \
|
||||
((s_msgqueue_dynamic_tsp)queue)->head = node; \
|
||||
if(node == NULL){ \
|
||||
((s_msgqueue_dynamic_tsp)queue)->tail = NULL; \
|
||||
} \
|
||||
else{ \
|
||||
node->last = NULL; \
|
||||
} \
|
||||
} \
|
||||
queue->counter--; \
|
||||
}while(false)
|
||||
|
||||
/* 静态队列 - 发送消息 */
|
||||
#define sSendMsg_Static(p) \
|
||||
do{ \
|
||||
if(((s_msgqueue_static_tsp)queue)->tail < ((s_msgqueue_static_tsp)queue)->base + queue->len - 1){ \
|
||||
((s_msgqueue_static_tsp)queue)->tail++; \
|
||||
} \
|
||||
else{ \
|
||||
((s_msgqueue_static_tsp)queue)->tail = ((s_msgqueue_static_tsp)queue)->base; \
|
||||
} \
|
||||
*((s_msgqueue_static_tsp)queue)->tail = p; \
|
||||
queue->counter++; \
|
||||
}while(false)
|
||||
|
||||
/* 静态队列 - 接收消息 */
|
||||
#define sRecvMsg_Static(p) \
|
||||
do{ \
|
||||
if(queue->mode == __MSGQUE_LIFO__){ \
|
||||
p = *((s_msgqueue_static_tsp)queue)->tail; \
|
||||
if(((s_msgqueue_static_tsp)queue)->tail > ((s_msgqueue_static_tsp)queue)->base){ \
|
||||
((s_msgqueue_static_tsp)queue)->tail--; \
|
||||
} \
|
||||
else{ \
|
||||
((s_msgqueue_static_tsp)queue)->tail = ((s_msgqueue_static_tsp)queue)->base + queue->len - 1; \
|
||||
} \
|
||||
} \
|
||||
else{ \
|
||||
p = *((s_msgqueue_static_tsp)queue)->head; \
|
||||
if(((s_msgqueue_static_tsp)queue)->head < ((s_msgqueue_static_tsp)queue)->base + queue->len - 1){ \
|
||||
((s_msgqueue_static_tsp)queue)->head++; \
|
||||
} \
|
||||
else{ \
|
||||
((s_msgqueue_static_tsp)queue)->head = ((s_msgqueue_static_tsp)queue)->base; \
|
||||
} \
|
||||
} \
|
||||
queue->counter--; \
|
||||
}while(false)
|
||||
|
||||
|
||||
|
||||
#endif
|
||||
23
System/os_base.h
Normal file
23
System/os_base.h
Normal file
@@ -0,0 +1,23 @@
|
||||
/**************************************************************************//**
|
||||
* @item CosyOS-II Kernel
|
||||
* @file os_base.h
|
||||
* @brief 基本数据类型定义
|
||||
* @author 迟凯峰
|
||||
* @version V2.0.0
|
||||
* @date 2024.03.17
|
||||
******************************************************************************/
|
||||
|
||||
#ifndef __OS_BASE_H
|
||||
#define __OS_BASE_H
|
||||
|
||||
typedef char s_s8_t;
|
||||
typedef short s_s16_t;
|
||||
typedef long s_s32_t;
|
||||
typedef unsigned char s_u8_t;
|
||||
typedef unsigned short s_u16_t;
|
||||
typedef unsigned long s_u32_t;
|
||||
typedef s_u8_t s_bool_t;
|
||||
|
||||
|
||||
|
||||
#endif
|
||||
136
System/os_debug.c
Normal file
136
System/os_debug.c
Normal file
@@ -0,0 +1,136 @@
|
||||
/**************************************************************************//**
|
||||
* @item CosyOS-II Kernel
|
||||
* @file os_debug.c
|
||||
* @brief DEBUG接口（串口发送和接收解析）
|
||||
* @author 迟凯峰
|
||||
* @version V2.0.0
|
||||
* @date 2024.03.17
|
||||
******************************************************************************/
|
||||
|
||||
#include "os_link.h"
|
||||
#if SYSCFG_DEBUGGING == __ENABLED__
|
||||
|
||||
#if SYSCFG_MCUCORE == 8051
|
||||
|
||||
static char* _strncpy_(char* src, const char* sub, size_t n)
|
||||
{
|
||||
if(src == NULL || sub == NULL || !*sub || !n){
|
||||
return src;
|
||||
}
|
||||
else{
|
||||
char* str = src;
|
||||
do{
|
||||
*str++ = *sub;
|
||||
if(!*sub++){
|
||||
return src;
|
||||
}
|
||||
}while(--n);
|
||||
*str = '\0';
|
||||
return src;
|
||||
}
|
||||
}
|
||||
|
||||
static char _strncmp_(const char* src, const char* sub, size_t n)
|
||||
{
|
||||
if(src == NULL || sub == NULL){
|
||||
return 1;
|
||||
}
|
||||
do{
|
||||
if(*src++ == *sub){
|
||||
if(!*sub++){
|
||||
return 0;
|
||||
}
|
||||
}
|
||||
else{
|
||||
return 1;
|
||||
}
|
||||
}while(--n);
|
||||
return 0;
|
||||
}
|
||||
|
||||
static int _atoi_(const char* str)
|
||||
{
|
||||
if(str == NULL || !*str){
|
||||
return 0;
|
||||
}
|
||||
else{
|
||||
int a = 0;
|
||||
int k = 1;
|
||||
s_u8_t i = s_strlen(str);
|
||||
while(i--){
|
||||
if(str[i] >= '0' && str[i] <= '9'){
|
||||
a += (str[i] - '0') * k;
|
||||
k *= 10;
|
||||
}
|
||||
else if(str[i] == '+'){
|
||||
return a;
|
||||
}
|
||||
else if(str[i] == '-'){
|
||||
return -a;
|
||||
}
|
||||
else{
|
||||
return 0;
|
||||
}
|
||||
}
|
||||
return a;
|
||||
}
|
||||
}
|
||||
|
||||
#else
|
||||
#define _strncpy_ strncpy
|
||||
#define _strncmp_ strncmp
|
||||
#define _atoi_ atoi
|
||||
#endif
|
||||
|
||||
static void _debug_recv_(void)
|
||||
{
|
||||
#define hptr s_debug_recvbuff
|
||||
s_u16_t temp;
|
||||
char strtmp[8];
|
||||
char _XDATA_MEM_ *mptr = hptr;
|
||||
char _XDATA_MEM_ *tptr = hptr + s_strlen(hptr) - 2;
|
||||
if(!s_strcmp(tptr, "\r\n")){
|
||||
if(!s_strcmp(hptr, "taskmgr\r\n")){
|
||||
s_sign_taskmgr = true;
|
||||
}
|
||||
else if(!s_strcmp(hptr, "exit\r\n")){
|
||||
s_sign_taskmgr = false;
|
||||
}
|
||||
else if(!_strncmp_(hptr, "taskmgr /s=", 11)){
|
||||
mptr += 11;
|
||||
_strncpy_(strtmp, mptr, tptr - mptr);
|
||||
strtmp[tptr - mptr] = '\0';
|
||||
temp = _atoi_(strtmp);
|
||||
if(temp >= 50 && temp <= 5000){
|
||||
mSysIRQ_Disable;
|
||||
s_timqry_reload[OS_TMID_TASKMGR] = (1000UL * temp) / SYSCFG_SYSTICKCYCLE;
|
||||
mSysIRQ_Enable;
|
||||
}
|
||||
}
|
||||
}
|
||||
#undef hptr
|
||||
}
|
||||
|
||||
uCreateTask_TimInt(OS_TMID_DEBUGGER, false, Debugger, SYSCFG_TASKPRIORITY - 1, MCUCFG_STACKSIZE_DEBUGGER, 0, 0)
|
||||
{
|
||||
s_debug_recvptr[0] = '\0';
|
||||
_debug_recv_();
|
||||
s_debug_recvptr = s_debug_recvbuff;
|
||||
uSuspendTasking;
|
||||
uEndTasking;
|
||||
}
|
||||
|
||||
uCreateHook_TimQry(OS_TMID_DEBUGHOOK, s_debug_sendtype, false, debug_hook)
|
||||
{
|
||||
if(s_debug_sendtype & OS_DEBUG_SEND_TASKMGR){
|
||||
s_debug_sendtype &= ~OS_DEBUG_SEND_TASKMGR;
|
||||
s_debug_sendptr = s_taskmgr_sendbuff;
|
||||
}
|
||||
else if(s_debug_sendtype & OS_DEBUG_SEND_CMDLINE){
|
||||
s_debug_sendtype &= ~OS_DEBUG_SEND_CMDLINE;
|
||||
s_debug_sendptr = s_cmdline_sendbuff;
|
||||
}
|
||||
SYSCFG_DEBUGSEND;
|
||||
}
|
||||
|
||||
#endif
|
||||
135
System/os_def.h
Normal file
135
System/os_def.h
Normal file
@@ -0,0 +1,135 @@
|
||||
/**************************************************************************//**
|
||||
* @item CosyOS-II Kernel
|
||||
* @file os_def.h
|
||||
* @brief 初始宏定义
|
||||
* @author 迟凯峰
|
||||
* @version V2.0.0
|
||||
* @date 2024.03.17
|
||||
******************************************************************************/
|
||||
|
||||
#ifndef __OS_DEF_H
|
||||
#define __OS_DEF_H
|
||||
|
||||
#define false 0
|
||||
#define true 1
|
||||
|
||||
/*
|
||||
* CONFIG VALUE
|
||||
*/
|
||||
|
||||
#define __DISABLED__ 0
|
||||
#define __ENABLED__ 1
|
||||
#define __STATIC__ 0
|
||||
#define __DYNAMIC__ 2
|
||||
#define __MSP__ 0
|
||||
#define __PSP__ 1
|
||||
#define __STCLK__ 0
|
||||
#define __FCLK__ 1
|
||||
#define __STANDARD__ 0
|
||||
#define __INTELLIGENT__ 0
|
||||
#define __PERFORMANCE__ 1
|
||||
#define __MSGQUE_FIFO__ 0
|
||||
#define __MSGQUE_LIFO__ 1
|
||||
#define __MCS_51__ 0
|
||||
#define __MCS_251__ 1
|
||||
#define __ARM__ 2
|
||||
|
||||
|
||||
|
||||
/*
|
||||
* 任务相关
|
||||
*/
|
||||
|
||||
#define OS_TASKQUEUELEN_MAX 255 // 任务队列最大长度
|
||||
|
||||
/* 任务状态 */
|
||||
#define OS_STATUS_READY 0x00 // 就绪
|
||||
#define OS_STATUS_FLOATING 0x01 // 浮动
|
||||
#define OS_STATUS_BLOCKED 0x02 // 阻塞
|
||||
#define OS_STATUS_OVERTIME 0x04 // 超时
|
||||
#define OS_STATUS_SUSPENDED 0x08 // 挂起
|
||||
#define OS_STATUS_STOPPED 0x10 // 停止
|
||||
#define OS_STATUS_STOPPED_TSOF 0x30 // 任务栈溢出停止
|
||||
#define OS_STATUS_STOPPED_TSRF 0x50 // 任务栈重分配失败停止
|
||||
#define OS_STATUS_DELETED 0x80 // 已删除/未启动
|
||||
|
||||
/* 阻塞事件类型 */
|
||||
#define OS_BLOCKED_DELAY 0x00 // 延时阻塞
|
||||
#define OS_BLOCKED_BINARY 0x10 // 二值信号量阻塞（获取/等待）
|
||||
#define OS_BLOCKED_MUTEX 0x20 // 互斥信号量阻塞（获取）
|
||||
#define OS_BLOCKED_SEMAPHORE 0x30 // 计数信号量阻塞（获取）
|
||||
#define OS_BLOCKED_FLAGGROUP 0x40 // 等待标志组阻塞
|
||||
#define OS_BLOCKED_TASKMSG 0x50 // 接收私信阻塞
|
||||
#define OS_BLOCKED_FETION 0x60 // 接收飞信阻塞
|
||||
#define OS_BLOCKED_MAIL 0x70 // 接收邮件阻塞
|
||||
#define OS_BLOCKED_MSG 0x80 // 接收消息阻塞
|
||||
|
||||
|
||||
|
||||
/*
|
||||
* DEBUG SEND TYPE
|
||||
*/
|
||||
|
||||
#define OS_DEBUG_SEND_CMDLINE 0x01
|
||||
#define OS_DEBUG_SEND_TASKMGR 0x02
|
||||
|
||||
|
||||
|
||||
/*
|
||||
* TASKMGR LEN
|
||||
*/
|
||||
|
||||
#define OS_TASKMGR_LEN_PRI 6
|
||||
#define OS_TASKMGR_LEN_STA 6
|
||||
#define OS_TASKMGR_LEN_CPU 9
|
||||
|
||||
|
||||
|
||||
/*
|
||||
* SVID（服务ID，中断挂起服务系统专用ID）
|
||||
*/
|
||||
|
||||
#define OS_SVID_RESUMETASK 0x00
|
||||
#define OS_SVID_SUSPENDTASK 0x01
|
||||
#define OS_SVID_DELETETASK 0x02
|
||||
#define OS_SVID_SETTASKPRI 0x03
|
||||
#define OS_SVID_SETBLOCK 0x04
|
||||
#define OS_SVID_CELARBLOCK 0x05
|
||||
#define OS_SVID_TIMINT 0x06
|
||||
#define OS_SVID_TIMQRY 0x07
|
||||
#define OS_SVID_BINARY 0x08
|
||||
#define OS_SVID_GIVESEM 0x09
|
||||
#define OS_SVID_SENDFETION 0x0A
|
||||
#define OS_SVID_SENDMAIL 0x0B
|
||||
#define OS_SVID_SENDMSG 0x0C
|
||||
#define OS_SVID_GROUP 0x0D
|
||||
#define OS_SVID_GVARWRITE 0x0E
|
||||
#define OS_SVID_PENDSVC 0x0F
|
||||
#define OS_SVID_SENDSIGN 0x10
|
||||
#define OS_SVID_END 0x11
|
||||
|
||||
|
||||
|
||||
/*
|
||||
* ECODE（错误码）
|
||||
*/
|
||||
|
||||
#define OS_ECODE_NOERROR 0 // 无错误
|
||||
#define OS_ECODE_OVERFLOW_MSGQUEUE 1 // 消息队列溢出
|
||||
#define OS_ECODE_OVERFLOW_TASKQUEUE 2 // 任务队列溢出
|
||||
#define OS_ECODE_OVERFLOW_TASKSTACK 3 // 任务栈溢出
|
||||
#define OS_ECODE_MALLOCFAIL_MSGNODE 4 // 消息节点内存分配失败
|
||||
#define OS_ECODE_MALLOCFAIL_TASKNODE 5 // 任务节点内存分配失败
|
||||
#define OS_ECODE_MALLOCFAIL_TASKSTACK 6 // 任务栈内存分配失败
|
||||
#define OS_ECODE_TASKSUSPENDED 7 // 任务已挂起
|
||||
#define OS_ECODE_TASKSTOPPED 8 // 任务已停止
|
||||
#define OS_ECODE_TASKNOTSTARTED 9 // 任务未启动/已删除
|
||||
#define OS_ECODE_TASKNOTREADY 10 // 任务未就绪
|
||||
#define OS_ECODE_TASKNOTBLOCKED 11 // 任务未阻塞
|
||||
#define OS_ECODE_TASKNOTSUSPENDED 12 // 任务未挂起
|
||||
#define OS_ECODE_TASKPRIUNCHANGED 13 // 任务优先级未改变
|
||||
#define OS_ECODE_DONOTKNOW 255 // 未知错误
|
||||
|
||||
|
||||
|
||||
#endif
|
||||
716
System/os_handler.c
Normal file
716
System/os_handler.c
Normal file
File diff suppressed because it is too large
Load Diff
33
System/os_hook.h
Normal file
33
System/os_hook.h
Normal file
@@ -0,0 +1,33 @@
|
||||
/**************************************************************************//**
|
||||
* @item CosyOS-II Kernel
|
||||
* @file os_hook.h
|
||||
* @brief 系统钩子函数声明
|
||||
* @author 迟凯峰
|
||||
* @version V2.0.0
|
||||
* @date 2024.03.17
|
||||
******************************************************************************/
|
||||
|
||||
#ifndef __OS_HOOK_H
|
||||
#define __OS_HOOK_H
|
||||
|
||||
/* 初始化钩子 */
|
||||
void init_hook(void);
|
||||
|
||||
/* 启动钩子 */
|
||||
void start_hook(void);
|
||||
|
||||
/* 滴答钩子 */
|
||||
void tick_hook(void);
|
||||
|
||||
/* 空闲钩子 */
|
||||
void idle_hook(void);
|
||||
|
||||
/* 挂起服务钩子 */
|
||||
void pendsv_hook(void);
|
||||
|
||||
/* 全局变量钩子 */
|
||||
void gvar_hook(void);
|
||||
|
||||
|
||||
|
||||
#endif
|
||||
26
System/os_link.h
Normal file
26
System/os_link.h
Normal file
@@ -0,0 +1,26 @@
|
||||
/**************************************************************************//**
|
||||
* @item CosyOS-II Kernel
|
||||
* @file os_link.h
|
||||
* @brief 系统链接头文件（用户的各个c文件中应包含此文件）
|
||||
* @author 迟凯峰
|
||||
* @version V2.0.0
|
||||
* @date 2024.03.17
|
||||
******************************************************************************/
|
||||
|
||||
#ifndef __OS_LINK_H
|
||||
#define __OS_LINK_H
|
||||
|
||||
#include "os_var.h"
|
||||
#include "os_api.h"
|
||||
#include "sv_create.h"
|
||||
#include "sv_task.h"
|
||||
#include "sv_tick.h"
|
||||
#include "sv_int_loc.h"
|
||||
#include "sv_int_pend.h"
|
||||
#include "ur_api.h"
|
||||
#include "os_task.h"
|
||||
#include "os_hook.h"
|
||||
|
||||
|
||||
|
||||
#endif
|
||||
36
System/os_main.c
Normal file
36
System/os_main.c
Normal file
@@ -0,0 +1,36 @@
|
||||
/**************************************************************************//**
|
||||
* @item CosyOS-II Kernel
|
||||
* @file os_main.c
|
||||
* @brief 主函数
|
||||
* @author 迟凯峰
|
||||
* @version V2.0.0
|
||||
* @date 2024.03.17
|
||||
******************************************************************************/
|
||||
|
||||
#include "os_link.h"
|
||||
|
||||
int main(void)
|
||||
{
|
||||
s_tid_t i;
|
||||
#if OS_TIMINTTOTAL || OS_TIMQRYTOTAL
|
||||
void s_init_timing(void);
|
||||
s_init_timing();
|
||||
#endif
|
||||
for(i = 0; i < OS_TASKTOTAL + 1; i++){
|
||||
s_delay_loader[i] = 0;
|
||||
#if SYSCFG_SAFERUNTIME == __ENABLED__
|
||||
s_sign_timeout[i] = 0;
|
||||
#endif
|
||||
}
|
||||
init_hook();
|
||||
mSys_INIT;
|
||||
#if SYSCFG_DEBUGGING == __ENABLED__
|
||||
sStartTask_TimQry(OS_TMID_TASKMGR);
|
||||
#endif
|
||||
uStartTask(Starter, OS_STATUS_READY);
|
||||
uStartTask(Sysidle, OS_STATUS_READY);
|
||||
s_sign_return = false;
|
||||
s_sign_scheduling = true;
|
||||
mPendSV_Set;
|
||||
while(true);
|
||||
}
|
||||
657
System/os_redef.h
Normal file
657
System/os_redef.h
Normal file
File diff suppressed because it is too large
Load Diff
Reference in New Issue
Block a user