libs/at_device
libs
/
at_device
4
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Merge pull request #9 from chenyong111/master 

【修改】适配 AT 组件文件及函数名称修改
This commit is contained in:
朱天龙 (Armink) 2018-07-22 10:14:16 +08:00 committed by GitHub
parent 76b2f40154 ed5038dc25
commit d4089364e5
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
4 changed files with 85 additions and 86 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
SConscript
View File

@ -11,6 +11,6 @@ if GetDepend(['AT_DEVICE_ESP8266']):
if GetDepend(['AT_DEVICE_NOT_SELECTED']):
src = Glob('*.c')
group = DefineGroup('at_device', src, depend = ['PKG_USING_AT_DEVICE','RT_AT_USING_CLIENT'], CPPPATH = [cwd])
group = DefineGroup('at_device', src, depend = ['PKG_USING_AT_DEVICE','AT_USING_SOCKET'], CPPPATH = [cwd])
Return('group')

16
at_client_sample.c
View File

@ -26,12 +26,12 @@
#include <string.h>
#include <rtthread.h>
#include <rt_at.h>
#include <at.h>
/* AT+CIFSR Query local IP address and MAC */
int at_client_test(int argc, char **argv)
{
rt_at_response_t resp = RT_NULL;
at_response_t resp = RT_NULL;
int result = 0;
if (argc != 1)
@ -40,7 +40,7 @@ int at_client_test(int argc, char **argv)
return -1;
}
resp = rt_at_create_resp(256, 0, rt_tick_from_millisecond(5000));
resp = at_create_resp(256, 0, rt_tick_from_millisecond(5000));
if (resp == RT_NULL)
{
LOG_E("No memory for response structure!");
@ -48,9 +48,9 @@ int at_client_test(int argc, char **argv)
}
/* close echo */
rt_at_exec_cmd(resp, "ATE0");
at_exec_cmd(resp, "ATE0");
result = rt_at_exec_cmd(resp, "AT+CIFSR");
result = at_exec_cmd(resp, "AT+CIFSR");
if (result != RT_EOK)
{
LOG_E("AT client send commands failed or return response error!");
@ -77,14 +77,14 @@ int at_client_test(int argc, char **argv)
}
{
char resp_arg[RT_AT_CMD_MAX_LEN] = { 0 };
char resp_arg[AT_CMD_MAX_LEN] = { 0 };
const char * resp_expr = "%*[^\"]\"%[^\"]\"";
LOG_D(" Parse arguments");
if (at_resp_parse_line_args(resp, 1, resp_expr, resp_arg) == 1)
{
LOG_D("Station IP : %s", resp_arg);
memset(resp_arg, 0x00, RT_AT_CMD_MAX_LEN);
memset(resp_arg, 0x00, AT_CMD_MAX_LEN);
}
else
{
@ -104,7 +104,7 @@ int at_client_test(int argc, char **argv)
__exit:
if(resp)
{
rt_at_delete_resp(resp);
at_delete_resp(resp);
}
return result;

74
at_socket_esp8266.c
View File

@ -22,13 +22,13 @@
* 2018-06-20 chenyong first version
*/
#include <at.h>
#include <stdio.h>
#include <string.h>
#include <rtthread.h>
#include <sys/socket.h>
#include <rt_at.h>
#include <at_socket.h>
#ifndef AT_DEVICE_NOT_SELECTED
@ -86,10 +86,10 @@ static int at_socket_event_recv(uint32_t event, uint32_t timeout, rt_uint8_t opt
*/
static int esp8266_socket_close(int socket)
{
rt_at_response_t resp = RT_NULL;
at_response_t resp = RT_NULL;
int result = RT_EOK;
resp = rt_at_create_resp(64, 0, rt_tick_from_millisecond(5000));
resp = at_create_resp(64, 0, rt_tick_from_millisecond(5000));
if (!resp)
{
LOG_E("No memory for response structure!");
@ -98,7 +98,7 @@ static int esp8266_socket_close(int socket)
rt_mutex_take(at_event_lock, RT_WAITING_FOREVER);
if (rt_at_exec_cmd(resp, "AT+CIPCLOSE=%d", socket) < 0)
if (at_exec_cmd(resp, "AT+CIPCLOSE=%d", socket) < 0)
{
LOG_E("socket(%d) close failed.", socket);
result = -RT_ERROR;
@ -110,7 +110,7 @@ static int esp8266_socket_close(int socket)
if (resp)
{
rt_at_delete_resp(resp);
at_delete_resp(resp);
}
return result;
@ -132,14 +132,14 @@ static int esp8266_socket_close(int socket)
*/
static int esp8266_socket_connect(int socket, char *ip, int32_t port, enum at_socket_type type, rt_bool_t is_client)
{
rt_at_response_t resp = RT_NULL;
at_response_t resp = RT_NULL;
int result = RT_EOK;
rt_bool_t retryed = RT_FALSE;
RT_ASSERT(ip);
RT_ASSERT(port >= 0);
resp = rt_at_create_resp(128, 0, rt_tick_from_millisecond(5000));
resp = at_create_resp(128, 0, rt_tick_from_millisecond(5000));
if (!resp)
{
LOG_E("No memory for response structure!");
@ -155,14 +155,14 @@ __retry:
{
case AT_SOCKET_TCP:
/* send AT commands to connect TCP server */
if (rt_at_exec_cmd(resp, "AT+CIPSTART=%d,\"TCP\",\"%s\",%d,60", socket, ip, port) < 0)
if (at_exec_cmd(resp, "AT+CIPSTART=%d,\"TCP\",\"%s\",%d,60", socket, ip, port) < 0)
{
result = -RT_ERROR;
}
break;
case AT_SOCKET_UDP:
if (rt_at_exec_cmd(resp, "AT+CIPSTART=%d,\"UDP\",\"%s\",%d", socket, ip, port) < 0)
if (at_exec_cmd(resp, "AT+CIPSTART=%d,\"UDP\",\"%s\",%d", socket, ip, port) < 0)
{
result = -RT_ERROR;
}
@ -196,7 +196,7 @@ __exit:
}
if (resp)
{
rt_at_delete_resp(resp);
at_delete_resp(resp);
}
return result;
@ -219,13 +219,13 @@ static int esp8266_socket_send(int socket, const char *buff, size_t bfsz, enum a
{
int result = RT_EOK;
int event_result = 0;
rt_at_response_t resp = RT_NULL;
at_response_t resp = RT_NULL;
size_t cur_pkt_size = 0, sent_size = 0;
RT_ASSERT(buff);
RT_ASSERT(bfsz > 0);
resp = rt_at_create_resp(128, 2, rt_tick_from_millisecond(5000));
resp = at_create_resp(128, 2, rt_tick_from_millisecond(5000));
if (!resp)
{
LOG_E("No memory for response structure!");
@ -238,7 +238,7 @@ static int esp8266_socket_send(int socket, const char *buff, size_t bfsz, enum a
cur_socket = socket;
/* set AT client end sign to deal with '>' sign.*/
extern int rt_at_set_end_sign(char ch);
rt_at_set_end_sign('>');
at_set_end_sign('>');
while (sent_size < bfsz)
{
@ -252,14 +252,14 @@ static int esp8266_socket_send(int socket, const char *buff, size_t bfsz, enum a
}
/* send the "AT+CIPSEND" commands to AT server than receive the '>' response on the first line. */
if (rt_at_exec_cmd(resp, "AT+CIPSEND=%d,%d", socket, cur_pkt_size) < 0)
if (at_exec_cmd(resp, "AT+CIPSEND=%d,%d", socket, cur_pkt_size) < 0)
{
result = -RT_ERROR;
goto __exit;
}
/* send the real data to server or client */
result = (int) rt_at_client_send(buff + sent_size, cur_pkt_size);
result = (int) at_client_send(buff + sent_size, cur_pkt_size);
if (result == 0)
{
result = -RT_ERROR;
@ -299,13 +299,13 @@ static int esp8266_socket_send(int socket, const char *buff, size_t bfsz, enum a
__exit:
/* reset the end sign for data */
rt_at_set_end_sign(0);
at_set_end_sign(0);
rt_mutex_release(at_event_lock);
if (resp)
{
rt_at_delete_resp(resp);
at_delete_resp(resp);
}
return result;
@ -325,12 +325,12 @@ static int esp8266_domain_resolve(const char *name, char ip[16])
{
int result = RT_EOK;
char recv_ip[16] = { 0 };
rt_at_response_t resp = RT_NULL;
at_response_t resp = RT_NULL;
RT_ASSERT(name);
RT_ASSERT(ip);
resp = rt_at_create_resp(128, 0, rt_tick_from_millisecond(5000));
resp = at_create_resp(128, 0, rt_tick_from_millisecond(5000));
if (!resp)
{
LOG_E("No memory for response structure!");
@ -340,7 +340,7 @@ static int esp8266_domain_resolve(const char *name, char ip[16])
rt_mutex_take(at_event_lock, RT_WAITING_FOREVER);
__restart:
if (rt_at_exec_cmd(resp, "AT+CIPDOMAIN=\"%s\"", name) < 0)
if (at_exec_cmd(resp, "AT+CIPDOMAIN=\"%s\"", name) < 0)
{
result = -RT_ERROR;
goto __exit;
@ -364,7 +364,7 @@ __exit:
if (resp)
{
rt_at_delete_resp(resp);
at_delete_resp(resp);
}
return result;
@ -447,11 +447,11 @@ static void urc_recv_func(const char *data, rt_size_t size)
{
if (bfsz - temp_size > sizeof(temp))
{
rt_at_client_recv(temp, sizeof(temp));
at_client_recv(temp, sizeof(temp));
}
else
{
rt_at_client_recv(temp, bfsz - temp_size);
at_client_recv(temp, bfsz - temp_size);
}
temp_size += sizeof(temp);
}
@ -459,7 +459,7 @@ static void urc_recv_func(const char *data, rt_size_t size)
}
/* sync receive data */
if (rt_at_client_recv(recv_buf, bfsz) != bfsz)
if (at_client_recv(recv_buf, bfsz) != bfsz)
{
LOG_E("receive size(%d) data failed!", bfsz);
rt_free(recv_buf);
@ -501,7 +501,7 @@ static void urc_func(const char *data, rt_size_t size)
}
}
static struct rt_at_urc urc_table[] = {
static struct at_urc urc_table[] = {
{"SEND OK", "\r\n", urc_send_func},
{"SEND FAIL", "\r\n", urc_send_func},
{"Recv", "bytes\r\n", urc_send_bfsz_func},
@ -514,7 +514,7 @@ static struct rt_at_urc urc_table[] = {
};
/* AT client port initialization */
int rt_at_client_port_init(void)
int at_client_port_init(void)
{
/* create current AT socket event */
at_socket_event = rt_event_create("at_sock_event", RT_IPC_FLAG_FIFO);
@ -534,7 +534,7 @@ int rt_at_client_port_init(void)
}
/* register URC data execution function */
rt_at_set_urc_table(urc_table, sizeof(urc_table) / sizeof(urc_table[0]));
at_set_urc_table(urc_table, sizeof(urc_table) / sizeof(urc_table[0]));
return RT_EOK;
}
@ -542,7 +542,7 @@ int rt_at_client_port_init(void)
#define AT_SEND_CMD(resp, cmd) \
do \
{ \
if (rt_at_exec_cmd(rt_at_resp_set_info(resp, 256, 0, rt_tick_from_millisecond(5000)), cmd) < 0) \
if (at_exec_cmd(at_resp_set_info(resp, 256, 0, rt_tick_from_millisecond(5000)), cmd) < 0) \
{ \
LOG_E("RT AT send commands(%s) error!", cmd); \
return -1; \
@ -551,10 +551,10 @@ int rt_at_client_port_init(void)
static int esp8266_net_init(void)
{
rt_at_response_t resp = RT_NULL;
at_response_t resp = RT_NULL;
rt_size_t i;
resp = rt_at_create_resp(128, 0, rt_tick_from_millisecond(5000));
resp = at_create_resp(128, 0, rt_tick_from_millisecond(5000));
if (!resp)
{
LOG_E("No memory for response structure!");
@ -576,7 +576,7 @@ static int esp8266_net_init(void)
LOG_D("%s", at_resp_get_line(resp, i + 1))
}
/* connect to WiFi AP */
if (rt_at_exec_cmd(rt_at_resp_set_info(resp, 128, 0, 20 * RT_TICK_PER_SECOND), "AT+CWJAP=\"%s\",\"%s\"",
if (at_exec_cmd(at_resp_set_info(resp, 128, 0, 20 * RT_TICK_PER_SECOND), "AT+CWJAP=\"%s\",\"%s\"",
AT_DEVICE_WIFI_SSID, AT_DEVICE_WIFI_PASSWORD) != RT_EOK)
{
LOG_E("AT network initialize failed, check ssid(%s) and password(%s).", AT_DEVICE_WIFI_SSID, AT_DEVICE_WIFI_PASSWORD);
@ -587,7 +587,7 @@ static int esp8266_net_init(void)
if (resp)
{
rt_at_delete_resp(resp);
at_delete_resp(resp);
}
LOG_I("AT network initialize success!");
@ -597,7 +597,7 @@ static int esp8266_net_init(void)
int esp8266_ping(int argc, char **argv)
{
rt_at_response_t resp = RT_NULL;
at_response_t resp = RT_NULL;
static int icmp_seq;
int req_time;
@ -607,7 +607,7 @@ int esp8266_ping(int argc, char **argv)
return -RT_ERROR;
}
resp = rt_at_create_resp(64, 0, rt_tick_from_millisecond(5000));
resp = at_create_resp(64, 0, rt_tick_from_millisecond(5000));
if (!resp)
{
rt_kprintf("No memory for response structure!\n");
@ -616,10 +616,10 @@ int esp8266_ping(int argc, char **argv)
for(icmp_seq = 1; icmp_seq <= 4; icmp_seq++)
{
if (rt_at_exec_cmd(resp, "AT+PING=\"%s\"", argv[1]) < 0)
if (at_exec_cmd(resp, "AT+PING=\"%s\"", argv[1]) < 0)
{
rt_kprintf("ping: unknown remote server host\n");
rt_at_delete_resp(resp);
at_delete_resp(resp);
return -RT_ERROR;
}
@ -632,7 +632,7 @@ int esp8266_ping(int argc, char **argv)
if (resp)
{
rt_at_delete_resp(resp);
at_delete_resp(resp);
}
return RT_EOK;

79
at_socket_m26.c
View File

@ -28,7 +28,7 @@
#include <rtthread.h>
#include <sys/socket.h>
#include <rt_at.h>
#include <at.h>
#include <at_socket.h>
#ifndef AT_DEVICE_NOT_SELECTED
@ -90,7 +90,7 @@ static int m26_socket_close(int socket)
rt_mutex_take(at_event_lock, RT_WAITING_FOREVER);
cur_socket = socket;
if (rt_at_exec_cmd(RT_NULL, "AT+QICLOSE=%d", socket) < 0)
if (at_exec_cmd(RT_NULL, "AT+QICLOSE=%d", socket) < 0)
{
result = -RT_ERROR;
goto __exit;
@ -143,7 +143,7 @@ __retry:
{
case AT_SOCKET_TCP:
/* send AT commands(eg: AT+QIOPEN=0,"TCP","x.x.x.x", 1234) to connect TCP server */
if (rt_at_exec_cmd(RT_NULL, "AT+QIOPEN=%d,\"TCP\",\"%s\",%d", socket, ip, port) < 0)
if (at_exec_cmd(RT_NULL, "AT+QIOPEN=%d,\"TCP\",\"%s\",%d", socket, ip, port) < 0)
{
result = -RT_ERROR;
goto __exit;
@ -151,7 +151,7 @@ __retry:
break;
case AT_SOCKET_UDP:
if (rt_at_exec_cmd(RT_NULL, "AT+QIOPEN=%d,\"UDP\",\"%s\",%d", socket, ip, port) < 0)
if (at_exec_cmd(RT_NULL, "AT+QIOPEN=%d,\"UDP\",\"%s\",%d", socket, ip, port) < 0)
{
result = -RT_ERROR;
goto __exit;
@ -206,7 +206,7 @@ __exit:
static int at_get_send_size(int socket, size_t *size, size_t *acked, size_t *nacked)
{
rt_at_response_t resp = rt_at_create_resp(64, 0, rt_tick_from_millisecond(5000));
at_response_t resp = at_create_resp(64, 0, rt_tick_from_millisecond(5000));
int result = 0;
if (!resp)
@ -216,7 +216,7 @@ static int at_get_send_size(int socket, size_t *size, size_t *acked, size_t *nac
goto __exit;
}
if (rt_at_exec_cmd(resp, "AT+QISACK=%d", socket) < 0)
if (at_exec_cmd(resp, "AT+QISACK=%d", socket) < 0)
{
result = -RT_ERROR;
goto __exit;
@ -231,7 +231,7 @@ static int at_get_send_size(int socket, size_t *size, size_t *acked, size_t *nac
__exit:
if (resp)
{
rt_at_delete_resp(resp);
at_delete_resp(resp);
}
return result;
@ -272,13 +272,12 @@ static int at_wait_send_finish(int socket, size_t settings_size)
static int m26_socket_send(int socket, const char *buff, size_t bfsz, enum at_socket_type type)
{
int result = 0, event_result = 0;
rt_at_response_t resp = RT_NULL;
at_response_t resp = RT_NULL;
size_t cur_pkt_size = 0, sent_size = 0;
RT_ASSERT(buff);
RT_ASSERT(bfsz);
resp = rt_at_create_resp(128, 2, rt_tick_from_millisecond(5000));
resp = at_create_resp(128, 2, rt_tick_from_millisecond(5000));
if (!resp)
{
LOG_E("No memory for response structure!");
@ -290,8 +289,8 @@ static int m26_socket_send(int socket, const char *buff, size_t bfsz, enum at_so
/* set current socket for send URC event */
cur_socket = socket;
/* set AT client end sign to deal with '>' sign.*/
extern int rt_at_set_end_sign(char ch);
rt_at_set_end_sign('>');
extern int at_set_end_sign(char ch);
at_set_end_sign('>');
while (sent_size < bfsz)
{
@ -305,14 +304,14 @@ static int m26_socket_send(int socket, const char *buff, size_t bfsz, enum at_so
}
/* send the "AT+QISEND" commands to AT server than receive the '>' response on the first line. */
if (rt_at_exec_cmd(resp, "AT+QISEND=%d,%d", socket, cur_pkt_size) < 0)
if (at_exec_cmd(resp, "AT+QISEND=%d,%d", socket, cur_pkt_size) < 0)
{
result = -RT_ERROR;
goto __exit;
}
/* send the real data to server or client */
result = (int) rt_at_client_send(buff + sent_size, cur_pkt_size);
result = (int) at_client_send(buff + sent_size, cur_pkt_size);
if (result == 0)
{
result = -RT_ERROR;
@ -353,13 +352,13 @@ static int m26_socket_send(int socket, const char *buff, size_t bfsz, enum at_so
__exit:
/* reset the end sign for data conflict */
rt_at_set_end_sign(0);
at_set_end_sign(0);
rt_mutex_release(at_event_lock);
if (resp)
{
rt_at_delete_resp(resp);
at_delete_resp(resp);
}
return result;
@ -380,12 +379,12 @@ static int m26_domain_resolve(const char *name, char ip[16])
{
int result = 0;
char recv_ip[16] = { 0 };
rt_at_response_t resp = RT_NULL;
at_response_t resp = RT_NULL;
RT_ASSERT(name);
RT_ASSERT(ip);
resp = rt_at_create_resp(128, 4, rt_tick_from_millisecond(5000));
resp = at_create_resp(128, 4, rt_tick_from_millisecond(5000));
if (!resp)
{
LOG_E("No memory for response structure!");
@ -395,7 +394,7 @@ static int m26_domain_resolve(const char *name, char ip[16])
rt_mutex_take(at_event_lock, RT_WAITING_FOREVER);
__restart:
if (rt_at_exec_cmd(resp, "AT+QIDNSGIP=\"%s\"", name) < 0)
if (at_exec_cmd(resp, "AT+QIDNSGIP=\"%s\"", name) < 0)
{
result = -RT_ERROR;
goto __exit;
@ -419,7 +418,7 @@ __exit:
if (resp)
{
rt_at_delete_resp(resp);
at_delete_resp(resp);
}
return result;
@ -516,11 +515,11 @@ static void urc_recv_func(const char *data, rt_size_t size)
{
if (bfsz - temp_size > sizeof(temp))
{
rt_at_client_recv(temp, sizeof(temp));
at_client_recv(temp, sizeof(temp));
}
else
{
rt_at_client_recv(temp, bfsz - temp_size);
at_client_recv(temp, bfsz - temp_size);
}
temp_size += sizeof(temp);
}
@ -528,7 +527,7 @@ static void urc_recv_func(const char *data, rt_size_t size)
}
/* sync receive data */
if (rt_at_client_recv(recv_buf, bfsz) != bfsz)
if (at_client_recv(recv_buf, bfsz) != bfsz)
{
LOG_E("receive size(%d) data failed!", bfsz);
rt_free(recv_buf);
@ -548,7 +547,7 @@ static void urc_ping_func(const char *data, rt_size_t size)
int result, recv_len, time, ttl;
char dst_ip[16] = { 0 };
RT_ASSERT(data && size);
RT_ASSERT(data);
sscanf(data, "+QPING: %d,%[^,],%d,%d,%d", &result, dst_ip, &recv_len, &time, &ttl);
@ -577,12 +576,12 @@ static void urc_ping_func(const char *data, rt_size_t size)
static void urc_func(const char *data, rt_size_t size)
{
RT_ASSERT(data && size);
RT_ASSERT(data);
LOG_I("URC data : %.*s", size, data);
}
static const struct rt_at_urc urc_table[] = {
static const struct at_urc urc_table[] = {
{"RING", "\r\n", urc_func},
{"Call Ready", "\r\n", urc_func},
{"RDY", "\r\n", urc_func},
@ -598,13 +597,13 @@ static const struct rt_at_urc urc_table[] = {
};
/* AT client port initialization */
int rt_at_client_port_init(void)
int at_client_port_init(void)
{
/* create current AT socket event */
at_socket_event = rt_event_create("at_sock_event", RT_IPC_FLAG_FIFO);
if (!at_socket_event)
{
LOG_E("RT AT client port initialize failed! at_sock_event create failed!");
LOG_E("AT client port initialize failed! at_sock_event create failed!");
return -RT_ENOMEM;
}
@ -612,13 +611,13 @@ int rt_at_client_port_init(void)
at_event_lock = rt_mutex_create("at_event_lock", RT_IPC_FLAG_FIFO);
if (!at_event_lock)
{
LOG_E("RT AT client port initialize failed! at_sock_lock create failed!");
LOG_E("AT client port initialize failed! at_sock_lock create failed!");
rt_event_delete(at_socket_event);
return -RT_ENOMEM;
}
/* register URC data execution function */
rt_at_set_urc_table(urc_table, sizeof(urc_table) / sizeof(urc_table[0]));
at_set_urc_table(urc_table, sizeof(urc_table) / sizeof(urc_table[0]));
return RT_EOK;
}
@ -626,25 +625,25 @@ int rt_at_client_port_init(void)
#define AT_SEND_CMD(resp, resp_line, cmd) \
do \
{ \
if (rt_at_exec_cmd(rt_at_resp_set_info(resp, 64, resp_line, rt_tick_from_millisecond(5000)), cmd) < 0) \
if (at_exec_cmd(at_resp_set_info(resp, 64, resp_line, rt_tick_from_millisecond(5000)), cmd) < 0) \
{ \
LOG_E("RT AT send commands(%s) error!", cmd); \
LOG_E("AT send commands(%s) error!", cmd); \
return -RT_ERROR; \
} \
} while(0); \
int m26_net_init(void)
{
rt_at_response_t resp = RT_NULL;
at_response_t resp = RT_NULL;
resp = rt_at_create_resp(64, 0, rt_tick_from_millisecond(5000));
resp = at_create_resp(64, 0, rt_tick_from_millisecond(5000));
if (!resp)
{
LOG_E("No memory for response structure!");
return -RT_ENOMEM;
}
if (rt_at_exec_cmd(rt_at_resp_set_info(resp, 64, 2, rt_tick_from_millisecond(5000)), "AT+QILOCIP") == RT_EOK)
if (at_exec_cmd(at_resp_set_info(resp, 64, 2, rt_tick_from_millisecond(5000)), "AT+QILOCIP") == RT_EOK)
{
LOG_I("AT network is already initialized!");
return RT_EOK;
@ -661,7 +660,7 @@ int m26_net_init(void)
if (resp)
{
rt_at_delete_resp(resp);
at_delete_resp(resp);
}
LOG_I("AT network initialize success!");
@ -671,7 +670,7 @@ int m26_net_init(void)
int m26_ping(int argc, char **argv)
{
rt_at_response_t resp = RT_NULL;
at_response_t resp = RT_NULL;
if (argc != 2)
{
@ -679,14 +678,14 @@ int m26_ping(int argc, char **argv)
return -RT_ERROR;
}
resp = rt_at_create_resp(64, 0, rt_tick_from_millisecond(5000));
resp = at_create_resp(64, 0, rt_tick_from_millisecond(5000));
if (!resp)
{
rt_kprintf("No memory for response structure!\n");
return -RT_ENOMEM;
}
if (rt_at_exec_cmd(resp, "AT+QPING=\"%s\"", argv[1]) < 0)
if (at_exec_cmd(resp, "AT+QPING=\"%s\"", argv[1]) < 0)
{
rt_kprintf("AT send ping commands error!\n");
return -RT_ERROR;
@ -694,7 +693,7 @@ int m26_ping(int argc, char **argv)
if (resp)
{
rt_at_delete_resp(resp);
at_delete_resp(resp);
}
return RT_EOK;