两个串口都用到各自的消息队列接受解析数据，其中一个一直显示发送消息队列满

发布于 2021-03-01 11:17:54 浏览：1319 订阅该版

1 个回答

等风来 2021-03-01

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

#include <rtthread.h>
#include <rtdevice.h>
#include <board.h>
#include <drv_log.h>
#include <stdio.h>
#include <string.h>

#define GPS_UART "uart3"
typedef struct {
    char buf[128];
    unsigned short sta;
}uart_rcv_typedef;

uart_rcv_typedef GPS_ur;

static rt_thread_t GPS_rcv_thread = RT_NULL, GPS_parse_thread = RT_NULL;
static rt_device_t GPS_DEV_UART;

static struct rt_messagequeue GPS_mq;
/* 消息队列中用到的放置消息的内存池*/
static rt_uint8_t GPS_msg_pool[1024];

static struct rt_semaphore GPS_rx_sem;

static void GPS_rcv_thread_entry(void* parameter); 
static void GPS_parse_thread_entry(void* parameter);

//static char Task_Uart0_Rx =0;
//			             
//static char Rx0_Buffer[30];			              
//static char Rx0_Process_Buffer[30];	         
//static char Rx0_Ptr; 	 		               	       
//    			   	             
//static char Rx0_Step=0;							                  
				                 
//static char Parse_DATA(unsigned char ch);
static rt_err_t GPS_uart_input(rt_device_t dev, rt_size_t size)
{
    rt_sem_release(&GPS_rx_sem);

return RT_EOK;
}
//主函数

int GPS_thread_start(void)
{  
	  struct serial_configure config = RT_SERIAL_CONFIG_DEFAULT;  /* 初始化配置参数 */

char str[] = "version\r\n";
    rt_sem_init(&GPS_rx_sem, "GPS_rx_sem", 0, RT_IPC_FLAG_FIFO);
    rt_err_t ret=rt_mq_init(&GPS_mq,"mqt",&GPS_msg_pool[0], 1024,sizeof(GPS_msg_pool),RT_IPC_FLAG_FIFO);/* 内存池指向GPS_msg_pool */
    if( ret==RT_EOK)
			 rt_kprintf("%s GPS_mq init sucessed\n");
    GPS_DEV_UART = rt_device_find(GPS_UART);

rt_kprintf("%s listen on\n",GPS_UART);
	  config.baud_rate = BAUD_RATE_115200;        //修改波特率为 921600

rt_device_control( GPS_DEV_UART, RT_DEVICE_CTRL_CONFIG, &config);
//    rt_device_open(GPS_DEV_UART , RT_DEVICE_OFLAG_RDWR | RT_DEVICE_FLAG_INT_RX );
    rt_device_open(GPS_DEV_UART , RT_DEVICE_OFLAG_RDWR | RT_DEVICE_FLAG_DMA_RX );

rt_device_set_rx_indicate(GPS_DEV_UART , GPS_uart_input);
    rt_device_write(GPS_DEV_UART, 0, str, (sizeof(str) - 1));
    GPS_rcv_thread =                        
    rt_thread_create( "listen_uart3",             
                      GPS_rcv_thread_entry,   
                      RT_NULL,            
                      512,                 
                      10,                  
                      20);

if (GPS_rcv_thread != RT_NULL)
        rt_thread_startup(GPS_rcv_thread);
    else
        return -1;

GPS_parse_thread =                        
    rt_thread_create( "parse_data",             
                      GPS_parse_thread_entry,   
                      RT_NULL,            
                      2048,                 
                      10,                  
                      20);

if (GPS_parse_thread != RT_NULL)
        rt_thread_startup(GPS_parse_thread);
    else
        return -1;
    return RT_EOK;
}

//线程函数

static void GPS_rcv_thread_entry(void* parameter)
{

unsigned char ch;
   rt_err_t ret=-RT_ERROR;
    while (1)
    {
        while (rt_device_read(GPS_DEV_UART , -1, &ch, 1) != 1)
        {
         
					rt_sem_take(&GPS_rx_sem, RT_WAITING_FOREVER);
					rt_kprintf("reget:%s\r\n",GPS_ur.buf);
					
        }
				
            GPS_ur.buf[GPS_ur.sta++] = ch;

if(ch == '\n')
            {
							  rt_kprintf("realized \r\n");
							  rt_kprintf("%s", GPS_ur.buf);
                GPS_ur.buf[GPS_ur.sta] = '\0';
                ret=rt_mq_send(&GPS_mq, &GPS_ur.buf, GPS_ur.sta);
							  if( ret==RT_EOK)
									rt_kprintf("rt_mq_send SUCEEDE \r\n");
								else if(ret==-RT_EFULL)
									rt_kprintf("rt_mq_send FULL \r\n");
								else if(ret==-RT_ERROR)
									rt_kprintf("rt_mq_send ERROR \r\n");								
                memset(&GPS_ur,0,sizeof(uart_rcv_typedef));
            }
          rt_thread_mdelay(10);
    }

}

static void GPS_parse_thread_entry(void* parameter)
{
    char tmp[128];
    while(1)
    {
        if (rt_mq_recv(&GPS_mq, &tmp, sizeof(tmp), RT_WAITING_FOREVER) == RT_EOK)
        {

rt_kprintf("get:%s",tmp);
			
        }
          rt_thread_mdelay(10);
    }
}

INIT_APP_EXPORT(GPS_thread_start);1. 这里是列表文本