1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
|
#include <stdlib.h>
#include <string.h>
#include <freertos/FreeRTOS.h>
#include <freertos/semphr.h>
#include <esp_timer.h>
#include <esp_log.h>
#include "eos.h"
#include "cell.h"
#include "at_cmd.h"
static const char *TAG = "EOS ATCMD";
typedef struct ATURCItem {
regex_t re;
at_urc_cb_t cb;
char pattern[AT_SIZE_PATTERN];
} ATURCItem;
typedef struct ATURCList {
ATURCItem item[AT_SIZE_URC_LIST];
int len;
} ATURCList;
static ATURCList urc_list;
static SemaphoreHandle_t mutex;
static char at_buf[EOS_CELL_UART_SIZE_BUF];
void at_init(void) {
memset(&urc_list, 0, sizeof(ATURCList));
mutex = xSemaphoreCreateBinary();
xSemaphoreGive(mutex);
}
int at_urc_process(char *urc) {
regmatch_t match[AT_SIZE_NMATCH];
at_urc_cb_t cb = NULL;
int i;
if (urc[0] == '\0') return 0;
xSemaphoreTake(mutex, portMAX_DELAY);
for (i=0; i<urc_list.len; i++) {
if (regexec(&urc_list.item[i].re, urc, AT_SIZE_NMATCH, match, 0) == 0) {
cb = urc_list.item[i].cb;
break;
}
}
xSemaphoreGive(mutex);
if (cb) {
cb(urc, match);
ESP_LOGI(TAG, "URC Processed: %s", urc);
return 1;
}
ESP_LOGI(TAG, "URC NOT Processed: %d %d %d %d", urc[0], urc[1], urc[0] == '\r', strlen(urc));
return 0;
}
int at_urc_insert(char *pattern, at_urc_cb_t cb, int flags) {
int r;
int rv = EOS_OK;
if (strlen(pattern) >= AT_SIZE_PATTERN) return EOS_ERR;
xSemaphoreTake(mutex, portMAX_DELAY);
r = regcomp(&urc_list.item[urc_list.len].re, pattern, flags);
if (r) rv = EOS_ERR;
if (!rv && (urc_list.len == AT_SIZE_URC_LIST)) rv = EOS_ERR_FULL;
if (!rv) {
strcpy(urc_list.item[urc_list.len].pattern, pattern);
urc_list.item[urc_list.len].cb = cb;
urc_list.len++;
}
xSemaphoreGive(mutex);
return rv;
}
int at_urc_delete(char *pattern) {
int i;
int rv = EOS_ERR_NOTFOUND;
xSemaphoreTake(mutex, portMAX_DELAY);
for (i=0; i<urc_list.len; i++) {
if ((strcmp(pattern, urc_list.item[i].pattern) == 0)) {
if (i != urc_list.len - 1) memmove(&urc_list.item[i], &urc_list.item[i + 1], (urc_list.len - i - 1) * sizeof(ATURCItem));
urc_list.len--;
memset(&urc_list.item[urc_list.len], 0, sizeof(ATURCItem));
rv = EOS_OK;
break;
}
}
xSemaphoreGive(mutex);
return rv;
}
void at_cmd(char *cmd) {
eos_modem_write(cmd, strlen(cmd));
ESP_LOGI(TAG, "Cmd: %s", cmd);
}
int at_expect(char *str_ok, char *str_err, uint32_t timeout) {
int rv;
regex_t re_ok;
regex_t re_err;
uint32_t e = 0;
uint64_t t_start = esp_timer_get_time();
if (str_ok) {
rv = regcomp(&re_ok, str_ok, REG_EXTENDED | REG_NOSUB);
if (rv) return EOS_ERR;
}
if (str_err) {
rv = regcomp(&re_err, str_err, REG_EXTENDED | REG_NOSUB);
if (rv) return EOS_ERR;
}
do {
rv = eos_modem_readln(at_buf, sizeof(at_buf), timeout ? timeout - e : 0);
ESP_LOGI(TAG, "Expect: %s", at_buf);
if (!rv && str_ok && (regexec(&re_ok, at_buf, 0, NULL, 0) == 0)) return 1;
if (!rv && str_err && (regexec(&re_err, at_buf, 0, NULL, 0) == 0)) return 0;
at_urc_process(at_buf);
e = (uint32_t)(esp_timer_get_time() - t_start) / 1000;
if (timeout && (e > timeout)) return EOS_ERR_TIMEOUT;
} while (1);
}
|
