chos
/
crtos
forked from xuos/xiuos
0
0
Fork 3
Code Issues Pull Requests Packages Projects Releases Wiki Activity

消息队列接收与紧急发送代码修改 #1

Merged
smileyk merged 1 commits from msg_que_modifications into master 2026-04-03 17:32:46 +08:00
Conversation 0 Commits 1 Files Changed 1 +2 -2
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
Ubiquitous/XiZi_IIoT_Macro/kernel/thread/msgqueue.c
View File

@ -180,7 +180,7 @@ static x_err_t _MsgQueueUrgentSend(struct MsgQueue *mq, const void *buffer, x_si
if (mq->index < 0)
mq->index += mq->max_msgs;
msg = mq->msg_buf + ( ( mq->index + mq->num_msgs ) % mq->max_msgs ) * mq->each_len ;
msg = mq->msg_buf + (mq->index % mq->max_msgs) * mq->each_len;
memcpy(msg , buffer, size);
mq->num_msgs ++;
if (!IsDoubleLinkListEmpty(&mq->send_pend_list)) {
@ -214,7 +214,7 @@ static x_err_t _MsgQueueRecv(struct MsgQueue* mq,
timeout = CalculateTickFromTimeMs(msec);
lock = CriticalAreaLock();
if (mq->index == 0 && timeout == 0) {
if (timeout == 0 && mq->num_msgs <= 0) {
CriticalAreaUnLock(lock);
return -ETIMEOUT;
}