libs/rt-thread-official
libs/rt-thread-official
4
0
Fork 0
mirror of https://github.com/RT-Thread/rt-thread.git synced 2025-01-30 22:10:28 +08:00
Code Issues Releases Wiki Activity

Merge pull request #1707 from qgyhd1234/at

Browse Source 
[net][at] at_client_wait_connect
This commit is contained in:
朱天龙 (Armink) 2018-08-08 18:28:46 +08:00 committed by GitHub
commit df6c1836e6
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 61 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
components/net/at/include/at.h
View File

@ -27,7 +27,7 @@
#include <rtthread.h> #include <rtthread.h>
#define AT_SW_VERSION "0.2.3" #define AT_SW_VERSION "0.2.4"
#define DBG_ENABLE #define DBG_ENABLE
#define DBG_SECTION_NAME "AT" #define DBG_SECTION_NAME "AT"
@ -216,6 +216,9 @@ int at_req_parse_args(const char *req_args, const char *req_expr, ...);
/* AT client initialize and start */ /* AT client initialize and start */
int at_client_init(void); int at_client_init(void);
/* AT client wait for connection to external devices. */
int at_client_wait_connect(rt_uint32_t timeout);
/* AT client send commands to AT server and waiter response */ /* AT client send commands to AT server and waiter response */
int at_exec_cmd(at_response_t resp, const char *cmd_expr, ...); int at_exec_cmd(at_response_t resp, const char *cmd_expr, ...);

57
components/net/at/src/at_client.c
View File

@ -329,6 +329,63 @@ __exit:
return result; return result;
} }
/**
* Waiting for connection to external devices.
*
* @param timeout millisecond for timeout
*
* @return 0 : success
* -2 : timeout
* -5 : no memory
*/
int at_client_wait_connect(rt_uint32_t timeout)
{
rt_err_t result = RT_EOK;
at_response_t resp = RT_NULL;
at_client_t client = at_client_local;
rt_tick_t start_time = 0;
resp = at_create_resp(16, 0, rt_tick_from_millisecond(500));
if (!resp)
{
LOG_E("No memory for response structure!");
return -RT_ENOMEM;
}
rt_mutex_take(client->lock, RT_WAITING_FOREVER);
client->resp = resp;
start_time = rt_tick_get();
while (1)
{
/* Check whether it is timeout */
if (rt_tick_get() - start_time > timeout)
{
LOG_E("wait connect timeout (%d millisecond)!", timeout);
result = -RT_ETIMEOUT;
break;
}
/* Check whether it is already connected */
resp->line_counts = 0;
rt_device_write(client->device, 0, "AT\r\n", 4);
if (rt_sem_take(client->resp_notice, resp->timeout) != RT_EOK)
continue;
else
break;
}
at_delete_resp(resp);
client->resp = RT_NULL;
rt_mutex_release(client->lock);
return result;
}
/** /**
* Send data to AT server, send data don't have end sign(eg: \r\n). * Send data to AT server, send data don't have end sign(eg: \r\n).
* *