?? os_q.c
字號:
* 1) OS_POST_OPT_NONE
* 相當于 OSQPost()
*
* 2) OS_POST_OPT_FRONT
* 相當于 OSQPostFront()
*
* 3) OS_POST_OPT_BROADCAST
* 相當于 OSQPost() 但可以以廣播方式發送 to ALL waiting tasks
*
* 4) OS_POST_OPT_FRONT + OS_POST_OPT_BROADCAST 相當于
* OSQPostFront() 可以以廣播方式發送
*********************************************************************************************************
*/
#if OS_Q_POST_OPT_EN > 0
INT8U OSQPostOpt (OS_EVENT *pevent, void *msg, INT8U opt)
{
#if OS_CRITICAL_METHOD == 3 /* Allocate storage for CPU status register */
OS_CPU_SR cpu_sr;
#endif
OS_Q *pq;
#if OS_ARG_CHK_EN > 0
if (pevent == (OS_EVENT *)0) { /* Validate 'pevent' */
return (OS_ERR_PEVENT_NULL);
}//非法pevent
if (msg == (void *)0) { /* Make sure we are not posting a NULL pointer */
return (OS_ERR_POST_NULL_PTR);
}//保證沒有送空指針
if (pevent->OSEventType != OS_EVENT_TYPE_Q) { /* Validate event block type */
return (OS_ERR_EVENT_TYPE);
}//不是事件塊類型
#endif
OS_ENTER_CRITICAL();
if (pevent->OSEventGrp != 0x00) { /* See if any task pending on queue */
//如果有任務在隊列中掛起
if ((opt & OS_POST_OPT_BROADCAST) != 0x00) { /* Do we need to post msg to ALL waiting tasks ? */
//向所有任務發送?
while (pevent->OSEventGrp != 0x00) { /* Yes, Post to ALL tasks waiting on queue */
OS_EventTaskRdy(pevent, msg, OS_STAT_Q);
}//是的。如果將opt參數中的OS_POST_OPT_BROADCAST位置為1,則所有正在等待消息
//的任務都能接收到這則消息,并且被OS_EventTaskRdy從等待列表中刪除。
} else {//不要向所有的等待任務發消息
OS_EventTaskRdy(pevent, msg, OS_STAT_Q); /* No, Post to HPT waiting on queue */
//那就只發優先級最高的。
}
OS_EXIT_CRITICAL();
OS_Sched(); /* Find highest priority task ready to run */
//要任務調度
return (OS_NO_ERR);
}
pq = (OS_Q *)pevent->OSEventPtr; /* Point to queue control block */
//指向隊列控制塊
if (pq->OSQEntries >= pq->OSQSize) { /* Make sure queue is not full */
OS_EXIT_CRITICAL();//如果滿了,返回錯誤代碼
return (OS_Q_FULL);
}
if ((opt & OS_POST_OPT_FRONT) != 0x00) { /* Do we post to the FRONT of the queue? */
//FIFO還是LIFO,如果是LIFO
if (pq->OSQOut == pq->OSQStart) { /* Yes, Post as LIFO, Wrap OUT pointer if we ... */
pq->OSQOut = pq->OSQEnd; /* ... are at the 1st queue entry */
}//如果是后進先出,則相當于OSQPostFront 。如果我人在隊列第一個,則調整
pq->OSQOut--;
*pq->OSQOut = msg; /* Insert message into queue */
//插入消息
} else { /* No, Post as FIFO */
//如果是FIFO
*pq->OSQIn++ = msg; /* Insert message into queue */
if (pq->OSQIn == pq->OSQEnd) { /* Wrap IN ptr if we are at end of queue */
pq->OSQIn = pq->OSQStart;//如果在最末尾,則調整
}
}
pq->OSQEntries++; /* Update the nbr of entries in the queue */
//更新消息條數
OS_EXIT_CRITICAL();
return (OS_NO_ERR);
}
#endif
/*$PAGE*/
/*
*********************************************************************************************************
* QUERY A MESSAGE QUEUE
*
* Description: This function obtains information about a message queue.
*
* Arguments : pevent is a pointer to the event control block associated with the desired queue
*
* pdata is a pointer to a structure that will contain information about the message
* queue.
*
* Returns : OS_NO_ERR The call was successful and the message was sent
* OS_ERR_EVENT_TYPE If you are attempting to obtain data from a non queue.
* OS_ERR_PEVENT_NULL If 'pevent' is a NULL pointer
獲取消息隊列狀態
描述:獲取消息隊列的信息
參數:pevent:指向事件控制塊結合目標隊列的指針
pdata:指向消息隊列包含信息的結構指針
返回:OS_NO_ERR 調用成功,消息成功發送
* OS_ERR_EVENT_TYPE 你想獲取非隊列的信息
* OS_ERR_PEVENT_NULL 如果 'pevent' 是一個NULL指針
*********************************************************************************************************
*/
#if OS_Q_QUERY_EN > 0
INT8U OSQQuery (OS_EVENT *pevent, OS_Q_DATA *pdata)
{
#if OS_CRITICAL_METHOD == 3 /* Allocate storage for CPU status register */
OS_CPU_SR cpu_sr;
#endif
OS_Q *pq;
INT8U *psrc;
INT8U *pdest;
#if OS_ARG_CHK_EN > 0
if (pevent == (OS_EVENT *)0) { /* Validate 'pevent' */
return (OS_ERR_PEVENT_NULL);
}//非法pevent
if (pevent->OSEventType != OS_EVENT_TYPE_Q) { /* Validate event block type */
return (OS_ERR_EVENT_TYPE);
}//保證沒有送空指針
#endif
OS_ENTER_CRITICAL();
//復制等待任務列表
pdata->OSEventGrp = pevent->OSEventGrp; /* Copy message queue wait list */
psrc = &pevent->OSEventTbl[0];
pdest = &pdata->OSEventTbl[0];
#if OS_EVENT_TBL_SIZE > 0//從0開始,慢慢復制吧。
*pdest++ = *psrc++;
#endif
#if OS_EVENT_TBL_SIZE > 1
*pdest++ = *psrc++;
#endif
#if OS_EVENT_TBL_SIZE > 2
*pdest++ = *psrc++;
#endif
#if OS_EVENT_TBL_SIZE > 3
*pdest++ = *psrc++;
#endif
#if OS_EVENT_TBL_SIZE > 4
*pdest++ = *psrc++;
#endif
#if OS_EVENT_TBL_SIZE > 5
*pdest++ = *psrc++;
#endif
#if OS_EVENT_TBL_SIZE > 6
*pdest++ = *psrc++;
#endif
#if OS_EVENT_TBL_SIZE > 7
*pdest = *psrc;
#endif
pq = (OS_Q *)pevent->OSEventPtr;
if (pq->OSQEntries > 0) {//如果有消息等待,則提取出(并沒有刪除)隊列中最早進入
//隊列的消息,并將其復制到OSMsg中,OSQQuery并沒有改動.OSQOut的指針。
pdata->OSMsg = *pq->OSQOut; /* Get next message to return if available */
} else {//如果沒有任務等待,則返回空指針
pdata->OSMsg = (void *)0;
}
pdata->OSNMsgs = pq->OSQEntries;//隊列中消息數
pdata->OSQSize = pq->OSQSize;//隊列容易大小
OS_EXIT_CRITICAL();
return (OS_NO_ERR);
}
#endif /* OS_Q_QUERY_EN */
/*$PAGE*/
/*
*********************************************************************************************************
* QUEUE MODULE INITIALIZATION
*
* Description : This function is called by uC/OS-II to initialize the message queue module. Your
* application MUST NOT call this function.
*
* Arguments : none
*
* Returns : none
*
* Note(s) : This function is INTERNAL to uC/OS-II and your application should not call it.
初始化消息隊列
描述:由ucos調用初始化消息隊列模型,應用程序不能調用
參數:無
返回:無
備注:由ucos調用初始化消息隊列模型,應用程序不能調用
*********************************************************************************************************
*/
void OS_QInit (void)
{
#if OS_MAX_QS == 1//如果只有一個隊列
OSQFreeList = &OSQTbl[0]; /* Only ONE queue! */
OSQFreeList->OSQPtr = (OS_Q *)0;//前趨為零指針
#endif
#if OS_MAX_QS >= 2
INT16U i;
OS_Q *pq1;
OS_Q *pq2;
pq1 = &OSQTbl[0];
pq2 = &OSQTbl[1];
for (i = 0; i < (OS_MAX_QS - 1); i++) { /* Init. list of free QUEUE control blocks */
//初始化空閑隊列控制塊,組成一個單向鏈表
pq1->OSQPtr = pq2;
pq1++;
pq2++;
}
pq1->OSQPtr = (OS_Q *)0;//后趨附指向NULL指針
OSQFreeList = &OSQTbl[0];//空鏈表指針指向首地址。
#endif
}
#endif /* OS_Q_EN */
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -