5 RT-thread 串口DMA接收丢数据

发布于 2020-11-27 17:03:47 浏览：3251 订阅该版

[tocm]

# 问题描述
+ 1.DMA接收数据的时候丢数据了，数据偶尔被拆掉了
+ 2.例如我一个包大概是28个字节，然后会被串口的接收回调认为是两条消息，一条是1Byte，一条是27Byte。然后有时候比如说两个数据包，会被拆成3个消息。第一个消息是第一个包的第一个字节（1Byte），第二个消息是第一个包后边的27Byte和第二个包的第一个Byte，第三个消息是第二个包后边的27Byte。这样导致两个包直接废掉了。

# 实验方法
+ 1.使用RT-thread的串口例程，使能串口模式为DMA_TX和DMA_RX,开启接收回调。（使用了消息队列）。
+ 2.轮询不等待的形式检测消息队列的消息
+ 3.具体相关的部分代码
```c
void HAL_UART_RxCpltCallback(UART_HandleTypeDef *huart)
{
    struct stm32_uart *uart;
    RT_ASSERT(huart != NULL);
    uart = (struct stm32_uart *)huart;
//    dma_isr(&uart->serial);    //注释了
}

/**
  * @brief  Rx Half transfer completed callback
  * @param  huart: UART handle
  * @note   This example shows a simple way to report end of DMA Rx Half transfer, 
  *         and you can add your own implementation.
  * @retval None
  */
void HAL_UART_RxHalfCpltCallback(UART_HandleTypeDef *huart)
{
    struct stm32_uart *uart;
    RT_ASSERT(huart != NULL);
    uart = (struct stm32_uart *)huart;
//    dma_isr(&uart->serial);    //注释了
}
```

```c
/* 接收数据回调函数 */
static rt_err_t uart3_input(rt_device_t dev, rt_size_t size)
{
	//static int recv_tick=0;
    struct rx_msg msg;
    rt_err_t result;
    msg.dev = dev;
    msg.size = size;
//	uint32_t ttt = (HAL_GetTick()/((uint32_t)HAL_GetTickFreq()));
//	SEGGER_RTT_printf(0,"(U3)tttz:%d!\n",ttt);					
    result = rt_mq_send(&rx_u3mq, &msg, sizeof(msg));			//	如果数据包断掉了，两个消息队列之间的间隔是大约大于1ms
    if ( result == -RT_EFULL)	
    {
        /* 消息队列满 */
        rt_kprintf("message U3 queue full！\n");
    }
    return result;
}

/* 从硬件中读取数据 */
static rt_uint16_t uart_read (struct rt_messagequeue *tp_rxMq_obj,unsigned char *tp_rx_buf)
{
	rt_uint16_t rec_len;
	rt_uint16_t pkg_all_len = 0;
	struct rx_msg msg;
	rt_err_t result;
	rt_uint8_t timeout = 0;
	rt_memset ( &msg, 0, sizeof ( msg ) );
	result = rt_mq_recv ( tp_rxMq_obj, &msg, sizeof ( msg ), RT_WAITING_NO );
	if ( result == RT_EOK )
	{
		//	记录上一个消息包的长度
		pkg_all_len = msg.size;																//	也有可能多个包被中断回调处理成一个包
		if(pkg_all_len <= 1)
		{
			SEGGER_RTT_printf(0,"(b)msg.size:%d!\n",msg.size);
			timeout = 13;				//	1.3ms稍微正常
			while ( timeout ) //接收不定长数据
			{
				timeout--;
				rt_hw_us_delay ( 100 ); 	
			//			ttt = (HAL_GetTick()/((uint32_t)HAL_GetTickFreq()));
				//SEGGER_RTT_printf(0,"(U3)rx_length:%d!\n",rx_length);
				
				result = rt_mq_recv ( tp_rxMq_obj, &msg, sizeof ( msg ), RT_WAITING_NO );		//	一般一条数据有可能会被拆成两条指令，1和27，可以增加判断如果等于长度等于28的时候可以直接截断命令，节省时间。
				if ( result == RT_EOK )	//	接收成功
				{
					result = -RT_ERROR;
					SEGGER_RTT_printf(0,"(l)msg.size:%d!\n",msg.size);
					//pkg_all_len = pkg_all_len + msg.size;	//	补上后面的数据
					pkg_all_len = msg.size;	//	补上后面的数据
					SEGGER_RTT_printf(0,"(l)pkg_all_len:%d!\n",pkg_all_len);
					break;
				}
			}
		}
		
		/* 从串口读取数据*/
		rec_len = rt_device_read ( msg.dev, 0, tp_rx_buf, pkg_all_len );	//	如果需要读取的数值大于缓冲区实际的数值，那么返回的值则是缓冲区内容实际的值
		
		SEGGER_RTT_printf(0,"(l)rec_len:%d!\n",rec_len);
		SEGGER_RTT_printf(0,"Read_Data:%\n");
		for(uint8_t l_i = 0;l_i < rec_len;l_i++) SEGGER_RTT_printf(0,"%02X ",tp_rx_buf[l_i]);
		SEGGER_RTT_printf(0,"\r\n");
	}
	else
	{
		rec_len = 0;
	}
	return rec_len;
}
```