串口程序调试中遇到的问题

发布于 2016-12-23 15:33:21 浏览：2198 订阅该版

程序能够跳到 thread=rt_thread_create("devt",
                   usr_echo_thread_entry,RT_NULL,
                   1024,25,7);
但是无法进入void usr_echo_thread_entry(void* parameter)

[Code=c][/Code]
#include <board.h>
#include <rtthread.h>
#include "gpio.h"
#include "echo.h"

struct rx_msg
{
    rt_device_t dev;
    rt_size_t size;
};
static struct rt_messagequeue rx_mq;
static char uart_rx_buffer[64];
static char msg_pool[2048];

//串口侦听回调函数
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 usr_echo_thread_entry(void* parameter)
{
  //  int count=0;
    struct rx_msg msg;

rt_device_t device;//write_device;
    rt_err_t result=RT_EOK;
   //GPIO_Configuration();
    
    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);
        //rt_device_open(device,RT_DEVICE_OFLAG_RDWR);
    }
 //   write_device=device;
    while(1)
    {
			//从消息队列中读取消息
        result=rt_mq_recv(&rx_mq,&msg,sizeof(struct rx_msg),50);
        if(result==-RT_ETIMEOUT)
        {
           //rt_kprintf("timeout count:%d<br>,++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]='\0';
//写到写设备中
   //         if(write_device!=RT_NULL)
						rt_device_write(device,0,&uart_rx_buffer[0],rx_length);
               // rt_device_write(write_device,0,&uart_rx_buffer[0],rx_length);
        } 
    }
}

void usr_echo_init(void)
{
		 rt_thread_t thread;
		 rt_err_t result;
	//创建消息队列，分配队列存储空间
		result= rt_mq_init(&rx_mq,
                    "mqt",
                   &msg_pool[0],
                   128 - sizeof (void*),
                   sizeof(msg_pool),
                    RT_IPC_FLAG_FIFO);
		if(result!=RT_EOK)
    {
        rt_kprintf("init message falied<br>");
        return;
    }
				
    thread=rt_thread_create("devt",
                   usr_echo_thread_entry,RT_NULL,
                   1024,25,7);
		 if (thread != RT_NULL) 
		 rt_thread_startup(thread);
	 }

3 个回答

IODO 2016-12-26

这家伙很懒，什么也没写！

因为程序中同时使用了小灯闪烁和串口程序，但是没有合理的处理两者之间的关系。现在暂时也没有弄明白应该怎么处理，但是把小灯的程序屏蔽掉之后，串口就能实现正常的收发。和论坛2013年的帖子相比，我稍微改动了一下，参照的是网上下载的一个PDF。在 rt_application_init()中加入初始化代码void usr_echo_init(void)

```

struct rx_msg
{
    rt_device_t dev;
    rt_size_t size;
};
static struct rt_messagequeue rx_mq;
static char uart_rx_buffer[64];
static char msg_pool[2048];

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;
}
static void usr_echo_thread_entry(void* parameter)
{
 
    struct rx_msg msg; 
    rt_device_t device;
    rt_err_t result=RT_EOK;
    
    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);
    }
    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(device != RT_NULL)
						rt_device_write(device,0,&uart_rx_buffer[0],rx_length);
        } 
    }
}
void usr_echo_init(void)
{
		 rt_thread_t thread;
		 rt_err_t result;
		result= rt_mq_init(&rx_mq,
                    "mqt",
                   &msg_pool[0],
                   128 - sizeof (void*),
                   sizeof(msg_pool),
                    RT_IPC_FLAG_FIFO);
		if(result!=RT_EOK)
    {
        rt_kprintf("init message falied
");
        return;
    }
			
    thread=rt_thread_create("devt",
                   usr_echo_thread_entry,RT_NULL,
                   1024,25,7);
		 if (thread != RT_NULL) 
		 rt_thread_startup(thread);
}

```