分享一个平时用的接收缓冲+缓冲处理回调函数的结构

nome

功能简介：
        实现一个数据流(笔者用于串口)的接收缓冲，然后在cpu空闲的时候处理这些数据流，一般数据流有特定的格式，以便于程序分割命令和参数。

本文使用的是类似linxu shell的可见字符串。实际使用中也可以更改为16进制数据。


使用环境示例：
        串口接收函数调用write_queue();插入上位机输入的数据。程序通过调用read_queue()获取数据。

1. /*
   
2.         queue.c
   
3.         --实现功能：定义一个环形消息队列，实现1.读一个字节 2.插入一个字节 3.取出一条命令。
   
4.         ----------  命令格式定义：cmd prama\r    获取命令依照" "区分命令和参数，依照"\r"区分结尾。
   
5. 
   
6. 
   
7.         author:nome
   
8.         date  :2014/4/18
   
9. 
   
10. 
    
11. */
    
12. 
    
13. 
    
14. #include "string.h"
    
15. #include "queue.h"
    
16. 
    
17. 
    
18. #define Q_LEN 100           //队列长度
    
19. 
    
20. #define TIMEOUT 900000      
    
21. 
    
22. char strqueue[Q_LEN];       //队列数组
    
23. 
    
24. 
    
25. 
    
26. int write = 0;               //写偏移
    
27. int read = 0;                                                                //读偏移
    
28. 
    
29. 
    
30. 
    
31. 
    
32. /*
    
33. * 功能：从队列中读取一个字节
    
34. * 失败：返回-1
    
35. * 成功：返回0
    
36. */
    
37. char read_queue(char *pdata)
    
38. {
    
39.         if(write==read)
    
40.                 return -1;               
    
41.         *pdata = strqueue[read];
    
42.         read = (read+1)%Q_LEN;
    
43.         return 0;
    
44. }
    
45. /*
    
46. * 功能：往队列中写入一个字节
    
47. * 失败：返回-1
    
48. * 成功：返回0
    
49. */
    
50. char write_queue(char data)
    
51. {
    
52.         if((write+1)%Q_LEN==read)
    
53.                 return -1;
    
54.         strqueue[write] = data;
    
55.         write = (write+1)%Q_LEN;
    
56.         return 0;
    
57. }
    
58. 
    
59. 
    
60. /*
    
61. * 功能：从队列中取出一个完整的字符串命令。
    
62. * 失败：返回-1
    
63. * 成功：返回0
    
64. *cmd 存放命令的指针，param 存放参数的指针。
    
65. */
    
66. int get_q_string(char *cmd,char *param)
    
67. {
    
68.         int i = 0;
    
69.         int timeout = 0;
    
70.         char data;
    
71.         if(read_queue(&data)) //查看队列中是否有数据，没有数据返回，有数据等待接收完整命令。
    
72.                 return -1;
    
73.         cmd[i++] = data;
    
74.         for(;;){
    
75.                 if(0==read_queue(&cmd[i]))
    
76.                         i++;
    
77.                 if(cmd[i-1]==' ')
    
78.                         break;
    
79.                 if(timeout>TIMEOUT)
    
80.                         return -1;
    
81.                 timeout++;
    
82.         }
    
83.         cmd[i] = 0; //提供一个cmd结束符
    
84.         timeout = 0;
    
85.         i = 0;
    
86.         for(;;){
    
87.                 if(0==read_queue(&param[i]))
    
88.                         i++;
    
89.                 if(param[i-1]=='\r')
    
90.                         break;
    
91.                 if(timeout>TIMEOUT)
    
92.                         return -1;
    
93.                         timeout++;               
    
94.         }
    
95.         param[i-1] = 0; //去掉\r 换成结束符
    
96.         return 0;
    
97. }
    

复制代码

下面一个.c和一个.h用于处理上面.c取出的字符串。

1. #ifndef _USART_CMD_H
   
2. #define _USART_CMD_H
   
3. 
   
4. 
   
5. 
   
6. 
   
7. struct _cmd_list{
   
8.         char *cmd;
   
9.         void (*func)(char *param);
   
10. };
    
11. 
    
12. #define CMD_CALLBACK_LIST_BEGIN struct _cmd_list cmd_list[] = {NULL,null,
    
13. #define CMD_CALLBACK_LIST_END NULL,NULL};
    
14. #define CMD_CALLBACK(cmd_string,callback)        cmd_string,callback,
    
15. 
    
16. 
    
17. 
    
18. #endif

复制代码

1. #include "queue.h"
   
2. #include "string.h"
   
3. #include "math.h"
   
4. #include "stdio.h"
   
5. #include "usart_cmd.h"
   
6. 
   
7. 
   
8. extern void usart_sendstring(char *str); //定义一个串口发送字符串的函数
   
9. 
   
10. //字符串转int
    
11. int str_to_int(char *str)
    
12. {
    
13.         int i = 0,j = 0;
    
14.         int ret = 0;
    
15.         for(;;){
    
16.         if(str[i++]==0||i>20)
    
17.                 break;
    
18.         }
    
19.         j = i = i-2;
    
20.         for(;i>=0;i--)
    
21.         {
    
22.                 ret += (str[i]-'0')*(pow(10,(j-i)));
    
23.         }
    
24.         return ret;
    
25. }
    
26. 
    
27. /********************一些回调函数 不必在意*****************************/
    
28. void setfreq(char *param)
    
29. {
    
30. SX1276LoRaSetRFFrequency(str_to_int(param));   
    
31.                                                                                                 memset(param,0,32);
    
32.                                                                                                 sprintf(param,"setfreq ok! freq=%d\r\n",SX1276LoRaGetRFFrequency());   
    
33.                                                                                                 usart_sendstring(param);         
    
34. }
    
35. 
    
36. extern int send_receive_flag ;
    
37. extern int packet_num ;
    
38. 
    
39. void send(char *param)
    
40. {
    
41.         send_receive_flag = 0;
    
42.         packet_num = str_to_int(param);
    
43. }
    
44. 
    
45. void receive(char *param)
    
46. {
    
47.         send_receive_flag = 1;
    
48. }
    
49. 
    
50. void null(char *param)
    
51. {}
    
52. /********************一些回调函数 不必在意*****************************/       
    
53. 
    
54. //在此处添加你的命令字符串和回调函数
    
55. CMD_CALLBACK_LIST_BEGIN
    
56. 
    
57. CMD_CALLBACK("setfreq",setfreq)
    
58. CMD_CALLBACK("send",send)
    
59. CMD_CALLBACK("receive",receive)
    
60. 
    
61. 
    
62. 
    
63. CMD_CALLBACK_LIST_END
    
64. 
    
65. 
    
66. 
    
67. 
    
68. 
    
69. 
    
70. char cmd[10];
    
71. char param[32];
    
72. int get_cmd(void)
    
73. {
    
74.         int i = 0;
    
75.         if(get_q_string(cmd,param))
    
76.                 return 0;
    
77.         for(;;){
    
78.                 if(strcmp(cmd,cmd_list[i].cmd)==0)
    
79.                         return i;       
    
80.                 if(cmd_list[++i].cmd==NULL)
    
81.                         return 0;
    
82.         }
    
83. }
    
84. 
    
85. 
    
86. 
    
87. //这个函数需要在main函数中轮询调用
    
88. void dispose_cmd(void)
    
89. {
    
90.         cmd_list[get_cmd()].func(param);
    
91. }

复制代码

jiwx2011

学习一下。。

机器人天空

谢谢楼主，很有用

yayagepei

学习学习

shangyu60104

学习一下

一杯茶2009

学习，感谢分享

zyw19987

格式定义太死吧，协议中就会有0x20怎么搞？

nome

zyw19987 发表于 2016-4-24 06:25
格式定义太死吧，协议中就会有0x20怎么搞？

  这个是借鉴的 linux 命令行，   格式是    命令+空格+参数

字符串 默认空格是个分节符， 一般不会有别的使用吧

Excellence

e1ki0lp

短小精湛，可读性好，收藏。

想不到

谢谢分享         

mypear

楼主，这么早就搞LoRa了？

lijg8421

学习了，实用。

Lyndon.Sun

write和read是不是应该加volatile修饰。

oooios

lihai xxxxx