5 串口DMA消息队列接收数据，消息队列接收不到

发布于 2021-03-22 11:15:23 浏览：2267 订阅该版

安装RT-Thread官方文档写串口DMA接收数据。
上位机向串口发送数据时，可以进入串口接收回调函数，发送数据到消息队列。但是在线程中接收消息队列一直接收不到（使用RT_WAITING_FOREVER一直等待就会一直卡死）。好像是串口接收数据格式的原因，官方文档是建立一个结构体储存串口数据结构，将这个结构体发送到消息队列，我将这个结构体变换成一个字符发送消息队列就可以接收到。请问这是什么原因呢？
```
#include <rtthread.h>

#define DBG_TAG "main"
#define DBG_LVL DBG_LOG
#include <rtdbg.h>

extern void XIAOXI_test(void);
int main(void)
{
    int count = 1;
    XIAOXI_test();
    while (count++)
    {
//        LOG_D("Hello RT-Thread!");
        rt_thread_mdelay(1000);
    }

return RT_EOK;
}

static struct rt_messagequeue mq;
static rt_uint8_t msg_pool[2048];
#define SAMPLE_UART_NAME       "uart2"    /* 串口设备名称 */
static rt_device_t serial;                /* 串口设备句柄 */

struct rx_msg
{
    rt_device_t dev;
    rt_size_t size;
};

static rt_err_t uart_input(rt_device_t dev, rt_size_t size)
{

struct rx_msg msg;
    rt_err_t result;
    msg.dev = dev;
    msg.size = size;

rt_mq_send(&mq, &msg, sizeof(msg));

return result;
}

void my_xiaoxi1_entry(void *parameter)
{
    char str[]={"my_xiaoxi1_entry uart success\n"};
    serial = rt_device_find(SAMPLE_UART_NAME);
    rt_device_open(serial, RT_DEVICE_FLAG_DMA_RX);
    rt_device_set_rx_indicate(serial, uart_input);

struct rx_msg msg;
    rt_err_t result;
    rt_uint32_t rx_length;
    static char rx_buffer[RT_SERIAL_RB_BUFSZ + 1];
    while(1)
    {

rt_memset(&msg, 0, sizeof(msg));
        result=rt_mq_recv(&mq, &msg, sizeof(msg), RT_WAITING_FOREVER);
        if (result == RT_EOK)
        {
            rx_length = rt_device_read(msg.dev, 0, rx_buffer, msg.size);
            rx_buffer[rx_length] = '\0';
            rt_device_write(serial, 0, rx_buffer, rx_length);
            rt_kprintf("%s\n",rx_buffer);
        }
        rt_device_write(serial, 0, str, (sizeof(str) - 1));
        rt_thread_mdelay(5);
    }
}

void my_xiaoxi2_entry(void *parameter)
{
    while(1)
    {
        LOG_D("Hello RT-Thread!");
        rt_thread_mdelay(1000);
    }
}

void XIAOXI_test(void)
{
    rt_err_t result;
    result = rt_mq_init(&mq,
                        "mqt",
                        &msg_pool[0],             /* 内存池指向 msg_pool */
                        1,                          /* 每个消息的大小是 1 字节 */
                        sizeof(msg_pool),        /* 内存池的大小是 msg_pool 的大小 */
                        RT_IPC_FLAG_FIFO);       /* 如果有多个线程等待，按照先来先得到的方法分配消息 */

if (result == RT_EOK)
    {
        rt_kprintf("*************************************.\n");
//        return -1;
    }

rt_thread_t tid1;
    tid1 = rt_thread_create("XIAOXI1",
                        my_xiaoxi1_entry, RT_NULL,
                        1024,
                        8, 10);

if (tid1 != RT_NULL)
        rt_thread_startup(tid1);

rt_thread_t tid2;
    tid2 = rt_thread_create("XIAOXI2",
                        my_xiaoxi2_entry, RT_NULL,
                        1024,
                        20, 10);

if (tid2 != RT_NULL)
        rt_thread_startup(tid2);

}

```
使用了两个串口，控制台使用串口1，数据发送接收使用的串口2。