【LiteOS】LiteOS消息队列-实战
2024-09-05 03:02:53
前言
链接
参考
- 上面链接
笔录草稿
- 最近工作有点忙，远吗阅读推迟了哈哈
- 采用传地址方式
- 其实这些组件的应用是很简单的，没太在意，很快就搭建好看见，准备测试并看源码，
- 但是，今天下午却花了两小时，仅仅为了测试非拷贝方式通信失败问题
- bug就是我在函数里创建一个局部存放消息内容的缓冲区，采用函数
LOS_QueueWrite发送出去 - 接收时却出现各种问题，很明显就是地址错误，但是我一丢丢都没想起消息内容被改写的注意点，唉
- 采用地址方式时，必须保该地址内容没有被修改，且不推荐使用局部变量
- 采用地址方式时，必须保该地址内容没有被修改，且不推荐使用局部变量
- 采用地址方式时，必须保该地址内容没有被修改，且不推荐使用局部变量
创建测试任务
- 本任务用于 LiteOS 消息队列测试
- 步骤
- 创建任务相关值及函数
- 在
LssAppConfig.h中添加- 任务优先级宏
lssConfigvMsgQueueTaskPRIO (5) - 任务堆栈宏
lssConfigvMsgQueueTaskSIZE 512u - 任务初始化完成枚举
evMsgQueueTaskNum = 0x0D, - 消息队列外部句柄
extern UINT32 MsgQueueTask_Handle;
- 任务优先级宏
- 在
main.c中添加- 添加任务头文件
#include "MsgQueueAppTask.h" - 添加句柄
- 任务句柄
UINT32 MsgQueueTask_Handle = NULL; - 消息队列测试句柄
UINT32 TestAQue_Handle = NULL; - 创建消息队列任务函数
- 在启动任务中
- 添加
uwRet = Creat_vMsgQueue_Task();，以表示创建该任务 - 添加
uwRet = LOS_QueueCreate("Msg Queue", 20, &TestAQue_Handle, 0, 10);, 以表示创建消息
- 添加
- 任务句柄
- 添加任务头文件
- 在
- 创建任务文件
MsgQueueTask.c和MsgQueueTask.h- 主要用于消息队列的业务测试
- 编写任务函数
void vMsgQueueTask( void ) - 消息队列测试任务源文件
- 消息队列测试任务头文件
- 在
IPCApp.c文件中添加两个测试函数(框架需要) - 在
IPCCoreTask.c文件中void msgDecode(msgIpc_t * msg)函数中添加两条处理命令(框架需要)$QA#$QB#- 命令处理添加部分源码
- 创建任务相关值及函数
部分源码
- 创建消息队列任务函数
/**
* @brief 创建vMsgQueueTask任务
* @param
* @retval
* @author lzm
*/
static UINT32 Creat_vMsgQueue_Task()
{
//定义一个创建任务的返回类型，初始化为创建成功的返回值
UINT32 uwRet = LOS_OK;
TSK_INIT_PARAM_S task_init_param;
task_init_param.usTaskPrio = lssConfigvMsgQueueTaskPRIO;
task_init_param.pcName = "MsgQueue Task";
task_init_param.pfnTaskEntry = (TSK_ENTRY_FUNC)vMsgQueueTask;
task_init_param.uwStackSize = lssConfigvMsgQueueTaskSIZE;
uwRet = LOS_TaskCreate(&MsgQueueTask_Handle, &task_init_param);
return uwRet;
}
- 消息队列测试任务源文件
/**
******************************************************************************
* @file MsgQueueTask.c
* @author lzm
* @version V1.0
* @date 2020-10-28
* @brief
* @attention
*
* 实验平台:LZM
*
*
*
******************************************************************************
*/
#include "MsgQueueTask.h"
#include "bsp_usart.h"
/*
*********************************************************************************************************
* FUNCTION
*********************************************************************************************************
*/
/**
* @brief 该任务的软硬件配置初始化
* @param
* @retval
* @author lzm
*/
static void msgQueueInit(void)
{
;
}
/**
* @brief 任务函数
* @param
* @retval
* @author lzm
*/
void vMsgQueueTask( void )
{
UINT32 uwRet = LOS_OK;
UINT32 msgLen = 30;
// 接收消息
UINT32 uwReadbuf;
msgQueueInit();
WaitAllTaskInitOk(evMsgQueueTaskNum); // 系统就绪检测及等待
while(1)
{
/* 等待消息 */
uwRet = LOS_QueueRead(TestAQue_Handle, // 消息队列 ID
&uwReadbuf, // 保存消息的位置
msgLen, // 接收消息的长度
LOS_WAIT_FOREVER); // 等待 - 一直等
if(uwRet != LOS_OK)
{
dbgPrintf("read message failure,error:%x\n",uwRet);
}
else
{
dbgPrintf("\r\nLOS_QueueRead is [%s]!",(char *)uwReadbuf);
}
}
}
- 消息队列测试任务头文件
/**
******************************************************************************
* @file MsgQueueTask.h
* @author lzm
* @version V1.0
* @date 2020-10-28
* @brief
* @attention
*
* 实验平台:LZM
*
******************************************************************************
*/
#ifndef __MSG_QUEUE_TASK_H_
#define __MSG_QUEUE_TASK_H_
#include "LssAppConfig.h"
#include "ipcConfig.h"
/*
*********************************************************************************************************
* API
*********************************************************************************************************
*/
/* function */
void vMsgQueueTask( void );
#endif
- 队列测试函数A
/**
* @brief
* 命令 [$QA#] 的回调函数。
* 消息队列测试 A
* @param
* @retval
* @author lzm
*/
void IPCAppMsgQueueA(msgIpc_t *msg)
{
static UINT32 i = 0;
static CHAR ABuf[] = "Test is message x";
UINT32 msgLen = sizeof(ABuf);
LOS_QueueWrite( TestAQue_Handle, /* 消息队列的句柄 */
ABuf, /* 发送的消息内容 发送字符串的地址*/
msgLen,
0); /* 消息大小 */
}
- 队列测试函数B
/**
* @brief
* 命令 [$QB#] 的回调函数。
* 消息队列测试 B
* @param
* @retval
* @author lzm
*/
void IPCAppMsgQueueB(msgIpc_t *msg)
{
static UINT32 i = 0;
static CHAR BBuf[] = "Test is message n";
UINT32 msgLen = sizeof(BBuf);
LOS_QueueWrite( TestAQue_Handle, /* 消息队列的句柄 */
BBuf, /* 发送的消息内容 发送字符串的地址*/
msgLen,
0); /* 消息大小 */
}
- 命令处理添加部分源码
...
else if(msg->data[msg->index + 1] == 'Q')
{
if(msg->data[msg->index + 2] == 'A')
{
MALLOC_REGISTER_INSTEREND_CBFUN_LIST(cmd, cmdItem, 2, msg, callbackFunctionList, xCBFunListSem_Handle, IPCAppMsgQueueA);
// ¸æÖªÖ´ÐÐÈÎÎñ
uwRet = LOS_SemPost(ListApp_Handle);
if (uwRet != LOS_OK){;}
}
else if(msg->data[msg->index + 2] == 'B')
{
MALLOC_REGISTER_INSTEREND_CBFUN_LIST(cmd, cmdItem, 3, msg, callbackFunctionList, xCBFunListSem_Handle, IPCAppMsgQueueB);
// ¸æÖªÖ´ÐÐÈÎÎñ
uwRet = LOS_SemPost(ListApp_Handle);
if (uwRet != LOS_OK){;}
}
}
...
最新文章
- Linux实战教学笔记04:Linux命令基础
- saltstack-部署
- c#变量缺少using引用，如何快速加上using，加Using的快捷键[bubuko.com]
- Eclipse+Mingw+Boost 环境搭建
- C语言的数据类型及其对应变量
- mySql常用sql
- 关于XML的DTD概述
- web开发工具IDE
- Android之使用MediaMetadataRetriever类获取媒体信息
- Hibernate学习（一）创建数据表
- loss函数和cost函数
- redis最全配置讲解
- Learning Structured Representation for Text Classification via Reinforcement Learning 学习笔记
- The Mathematics of the Rubik’s Cube
- 使用virsh管理KVM虚拟化主机
- c#多线程 Invoke方法的使用
- Java对象的强、软、弱和虚引用+ReferenceQueue
- 第三周vim入门学习1
- mysql-blog
- http 错误代码解释 && nginx 自定义错误【转】