手册第6章串口驱动的例子是否缺少了rx_mq的初始化

发布于 2015-12-19 23:42:44 浏览：2104 订阅该版

手册rtthread_manual.zh中第6章，关于串口驱动使用的代码如下（第6章最后），
```/*
 * 程序清单：串口设备操作例程
 *
 * 在这个例程中，将启动一个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|RT_DEVICE_FLAG_INT_RX);
	}
	/* 设置写设备为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);
}```
其中并没有rt_mq_create函数，
另外
```	/* 查找系统中的串口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);
	}```

uart2的rt_device_open函数没有用RT_DEVICE_FLAG_INT_RX参数，那么uart2就不会开启中断，回调函数uart_input就不会被调用，rx_mq也不会有数据，rt_mq_recv返回值不会是RT_EOK，所以也就不会调用rt_device_read函数，那么uart2接收的数据就不会被读取，不知道我分析的对不对？
是手册少了RT_DEVICE_FLAG_INT_RX参数还是其实可以正常运行？

我的理解是这个例子的作用是把uart1和uart2的输入都输出到uart1中，不知道是不是这样的？