STM32 loopback structure receives and processes serial port data

Use stm32 Connect a data acquisition terminal through serial port , Send an instruction to the terminal , The serial port will return non quantitative data ,

Just started to use the serial port to receive interrupts to process data , It is found that the processing speed is slow , Frame loss occurs .

Then it is changed into a loopback structure to receive data .

typedef struct 
{
    short write_point;// The write pointer
    u8 Reader_RX_Buffer_Second[4096];// Storage space
    short read_point;// Read pointer
    u8 loop;// If the writing pointer reaches the end , Start writing again to indicate

}READER_UART_REC_STRUCT_T;

Serial port receiving method ：

void DEBUG_Reader_IRQHandler(void)
{

    u8_t res;        
    if(USART_GetITStatus(DEBUG_Reader, USART_IT_RXNE) != RESET)// Data received
    {         
        res =USART_ReceiveData(DEBUG_Reader);//; Read received data USART2->DR
        
       
                if(reader_uart_rec_t.loop<1 && reader_uart_rec_t.write_point>=reader_uart_rec_t.read_point)
                {
                        reader_uart_rec_t.Reader_RX_Buffer_Second[reader_uart_rec_t.write_point++] = res;
                        if(reader_uart_rec_t.write_point == 4095)
                        {
                            reader_uart_rec_t.write_point = 0;
                            reader_uart_rec_t.loop = 1;
                        
                        }
                
                }else if(reader_uart_rec_t.write_point<reader_uart_rec_t.read_point)
                {
                
                        reader_uart_rec_t.Reader_RX_Buffer_Second[reader_uart_rec_t.write_point++] = res;
                }

        USART_ClearITPendingBit(DEBUG_Reader, USART_IT_RXNE);
    
    }                                       
}    

 

Data analysis method ：

main()

{

// The minimum data length of my protocol is 6   

     if(reader_uart_rec_t.write_point>(reader_uart_rec_t.read_point+5)  || reader_uart_rec_t.loop>0)
        {
     // Data processing method
                 AnalyData(&reader_uart_rec_t);
        }

}

typedef struct 
{
    u8 head;    
    u8 len;    
    u8 address;    
    u8 cmd; 

}RECEIVE_EPC_DATA_HEAD_T;

void AnalyData(READER_UART_REC_STRUCT_T* reader_uart_rec)
{

       RECEIVE_DATA_HEAD_T  head;
    if(reader_uart_rec->loop == 1)
    {
        len = 4095+reader_uart_rec->write_point - reader_uart_rec->read_point;
    }else
    {
        len = reader_uart_rec->write_point - reader_uart_rec->read_point;
         
    }
        while(len>0)
        {
                        len--;
                        if(reader_uart_rec->read_point >= 4096)
                            {
                                reader_uart_rec->read_point = 0;
                                reader_uart_rec->loop = 0;
                            
                            }

//0xA0 Is the protocol header     Loop through headers , If the header is wrong, move the pointer , If it is correct, the identifier does not conform to the protocol header , And then process the data
                        if(reader_uart_rec->Reader_RX_Buffer_Second[reader_uart_rec->read_point] == 0xA0)
                        {
                                
                                memcpy(&head,&reader_uart_rec->Reader_RX_Buffer_Second[reader_uart_rec->read_point],sizeof(RECEIVE_DATA_HEAD_T));
                            
                                switch(head.cmd)
                                {

                                    case 0x1:
                                           // Processing data
                                            if((reader_uart_rec->read_point+ head.len+2)>4095)
                                            {
                                                    reader_uart_rec->read_point = reader_uart_rec->read_point+ head.len+2-4095;
                                                    reader_uart_rec->loop = 0;
                                            }else
                                            {
                                                    reader_uart_rec->read_point = reader_uart_rec->read_point+ head.len+2;
                                            }
                                     
                                            len = len - head.len-1;
                                            break;

                                   
                                    default:
                                        
                                            reader_uart_rec->read_point++;// If the agreement is not within the scope of processing , It may be wrong data or frame loss , be read The subscript backwards
                                            break;
                                }
                        }else
                        {
                        // If the data does not conform to the Baotou read Move the subscript back and continue to find the header
                            reader_uart_rec->read_point++;
                        
                        }
            }
        
            
        }