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

Merge pull request #25 from Lawlieta/master 

【修改】EC20 中对服务器主动关闭连接时处理方式
This commit is contained in:
朱天龙 (Armink) 2018-08-31 12:55:48 +08:00 committed by GitHub
parent 2b21be6e5e e52126b13c
commit 51ffba7186
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 6 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
at_socket_ec20.c
View File

@ -442,7 +442,7 @@ static int ec20_socket_close(int socket)
int result = 0;
at_response_t resp = RT_NULL;
resp = at_create_resp(128, 2, rt_tick_from_millisecond(10*1000));
resp = at_create_resp(64, 2, rt_tick_from_millisecond(2 * 1000));
if (!resp)
{
LOG_E("No memory for response structure!");
@ -906,6 +906,10 @@ static void urc_close_func(const char *data, rt_size_t size)
{
at_evt_cb_set[AT_SOCKET_EVT_CLOSED](socket, AT_SOCKET_EVT_CLOSED, NULL, 0);
}
/* when TCP socket service is closed, host must send "AT+QICLOSE= <connID>,0" command to close socket */
at_exec_cmd(RT_NULL, "AT+QICLOSE=%d,0\r\n", socket);
rt_thread_delay(rt_tick_from_millisecond(100));
}
static void urc_recv_func(const char *data, rt_size_t size)
@ -997,10 +1001,6 @@ static void urc_dnsqip_func(const char *data, rt_size_t size)
{
at_tcp_ip_errcode_parse(result);
}
else
{
LOG_D("DNS got %d IP address, ttl=%dms", ip_count, dns_ttl);
}
}
}
@ -1015,7 +1015,7 @@ static void urc_qiurc_func(const char *data, rt_size_t size)
{
RT_ASSERT(data && size);
LOG_D("qiurc : %s", data);
// LOG_D("qiurc : %s", data);
switch(*(data+9))
{
case 'c' : urc_close_func(data, size); break;//+QIURC: "closed"

5
at_socket_esp8266.c
View File

@ -107,7 +107,6 @@ static int esp8266_socket_close(int socket)
if (at_exec_cmd(resp, "AT+CIPCLOSE=%d", socket) < 0)
{
LOG_E("socket(%d) close failed.", socket);
result = -RT_ERROR;
goto __exit;
}
@ -197,10 +196,6 @@ __retry:
__exit:
rt_mutex_release(at_event_lock);
if (result != RT_EOK)
{
LOG_E("socket (%d) connect failed, failed to establish a connection.", socket);
}
if (resp)
{
at_delete_resp(resp);