summaryrefslogtreecommitdiff
path: root/examples/network/udpclient.c
diff options
context:
space:
mode:
authoraozima <[email protected]>2018-02-06 18:59:24 +0800
committeraozima <[email protected]>2018-02-06 18:59:24 +0800
commite20fb2f5b2130093191f818d307bb9cc30b0bc28 (patch)
treedaa94054ad5ee826b6f19e12230fdc63feeae6f8 /examples/network/udpclient.c
parentff811a93ff0a834ae3080c435ee216e5b92cd759 (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.c60
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