[请教]串口收发程序

发布于 2016-12-23 10:57:07 浏览：2605 订阅该版

编译时是没有问题的，但是调试的时候程序老是进不去，收发有问题。
```#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);
    }
 //   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
,++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(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
");
        return;
    }
				
    thread=rt_thread_create("devt",
                   usr_echo_thread_entry,RT_NULL,
                   1024,25,7);
		 if (thread != RT_NULL) 
		 rt_thread_startup(thread);
	 }```
下载附件 [echo.c](https://oss-club.rt-thread.org/uploads/9818_15f952c6531aee8eff9dd4355af17629.c)

5 个回答

IODO 2016-12-23

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

>```
>
>#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)
>{
>    struct rx_msg msg; 
>
>    rt_device_t device;//write_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);
>    }
>    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(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
>");
>        return;
>    }
>				
>    thread=rt_thread_create("devt",
>                   usr_echo_thread_entry,RT_NULL,
>                   1024,25,7);
>		 if (thread != RT_NULL) 
>		 rt_thread_startup(thread);
>	 }
>```

---

编译时是没有问题的，但是调试的时候程序老是进不去，收发有问题。