0x05 LiteOS_Lab仓库组件详解--AT(下)

举报
樊心昊 发表于 2020/05/25 12:28:18 2020/05/25
【摘要】 AT框架关闭打印调试信息函数该函数用于关闭AT打印调试信息,如果关闭了AT框架在收到数据时就不会进行相应的打印了。1. int at_debugclose(void) 2. { 3. //for the debug 4. g_at_cb.rxdebugmode = en_at_debug_none; //本质上就是修改了结构体中的成员变量5. g_a...

AT框架关闭打印调试信息函数

该函数用于关闭AT打印调试信息,如果关闭了AT框架在收到数据时就不会进行相应的打印了。

1.  int at_debugclose(void)  

2.  {  

3.      //for the debug  

4.      g_at_cb.rxdebugmode = en_at_debug_none;  //本质上就是修改了结构体中的成员变量

5.      g_at_cb.txdebugmode = en_at_debug_none;  

6.    

7.      return 0;  

8.  }  

发送AT指令函数

调函该函数可以将长度为cmdlen的cmd字符串指针指向的指令发送出去,并查看返回信息中是否含有index字符串指针指向的关键字,如果需要处理返回信息还可以传入长度为respbuflen的内存地址指针respbuf来接收返回信息,等待超时时间为timeout。

1.  int  at_command(const void *cmd,size_t cmdlen,const char *index,void *respbuf,\  

2.                  size_t respbuflen,uint32_t timeout)  

3.  {  

4.      int ret = -1;  

5.      if(NULL == cmd)  

6.      {  

7.          return ret;  

8.      }  

9.  /* 如果需要判断回复信息中是否包含index关键词 */  

10.     if(NULL != index)  

11.     {  

12.         /* 创建一个命令结构体,用于发送和接收数据,并同步(信号量/互斥锁) */  

13.         ret = __cmd_create(cmd,cmdlen,index,respbuf,respbuflen,timeout);  

14.         if(0 == ret)  

15.         {  

16.         /* 调用底层发送函数将命令结构体中的数据发出 */  

17.             ret = __cmd_send(cmd,cmdlen,timeout);  

18.             if(0 == ret)  

19.             {  

20.             /* 通过挂起等待信号量获取回复 */  

21.                 if(osal_semp_pend(g_at_cb.cmd.respsync,timeout))  

22.                 {  

23.                     ret = g_at_cb.cmd.respdatalen;//返回回复值的大小  

24.                 }  

25.                 else  

26.                 {  

27.                     ret = -1;  

28.                 }  

29.             }  

30.             else  

31.             {  

32.                 ret = -1;  

33.             }  

34.   

35.             (void) __cmd_clear();   //清空命令结构体  

36.         }  

37.   

38.     }  

39.     else    //如果不需要处理回复,直接调用底层发送函数发送即可  

40.     {  

41.         ret = __cmd_send(cmd,cmdlen,timeout);  

42.     }  

43.   

44.     return ret;  

45. }  

AT框架中的接收任务

在初始化AT框架时,就会创建一个接收任务。

例1:我们调用at_command函数发送完一帧数据时,并需要回复和处理回复,发送之后我们通过信号量的方式让当前任务(含有发送指令的这个任务)挂起,等待信号量,接收任务中会帮我们去查询和读取回复,只要收到回复,接受任务就会释放信号量,让刚才挂起的任务恢复,来处理回复数据。

       例2:有的信息是异步的,例如nbiot设备收到了一条udp服务器下发的信息,正好我们之前通过at_oobregister函数注册了关键词处理函数,这时接收任务就会判断它收到的数据中是否含有index关键词(我们之前注册的“+NSONMI:”),它就会自动调用相应的处理函数帮我们处理数据。

1.  static int __rcv_task_entry(void *args)  

2.  {  

3.      bool_t matchret;  

4.      int oobret;  

5.      int  rcvlen = 0;  

6.    

7.      g_at_cb.devhandle = los_dev_open(g_at_cb.devname,O_RDWR);   //以读写方式开启设备  

8.      if(NULL == g_at_cb.devhandle)       //检查设备操作句柄是否正确  

9.      {  

10.         LINK_LOG_DEBUG("%s:open %s err\n\r",__FUNCTION__,g_at_cb.devname);  

11.         return 0;  

12.     }  

13.   

14.     while(NULL != g_at_cb.devhandle)  

15.     {  

16.     //streammode可能一帧数据分作分为多次下发,只要没有处理完一帧数据(rcvlen == 0),就一直累加  

17.         if (1 == g_at_cb.streammode)  //in stream mode, we need to save previous frames in buffer  

18.         {  

19.             if(rcvlen == 0) //为接收缓存区清空一块大小为CONFIG_AT_RECVMAXLEN的内存  

20.             {  

21.                 (void)memset(g_at_cb.rcvbuf,0,CONFIG_AT_RECVMAXLEN);  

22.             }  

23.             rcvlen += __resp_rcv(g_at_cb.rcvbuf+ rcvlen,CONFIG_AT_RECVMAXLEN,cn_osal_timeout_forever);  

24.             if( rcvlen > 0)  //如果收到了数据,开始处理数据  

25.             {  

26.                 matchret = __cmd_match(g_at_cb.rcvbuf,rcvlen);  //判断接收到的数据中是否有cmd结构体中的index  

27.                 if(0 != matchret)  

28.                 {  

29.                     oobret = __oob_match(g_at_cb.rcvbuf,rcvlen);//判断接收到的数据中是否有oob结构体中的index  

30.                     if(oobret != -1)  

31.                     {  

32.                         rcvlen = 0;  

33.                     }  

34.                 }  

35.                 else  

36.                 {  

37.                     rcvlen = 0;  

38.                 }  

39.             }  

40.         }  

41.         else    //一帧数据一定是一次下发完毕的  

42.         {  

43.             (void) memset(g_at_cb.rcvbuf,0,CONFIG_AT_RECVMAXLEN);  

44.             rcvlen = __resp_rcv(g_at_cb.rcvbuf,CONFIG_AT_RECVMAXLEN,cn_osal_timeout_forever);  

45.             if(rcvlen > 0)  

46.             {  

47.                 matchret = __cmd_match(g_at_cb.rcvbuf,rcvlen);  

48.                 if(0 != matchret)  

49.                 {  

50.                     (void) __oob_match(g_at_cb.rcvbuf,rcvlen);  

51.                 }  

52.             }  

53.         }  

54.     }  

55.   

56.     return 0;  

57. }  

 


【版权声明】本文为华为云社区用户原创内容,转载时必须标注文章的来源(华为云社区)、文章链接、文章作者等基本信息, 否则作者和本社区有权追究责任。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@huaweicloud.com
  • 点赞
  • 收藏
  • 关注作者

评论(0

0/1000
抱歉,系统识别当前为高风险访问,暂不支持该操作

全部回复

上滑加载中

设置昵称

在此一键设置昵称,即可参与社区互动!

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。