?? os_msg.c
字號:
/*********************************************************************************************************
** Small RTOS
** The Real-Time Kernel
** (c) Copyright 2002-2003, chenmingji
** All Rights Reserved
** V1.50.0
**
**--------------文件信息--------------------------------------------------------------------------------
**文 件 名: OS_msg.c
**創 建 人: 陳明計
**最后修改日期: 2005年6月10日
**描 述: Small RTOS消息處理代碼（任務之間直接發送消息）
**
**--------------歷史版本信息----------------------------------------------------------------------------
** 創建人: 陳明計
** 版 本: V1.00
** 日 期: 2005年6月10日
** 描 述: 基本完成全新的Small RTOS核
**
**------------------------------------------------------------------------------------------------------
** 修改人:
** 版 本:
** 日 期:
** 描 述:
**
**--------------當前版本修訂------------------------------------------------------------------------------
** 修改人: 焦進星
** 日 期: 2007年12月30日
** 描 述: 移植到AVR系列芯片，適用于atmega16/32等
**
**------------------------------------------------------------------------------------------------------
********************************************************************************************************/
#define IN_OS_MSG
#define IN_OS
#include "..\APP\config.h"
#if EN_OS_MSG > 0
/*********************************************************************************************************
** 函數名稱: OSMsgAccept
** 功能描述: 無等待獲取消息
** 輸 入: TaskId:用于返回發送消息的任務的任務ID
** err:錯誤狀態
** 輸 出: 指向消息的無類型指針
** 作 者: 陳明計
** 日 期: 2005年6月10日
**-------------------------------------------------------------------------------------------------------
** 修改人:
** 日 期:
**-------------------------------------------------------------------------------------------------------
********************************************************************************************************/
#if EN_OS_MSG_ACCEPT > 0
void * OSMsgAccept(TASK_ID *TaskId, uint8 *err)
{
void *Rt;
OS_TCB *Tcb;
OS_ENTER_CRITICAL();
if ((OSTCBCur->OSTCBInfo & OS_INFO_MSG) != 0) /* 如果有消息 */
{
Tcb = OSTCBCur->MsgHard;
Rt = Tcb->Msg; /* 返回消息 */
*TaskId = Tcb->OSTCBId; /* 返回發送消息的任務 */
/* 從隊列中刪除發送消息的任務 */
OSTCBCur->MsgHard = Tcb->MsgNext;
Tcb->MsgNext = NULL;
Tcb->MsgPrev = NULL;
if (OSTCBCur->MsgHard == NULL)
{
OSTCBCur->MsgEnd = NULL;
}
*err = OS_NO_ERR;
Tcb->OSTCBInfo |= OS_INFO_MSG_SENGED; /* 指明發送消息的任務獲已經發送了消息 */
/* 如果發送消息的任務在等待消息發送完畢，恢復它 */
if ((Tcb->OSTCBStat & OS_STAT_MSG_SENGED) != 0)
{
Tcb->OSTCBStat = 0;
_OS_TaskResume(Tcb);
OSSched();
}
}
else
{
*err = OS_MSG_EMPTY;
Rt = NULL;
}
if (OSTCBCur->MsgHard == NULL)
{
OSTCBCur->OSTCBInfo &= ~OS_INFO_MSG;
}
OS_EXIT_CRITICAL();
return Rt;
}
#endif
/*********************************************************************************************************
** 函數名稱: OSMsgPend
** 功能描述: 等待消息
** 輸 入: Tick:超時時間
** TaskId:用于返回發送消息的任務的任務ID
** err:錯誤狀態
** 輸 出: 指向消息的無類型指針
** 作 者: 陳明計
** 日 期: 2005年6月10日
**-------------------------------------------------------------------------------------------------------
** 修改人:
** 日 期:
**-------------------------------------------------------------------------------------------------------
********************************************************************************************************/
#if EN_OS_MSG_PENT > 0
void * OSMsgPend(uint8 Tick, TASK_ID *TaskId, uint8 *err)
{
void *Rt;
OS_TCB *Tcb;
OS_ENTER_CRITICAL();
if ((OSTCBCur->OSTCBInfo & OS_INFO_MSG) == 0) /* 如果沒有消息 */
{
OSTCBCur->OSTCBStat |= OS_INFO_MSG;
if (Tick > 0)
{
OS_TimeDly(Tick); /* 超時設置 */
}
else
{
_OS_TaskSuspend(OSTCBCur); /* 從優先級鏈表中刪除 */
}
OSSched();
}
/* 以下部分注釋參考OSMsgAccept */
if ((OSTCBCur->OSTCBInfo & OS_INFO_MSG) != 0)
{
Tcb = OSTCBCur->MsgHard;
Rt = Tcb->Msg;
*TaskId = Tcb->OSTCBId;
OSTCBCur->MsgHard = Tcb->MsgNext;
Tcb->MsgNext = NULL;
Tcb->MsgPrev = NULL;
if (OSTCBCur->MsgHard == NULL)
{
OSTCBCur->MsgEnd = NULL;
}
*err = OS_NO_ERR;
Tcb->OSTCBInfo |= OS_INFO_MSG_SENGED;
if ((Tcb->OSTCBStat & OS_STAT_MSG_SENGED) != 0)
{
Tcb->OSTCBStat = 0;
_OS_TaskResume(Tcb);
OSSched();
}
}
else
{
*err = OS_TIMEOUT;
Rt = NULL;
}
if (OSTCBCur->MsgHard == NULL)
{
OSTCBCur->OSTCBInfo &= ~OS_INFO_MSG;
}
OS_EXIT_CRITICAL();
return Rt;
}
#endif
/*********************************************************************************************************
** 函數名稱: OSMsgPost
** 功能描述: FIFO方式發送消息
** 輸 入: TaskId:消息的目的任務ID
** Msg:消息
** 輸 出: OS_NO_ERR:成功
** OS_TASKID_INVALID:目標任務不存在
** OS_MSG_SEND_ERR:消息發送錯誤
** 作 者: 陳明計
** 日 期: 2005年6月10日
**-------------------------------------------------------------------------------------------------------
** 修改人:
** 日 期:
**-------------------------------------------------------------------------------------------------------
********************************************************************************************************/
#if EN_OS_MSG_POST > 0
uint8 OSMsgPost(TASK_ID TaskId, void *Msg)
{
OS_TCB *Tcb;
uint8 Rt;
/* 目的必須有效 */
Rt = OS_TASKID_INVALID;
if (TaskId < OS_MAX_TASKS)
if (TaskId != OSTCBCur->OSTCBId) /* 不能發給自身 */
{
Rt = OS_MSG_SEND_ERR;
if ((OSTCBCur->OSTCBInfo & OS_INFO_MSG_SENGED) != 0) /* 上次發送消息完畢 */
{
Rt = OS_TASKID_INVALID;
OS_ENTER_CRITICAL();
Tcb = &(OSTCBTbl[TaskId]);
if (Tcb->OSTCBStat != OS_STAT_DEATH) /* 目標確實存在 */
{
/* 發送消息 */
OSTCBCur->OSTCBInfo &= ~(OS_INFO_MSG_SENGED | OS_INFO_MSG_BACK);
OSTCBCur->Msg = Msg;
/* 把任務加入鏈表 */
OSTCBCur->MsgNext = NULL;
OSTCBCur->MsgPrev = Tcb->MsgEnd;
if (Tcb->MsgEnd != NULL)
{
Tcb->MsgEnd->MsgNext = OSTCBCur;
}
if (Tcb->MsgHard == NULL)
{
Tcb->MsgHard = OSTCBCur;
}
Tcb->MsgEnd = OSTCBCur;
Rt = OS_NO_ERR;
Tcb->OSTCBInfo |= OS_INFO_MSG;
if ((Tcb->OSTCBStat & OS_STAT_MSG) != 0) /* 目標任務在等待消息 */
{
Tcb->OSTCBStat = 0;
_OS_TaskResume(Tcb);
OSSched();
}
}
OS_EXIT_CRITICAL();
}
}
return Rt;
}
#endif
/*********************************************************************************************************
** 函數名稱: OSMsgPostFront
** 功能描述: LIFO方式發送消息
** 輸 入: TaskId:消息的目的任務ID
** Msg:消息
** 輸 出: OS_NO_ERR:成功
** OS_TASKID_INVALID:目標任務不存在
** OS_MSG_SEND_ERR:消息發送錯誤
** 作 者: 陳明計
** 日 期: 2005年6月10日
**-------------------------------------------------------------------------------------------------------
** 修改人:
** 日 期:
**-------------------------------------------------------------------------------------------------------
********************************************************************************************************/
#if EN_OS_MSG_POST_FRONT > 0
uint8 OSMsgPostFront(TASK_ID TaskId, void * Msg)
{
OS_TCB *Tcb;
uint8 Rt;
/* 注釋參考OSMsgPost */
Rt = OS_TASKID_INVALID;
if (TaskId < OS_MAX_TASKS)
if (TaskId != OSTCBCur->OSTCBId)
{
Rt = OS_MSG_SEND_ERR;
if ((OSTCBCur->OSTCBInfo & OS_INFO_MSG_SENGED) != 0)
{
Rt = OS_TASKID_INVALID;
OS_ENTER_CRITICAL();
Tcb = &(OSTCBTbl[TaskId]);
if (Tcb->OSTCBStat != OS_STAT_DEATH)
{
OSTCBCur->OSTCBInfo &= ~(OS_INFO_MSG_SENGED | OS_INFO_MSG_BACK);
OSTCBCur->Msg = Msg;
OSTCBCur->MsgPrev = NULL;
OSTCBCur->MsgNext = Tcb->MsgHard;
if (Tcb->MsgHard != NULL)
{
Tcb->MsgHard->MsgPrev = OSTCBCur;
}
Tcb->MsgHard = OSTCBCur;
Rt = OS_NO_ERR;
Tcb->OSTCBInfo |= OS_INFO_MSG;
if ((Tcb->OSTCBStat & OS_STAT_MSG) != 0)
{
Tcb->OSTCBStat = 0;
_OS_TaskResume(Tcb);
OSSched();
}
}
OS_EXIT_CRITICAL();
}
}
return Rt;
}
#endif
/*********************************************************************************************************
** 函數名稱: OSMsgNMsgs
** 功能描述: 取得指定任務的消息數
** 輸 入: TaskId:任務ID
** 輸 出: 消息數目
** 作 者: 陳明計
** 日 期: 2005年6月10日
**-------------------------------------------------------------------------------------------------------
** 修改人:
** 日 期:
**-------------------------------------------------------------------------------------------------------
********************************************************************************************************/
#if EN_OS_MSG_NMsgs > 0
uint32 OSMsgNMsgs(TASK_ID TaskId)
{
OS_TCB *Tcb;
uint32 Rt;
Rt = 0;
Tcb = NULL;
if (TaskId == OS_ID_SELF)
{
Tcb = OSTCBCur;
}
if (TaskId < OS_MAX_TASKS)
{
Tcb = &(OSTCBTbl[TaskId]);
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -