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/tcpsendpacket.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/tcpsendpacket.c')
| -rw-r--r-- | examples/network/tcpsendpacket.c | 17 |
1 files changed, 9 insertions, 8 deletions
diff --git a/examples/network/tcpsendpacket.c b/examples/network/tcpsendpacket.c index e7c514806e..75134c19a2 100644 --- a/examples/network/tcpsendpacket.c +++ b/examples/network/tcpsendpacket.c @@ -1,8 +1,9 @@ #include <rtthread.h> -#include <lwip/netdb.h> /* Ϊ�˽�������������Ҫ����netdb.hͷ�ļ� */ -#include <lwip/sockets.h> /* ʹ��BSD socket����Ҫ����sockets.hͷ�ļ� */ -void tcp_senddata(const char* url, int port, int length) +#include <netdb.h> /* Ϊ�˽�������������Ҫ����netdb.hͷ�ļ� */ +#include <sys/socket.h> /* ʹ��BSD socket����Ҫ����socket.hͷ�ļ� */ + +void tcp_senddata(const char *url, int port, int length) { struct hostent *host; int sock, err, result, timeout, index; @@ -27,7 +28,7 @@ void tcp_senddata(const char* url, int port, int length) timeout = 100; /* ���÷��ͳ�ʱʱ��100ms */ - lwip_setsockopt(sock, SOL_SOCKET, SO_SNDTIMEO, &timeout, sizeof(timeout)); + setsockopt(sock, SOL_SOCKET, SO_SNDTIMEO, &timeout, sizeof(timeout)); /* ��ʼ��Ԥ���ӵķ���˵�ַ */ server_addr.sin_family = AF_INET; server_addr.sin_port = htons(port); @@ -38,20 +39,20 @@ void tcp_senddata(const char* url, int port, int length) err = connect(sock, (struct sockaddr *)&server_addr, sizeof(struct sockaddr)); rt_kprintf("TCP thread connect error code: %d\n", err); - while(1) + while (1) { /* �������ݵ�sock���� */ result = send(sock, buffer_ptr, length, MSG_DONTWAIT); - if(result < 0) //���ݷ��ʹ����� + if (result < 0) //���ݷ��ʹ����� { rt_kprintf("TCP thread send error: %d\n", result); - lwip_close(sock); + closesocket(sock); /* �ر����ӣ����´������� */ rt_thread_delay(10); if ((sock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP)) == -1) - rt_kprintf("TCP Socket error:%d\n",sock); + rt_kprintf("TCP Socket error:%d\n", sock); err = connect(sock, (struct sockaddr *)&server_addr, sizeof(struct sockaddr)); rt_kprintf("TCP thread connect error code: %d\n", err); |
