diff options
| author | aozima <[email protected]> | 2018-02-06 18:59:24 +0800 |
|---|---|---|
| committer | aozima <[email protected]> | 2018-02-06 18:59:24 +0800 |
| commit | e20fb2f5b2130093191f818d307bb9cc30b0bc28 (patch) | |
| tree | daa94054ad5ee826b6f19e12230fdc63feeae6f8 /examples/network/udpclient.c | |
| parent | ff811a93ff0a834ae3080c435ee216e5b92cd759 (diff) | |
[examples] update:
1. cleanup for posix dfs_net.
2. fixed recv buf overwrite.
3. format code.
Diffstat (limited to 'examples/network/udpclient.c')
| -rw-r--r-- | examples/network/udpclient.c | 60 |
1 files changed, 30 insertions, 30 deletions
diff --git a/examples/network/udpclient.c b/examples/network/udpclient.c index c19a25fa6c..5060c9a087 100644 --- a/examples/network/udpclient.c +++ b/examples/network/udpclient.c @@ -5,44 +5,44 @@ #include "netdb.h" const char send_data[] = "This is UDP Client from RT-Thread.\n"; /* 发送用到的数据 */ -void udpclient(const char* url, int port, int count) +void udpclient(const char *url, int port, int count) { - int sock; - struct hostent *host; - struct sockaddr_in server_addr; + int sock; + struct hostent *host; + struct sockaddr_in server_addr; - /* 通过函数入口参数url获得host地址(如果是域名,会做域名解析) */ - host= (struct hostent *) gethostbyname(url); + /* 通过函数入口参数url获得host地址(如果是域名,会做域名解析) */ + host = (struct hostent *) gethostbyname(url); - /* 创建一个socket,类型是SOCK_DGRAM,UDP类型 */ - if ((sock = socket(AF_INET, SOCK_DGRAM, 0)) == -1) - { - rt_kprintf("Socket error\n"); - return; - } + /* 创建一个socket,类型是SOCK_DGRAM,UDP类型 */ + if ((sock = socket(AF_INET, SOCK_DGRAM, 0)) == -1) + { + rt_kprintf("Socket error\n"); + return; + } - /* 初始化预连接的服务端地址 */ - server_addr.sin_family = AF_INET; - server_addr.sin_port = htons(port); - server_addr.sin_addr = *((struct in_addr *)host->h_addr); - rt_memset(&(server_addr.sin_zero), 0, sizeof(server_addr.sin_zero)); + /* 初始化预连接的服务端地址 */ + server_addr.sin_family = AF_INET; + server_addr.sin_port = htons(port); + server_addr.sin_addr = *((struct in_addr *)host->h_addr); + rt_memset(&(server_addr.sin_zero), 0, sizeof(server_addr.sin_zero)); - /* 总计发送count次数据 */ - while (count) - { - /* 发送数据到服务远端 */ - sendto(sock, send_data, strlen(send_data), 0, - (struct sockaddr *)&server_addr, sizeof(struct sockaddr)); + /* 总计发送count次数据 */ + while (count) + { + /* 发送数据到服务远端 */ + sendto(sock, send_data, strlen(send_data), 0, + (struct sockaddr *)&server_addr, sizeof(struct sockaddr)); - /* 线程休眠一段时间 */ - rt_thread_delay(50); + /* 线程休眠一段时间 */ + rt_thread_delay(50); - /* 计数值减一 */ - count --; - } + /* 计数值减一 */ + count --; + } - /* 关闭这个socket */ - closesocket(sock); + /* 关闭这个socket */ + closesocket(sock); } #ifdef RT_USING_FINSH |
