69 lines
2.2 KiB
C
69 lines
2.2 KiB
C
/**
|
||
******************************************************************************
|
||
* @file User\Os\os_queue.c
|
||
* @author 路淮
|
||
* @version v0.1
|
||
* @date 2026-05-21
|
||
* @brief 队列管理
|
||
******************************************************************************
|
||
*/
|
||
|
||
/* Includes -------------------------------------------------------------------*/
|
||
#include "os_queue.h"
|
||
#include "task_udp.h"
|
||
|
||
/*-内核对象句柄-队列-*/
|
||
QueueHandle_t Air724_Message_Queue = NULL; /* 4G数据接收队列 */
|
||
QueueHandle_t RS485_Message_Queue = NULL; /* RS485数据接收队列 */
|
||
QueueHandle_t UDP_Message_Queue = NULL; /* UDP数据接收队列 */
|
||
|
||
/* code --------------------------------------------------------------------------------------------------------*/
|
||
/**
|
||
* @brief Air724_Message_Queue_Init：4G数据接收队列初始化
|
||
* @note 初始化4G数据接收队列，队列大小为20，每个元素大小为UART1_RX_BUFFER_SIZE
|
||
* @param none
|
||
* @retval none
|
||
*/
|
||
void Air724_Message_Queue_Init(void)
|
||
{
|
||
Air724_Message_Queue = xQueueCreate(20, UART1_RX_BUFFER_SIZE);
|
||
if (Air724_Message_Queue == NULL)
|
||
{
|
||
printf("Air724_Message_Queue_Init Failed\r\n");
|
||
// 创建失败处理
|
||
Error_Handler();
|
||
}
|
||
}
|
||
/**
|
||
* @brief RS485_Message_Queue_Init：RS485数据接收队列初始化
|
||
* @note 初始化RS485数据接收队列，队列大小为5，每个元素大小为UART3_RX_BUFFER_SIZE
|
||
* @param none
|
||
* @retval none
|
||
*/
|
||
void RS485_Message_Queue_Init(void)
|
||
{
|
||
RS485_Message_Queue = xQueueCreate(5, UART3_RX_BUFFER_SIZE);
|
||
if (RS485_Message_Queue == NULL)
|
||
{
|
||
// 创建失败处理
|
||
printf("RS485_Message_Queue_Init error\r\n");
|
||
Error_Handler();
|
||
}
|
||
}
|
||
/**
|
||
* @brief UDP_Message_Queue_Init：UDP数据接收队列初始化
|
||
* @note 初始化UDP数据接收队列，队列大小为20，每个元素大小为UdpMsg_t
|
||
* @param none
|
||
* @retval none
|
||
*/
|
||
void UDP_Message_Queue_Init(void)
|
||
{
|
||
UDP_Message_Queue = xQueueCreate(20, sizeof(UdpMsg_t));
|
||
if (UDP_Message_Queue == NULL)
|
||
{
|
||
// 创建失败处理
|
||
printf("UDP_Message_Queue_Init Failed\r\n");
|
||
Error_Handler();
|
||
}
|
||
}
|