From cf7c06297d04bade9cd04c056f9ed510e64dd7bd Mon Sep 17 00:00:00 2001 From: Uros Majstorovic Date: Wed, 5 Aug 2020 03:39:22 +0200 Subject: code -> fw --- code/esp32/components/eos/at_cmd.c | 164 ------------------------------------- 1 file changed, 164 deletions(-) delete mode 100644 code/esp32/components/eos/at_cmd.c (limited to 'code/esp32/components/eos/at_cmd.c') diff --git a/code/esp32/components/eos/at_cmd.c b/code/esp32/components/eos/at_cmd.c deleted file mode 100644 index 4712ad7..0000000 --- a/code/esp32/components/eos/at_cmd.c +++ /dev/null @@ -1,164 +0,0 @@ -#include -#include - -#include -#include -#include - -#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 ATURCItem *urc_curr; -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; - regmatch_t *m = NULL; - - xSemaphoreTake(mutex, portMAX_DELAY); - - if (urc_curr == NULL) { - int i; - - for (i=0; icb; - - xSemaphoreGive(mutex); - - if (cb) { - int r = cb(urc, m); - - if (r != AT_URC_MORE) { - xSemaphoreTake(mutex, portMAX_DELAY); - urc_curr = NULL; - xSemaphoreGive(mutex); - } - ESP_LOGD(TAG, "URC Processed: %s", urc); - return 1; - } - - ESP_LOGD(TAG, "URC NOT Processed: %s", 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.item[i]) { - urc_curr--; - } - } - rv = EOS_OK; - break; - } - } - - xSemaphoreGive(mutex); - - return rv; -} - -void at_cmd(char *cmd) { - eos_modem_write(cmd, strlen(cmd)); - ESP_LOGD(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 - e); - ESP_LOGD(TAG, "Expect: %s", at_buf); - - if (at_buf[0] != '\0') { - 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 (e > timeout) return EOS_ERR_TIMEOUT; - } while (1); -} -- cgit v1.2.3