用戶(hù)接口部分處理
/*串口數(shù)據(jù)接收處理結(jié)構(gòu)*/
struct rcv_deal_pro_st
{
char rcv_buff[1024];
int total_len;
int port;
void *result;
int (*resolve_pro_func)(unsigned char *, int, void *);
int (*deal_pro_func)(int, void *);
};
用戶(hù)接口實(shí)現(xiàn)細(xì)節(jié)
/*
*函數(shù)功能：?jiǎn)?dòng)串口數(shù)據(jù)發(fā)送功能
* des：要寫(xiě)入?yún)?shù)的地址
* len：要寫(xiě)入?yún)?shù)的長(zhǎng)度
* port：要寫(xiě)入的串口號(hào)
* 返回值：實(shí)際寫(xiě)入的數(shù)據(jù)長(zhǎng)度，這個(gè)參數(shù)有點(diǎn)雞肋啊。。。
*/
int write_serial(unsigned char *des,int len,int port)
{
int i,temp_len=0;
SERIAL_STR *serial_snd = &serial_snd_g[port -1];
if(serial_snd!=0)
{
for(i=0;i
*serial_snd->write_pointer = des[temp_len++];
serial_snd->write_pointer++;
if((serial_snd->write_pointer-serial_snd->datas_buffer)>MAX_REC_SIZE-1)
{
serial_snd->write_pointer=serial_snd->datas_buffer;
serial_snd->write_full_flag=1;
}
}
if(port==1)
{
USART_ITConfig( USART1, USART_IT_TC, ENABLE );
}
else if(port==2)
{
USART_ITConfig( USART2, USART_IT_TXE, ENABLE );
}
else if(port==3)
{
USART_ITConfig( USART3, USART_IT_TXE, ENABLE );
}
}
return temp_len;
}
int rcv_deal_datas(void *datas, void *param, void *flag)
{
struct rcv_deal_pro_st *pro = (struct rcv_deal_pro_st *)datas;
int len = 0;
int type = 0;
len=read_serial( (unsigned char *)(pro->rcv_buff+pro->total_len), sizeof(pro->rcv_buff)-len-1, pro->port);
if(len)
{
pro->total_len += len;
}
else if(pro->total_len)
{
unsigned char *point = (unsigned char *)pro->rcv_buff;
while(point < pro->rcv_buff + pro->total_len)
{
type = pro->resolve_pro_func(pro->rcv_buff, pro->total_len, pro->result);
//清除緩存數(shù)據(jù)
if(type && pro->deal_pro_func)
{
pro->deal_pro_func(type, pro->result);
}
point = (unsigned char *)&pro->result;
memset(pro->rcv_buff,0,1024);
}
pro->total_len=0;
}
return 1;
}
接下來(lái)看下RTT內(nèi)部對(duì)于設(shè)備層的管理是如何定義的：
struct rt_device
{
struct rt_object parent;
/*設(shè)備類(lèi)型*/
enum rt_device_class_type type;
/*設(shè)備參數(shù)及打開(kāi)參數(shù)*/
rt_uint16_t flag,open_flag;
/*提供給上層應(yīng)用的回調(diào)函數(shù)*/
rt_err_t (*rx_indicate)(rt_device_t dev,rt_size_t size);
rt_err_t (*tx_complete)(rt_device_t dev,void* buffer);
/*公共的設(shè)備接口(由驅(qū)動(dòng)程序提供)*/
rt_err_t (*init)(rt_device_t dev);
rt_err_t (*open)(rt_device_t dev,rt_uint16_t oflag);
rt_err_t (*close)(rt_device dev);
rt_size_t (*read)(rt_device_t dev,rt_off_t pos,void* buffer,rt_size_t size);
rt_size_t (*write)(rt_device_t dev,rt_off_t pos,const void* buffer,rt_size_t size);
rt_err_t (*control)(rt_device_t dev,rt_uint8_t cmd,void* args);
/*設(shè)備的私有數(shù)據(jù)*/
void* user_data;
};
typedef struct rt_device* rt_device_t;
【本帖內(nèi)容】RT-thread學(xué)習(xí)之設(shè)備層框架設(shè)計(jì)淺析
RT-thread學(xué)習(xí)之一直走下去
RT-thread學(xué)習(xí)之RTT 的與眾不同
RT-thread學(xué)習(xí)之object對(duì)象管理機(jī)制
RT-thread學(xué)習(xí)之Thread線程機(jī)制及應(yīng)用
RT-thread學(xué)習(xí)之線程間的同步
