串口收发的例程，出现问题

发布于 2013-03-07 13:35:56 浏览：14621 订阅该版

我还是新手，照抄的RT-Thread 1.0文档第十章中的串口例程，但是运行以后，在控制台有输出：(mq != RT_NULL) assert failed at rt_mq_recv:2085

我看了下源代码，貌似rx_mq的确是没有初始化的。不知道要如何初始化？是否是这样：
rx_mq = rt_mq_create( "serial_mq", sizeof( struct rx_msg ), 50, RT_NULL );
我不知道rt_mq_create的最后一个参数flag是什么意义呢？
我暂时照上面的那句调用的rt_mq_create()，但是貌似这样随后的rt_mq_recv()从未返回过RT_EOK，即使我从PC上发送了一些东西过去。

代码如下：
```/* 
 * 程序清单：串口设备操作例程 
 * 
 * 在这个例程中，将启动一个devt线程，然后打开串口1和2 
 * 当串口1和2有输入时，将读取其中的输入数据然后写入到 
 * 串口1设备中。 
 * 
 */ 
#include <rtthread.h> 
 
/* UART接收消息结构*/ 
struct rx_msg 
{ 
  rt_device_t dev; 
  rt_size_t size; 
}; 
/* 用于接收消息的消息队列*/ 
static rt_mq_t rx_mq; 
/* 接收线程的接收缓冲区*/ 
static char uart_rx_buffer[64]; 
 
/* 数据到达回调函数*/ 
rt_err_t uart_input(rt_device_t dev, rt_size_t size) 
{ 
  struct rx_msg msg; 
  msg.dev = dev; 
  msg.size = size; 
 
  /* 发送消息到消息队列中*/ 
  rt_mq_send(rx_mq, &msg, sizeof(struct rx_msg)); 
 
  return RT_EOK; 
} 
 
void device_thread_entry(void* parameter) 
{ 
  struct rx_msg msg; 
  int count = 0; 
  rt_device_t device, write_device; 
  rt_err_t result = RT_EOK; 
 
  /* 查找系统中的串口1设备 */ 
  device = rt_device_find("uart1"); 
  if (device!= RT_NULL) 
  { 
    /* 设置回调函数及打开设备*/ 
    rt_device_set_rx_indicate(device, uart_input); 
    rt_device_open(device, RT_DEVICE_OFLAG_RDWR); 
  } 
  /* 设置写设备为uart1设备 */ 
  write_device = device; 
 
  /* 查找系统中的串口2设备 */ 
  device= rt_device_find("uart2"); 
  if (device_!= RT_NULL) 
  { 
    /* 设置回调函数及打开设备*/ 
    rt_device_set_rx_indicate(device, uart_input); 
    rt_device_open(device, RT_DEVICE_OFLAG_RDWR); 
  } 
 
  while (1) 
  { 
    /* 从消息队列中读取消息*/ 
    result = rt_mq_recv(rx_mq, &msg,  
      sizeof(struct rx_msg), 50); 
    if (result == -RT_ETIMEOUT) 
    { 
      /* 接收超时*/ 
      rt_kprintf("timeout count:%d
", ++count); 
    } 
 
    /* 成功收到消息*/ 
    if (result == RT_EOK) 
    { 
      rt_uint32_t rx_length; 
      rx_length = (sizeof(uart_rx_buffer) - 1) > 
msg.size ? msg.size : sizeof(uart_rx_buffer) - 1; 
 
      /* 读取消息*/ 
      rx_length = rt_device_read(msg.dev, 0, 
&uart_rx_buffer[0], rx_length); 
      uart_rx_buffer[rx_length] = '�'; 
 
      /* 写到写设备中*/ 
      if (write_device != RT_NULL) 
        rt_device_write(write_device, 0, 
&uart_rx_buffer[0], rx_length); 
    } 
  } 
} 
 
int rt_application_init() 
{ 
  /* 创建devt线程*/ 
  rt_thread_t thread = rt_thread_create("devt", 
    device_thread_entry, RT_NULL, 
    1024, 25, 7); 
  /* 创建成功则启动线程*/ 
  if (thread_!= RT_NULL) 
    rt_thread_startup(&thread); 
} ```
![无标题.png](https://oss-club.rt-thread.org/uploads/5500_4149f9860e45ccc7faa4d23600817158.png)