lzc56/AT-Command
1
0
Fork 0
mirror of https://gitee.com/moluo-tech/AT-Command synced 2025-08-13 21:52:53 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

优化URC匹配逻辑，并修正描述信息。

Browse Source
This commit is contained in:
魔罗技术 2021-05-15 15:37:00 +08:00
parent 463baf0f5c
commit 76d13e373b
2 changed files with 50 additions and 47 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

87
at.c
View File

@ -14,6 +14,7 @@
* 2.删除 at_obj_destroy接口 * 2.删除 at_obj_destroy接口
* 2021-03-21 Morro 删除at_obj中的at_work_ctx_t域,减少内存使用 * 2021-03-21 Morro 删除at_obj中的at_work_ctx_t域,减少内存使用
* 2021-04-08 Morro 解决重复释放信号量导致命令出现等待超时的问题 * 2021-04-08 Morro 解决重复释放信号量导致命令出现等待超时的问题
* 2021-05-15 Morro 优化URC匹配程序
****************************************************************************** ******************************************************************************
*/ */
#include "at.h" #include "at.h"
@ -122,7 +123,7 @@ void at_obj_init(at_obj_t *at, const at_adapter_t *adap)
at->cmd_lock = ril_sem_new(1); at->cmd_lock = ril_sem_new(1);
at->completed = ril_sem_new(0); at->completed = ril_sem_new(0);
at->urc_item = NULL;
if (at->adap.debug == NULL) if (at->adap.debug == NULL)
at->adap.debug = nop_dbg; at->adap.debug = nop_dbg;
@ -216,40 +217,34 @@ int at_split_respond_lines(char *recvbuf, char *lines[], int count, char separat
} }
return i; return i;
} }
/**
* @brief 从URC缓冲区中查询URC项
* @param[in] urcline - URC行
* @return true - 正常识别并处理, false - 未识别URC
*/
const urc_item_t *find_urc_item(at_obj_t *at, char *urc_buf, unsigned int size)
{
const urc_item_t *tbl = at->adap.utc_tbl;
int i;
if (size < 2)
return NULL;
for (i = 0; i < at->adap.urc_tbl_count; i++) {
if (strstr(urc_buf, tbl->prefix))
return tbl;
tbl++;
}
return NULL;
}
/** /**
* @brief urc 处理总入口 * @brief urc 处理总入口
* @param[in] urcline - URC行 * @param[in] urcline - URC行
* @return true - 正常识别并处理, false - 未识别URC
*/ */
static bool urc_handler_entry(at_obj_t *at, char *urcline, unsigned int size) static void urc_handler_entry(at_obj_t *at, char *urcline, unsigned int size)
{ {
int i;
int ch = urcline[size - 1];
at_urc_ctx_t context = {at->adap.read, urcline, at->adap.urc_bufsize, size}; at_urc_ctx_t context = {at->adap.read, urcline, at->adap.urc_bufsize, size};
at->adap.debug("<=\r\n%s\r\n", urcline);
const utc_item_t *tbl = at->adap.utc_tbl; at->urc_item->handler(&context); /* 递交到上层处理 */
if (tbl == NULL)
return true;
for (i = 0; i < at->adap.urc_tbl_count; i++) {
if (strstr(urcline, tbl->prefix)) { /* 匹配前缀*/
if (tbl->end_mark) { /* 匹配结束标记*/
if (!strchr(tbl->end_mark, ch))
return false;
} else if (!(ch == '\r' || ch == '\n'|| ch == '\0'))
return false;
at->adap.debug("<=\r\n%s\r\n", urcline);
tbl->handler(&context); /* 递交到上层处理 */
return true;
}
tbl++;
}
return false;
} }
/** /**
@ -266,30 +261,36 @@ static void urc_recv_process(at_obj_t *at, const char *buf, unsigned int size)
//接收超时处理,默认MAX_URC_RECV_TIMEOUT //接收超时处理,默认MAX_URC_RECV_TIMEOUT
if (at->urc_cnt > 0 && at_istimeout(at->urc_timer, MAX_URC_RECV_TIMEOUT)) { if (at->urc_cnt > 0 && at_istimeout(at->urc_timer, MAX_URC_RECV_TIMEOUT)) {
urc_buf[at->urc_cnt] = '\0'; urc_buf[at->urc_cnt] = '\0';
at->urc_cnt = 0; at->urc_cnt = 0;
at->urc_item = NULL;
if (at->urc_cnt > 2) if (at->urc_cnt > 2)
at->adap.debug("urc recv timeout=>%s\r\n", urc_buf); at->adap.debug("urc recv timeout=>%s\r\n", urc_buf);
} }
while (size--) { while (size--) {
at->urc_timer = at_get_ms(); at->urc_timer = at_get_ms();
ch = *buf++; ch = *buf++;
urc_buf[at->urc_cnt++] = ch; urc_buf[at->urc_cnt++] = ch;
if (strchr(SPEC_URC_END_MARKS, ch) || ch == '\0') { //结束标记 if (strchr(SPEC_URC_END_MARKS, ch) || ch == '\0') { //结束标记列表
urc_buf[at->urc_cnt] = '\0'; urc_buf[at->urc_cnt] = '\0';
if (at->urc_item == NULL)
if (ch == '\r' || ch == '\n'|| ch == '\0') { //检测到1行URC at->urc_item = find_urc_item(at, urc_buf, at->urc_cnt);
if (at->urc_cnt > 2) { if (at->urc_item != NULL){
if (!urc_handler_entry(at, urc_buf, at->urc_cnt) && !at->busy) if (strchr(at->urc_item->end_mark, ch)) { //匹配结束标记
at->adap.debug("%s\r\n", urc_buf); //未识别到的URC urc_handler_entry(at, urc_buf, at->urc_cnt);
at->urc_cnt = 0;
at->urc_item = NULL;
} }
at->urc_cnt = 0; } else if (ch == '\r' || ch == '\n'|| ch == '\0') {
} else if (urc_handler_entry(at, urc_buf, at->urc_cnt)) { if (at->urc_cnt > 2 && !at->busy) {
at->urc_cnt = 0; at->adap.debug("%s\r\n", urc_buf); //未识别到的URC
}
at->urc_cnt = 0;
} }
} else if (at->urc_cnt >= at->adap.urc_bufsize) //溢出处理 } else if (at->urc_cnt >= at->adap.urc_bufsize) { //溢出处理
at->urc_cnt = 0; at->urc_cnt = 0;
at->urc_item = NULL;
}
} }
} }

10
at.h
View File

@ -13,6 +13,7 @@
* 2.删除 at_obj_destroy接口 * 2.删除 at_obj_destroy接口
* 2021-03-21 Morro 删除at_obj中的at_work_ctx_t域,减少内存使用 * 2021-03-21 Morro 删除at_obj中的at_work_ctx_t域,减少内存使用
* 2021-04-08 Morro 解决重复释放信号量导致命令出现等待超时的问题 * 2021-04-08 Morro 解决重复释放信号量导致命令出现等待超时的问题
* 2021-05-15 Morro 优化URC匹配程序
******************************************************************************/ ******************************************************************************/
#ifndef _AT_H_ #ifndef _AT_H_
@ -28,7 +29,7 @@
#define MAX_URC_RECV_TIMEOUT 300 #define MAX_URC_RECV_TIMEOUT 300
/* 指定的URC 结束标记列表 */ /* 指定的URC 结束标记列表 */
#define SPEC_URC_END_MARKS ",\r\n" #define SPEC_URC_END_MARKS ":,\r\n"
struct at_obj; /* AT对象*/ struct at_obj; /* AT对象*/
@ -71,7 +72,7 @@ typedef struct {
* @params ctx - URC 上下文 * @params ctx - URC 上下文
*/ */
void (*handler)(at_urc_ctx_t *ctx); void (*handler)(at_urc_ctx_t *ctx);
}utc_item_t; }urc_item_t;
/**AT接口适配器 --------------------------------------------------------------*/ /**AT接口适配器 --------------------------------------------------------------*/
typedef struct { typedef struct {
@ -82,7 +83,7 @@ typedef struct {
//调试打印输出,如果不需要则填NULL //调试打印输出,如果不需要则填NULL
void (*debug)(const char *fmt, ...); void (*debug)(const char *fmt, ...);
//utc 处理函数表,如果不需要则填NULL //utc 处理函数表,如果不需要则填NULL
utc_item_t *utc_tbl; urc_item_t *utc_tbl;
//urc接收缓冲区,如果不需要则填NULL //urc接收缓冲区,如果不需要则填NULL
char *urc_buf; char *urc_buf;
//urc表项个数,如果不需要则填0 //urc表项个数,如果不需要则填0
@ -133,10 +134,11 @@ typedef struct at_obj {
at_sem_t cmd_lock; /* 命令锁*/ at_sem_t cmd_lock; /* 命令锁*/
at_sem_t completed; /* 命令完成信号*/ at_sem_t completed; /* 命令完成信号*/
at_respond_t *resp; /* AT应答信息*/ at_respond_t *resp; /* AT应答信息*/
const urc_item_t *urc_item; /* 当前URC项*/
unsigned int resp_timer; /* 响应接收定时器*/ unsigned int resp_timer; /* 响应接收定时器*/
unsigned int urc_timer; /* URC定时器 */ unsigned int urc_timer; /* URC定时器 */
at_return ret; /* 命令执行结果*/ at_return ret; /* 命令执行结果*/
unsigned short urc_cnt, rcv_cnt; unsigned short urc_cnt, rcv_cnt; /* 接收计数器*/
unsigned char busy : 1; unsigned char busy : 1;
unsigned char suspend: 1; unsigned char suspend: 1;
unsigned char dowork : 1; unsigned char dowork : 1;